127 lines
2.9 KiB
Ruby
127 lines
2.9 KiB
Ruby
|
|
require 'fileutils'
|
|
require 'qasim/map/generic'
|
|
require 'qasim/map/smb'
|
|
require 'qasim/map/ssh'
|
|
require 'qasim/map/webdav'
|
|
|
|
module Qasim ; module Map
|
|
|
|
class ParseError < RuntimeError ; end
|
|
class ConnectError < RuntimeError ; end
|
|
|
|
def class_for type
|
|
plugin = nil
|
|
ObjectSpace.each_object(Class) do |cls|
|
|
|
|
if cls < Qasim::Map::Generic then
|
|
puts "Searching #{type} in " + cls.handles.inspect
|
|
plugin = cls if cls.handles.include? type.to_sym
|
|
end
|
|
end
|
|
plugin
|
|
end
|
|
|
|
#
|
|
# replace magic values withing map lines
|
|
#
|
|
# Allowed values :
|
|
#
|
|
# $(var) => variable value from environment
|
|
# ${var} => variable value from environment
|
|
#
|
|
def env_substitute text
|
|
seek = true
|
|
str = text
|
|
|
|
while seek do
|
|
seek = false
|
|
case str
|
|
when /^(.*)\${([^}]+?)}(.*)$/ then
|
|
before, pattern, after = [$1, $2, $3]
|
|
pattern_value = env_substitute(pattern)
|
|
pattern_value = (ENV[pattern_value] || "")
|
|
str = before + pattern_value + after
|
|
seek = true
|
|
when /^(.*)\$(\w+)(.*)$/ then
|
|
before, pattern, after = [$1, $2, $3]
|
|
pattern_value = (ENV[pattern] || "")
|
|
str = before + pattern_value + after
|
|
seek = true
|
|
end
|
|
end
|
|
str
|
|
end
|
|
|
|
#
|
|
# Load description from file and create a Map object
|
|
#
|
|
def from_file appcfg, filename
|
|
params = {
|
|
type: :ssh # for params V1, we assume SSHFS by default
|
|
}
|
|
map = nil
|
|
|
|
f = File.open filename
|
|
linect = 0
|
|
f.each do |line|
|
|
line = line.strip
|
|
linect += 1
|
|
|
|
line = env_substitute(line)
|
|
params[:filename] = filename
|
|
case line
|
|
when /^\s*REMOTE_USER\s*=\s*(.*)\s*$/ then
|
|
params[:ssh_user] = $1
|
|
when /^\s*REMOTE_PORT\s*=\s*(.*)\s*$/ then
|
|
params[:ssh_port] = $1.to_i
|
|
when /^\s*REMOTE_HOST\s*=\s*(.*)\s*$/ then
|
|
params[:ssh_host] = $1
|
|
when /^\s*REMOTE_CYPHER\s*=\s*(.*)\s*$/ then
|
|
if CYPHERS.map(&:to_s).include? $1 then
|
|
params[:ssh_cypher] = $1.to_sym
|
|
end
|
|
when /^\s*MAP\s*=\s*(.*)\s+(.*)\s*$/ then
|
|
params[:links] ||= {}
|
|
params[:links][$1] = $2
|
|
when /^\s*([A-Z_]+)\s*=\s*(.*)\s*$/ then
|
|
key = $1.downcase.to_sym
|
|
params[key] = $2
|
|
when /^\s*$/,/^\s*#/ then
|
|
else
|
|
STDERR.puts line
|
|
raise ParseError, "parse error at #{filename}:#{linect}"
|
|
end
|
|
end
|
|
f.close
|
|
map_class = class_for params[:type]
|
|
if map_class.nil? then
|
|
raise ParseError, "no plugin found for type « #{params[:type]} »"
|
|
end
|
|
map = map_class.new appcfg, params
|
|
return map
|
|
end
|
|
|
|
|
|
#
|
|
# Write map description to file
|
|
#
|
|
def to_file path=nil
|
|
@path=path unless path.nil?
|
|
|
|
File.open(@path, "w") do |f|
|
|
f.puts "REMOTE_USER=%s" % @user
|
|
f.puts "REMOTE_PORT=%s" % @port
|
|
f.puts "REMOTE_HOST=%s" % @host
|
|
f.puts "REMOTE_CYPHER=%s" % @cypher
|
|
end
|
|
end
|
|
|
|
module_function :from_file
|
|
module_function :env_substitute
|
|
module_function :class_for
|
|
module_function :select
|
|
|
|
end ; end
|
|
|