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

def discover(connection_config)
  connection_config = connection_config.with_indifferent_access
  db = create_connection(connection_config)
  @sftp.download!(@remote_file_path, @tempfile.path)
  query = "SELECT * FROM read_csv_auto('#{@tempfile.path}')"
  records = db.query(query).columns
  catalog = Catalog.new(streams: create_streams(records.map(&:name)))
  catalog.to_multiwoven_message
rescue StandardError => e
  handle_exception(e, {
                     context: "SFTP:DISCOVER:EXCEPTION",
                     type: "error"
                   })
ensure
  @tempfile&.close!
end