Changeset 244

Timestamp:

12/15/06 18:07:39 (2 years ago)

Author:

sacha

Message:

started to validate ebMS acks.

Files:

• branches/message-handling-refactor-branch/src/hefeweizen_big_ania.rb (modified) (6 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_b2b_system.rb (modified) (11 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_ebMS_message2.rb (modified) (9 diffs)
• branches/message-handling-refactor-branch/src/taskers/hefeweizen_tasker_application_dir_observer.rb (modified) (1 diff)
• branches/message-handling-refactor-branch/src/taskers/hefeweizen_tasker_application_http_server.rb (modified) (4 diffs)
• branches/message-handling-refactor-branch/src/taskers/hefeweizen_tasker_application_send_ebXML_message.rb (modified) (1 diff)

branches/message-handling-refactor-branch/src/hefeweizen_big_ania.rb

@@ -26 +26 @@
-
---------------------------> set status of ebXML message (specially user message)
+-----------------------------> if no ack requested set it to delviered.
+-----------------------------> if ack requested set it to waiting for ack.
+-----------------------------> if ack receieved set it to delivered_and_acked
+-----------------------------> if ack requested or not if error message received set it to failed.
----------------------------------> link ebXML messages
-
@@ -1030 +1034 @@
-
-        # no validation errors
-
+
-        if ebXML_message_object.is_user_message? or ebXML_message_object.is_pig? then
-          # creating HefeWeizenDirective about new incoming ebXML message.
@@ -1141 +1145 @@
-              complete_ebXML_message_parameters_file_path = "#{path}/ebXML_message_parameters.yml"
-              
-(response)
-(response)
+ response
+ response
-              
-              # attach the ebXML message to the transaction
@@ -1232 +1236 @@
-#      end
-
+      if instruction_pipe.nil? or instruction_pipe.empty? then
+        return nil
+      end
-      command_to_http_server = {
-        "from" => "big_ania", 
@@ -1253 +1260 @@
-        create_signed_ack = false
-        
- ? true : false
+
-        
-        if create_ack then 
- ? true : false
-
-
+
+
+
-        if create_ack == true and create_signed_ack == false then
-          return true, "Acknowledgment"
@@ -1264 +1271 @@
-          return true, "SignedAcknowledgment"
-        end
-
+
+
+
-      elsif ebXML_message_object.is_ebMS_signal? then
-        # an ebMS signal

branches/message-handling-refactor-branch/src/hefeweizen_library_b2b_system.rb

@@ -166 +166 @@
-        file_path = "#{@config['MESSAGE_DIR']}/#{system_name}/#{ebXML_message_id}/ebXML_message_parameters.yml"
-        if FileTest.exists? file_path and FileTest.readable? file_path then
-file_path
+"r"
-        else
-          @logger.warn "There is no ebXML message parameters file for ebXML message with id '#{ebXML_message_id}' in the path of '#{file_path}'."
-          return nil
+        end
+      end
+
+      def exists_ebXML_message_by_id? referenced_ebXML_message_id
+        path = "#{@config['MESSAGE_DIR']}/#{system_name}/#{referenced_ebXML_message_id}"
+        if FileTest.exists? path and FileTest.directory? path then
+          ebXML_message = path + "/ebXML_message.ebMS2"
+          if FileTest.exists? ebXML_message then
+            return true
+          else
+            @logger.warn "Message with id #{referenced_ebXML_message_id} does have a directory but does not contain an ebXML_message.ebMS2 message."
+            return false
+          end
+        else
+          @logger.warn "Message with id #{referenced_ebXML_message_id} does not exist in the message store"
+          return false
-        end
-      end
@@ -202 +218 @@
-        dev['ebXML_message_conversation_id'] = metadata['ebXML_message_conversation_id']
-        dev['ebXML_message_is_mutliparty'] = metadata['ebXML_message_is_multiparty']
-
+
+
+
-        # add directive stuff to ebMS_info
-        directive_info = ebMS_message_info['directive'] = Hash.new
@@ -259 +277 @@
-        
-        if command_hash['file_header'] then
+        
-          # 1. very basic transport header validation only possible from an transport server
-          transport_header_validation = @ebMS_message_manager.ebXML_message_transport_protocol_header_validation command_hash['file_header']
@@ -271 +290 @@
-        end
-        
+        # this is required because an ebXML message can come in async or synchronouse.
-        file = command_hash['file_full'].nil? ? command_hash['response_file_path'] : command_hash['file_full']
-
@@ -282 +302 @@
-        
-        # 1. validate whether it is OK to receive such an ebXML message
+        #    -> this includes the validation of acknowledgments. whether there are 
+        #       ebXML messages in the message store that are acknowledged
-        ok, ebMS_message_info, validation_errors = validate_ebXML_message command_hash, ebXML_message_object
-        if ok.nil? or ok == false then
@@ -530 +552 @@
-        if ebXML_message_object.is_pig? then
-          @logger.warn "An ebMS signal that piggy backs a user message is not yet implemented."
+          
-        elsif ebXML_message_object.is_user_message? then
+          @logger.debug "We are looking at a user message."
+
+          #######################
-          #######################
-          # CHECK USER MESSAGE
-          #######################
-@logger.debug "We are looking at a user message."
+#######################
-
-          #################################
@@ -544 +570 @@
-          # ---------------
-          sync_possible = false
+
-          if command_hash['transport_protocol'].upcase == 'HTTP' then
-            @logger.debug "The ebXML message was received over HTTP."
@@ -590 +617 @@
-            check_ack_signature_requested = true
-          else
+            # per message is always ok.
-            check_ack_signature_requested = true
-            # per message is always ok.
-          end
-
@@ -615 +642 @@
-          # CHECK DUPLICATE ELIMINATION
-          # ---------------------------
-
+
-          if info_structure['mc-duplicateElimination'] == 'never' and ebXML_message_object.has_duplicate_elimination? then
-            errors << ( HefeWeizen::HefeWeizenLibrary::EBMSError.new "", "CPA says this message must be sent never with duplicateElimination set but this message has duplicate elimination set. This is wrong." )
@@ -671 +698 @@
-        else
-
-          #######################
-          # CHECK USER MESSAGE
-          #######################
-
-          # 2. ebMS signal
-          @logger.debug "We are looking at an ebMS signal."
-          
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-        end
@@ -693 +920 @@
-        
-        @logger.debug "ebMS message validation checks done."
-
+  
-          msg = errors.join("\n")
-          @logger.warn msg

branches/message-handling-refactor-branch/src/hefeweizen_library_ebMS_message2.rb

@@ -71 +71 @@
-
-        # creating the ebXML message
-
+, has_ack_requested, has_signed_ack_requested
-                                                 file_path, @config, message_id, conversation_id)
-        
@@ -86 +86 @@
-          'ebXML_message_id' => message_id, 
-          'ebXML_message_conversation_id' => conversation_id,
-
+
+
+
-        }
-
@@ -283 +285 @@
-      attr_reader :errors
-      attr_accessor :raw_message_file_path
-
+
+
-      def get_hash_value cpa
-        hash = Hash.new
@@ -324 +327 @@
-      end
-
+      def is_user_message?
+        @service != "urn:oasis:names:tc:ebxml-msg:service"
+      end
+
-      def is_ebMS_signal?
-        (@service == "urn:oasis:names:tc:ebxml-msg:service" and ["MessageError", "Ping", "Pong", "StatusRequest", "StatusResponse", "Acknowledgment"].include? @action ) ? true : false
-      end
-      
-user_message
-@service != "urn:oasis:names:tc:ebxml-msg:service"
+acknowledgment
+(@service == "urn:oasis:names:tc:ebxml-msg:service" and @action == "Acknowledgment") ? true : false
-      end
-
@@ -342 +349 @@
-      def is_status_request?
-        (@service == "urn:oasis:names:tc:ebxml-msg:service" and @action == "StatusRequest") ? true : false
+      end
+
+      def is_status_response?
+        (@service == "urn:oasis:names:tc:ebxml-msg:service" and @action == "StatusResponse") ? true : false
-      end
-
@@ -395 +406 @@
-
-        is_multiparty = false
+        
+        has_ack_requested = false
+        has_signed_ack_requested = false
-
-        # Party Identities
@@ -430 +444 @@
-          
-          ebXML_message.close
-
+, false, false
-
-        else
@@ -448 +462 @@
-          if ebMS_message_info['info']['mc-ackRequested']  == 'always' or
-              (ebMS_message_info['info']['mc-ackRequested'] == 'perMessage' and directive.ackRequested == 'yes') then
+            has_ack_requested = true
-            if ebMS_message_info['info']['mc-ackSignatureRequested'] == 'always' or
-                (ebMS_message_info['info']['mc-ackSignatureRequested'] == 'perMessage' and directive.ackSignatureRequested == 'yes') then
-              signed = "yes"
+              has_signed_ack_requested = true
-            else
-              signed = "false"
@@ -564 +580 @@
-          end
-          
-
+, has_ack_requested, has_signed_ack_requested
-          
-        end

branches/message-handling-refactor-branch/src/taskers/hefeweizen_tasker_application_dir_observer.rb

@@ -76 +76 @@
-        if !@pipe_to_monitor.nil? then
-          f = File.open @pipe_to_monitor, "w"
-
+
+
-          f.close
-        else

branches/message-handling-refactor-branch/src/taskers/hefeweizen_tasker_application_http_server.rb

@@ -32 +32 @@
-    # the thread can exit.
-    class EBMSServlet < WEBrick::HTTPServlet::AbstractServlet
-
-
-
+
-      def do_POST(req, resp)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-          command_hash = {
-            "from" => "hefeweizen_tasker_application_http_server", 
-            "to" => "big ania", 
-            "b2b_system_name" => @b2b_system_name,
-
-
-
-
-
-
-
+
+
-            "time" => now.to_s,
-"#{HefeWeizen::HefeWeizenLibrary::HefeWeizenUUID.uuid}_#{@b2b_system_name}"
+hash['transaction_id']
-          }
+            
+          # TODO
+          # how does sending an response fail?
+          # --> maybe calling side closed the connection?
+          
+          if true then
+            # send big ania that sending the response was successful.
+            command_hash["status"] = "OK"
+          else
+            # send big ania that sending the response failed.
+            command_hash["status"] = "FAILED"
+            command_hash["reason"] = "????????????????? description"
+          end
-          
-          command = HefeWeizen::HefeWeizenLibrary::HefeWeizenCommand.hash_to_command command_hash
-          write_to_ania command
-          
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
-        return true
-      end
@@ -181 +178 @@
-        @config = config
-        @pipe_to_ania = pipe_to_ania
-        require "#{@config['LIB_DIR']}/hefeweizen_library_utils"
-      end
-
@@ -269 +265 @@
-
-      def http_server_serve
-        
-        s = WEBrick::HTTPServer.new( {:Logger => @logger, :Port => @port} )
-        s.mount @path, InitializedEBMSServlet, @b2b_system_name, @config, @pipe_to_ania
-        trap("INT"){ s.shutdown }
-        s.start
-
-        return 0
-
@@ -291 +285 @@
-        end
-      end
-
+ HTTPServer
-
-  end # module Tasker

branches/message-handling-refactor-branch/src/taskers/hefeweizen_tasker_application_send_ebXML_message.rb

@@ -130 +130 @@
-          
-          #        command = "wget -S --user-agent=\"HefeWeizen\" --post-file=#{@ebXML_message_file_path} --header='#{extra_header}' --header='SOAPAction: \"ebXML\"' --output-document=#{response_file_path} --tries=#{number_of_retries} --wait=#{seconds_to_wait_between_retries} --quiet #{http_url}"
-
+          
-          # no retries here!
-
-
-
+          
-
-          # added ignore-length ... had problems with it when using webrick and setting code 204 to it.