class Multiwoven::Integrations::Source::Sftp::Client

def query(conn, query)
  @sftp.download!(@remote_file_path, @tempfile.path)
  query = query.gsub(/FROM\s+\S+/i, "FROM read_csv_auto('#{@tempfile.path}')") if query.match?(/\bFROM\b/i)
  records = get_results(conn, query)
  records.map do |row|
    RecordMessage.new(data: row, emitted_at: Time.now.to_i).to_multiwoven_message
  end
end