Changeset 233

Timestamp:

12/14/06 15:24:52 (2 years ago)

Author:

sacha

Message:

more fixes to get the basics working

Files:

• branches/message-handling-refactor-branch/src/hefeweizen_big_ania.rb (modified) (9 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_b2b_system.rb (modified) (2 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_ebMS_message2.rb (modified) (1 diff)
• branches/message-handling-refactor-branch/src/hefeweizen_library_transactions.rb (modified) (1 diff)
• branches/message-handling-refactor-branch/src/hefeweizen_library_utils.rb (modified) (1 diff)
• 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

@@ -666 +666 @@
-    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
@@ -760 +756 @@
-              return false, msg
-            else
-l
+L
-              result = process_new_ebXML_message2 command, command_hash, transaction              
-              if result == false then
@@ -915 +911 @@
-      # depends whether this is received on server or is a response from a client.
-      if command_hash['file_full'] then
+        @logger.debug "This ebXML message seems to be received by an server"
-        # setting root cause of this new transaction.
-        transaction.set_root_cause command_hash['file_full']
@@ -923 +920 @@
-        transaction.remember_file_to_remove [command_hash['file_full'], command_hash['file_body'], command_hash['file_header']]
-      else
+        @logger.debug "This ebXML message seems to be received by an client"
-        # setting root cause of this new transaction.
-        transaction.set_root_cause command_hash['response_file_path']
@@ -976 +974 @@
-
-
-      
-      # CONTINUE WITH PROCESSING
-      # ------------------------
@@ -1034 +1031 @@
-
-        # CONTINUE PROCESSING
+        # -------------------
-
-        # Check if there is something else to do.
@@ -1068 +1066 @@
-          @logger.debug "No futher action required for ebXML message '#{ebXML_message_object.summary}'."
-        end
-
-
-
-
-
-
+
+
+
+
+
-          
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-            
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-                return false
-              end
-
+              @logger.debug "Created a new transaction for outgoing ebXML response message. Transaction id: #{new_transaction.transaction_id}"
+
+              # This is a new transaction so we have to set the root cause of this new transaction.
+              if !new_transaction.set_root_cause new_ebXML_message_object.raw_message_file_path then
+                @logger.error "Unable to store the new response ebXML message as root cause to the new transaction"
+                # TODO remove stuff?
+                return false
+              else
+                @logger.debug "Succesfully stored the directive as root cause"
+              end
+              
+              # Some transaction stuff
+              path = "#{@config['MESSAGE_DIR']}/#{b2b_system.system_name}/#{new_ebXML_message_object.message_id}"
+              complete_ebXML_message_file_path = "#{path}/ebXML_message.ebMS2"
+              complete_ebXML_message_parameters_file_path = "#{path}/ebXML_message_parameters.yml"
+              
+              new_transaction.attach_file complete_ebXML_message_file_path, "outgoing ebXML message (response)"
+              new_transaction.attach_file complete_ebXML_message_parameters_file_path, "outgoing ebXML message parameters (response)"
+              
+              # attach the ebXML message to the transaction
+              new_transaction.transition_to_new_state "plain outgoing ebXML message created"
+              @logger.debug "Setting ebXML message id '#{ebMS_info['ebXML_message']['ebXML_message_id']}' to transaction."
+              new_transaction.add_ebXML_message_id_reference new_ebXML_message_object.message_id
+              
+              command, expectation = start_delivery( new_transaction, b2b_system.system_name )
+              if command.nil? then
+                @logger.warn "Unable to proceed with start deliervy."
+                transaction.fail "Error starting delivery"
+                return true
+              else
+                transaction.set_next_expectation(expectation)
+                say_to_ania command
+                return true
+              end
+
+            elsif ebMS_info['info']['mc-syncReplyMode'] == 'mshSignalsOnly'
+              @logger.debug "Sending msh signal synchronously back over HTTP transport protocol."
+              send_sync_response new_ebXML_message_object.raw_message_file_path, transaction, instruction_pipe
+              
+            elsif ebMS_info['info']['mc-syncReplyMode'] == 'signalsOnly'
+              @logger.warn "signalsAndResponse as syncReplyMode not implemented."
+              close_open_connection instruction_pipe, transaction
+              # ????
+              return false
+              
+            elsif ebMS_info['info']['mc-syncReplyMode'] == 'signalsAndResponse'
+              @logger.warn "signalsAndResponse as syncReplyMode not implemented."
+              close_open_connection instruction_pipe, transaction
+              # ????
+              return false
+              
+            elsif ebMS_info['info']['mc-syncReplyMode'] == 'responseOnly'
+              @logger.warn "signalsAndResponse as syncReplyMode not implemented."
+              close_open_connection instruction_pipe, transaction
+              # ????
+              return false
+              
-            else
+              @logger.debug "Unknown syncReplyMode '#{ebMS_info['info']['mc-syncReplyMode']}'. Not returning new responses."
+              close_open_connection instruction_pipe, transaction
+              # ????
+              return false
-            end
-
+          else
+            @logger.error "Responding an ebXML user message as a response to an ebXML message is not yet implemented."
+            return false
-          end
-
-
-
-
-
-
-
+
+
+
+
-        # o if sync protocol and no sync response expected.
-        
-
-
-
-
+
+
+
+
+
-
-      return true
-
-
-    end
@@ -1209 +1258 @@
-          return false
-        else
-
+
+
-        end
-      else
@@ -1216 +1266 @@
-      end
-    end
+
+
+
+
+
+
-
-    ################# rewrite

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

@@ -267 +267 @@
-        end
-        
-
+_path
-
-        # 1. create an ebXML message object
@@ -445 +445 @@
-          # TODO remove new ebxml object ?
-          return nil
+        else
+          ebXML_message_object.raw_message_file_path = "#{directory}/ebXML_message.ebMS2"
-        end
-

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

@@ -280 +280 @@
-      attr_reader :references, :payloads
-      attr_reader :errors
-reade
+accesso
-      
-      def get_hash_value cpa

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

@@ -69 +69 @@
-      end
-      
+      def get_new_transaction
+        get_transaction HefeWeizen::HefeWeizenLibrary::HefeWeizenUUID.uuid
+      end
+
-      def get_transaction transaction_id
-        transaction = nil

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

@@ -69 +69 @@
-    
-    class HefeWeizenUUID
-self
+HefeWeizenUUID
-        %x( uuid ).strip
-      end

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

@@ -107 +107 @@
-          # FIX ME FOR TESTING PURPOSE SEND IT TO A LOCAL WEBSERVER
-          #        http_url = "localhost:5555/test"
+
+          # FIX ME FOR TESTING PURPOSE SEND IT TO A LOCAL WEBSERVER
+#          http_url = "192.168.1.49:8888/gnaraloo"
-          
-          time = Time.now.to_f.to_s