module Octo::Helpers::ApiConsumerHelper

Helper Module for Octo Consumer

Public Instance Methods

call_hooks(event, *args) click to toggle source

Set Octo callbacks @param [String] event Event name @param [Hash] *args Points to the messsage hash

# File lib/octocore-mongo/helpers/api_consumer_helper.rb, line 43
def call_hooks(event, *args)
  hook = [:after, event.gsub('.', '_')].join('_').to_sym
  Octo::Callbacks.run_hook(hook, *args)
end
handle(msg) click to toggle source

Handles Kafka messages and perform required operations @param [Hash] msg Hash Message

# File lib/octocore-mongo/helpers/api_consumer_helper.rb, line 26
def handle(msg)
  msg_obj = Octo::Message::Message.new(msg)
  msg = msg_obj.to_h
  begin
    eventName = msg[:event_name]
    if (valid_events.include?eventName)
      call_hooks(eventName, msg)
    end
  rescue Exception => e  
    puts e.message
    puts e.backtrace.inspect
  end
end
valid_events() click to toggle source

Get all the valid events @return [Set<Symbol>] Valid events globally

# File lib/octocore-mongo/helpers/api_consumer_helper.rb, line 12
def valid_events
  Set.new(Octo.get_config(:allowed_events))
end