#--
# Copyright (c) 2008-2009, John Mettraux, jmettraux@gmail.com
#
# Permission is hereby granted, free of charge, to any person obtaining a copy
# of this software and associated documentation files (the "Software"), to deal
# in the Software without restriction, including without limitation the rights
# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
# copies of the Software, and to permit persons to whom the Software is
# furnished to do so, subject to the following conditions:
#
# The above copyright notice and this permission notice shall be included in
# all copies or substantial portions of the Software.
#
# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
# THE SOFTWARE.
#
# Made in Japan.
#++
 
 
require 'rufus/verbs'
require 'openwfe/expressions/flowexpression'
require 'openwfe/expressions/time'
 
 
module OpenWFE
 
  #
  # A module shared by the expression classes dealing with HTTP (ROA).
  #
  module HttpRequestPreparation
 
    protected
 
      def prepare_params (verb, workitem)
 
        uri =
          lookup_attribute(:uri, workitem) ||
          fetch_text_content(workitem)
 
        data = (verb == 'put' or verb == 'post') ?
          workitem.attributes['hdata'] : nil
 
        opts = workitem.attributes['hoptions'] || {}
 
        params = lookup_attributes workitem
 
        params['timeout'] = params['htimeout'] || params['hto']
          # the :timeout param is reserved for the poll timeout
          # not the http timeout
 
        params = params.merge opts
 
        params = params.inject({}) { |r, (k, v)| r[k.intern] = v; r }
          # 'symbolize' keys
 
        params[:uri] = uri
        params[:data] = data if data
 
        params
      end
  end
 
  #
  # The HTTP verbs as OpenWFEru (Ruote) expressions.
  #
  # Useful for basic RESTful BPM.
  #
  # This expression uses the rufus-verbs gem and accepts the exact
  # sames parameters (attributes) as this gem.
  #
  # see http://rufus.rubyforge.org/rufus-verbs
  #
  # some examples (in a ruby process definition) :
  #
  #   sequence do
  #
  #     get "http://server.example.com/res0.xml"
  #       # stores the XML content in the field 'rbody'
  #   end
  #
  class HttpExpression < FlowExpression
    include HttpRequestPreparation
 
    names :hpost, :hget, :hput, :hdelete
 
 
    def apply (workitem)
 
      verb = @fei.expression_name[1..-1]
 
      params = prepare_params verb, workitem
 
      # do it
 
      Thread.new do
        #
        # move execution out of process engine main thread
        # else would block other processes execution
 
        begin
 
          res = Rufus::Verbs.send verb, params
 
          workitem.hcode = res.code
          workitem.hheaders = res.to_hash
          workitem.hdata = res.body
 
        #rescue Timeout::Error => te
        #
        #  workitem.rerror = te.to_s
        #  workitem.rcode = -1
 
        rescue Exception => e
 
          linfo do
            "apply() #{verb.upcase} #{params[:uri]} failed : " +
            "#{e.to_s}"
          end
 
          workitem.hcode = -1
          workitem.herror = e.to_s
        end
 
        # over
 
        reply_to_parent workitem
      end
    end
 
    #def reply (workitem)
    #end
 
    #def cancel
    #   # kill thread ...
    #   nil
    #end
 
  end
 
  #
  # Polls repeatedly a web resource until a condition realizes.
  #
  # If there is no condition given, will be equivalent to 'hget'.
  #
  class HpollExpression < WaitingExpression
    include HttpRequestPreparation
 
    names :hpoll
    conditions :until
 
    attr_accessor :hparams
 
 
    def apply (workitem)
 
      @hparams = prepare_params 'get', workitem
 
      super
    end
 
    def trigger (params={})
 
      do_get unless params[:do_timeout!]
 
      super
    end
 
    protected
 
      def do_get
 
        ldebug { "do_get() #{@hparams.inspect}" }
 
        res = Rufus::Verbs.get @hparams
 
        @applied_workitem.hcode = res.code
        @applied_workitem.hheaders = res.to_hash
        @applied_workitem.hdata = res.body
 
      rescue Exception => e
 
        linfo do
          "do_get() #{verb.upcase} #{uri} failed : #{e.to_s}"
        end
 
        @applied_workitem.hcode = -1
        @applied_workitem.herror = e.to_s
      end
  end
 
end