class Multiwoven::Integrations::Core::DestinationConnector

def auth_headers(access_token)
  {
    "Accept" => "application/json",
    "Authorization" => "Bearer #{access_token}",
    "Content-Type" => "application/json"
  }
end

def tracking_message(success, failure, log_message_array)
  Multiwoven::Integrations::Protocol::TrackingMessage.new(
    success: success, failed: failure, logs: log_message_array
  ).to_multiwoven_message
end

def write(_sync_config, _records, _action = "destination_insert")
  raise "Not implemented"
  # return Protocol::TrackingMessage
end