Class: Synco::Methods::RSyncSnapshot

Inherits:
RSync show all
Defined in:
lib/synco/methods/rsync.rb

Instance Attribute Summary

Attributes inherited from Synco::Method

#arguments, #options

Attributes inherited from Controller

#events

Instance Method Summary collapse

Methods inherited from RSync

#connect_arguments, #default_command, #escape

Methods inherited from Controller

#abort!, build, #fire, #freeze, #on, #try

Constructor Details

#initialize(*command, arguments: [], archive: true, stats: true, **options) ⇒ RSyncSnapshot

Returns a new instance of RSyncSnapshot.



113
114
115
 
# File 'lib/synco/methods/rsync.rb', line 113

def initialize(*command, arguments: [], archive: true, stats: true, **options)
	super
end

Instance Method Details

#call(scope) ⇒ Object 



137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
 
# File 'lib/synco/methods/rsync.rb', line 137

def call(scope)
	master_server = scope.master_server
	target_server = scope.target_server
	
	directory = scope.directory
	incremental_path = compute_incremental_path(directory)
	link_arguments = compute_link_arguments(directory, incremental_path)
	
	# Create the destination backup directory
	target_server.run('mkdir', '-p', target_server.full_path(incremental_path))
	
	master_server.run(
		*@command,
		*@arguments,
		*directory.arguments,
		*connect_arguments(master_server, target_server),
		*link_arguments,
		master_server.connection_string(directory, on: master_server),
		target_server.connection_string(incremental_path, on: master_server)
	)
rescue CommandFailure => failure
	raise unless failure.status.to_i == 24
end

#compute_incremental_path(directory) ⇒ Object 



125
126
127
 
# File 'lib/synco/methods/rsync.rb', line 125

def compute_incremental_path(directory)
	File.join(snapshot_name, directory.path)
end

#compute_link_arguments(directory, incremental_path) ⇒ Object 



129
130
131
132
133
134
135
 
# File 'lib/synco/methods/rsync.rb', line 129

def compute_link_arguments(directory, incremental_path)
	depth = Directory.depth(incremental_path)
	
	latest_path = File.join("../" * depth, latest_name, directory.path)
	
	return ['--link-dest', latest_path]
end

#latest_name ⇒ Object 



121
122
123
 
# File 'lib/synco/methods/rsync.rb', line 121

def latest_name
	@options[:latest_name] || LATEST_NAME
end

#snapshot_name ⇒ Object 



117
118
119
 
# File 'lib/synco/methods/rsync.rb', line 117

def snapshot_name
	@options[:snapshot_name] || SNAPSHOT_NAME
end