sqs_processor.rbs

module ElasticGraph
  module IndexerLambda
    class SqsProcessor
      interface _EventPayloadDecoder
        def decode_events: (
          sqs_record: ::Hash[::String, untyped],
          body: ::String
        ) -> ::Array[::Hash[::String, untyped]]
      end

      interface _MessageBodyLoader
        def load_body: (
          sqs_record: ::Hash[::String, untyped]
        ) -> ::String
      end

      def initialize: (
        Indexer::Processor,
        logger: ::Logger,
        ignore_sqs_latency_timestamps_from_arns: ::Set[::String],
        ?event_payload_decoder: _EventPayloadDecoder,
        ?message_body_loader: _MessageBodyLoader,
      ) -> void

      def process: (
        ::Hash[::String, untyped],
        ?refresh_indices: bool
      ) -> {"batchItemFailures" => ::Array[{"itemIdentifier" => ::String}]}

      private

      @indexer_processor: Indexer::Processor
      @logger: ::Logger
      @event_payload_decoder: _EventPayloadDecoder
      @message_body_loader: _MessageBodyLoader

      attr_reader ignore_sqs_latency_timestamps_from_arns: ::Set[::String]

      def events_from: (::Hash[::String, untyped]) -> ::Array[::Hash[::String, untyped]]
      def extract_sqs_metadata: (::Hash[String, untyped]) -> ::Hash[::String, untyped]
      def millis_to_iso8601: (::String) -> ::String?
      def format_response: (
        ::Array[Indexer::FailedEventError]
      ) -> {"batchItemFailures" => ::Array[{"itemIdentifier" => ::String}]}
    end
  end
end