Class: Controller

Inherits:

Object

• Object
• Controller

Defined in:

lib/meshx-plugin-sdk.rb

Instance Method Summary

• #initialize(plugin) ⇒ Controller constructor

  A new instance of Controller.

• #run ⇒ Object
• #valid_json?(json) ⇒ Boolean

Constructor Details

#initialize(plugin) ⇒ Controller

Returns a new instance of Controller.

# File 'lib/meshx-plugin-sdk.rb', line 117

def initialize(plugin)
  @api = FoundationApi.new()
  @log = Logger.new(STDOUT)
  @config = Config.new()
  @plugin = Plugin.new(@api, @log, @config)
end

Instance Method Details

#run ⇒ Object

# File 'lib/meshx-plugin-sdk.rb', line 131

def run()
  exit_run = false
  begin
    @log.info("calling on_init()")
    @plugin.on_init()
  rescue StandardError => e
    @log.error("error calling on_init(): #{e.message}")
  end
  
  begin
    @log.info("calling on_start()")
    @plugin.on_start()
  rescue StandardError => e
    @log.error("error calling on_start(): #{e.message}")
  end

  keep_reading = true
  @log.info("starting controller loop")
  while keep_reading && exit_run == false
    begin
      exit_run = @plugin.exit?()
      rtn = @api.get_messages()
      @log.info("rtn: #{rtn.message} #{rtn.error} #{rtn.exit_code}")
      # convert message to fileevent
      if valid_json?(rtn.message)
        hash = JSON.parse()
        hash["items"].each do |item|
          @log.info("message kind: #{item["kind"]}")
          case item["kind"]
          when "FileEvent"
            @log.info("FileEvent")
            event = FileEvent.new(item)
            @plugin.on_file_event(event)
          when "FolderEvent"
            @log.info("FolderEvent")
            event = FolderEvent.new(item)
            @plugin.on_folder_event(event)
          when "CompleteEvent"
            @log.info("CompleteEvent")
            event = CompleteEvent.new(item)
            @plugin.on_complete_event(event)
            keep_reading = false
          else
            @log.info("unknown event kind: #{item["kind"]}")
          end
        end
      else
        @log.info("invalid message [#{rtn.message}]")        
      end             
    rescue Exception => e
      @log.error("error event processing: #{e.message}")
    end
  end
  @log.info("ending controller loop sending complete event")
  res2 = @api.send_complete_events()
  if res2.exit_code != 0
    @log.error("failed to send complete event: #{res2.error} #{res2.exit_code}")
  end
  
  begin
    @log.info("calling on_end()")
    @plugin.on_end()
  rescue StandardError => e
    @log.error("error calling on_end(): #{e.message}")
  end

end

#valid_json?(json) ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/meshx-plugin-sdk.rb', line 124

def valid_json?(json)
  JSON.parse(json)
  true
rescue JSON::ParserError, TypeError => e
  false
end