Class: CPEE::Instantiation::ContinueTask

Inherits:

Riddl::Implementation

• Object
• Riddl::Implementation
• CPEE::Instantiation::ContinueTask

Defined in:

lib/cpee-instantiation/instantiation.rb

Overview

}}}

Instance Method Summary

• #response ⇒ Object

  {{{.

Instance Method Details

#response ⇒ Object

{{{

# File 'lib/cpee-instantiation/instantiation.rb', line 241

def response
  cblist       = @a[1]
  topic        = @p[1].value
  event_name   = @p[2].value
  notification = if @p[3].class === Riddl::Parameter::Simple
    JSON.parse(@p[3].value)
  else
    JSON.parse(@p[3].value.read)
  end

  key = @r.last
  cb, condition, instance, uuid, instance_url = cblist.lrange(key,0,-1)

  return if cb.nil?

  cpee = File.dirname(instance_url)

  send = {
    'CPEE-INSTANCE' => instance,
    'CPEE-INSTANCE-URL' => instance_url,
    'CPEE-INSTANCE-UUID' => uuid,
    'CPEE-STATE' => notification['content']['state']
  }

  if notification['content']['state'] == condition
    cblist.del(key)
    srv = Riddl::Client.new(cpee)
    res = srv.resource("/#{instance}/properties/dataelements")
    status, response = res.get
    if status >= 200 && status < 300
      doc = XML::Smart.string(response[0].value.read)
      doc.register_namespace 'p', 'http://cpee.org/ns/properties/2.0'
      doc.find('/p:dataelements/*').each do |e|
        send[e.qname.name] = CPEE::ValueHelper::parse(e.text)
      end
    end
    Riddl::Client.new(cb).put Riddl::Parameter::Complex.new('dataelements','application/json',JSON::generate(send))
  else
    Riddl::Client.new(cb).put [
      Riddl::Header.new('CPEE-UPDATE','true'),
      Riddl::Parameter::Complex.new('dataelements','application/json',JSON::generate(send))
    ]
  end
end