a conversation with Thibaut

maillisteners.rb

require 'rufus/scheduler'
require 'openwfe/service'
require 'openwfe/listeners/listener'


module OpenWFE

  class Emailistener < Service
    include WorkItemListener
    include Rufus::Schedulable

    def initialize (service_name, application_context)
      super
      linfo { "new() EmailListener started!" }
    end

    #
    # Polls the imap/pop3 account for incoming workitems/launchitems
    #
    def trigger (params)

      ldebug { 'trigger()' }

      mails = fetch_mail(params)
        #
        # assuming the emails have been turned into a list of hashes

      mails.each do |mail|

        workitem = if fei = mail[:flow_expression_id]
          #
          # there is a fei, it's a workitem coming back
          wi = InFlowWorkItem.new
          wi.fei = FlowExpressionId.from_s(fei)
          wi
        else
          #
          # no fei (no process instance awaiting) it's probably a launchitem
          procdef = mail[:process_definition_url] || mail[:process_definition]
          LaunchItem.new(procdef)
        end

        workitem.attributes = mail
          # using the whole 'mail' hash as the workitem/launchitem payload

        #handle_item(workitem)
        get_engine.reply(workitem) # inlining... a bit more explicit
          # resumes process instance or launches new one

        linfo { "trigger() handled #{workitem.class}" }
      end
    end

    protected

      def fetch_mail (params)
        # ...
      end
  end

end