# frozen_string_literal: true

module Multiwoven
  module Integrations::Core
    class DestinationConnector < BaseConnector
      # Records are transformed json payload send it to the destination
      # SyncConfig is the Protocol::SyncConfig object
      def write(_sync_config, _records, _action = "destination_insert")
        raise "Not implemented"
        # return Protocol::TrackingMessage
      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 auth_headers(access_token)
        {
          "Accept" => "application/json",
          "Authorization" => "Bearer #{access_token}",
          "Content-Type" => "application/json"
        }
      end
    end
  end
end