Contents

# frozen_string_literal: true

require 'pub_sub_model_sync/payload'
module PubSubModelSync
  class ServiceBase < PubSubModelSync::Base
    SERVICE_KEY = 'service_model_sync'

    def listen_messages
      raise NoMethodError, 'method :listen_messages must be defined in service'
    end

    # @param _payload (Payload)
    def publish(_payload)
      raise NoMethodError, 'method :publish must be defined in service'
    end

    def stop
      raise NoMethodError, 'method :stop must be defined in service'
    end

    private

    # @param payload (Payload)
    # @return (String): Json Format
    def encode_payload(payload)
      data = payload.to_h
      not_important_keys = %i[forced_ordering_key cache]
      reduce_payload_size = !config.debug
      data[:headers].except!(*not_important_keys) if reduce_payload_size
      data.to_json
    end

    # @param (String: Payload in json format)
    def process_message(payload_info)
      payload = decode_payload(payload_info)
      return unless payload
      return if same_app_message?(payload)

      payload.process
    end

    # @return [Payload,Nil]
    def decode_payload(payload_info)
      payload = ::PubSubModelSync::Payload.from_payload_data(JSON.parse(payload_info))
      log("Received message: #{[payload]}") if config.debug
      payload
    rescue => e
      error_payload = [payload_info, e.message, e.backtrace]
      log("Error while parsing payload: #{error_payload}", :error)
      nil
    end

    # @param payload (Payload)
    def same_app_message?(payload)
      key = payload.headers[:app_key]
      res = key && key == config.subscription_key
      log("Skipping message from same origin: #{[payload]}") if res && config.debug
      res
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
pub_sub_model_sync-1.5.0	lib/pub_sub_model_sync/service_base.rb