Changeset 232

Timestamp:

12/14/06 13:55:12 (2 years ago)

Author:

sacha

Message:

added more to exchange messages.

Files:

• branches/message-handling-refactor-branch/src/hefeweizen_big_ania.rb (modified) (15 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_b2b_system.rb (modified) (5 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_cpa.rb (modified) (2 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_ebMS_message2.rb (modified) (23 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_transactions.rb (modified) (1 diff)
• branches/message-handling-refactor-branch/src/taskers/hefeweizen_tasker_application_http_server.rb (modified) (3 diffs)
• branches/message-handling-refactor-branch/src/taskers/hefeweizen_tasker_application_send_ebXML_message.rb (modified) (2 diffs)
• branches/message-handling-refactor-branch/test/tools/hefeweizen_tool_tester.rb (modified) (2 diffs)
• branches/message-handling-refactor-branch/test/unit-tests/tc_hefeweizen_library_cpa_test.rb (modified) (5 diffs)
• branches/message-handling-refactor-branch/test/unit-tests/tc_hefeweizen_library_ebMS_message_test.rb (modified) (3 diffs)

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

@@ -7 +7 @@
-require 'yaml'
-require 'xsd/mapping'
+
+
+=begin
+todo: 
+
+check ebXML message validation  in b2b system
+
+-> problem of ebXML message ... to find the right ebMS info. eg if error message is coming back as a http sync response then we need the ebMS info of the orignal action. i think transport information must be passed on to the validator.
+
+-> if transport protocol async then no problem.
+-> if transport protocol sync then message receiver must provide info whether it is on the request or the response leg.
+
+o proper delivery preparation for sending ebxml message
+o proper delivery preparation for incoming ebxml message
+o create response (ebxml ack, http ok, nothing, error message)
+  o no user message response, yet
+o produce directive of incoming ebxml message
+
+--------------------------> set status of ebXML message (specially user message)
+---------------------------------> link ebXML messages
+
+
+=end
-
-module HefeWeizen
@@ -426 +449 @@
-            if result == true
-              @logger.debug "Successfully processed new directive."
+
-              @logger.debug "Its time to deliver the ebXML message."
-              command, expectation = start_delivery( transaction, command_hash['b2b_system_name'] )
-
-
-
+
+
+
+
+
+
+
+
+
-            elsif result == false then
-              @logger.debug "Problems processing new directive xx."
@@ -455 +485 @@
-          
-          command, expectation = start_an_encrypting_tasker metadata, transaction.transaction_id, command_hash['b2b_system_name']
+          if command.nil? then
+            @logger.warn "Unable to proceed with start deliervy."
+            transaction.fail "Error starting delivery"
+            return true
+          else
+            # SET EXPECTED NEW STATE
+            transaction.set_next_expectation(expectation)
+            say_to_ania command
+            return true
+          end
+        else
+          @logger.debug "ebXML message must NOT be encrypted."
+        end
+
+        @logger.debug "Its time to deliver the ebXML message."
+        command, expectation = start_delivery( transaction, command_hash['b2b_system_name'] )
+        if command.nil? then
+          @logger.warn "Unable to proceed with start deliervy."
+          transaction.fail "Error starting delivery"
+          return true
+        else
-          # SET EXPECTED NEW STATE
-          transaction.set_next_expectation(expectation)
-          say_to_ania command
-          return true
-
-
-
-
-
-
-
-
-
+
-      elsif command == 'encrypt ebXML message done' then
-        @logger.debug "Received encrypt ebXML message is done."
-        transaction.transition_to_new_state "encrypt ebXML message done"
+
-        @logger.debug "Its time to deliver the ebXML message."
-        command, expectation = start_delivery( transaction, command_hash['b2b_system_name'] )
-
-
-
+
+
+
+
+
+
+
+
+
+
-        
-      elsif command == 'start ebXML message delivery' then
-        @logger.debug "Received start ebXML message delivery command."
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
-          transaction.fail msg
+          return false
+        else
+          @logger.debug "Start of delivery of ebXML message can start."
+          transaction.set_next_expectation(expectation)
+          say_to_ania command
-          return true
-        end
+
-      elsif command == 'send ebXML message done'
-        @logger.debug "Send ebXML message done."
@@ -509 +549 @@
-        # o synchronous or asynchronous ebXML error message for this ebXML message is received.
-        # o an acknowledgment may be required for the ebXML message.
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-      elsif command == 'new ebXML message received' then
+        @logger.debug "Received new ebXML message!"
-        if !transaction.open_and_new? then
-
-
-
-
+
+
+
-          result = process_new_ebXML_message2 command, command_hash, transaction
-          if result == false then
-
-close_transaction('failed', "Failed to process ebXML message.")
+incoming 
+fail "Failed to process ebXML message."
-            return false
-          else
@@ -541 +595 @@
-    end
-
-
-ebMS_info['ebXML_message']['ebXML_message_dir']}/#{ebMS_info['ebXML_message']['ebXML_message_parameters_file_name']}
+, b2b_system_name
+@config['MESSAGE_DIR']}/#{b2b_system_name}/#{ebMS_info['ebXML_message']['ebXML_message_id']}/ebXML_message_parameters.yml
-      file = File.new(path, "w")
-      YAML.dump ebMS_info, file
@@ -557 +611 @@
-    end
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-      ebMS_info = get_ebMS_info ebXML_message_id, b2b_system_name
-      if ebMS_info.nil? then
@@ -564 +641 @@
-      end
-      @logger.debug "Successfully read the ebXML message info structure for ebXML message with id #{ebXML_message_id}."
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
-      
-      #call tasker to send ebXML message
@@ -586 +659 @@
-        "command" => "start_tasker",
-        "tasker" => "#{@config['BIN_DIR']}/hefeweizen_tasker_application_send_ebXML_message.rb",
-MS_info['ebXML_message']['ebXML_message_dir']}/#{ebMS_info['ebXML_message']['ebXML_message_file_name']} --parameters-file-path #{ebMS_info['ebXML_message']['ebXML_message_dir']}/#{ebMS_info['ebXML_message']['ebXML_message_parameters_file_name']
+XML_message_file_path} --parameters-file-path #{ebXML_message_parameters_file_path
-        "uuid" => HefeWeizen::HefeWeizenLibrary::HefeWeizenUUID.uuid
-      }
-      
-
-
-
-
-
-
-
-
-
+
-    end
-    
+    def temp_close_connection command, command_hash, transaction
+      puts 'xxxxxxxxxxxxxxxxxxxx'
+    end
+
-    def delivery_ack_requested? ebMS_info
-      (ebMS_info['info']['mc-ackRequested'] == 'always' or ( ebMS_info['info']['mc-ackRequested'] == 'perMessage' and !ebMS_info['directive']['ackRequested'].nil? ) ) ? true : false
@@ -609 +678 @@
-    end
-
+    # This method starts the delivery of an ebXML message.
-    def start_delivery transaction, b2b_system_name
-Lets beam us to the ebXML message deliver state
+Starting the delivery process.
-      transaction.transition_to_new_state "ebXML message delivery process started"
+
-      expectation = "start_ebXML_message_delivery"
-      command_hash = {
@@ -626 +697 @@
-    end
-
+    # This meesage processes the response of sending an ebXML message.
+    # o when the message was sent via SMTP then there is no info here.
+    # o when the message was sent via HTTP and there was no sync response then there is no info here.
+    # o when the message was sent via HTPT and there was a sync response then we have to process the response.
+    def process_send_ebXML_message_response transaction, command, command_hash
+      @logger.debug "sending of ebXML message done. received answer from sending tasker."
+      transaction.transition_to_new_state "ebXML message sent. processing response."
+      transaction.attach_file command_hash['transfer_info_path'], "transfer information" if command_hash['transfer_info_path']
+      transaction.remember_file_to_remove command_hash['transfer_info_path'] if command_hash['transfer_info_path']
+      transaction.attach_file command_hash['response_file_path'], "outgoing ebXML message response" if command_hash['response_file_path']
+      transaction.remember_file_to_remove command_hash['response_file_path'] if command_hash['response_file_path']
+
+      if command_hash['status'].upcase == "OK" then
+        @logger.debug "Received Success OK from the ebXML message sending tasker."
+      else
+        msg = "Received a FAILURE as status from the ebXML message sending tasker."
+        @logger.warn msg 
+        return false, msg
+      end
+
+      if command_hash['transport_protocol'].upcase  == "SMTP" then
+        @logger.debug "The SMTP transport protocol was used so no direct response (ebXML MS signal) possible."
+
+        # TODO set ebXML message to delivered!
+        return true, "Successfully completed transaction."
+      else
+        transfer_info_file = command_hash['transfer_info_path']
+        response_file = command_hash['response_file_path']
+
+        has_content = true
+        if FileTest.exists? transfer_info_file and FileTest.readable? transfer_info_file then
+          transfer_info = File.read transfer_info_file
+          transfer_info.each_line{ | line |
+            if line =~ /.*HTTP\/1\.1 204 No Content/ then
+              has_content = false
+              break
+            end
+          }
+
+          if has_content == false then
+            if FileTest.exists? response_file and !FileTest.zero? response_file then
+              @logger.warn "HTTP response indicates that there is no content (response code 204) but the response file exists and is not empty."
+              @logger.debug "Continuing with processing response file."
+              result = process_new_ebXML_message2 command, command_hash, transaction              
+              if result == false then
+                msg = "Error processing response from sending an ebXML Message."
+                @logger.warn msg 
+                return false, msg
+              end
+              return true, "Succesfully processed response ebXML message."
+            else
+              @logger.debug 'There was no response from sending ebXML message.'
+              # TODO validate if that is OK.
+              return true, "I ASSUME THIS FUCKER IS OKEY."
+            end
+
+          elsif has_content == true then
+            if FileTest.exists? response_file and FileTest.zero? response_file then
+              msg = "HTTP response indicates that there is content but the resposne file is empty."
+              @logger.warn msg
+              @logger.debug "Failing transction"
+              return false, msg
+            else
+              @logger.debug "Processing response from sending ebXMl message."
+              result = process_new_ebXML_message2 command, command_hash, transaction              
+              if result == false then
+                msg = "Error processing response from sending an ebXML Message."
+                @logger.warn msg 
+                return false, msg
+              end
+              return true, "Succesfully processed response ebXML message."
+            end
+          end
+
+        else
+          msg = "Unable to read transfer log of HTTP ebXML sending tasker to determine if there is a response."
+          @logger.warn msg
+          return false, msg
+        end
+
+
+      end
+      
+    end
+
+
-    def process_new_directive2 command, command_hash, transaction
-      
@@ -674 +831 @@
-      end
-      
+      # Some transaction stuff
-      path = "#{@config['MESSAGE_DIR']}/#{b2b_system.system_name}/#{ebMS_info['ebXML_message']['ebXML_message_id']}"
-puts 
-puts 
+
+
-
-      transaction.attach_file complete_ebXML_message_file_path, "outgoing ebXML message"
@@ -682 +840 @@
-
-      # attach the ebXML message to the transaction
-
+outgoing 
-      @logger.debug "Setting ebXML message id '#{ebMS_info['ebXML_message']['ebXML_message_id']}' to transaction."
-      transaction.add_ebXML_message_id_reference ebMS_info['ebXML_message']['ebXML_message_id']
+
-
-      # ebXML message is created.
@@ -753 +912 @@
-    def process_new_ebXML_message2 command, command_hash, transaction
-      @logger.debug "Reading received ebXML message."
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
-        transaction.remember_file_to_remove [command_hash['file_full'], command_hash['file_body'], command_hash['file_header']]
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
-      
-      b2b_system = @b2b_systems[command_hash['b2b_system_name']]
@@ -785 +937 @@
-        return false
-      end
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-        return true
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-    ################# rewrite
@@ -819 +1222 @@
-    ################# rewrite
-    
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-

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

@@ -163 +163 @@
-      end
-
+      def get_ebXML_message_parameters_file_content ebXML_message_id
+        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
+          return YAML.load((File.open file_path, file_path))
+        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
-
-      # This message processes a directive. This typically invloves to create an ebXML message.
@@ -206 +215 @@
-        end
-
+        comment = HefeWeizen::HefeWeizenLibrary::TempEBMessage2.ebMS_info_includes_ebMS_signal?(ebMS_message_info) ? "is_ebMS_signal" : "is_user_message"
+        @ebMS_message_manager.add_comment_to_ebXML_message system_name, metadata['ebXML_message_id'], comment
+
-        success = @ebMS_message_manager.add_ebXML_message_info_file_to_message_store system_name, directory, ebMS_info_file_path
-        if success.nil? then
@@ -211 +223 @@
-          return nil
-        end
+
-        return ebMS_message_info
-      end
@@ -231 +244 @@
-
-      # This method processes an incoming ebXML message
-
+
+
+
+
+
-        if command_hash.nil? then
-          @logger.warn "The command hash is null."
-          return nil
-        end
+        
+        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']
+          if transport_header_validation.nil? then
+            @logger.warn "Unable to process ebXML message transport header file."
+            return nil, nil, "System Error"
+          elsif transport_header_validation == false then
+            @logger.warn "The ebXML message transport header does not look qualify for an ebXML message. Rejecting this message."
+            return nil, nil, "Not an ebXML message."
+          end
+          @logger.debug "Incoming message transport header qualifies for an ebXML message."
+        end
+        
+        file = command_hash['file_full'].nil? ? command_hash['response_file'] : command_hash['file_full']
-
-        # 1. create an ebXML message object
-command_hash['file_full']
+file
-        if ebXML_message_object.nil? then
-          @logger.warn "Unable to create an ebXML message object from the command_hash"
-
+, nil, "Unable to parse ebXML message."
-        end
-        @logger.debug "Successfully create an ebXML object from the incoming ebXML message. ebXML message is not yet added to the message store."
-
+
-        # 1. validate whether it is OK to receive such an ebXML message
-info, validation_errors = validate_ebXML_message command_hash, ebMS
+message_info, validation_errors = validate_ebXML_message command_hash, ebXML
-        if ok.nil? or ok == false then
-MS_message
-
+XML_message_object
+ if !validation_errors.nil?
-          @logger.warn msg
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-        }
-
-
-
-
-
-
-
-