mirror of
https://github.com/nishiki/manage-password.git
synced 2024-11-30 08:53:05 +00:00
147 lines
3.2 KiB
Ruby
147 lines
3.2 KiB
Ruby
#!/usr/bin/ruby
|
|
# author: nishiki
|
|
# mail: nishiki@yaegashi.fr
|
|
# info: a simple script who manage your passwords
|
|
|
|
module MPW
|
|
|
|
module Sync
|
|
|
|
require 'rubygems'
|
|
require 'i18n'
|
|
require 'socket'
|
|
require 'json'
|
|
require 'timeout'
|
|
|
|
class MPWSync
|
|
|
|
attr_accessor :error_msg
|
|
attr_accessor :enable
|
|
|
|
# Constructor
|
|
def initialize
|
|
@error_msg = nil
|
|
@enable = false
|
|
end
|
|
|
|
# Connect to server
|
|
# @args: host -> the server host
|
|
# port -> ther connection port
|
|
# gpg_key -> the gpg key
|
|
# password -> the remote password
|
|
# suffix -> the suffix file
|
|
# @rtrn: false if the connection fail
|
|
def connect(host, user, password, path, port=nil)
|
|
@host = host
|
|
@port = !port.instance_of?(Integer) ? 2201 : port
|
|
@gpg_key = user
|
|
@password = password
|
|
@suffix = path
|
|
|
|
Timeout.timeout(10) do
|
|
begin
|
|
TCPSocket.open(@host, @port) do
|
|
@enable = true
|
|
end
|
|
rescue Errno::ENETUNREACH
|
|
retry
|
|
end
|
|
end
|
|
rescue Timeout::Error
|
|
puts 'timeout'
|
|
@error_msg = "#{I18n.t('error.timeout')}\n#{e}"
|
|
@enable = false
|
|
rescue Exception => e
|
|
@error_msg = "#{I18n.t('error.sync.connection')}\n#{e}"
|
|
@enable = false
|
|
else
|
|
return @enable
|
|
end
|
|
|
|
# Get data on server
|
|
# @args: gpg_password -> the gpg password
|
|
# @rtrn: nil if nothing data or error
|
|
def get(gpg_password)
|
|
return nil if not @enable
|
|
|
|
msg = nil
|
|
TCPSocket.open(@host, @port) do |socket|
|
|
send_msg = {action: 'get',
|
|
gpg_key: @gpg_key,
|
|
password: @password,
|
|
suffix: @suffix
|
|
}
|
|
|
|
socket.puts send_msg.to_json
|
|
msg = JSON.parse(socket.gets)
|
|
end
|
|
|
|
if not defined?(msg['error'])
|
|
@error_msg = I18n.t('error.sync.communication')
|
|
return nil
|
|
elsif not msg['error'].nil?
|
|
@error_msg = I18n.t(msg['error'])
|
|
return nil
|
|
elsif msg['data'].nil? or msg['data'].empty?
|
|
return {}
|
|
else
|
|
tmp_file = tmpfile
|
|
File.open(tmp_file, 'w') do |file|
|
|
file << msg['data']
|
|
end
|
|
|
|
mpw = MPW.new(tmp_file)
|
|
if not mpw.decrypt(gpg_password)
|
|
@error_msg = mpw.error_msg
|
|
return nil
|
|
end
|
|
|
|
File.unlink(tmp_file)
|
|
return mpw.search
|
|
end
|
|
end
|
|
|
|
# Update the remote data
|
|
# @args: data -> the data to send on server
|
|
# @rtrn: false if there is a problem
|
|
def update(data)
|
|
return true if not @enable
|
|
|
|
msg = nil
|
|
TCPSocket.open(@host, @port) do |socket|
|
|
send_msg = {action: 'update',
|
|
gpg_key: @gpg_key,
|
|
password: @password,
|
|
suffix: @suffix,
|
|
data: data
|
|
}
|
|
|
|
socket.puts send_msg.to_json
|
|
msg = JSON.parse(socket.gets)
|
|
end
|
|
|
|
if not defined?(msg['error'])
|
|
@error_msg = I18n.t('error.sync.communication')
|
|
return false
|
|
elsif msg['error'].nil?
|
|
return true
|
|
else
|
|
@error_msg = I18n.t(msg['error'])
|
|
return false
|
|
end
|
|
end
|
|
|
|
# Generate a random string
|
|
# @rtrn: a random string
|
|
def tmpfile
|
|
result = ''
|
|
result << ([*('A'..'Z'),*('a'..'z'),*('0'..'9')]).sample(6).join
|
|
|
|
return "/tmp/mpw-#{result}"
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|