Sha256: 2d905fc9ceb885a6d929fa95f0ff4f6b969e4410d071db5426a5511cf3e1a882
Contents?: true
Size: 1.43 KB
Versions: 35
Compression:
Stored size: 1.43 KB
Contents
require 'rubygems'
require 'posix/spawn'
class HglibClient
def initialize(repository_url)
@repository_url = repository_url
@py_script = File.dirname(__FILE__) + '/server.py'
end
def start
@pid, @stdin, @stdout, @stderr = POSIX::Spawn::popen4 "python #{@py_script}"
open_repository
end
def open_repository
send_command("REPO_OPEN\t#{@repository_url}")
end
def cat_file(revision, file)
begin
send_command("CAT_FILE\t#{revision}\t#{file}")
rescue RuntimeError => e
if e.message =~ /not found in manifest/
return nil # File does not exist.
else
raise
end
end
end
def parent_tokens(revision)
send_command("PARENT_TOKENS\t#{revision}").split("\t")
end
def send_command(cmd)
# send the command
@stdin.puts cmd
@stdin.flush
return if cmd == "QUIT"
# get status on stderr, first letter indicates state,
# remaing value indicates length of the file content
status = @stderr.read(10)
flag = status[0,1]
size = status[1,9].to_i
if flag == 'F'
return nil
elsif flag == 'E'
error = @stdout.read(size)
raise RuntimeError.new("Exception in server process\n#{error}")
end
# read content from stdout
return @stdout.read(size)
end
def shutdown
send_command("QUIT")
[@stdout, @stdin, @stderr].each { |io| io.close unless io.closed? }
Process.waitpid(@pid, Process::WNOHANG)
end
end
Version data entries
35 entries across 35 versions & 1 rubygems