# replicated to a file.
class Replicator
def initialize(config)
- @config = YAML.load(File.read(config))
- @state = YAML.load(File.read(@config["state_file"]))
+ @config = YAML.safe_load(File.read(config))
+ @state = YAML.safe_load(File.read(@config["state_file"]), [Time])
@conn = PGconn.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]
# move them into place later, to avoid in-progress
# clashes, or people seeing incomplete files.
begin
+ changesets = open_changesets
@state["sequence"] = sequence
@state["last_run"] = @now
- changesets = open_changesets
write_tmp_files!(changesets)