class Multiwoven::Integrations::Source::SalesforceConsumerGoodsCloud::Client

def query(connection, query)
  queried_data = connection.query(query)
  results = queried_data.map do |record|
    flatten_nested_hash(record)
  end
  results.map do |row|
    RecordMessage.new(data: row, emitted_at: Time.now.to_i).to_multiwoven_message
  end
end