Class: Docker_Sync::SyncStrategy::Unison

Inherits:
Object
  • Object
show all
Includes:
Preconditions, Thor::Shell
Defined in:
lib/docker_sync/sync_strategy/unison.rb

Constant Summary collapse

UNISON_IMAGE = 
'leighmcculloch/unison'
UNISON_VERSION = 
'2.48.3'
UNISON_CONTAINER_PORT = 
'5000'

Instance Method Summary collapse

Methods included from Preconditions

#check_all_preconditions, #docker_available, #docker_running, #docker_sync_available, #fswatch_available, #rsync_available, #unison_available

Constructor Details

#initialize(sync_name, options) ⇒ Unison

Returns a new instance of Unison.



18
19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/docker_sync/sync_strategy/unison.rb', line 18

def initialize(sync_name, options)
  @sync_name = sync_name
  @options = options

  begin
    unison_available
  rescue Exception => e
    say_status 'error', "#{@sync_name} has been configured to sync with unison, but no unison available", :red
    say_status 'error', e.message, :red
    exit 1
  end
end

Instance Method Details

#clean ⇒ Object 



107
108
109
 
# File 'lib/docker_sync/sync_strategy/unison.rb', line 107

def clean
  reset_container
end

#reset_container ⇒ Object 



101
102
103
104
105
 
# File 'lib/docker_sync/sync_strategy/unison.rb', line 101

def reset_container
  stop_container
  `docker rm #{@sync_name}`
  `docker volume rm #{@sync_name}`
end

#run ⇒ Object 



31
32
33
34
 
# File 'lib/docker_sync/sync_strategy/unison.rb', line 31

def run
  start_container
  sync
end

#start_container ⇒ Object 



72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
 
# File 'lib/docker_sync/sync_strategy/unison.rb', line 72

def start_container
  say_status 'ok', 'Starting unison', :white
  running = `docker ps --filter 'status=running' --filter 'name=#{@sync_name}' | grep #{@sync_name}`
  if running == ''
    say_status 'ok', "#{@sync_name} container not running", :white if @options['verbose']
    exists = `docker ps --filter "status=exited" --filter "name=#{@sync_name}" | grep #{@sync_name}`
    if exists == ''
      say_status 'ok', "creating #{@sync_name} container", :white if @options['verbose']
      cmd = "docker run -p '#{@options['sync_host_port']}:#{UNISON_CONTAINER_PORT}' -v #{@sync_name}:#{@options['dest']} -e UNISON_VERSION=#{UNISON_VERSION} -e UNISON_WORKING_DIR=#{@options['dest']} --name #{@sync_name} -d #{UNISON_IMAGE}"
    else
      say_status 'ok', "starting #{@sync_name} container", :ok if @options['verbose']
      cmd = "docker start #{@sync_name}"
    end
    say_status 'command', cmd, :white if @options['verbose']
    `#{cmd}` || raise('Start failed')
  else
    say_status 'ok', "#{@sync_name} container still running", :blue
  end
  say_status 'ok', "starting initial #{@sync_name} of src", :white if @options['verbose']
  # this sleep is needed since the container could be not started
  sleep 1
  sync
  say_status 'success', 'Unison server started', :green
end

#stop ⇒ Object 



111
112
113
114
115
116
117
118
119
 
# File 'lib/docker_sync/sync_strategy/unison.rb', line 111

def stop
  say_status 'ok', "Stopping sync container #{@sync_name}"
  begin
    stop_container
  rescue Exception => e
    say_status 'error', "Stopping failed of #{@sync_name}:", :red
    puts e.message
  end
end

#stop_container ⇒ Object 



97
98
99
 
# File 'lib/docker_sync/sync_strategy/unison.rb', line 97

def stop_container
  `docker stop #{@sync_name}`
end

#sync ⇒ Object 



36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/docker_sync/sync_strategy/unison.rb', line 36

def sync
  args = sync_options
  cmd = 'unison ' + args.join(' ')

  say_status 'command', cmd, :white if @options['verbose']

  Open3.popen3(cmd)
  if $?.exitstatus > 0
    say_status 'error', "Error starting sync, exit code #{$?.exitstatus}", :red
    say_status 'message', out
  else
    say_status 'ok', "Synced #{@options['src']}", :white
    if @options['verbose']
      say_status 'output', out
    end
  end
end

#sync_options ⇒ Object 



54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
 
# File 'lib/docker_sync/sync_strategy/unison.rb', line 54

def sync_options
  args = []

  unless @options['sync_excludes'].nil?
    # TODO: does unison support excludes as a command parameter? seems to be a config-value only
    say_status 'warning','Excludes are yet not implemented for unison!', :yellow
    #  args = @options['sync_excludes'].map { |pattern| "--exclude='#{pattern}'" } + args
  end
  args.push(@options['src'])
  args.push('-auto')
  args.push('-batch')
  args.push(@options['sync_args']) if @options.key?('sync_args')
  args.push("socket://#{@options['sync_host_ip']}:#{@options['sync_host_port']}/")
  if @options.key?('sync_user') || @options.key?('sync_group') || @options.key?('sync_groupid') || @options.key?('sync_userid')
    raise('Unison does not support sync_user, sync_group, sync_groupid or sync_userid - please use rsync if you need that')
  end
end