class SpsFtpdDriver

# File lib/sps-ftpd-driver.rb, line 12
def initialize(dir, sps: {}, between_times: '')

  @dir = dir

  opt = {host: 'sps', port: '59000', topic: 'test'}.merge(sps)

  @sps_topic = opt[:topic]
  @sps_host = opt[:host]
  @sps_port = opt[:port]
  @times = between_times
  
  Thread.new do  
    sp = SPSSubPing.new host: @sps_host, port: @sps_port, \
                                                identifier: 'SPSFtpdDriver'
    sp.start
  end          
end

# File lib/sps-ftpd-driver.rb, line 30
def authenticate(user, password)
  true
end

# File lib/sps-ftpd-driver.rb, line 34
def file_system(user)

  fs = Ftpd::DiskFileSystem.new(@dir)

  fs.instance_eval("
    @sps_topic = '#{@sps_topic}'
    @sps_host = '#{@sps_host}'
    @sps_port = '#{@sps_port}'
    @times = '#{@times}'
  ")

  def fs.write(ftp_path, contents)
    
    if @times.empty? or ChronicBetween.new(@times).within?(Time.now) then
      message = "%s: uploaded file %s" % [@sps_topic, ftp_path]
      begin
        SPSPub.notice message, address: @sps_host, port: @sps_port
      rescue
        puts 'sps-ftp-driver: warning: unable to publish SPS notice ' + ($!).inspect
      end
    end
    super(ftp_path, contents)
  end

  fs
end