def initialize(config)
@config = YAML.safe_load(File.read(config))
@state = YAML.safe_load(File.read(@config["state_file"]), [Time])
- @conn = PGconn.connect(@config["db"])
+ @conn = PG::Connection.connect(@config["db"])
# get current time from the database rather than the current system
@now = @conn.exec("select now() as now").map { |row| Time.parse(row["now"]) }[0]
end
fl.flock(File::LOCK_UN)
rescue StandardError
- STDERR.puts("Error! Couldn't update state.")
+ warn "Error! Couldn't update state."
fl.flock(File::LOCK_UN)
raise
end
rep = Replicator.new(ARGV[0])
rep.save!
rescue StandardError => e
- STDERR.puts "ERROR: #{e.message}"
+ warn "ERROR: #{e.message}"
exit 1
end