server/executionhandlers/ruby/connection.rb in cpee-2.1.27 vs server/executionhandlers/ruby/connection.rb in cpee-2.1.29
- old
+ new
@@ -147,12 +147,12 @@
end #}}}
def activity_handle(passthrough, parameters) # {{{
raise "Wrong endpoint" if @handler_endpoint.nil? || @handler_endpoint.empty?
@label = parameters[:label]
- @anno = parameters[:annotations]
- @controller.notify("activity/calling", :'activity-uuid' => @handler_activity_uuid, :label => @label, :activity => @handler_position, :passthrough => passthrough, :endpoint => @handler_endpoint, :parameters => parameters, :annotations => anno)
+ @anno = parameters.delete(:annotations) rescue nil
+ @controller.notify("activity/calling", :'activity-uuid' => @handler_activity_uuid, :label => @label, :activity => @handler_position, :passthrough => passthrough, :endpoint => @handler_endpoint, :parameters => parameters, :annotations => @anno)
if passthrough.to_s.empty?
proto_curl parameters
else
@controller.callback(self,passthrough,:'activity-uuid' => @handler_activity_uuid, :label => @label, :activity => @handler_position)
@handler_passthrough = passthrough
@@ -196,11 +196,11 @@
def inform_manipulate_change(status,changed_dataelements,changed_endpoints,dataelements,endpoints) # {{{
unless status.nil?
@controller.notify("status/change", :'activity-uuid' => @handler_activity_uuid, :endpoint => @handler_endpoint, :label => @label, :activity => @handler_position, :id => status.id, :message => status.message)
end
unless changed_dataelements.nil? || changed_dataelements.empty?
- de = dataelements.slice(*changed_dataelements).transform_values { |v| enc = detect_encoding(v); (enc == 'OTHER' ? v.inspect : (v.encode('UTF-8',enc) rescue convert_to_base64(v))) }
+ de = dataelements.slice(*changed_dataelements).transform_values { |v| enc = detect_encoding(v); (enc == 'OTHER' ? v : (v.encode('UTF-8',enc) rescue convert_to_base64(v))) }
@controller.notify("dataelements/change", :'activity-uuid' => @handler_activity_uuid, :endpoint => @handler_endpoint, :label => @label, :activity => @handler_position, :changed => changed_dataelements, :values => de)
end
unless changed_endpoints.nil? || changed_endpoints.empty?
@controller.notify("endpoints/change", :'activity-uuid' => @handler_activity_uuid, :endpoint => @handler_endpoint, :label => @label, :activity => @handler_position, :changed => changed_endpoints, :values => endpoints.slice(*changed_endpoints))
end
@@ -274,10 +274,10 @@
ttt = JSON::parse(r.value.read) rescue nil
if ttt.nil?
''
else
enc = detect_encoding(ttt)
- enc == 'OTHER' ? ttt.inspect : (ttt.encode('UTF-8',enc) rescue convert_to_base64(ttt))
+ enc == 'OTHER' ? ttt : (ttt.encode('UTF-8',enc) rescue convert_to_base64(ttt))
end
elsif r.mimetype == 'text/plain' || r.mimetype == 'text/html'
ttt = r.value.read
ttt = ttt.to_f if ttt == ttt.to_f.to_s
ttt = ttt.to_i if ttt == ttt.to_i.to_s