#!/usr/bin/ruby

#

# Apache License, Version 2.0

#

# Copyright (c) 2013 Juergen Mangler

#

# Licensed under the Apache License, Version 2.0 (the "License");

# you may not use this file except in compliance with the License.

# You may obtain a copy of the License at

#

#     http://www.apache.org/licenses/LICENSE-2.0

#

# Unless required by applicable law or agreed to in writing, software

# distributed under the License is distributed on an "AS IS" BASIS,

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

# See the License for the specific language governing permissions and

# limitations under the License.

 

require 'rubygems'

require 'riddl/server'

require 'xml/smart'

require 'chronic_duration'

 

class Sleep < Riddl::Implementation

  def response

    doc = XML::Smart.string(@p[0].value.read)

    doc.register_namespace 'g', 'http://www.fp7-adventure.eu/xmlSchema/Gateways/'

    mop = doc.find('string(//g:header/g:operationName)')

 

    if mop == 'sleep'

      sleep = doc.find('string(//g:payload/g:inputParameter[@paramName="sleep"])')

 

      secs = ChronicDuration.parse(sleep)

 

      sleep(secs) unless secs.nil?

 

      if @h['CPEE_CALLBACK']

        gwr = XML::Smart.open_unprotected(File.dirname(__FILE__) + "/gatewayresponse.xml")

        gwr.register_namespace 'g', 'http://www.fp7-adventure.eu/xmlSchema/Gateways/'

 

        srv = Riddl::Client.new("xmpp://" + @h['CPEE_CALLBACK'], File.dirname(__FILE__) + "/callback.xml", :xmpp => @env['xmpp'])

        srv.put [

          Riddl::Parameter::Complex.new("gatewayResponse","text/xml",gwr.root.dump)

        ]  

      end

    end

    nil

  end

end

 

Riddl::Server.new(File.dirname(__FILE__) + '/gateway.xml', :port => 9293, :debug => STDOUT) do

  xmpp '[email protected]', 'adventure_gateway_timer'

  accessible_description true

  cross_site_xhr true

 

  on resource do

    run Sleep if post 'gateway-request'

  end

end.loop!