Changeset 229

Timestamp:

12/09/06 14:41:39 (2 years ago)

Author:

sacha

Message:

in the middle of refactoring.
processing of directive ok
creation of ebXML message ok
adding ebXML message to message store ok
adding ebXML message parameters file to message store ok

Files:

• branches/message-handling-refactor-branch/bin/run-command-center.rb (modified) (1 diff)
• branches/message-handling-refactor-branch/bin/run-copy-directive-n.sh (modified) (1 diff)
• branches/message-handling-refactor-branch/src/hefeweizen_big_ania.rb (modified) (12 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_b2b_system.rb (modified) (2 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_directive.rb (modified) (1 diff)
• branches/message-handling-refactor-branch/src/hefeweizen_library_ebMS_message2.rb (modified) (14 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_transactions.rb (modified) (1 diff)
• branches/message-handling-refactor-branch/src/taskers/hefeweizen_tasker_application_send_ebXML_message.rb (modified) (5 diffs)
• branches/message-handling-refactor-branch/src/taskers/hefeweizen_tasker_system_tasker_monitor.sh (modified) (1 diff)
• branches/message-handling-refactor-branch/test/tools/hefeweizen_tool_tester.rb (modified) (1 diff)
• branches/message-handling-refactor-branch/test/unit-tests/tc_hefeweizen_library_cpa_test.rb (modified) (1 diff)
• branches/message-handling-refactor-branch/test/unit-tests/tc_hefeweizen_library_ebMS_message_test.rb (modified) (16 diffs)
• branches/message-handling-refactor-branch/test/unit-tests/tc_hefeweizen_library_transactions_test.rb (modified) (1 diff)
• branches/message-handling-refactor-branch/test/various/sending_lots_of_pings.rb (modified) (2 diffs)

branches/message-handling-refactor-branch/bin/run-command-center.rb

@@ -247 +247 @@
-                          { :type => "urn:li.coronation.b2b", :id => "coronation_test_system"} ]
-
- cpa.id, party_name, party_identities
+( cpa.id, party_name, party_identities )
-      number_directives = work_directive_dynamic_menu cpas_info, number_directives
-    when "S"

branches/message-handling-refactor-branch/bin/run-copy-directive-n.sh

@@ -10 +10 @@
-  cp "../test/sample-directives/directive_send_invoice_cpa_id_Coronation::Gnaraloo::UBL 1.0 Invoice Notification.xml" /tmp/test
-  su hefeweizen -c "cp \"../test/sample-directives/directive_send_invoice_cpa_id_Coronation::Gnaraloo::UBL 1.0 Invoice Notification.xml\" /var/spool/hefeweizen/coronation/outgoing/directives/directive_invoice_$UUID1_$UUID1"
-1
+
-done
-

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

@@ -414 +414 @@
-        @logger.debug "Received new directive!"
-        if !transaction.open_and_new? then
-
+
+
-        else
-          result = process_new_directive2 command, command_hash, transaction
@@ -426 +427 @@
-              @logger.debug "Successfully processed new directive."
-              @logger.debug "Its time to deliver the ebXML message."
-
+
+
+
+
-            elsif result == false then
-              @logger.debug "Problems processing new directive xx."
-
+
+
-            end
-          elsif result.class == String then
@@ -436 +441 @@
-          else
-            @logger.warn "Problems processing new directive: #{result}"
-
+
+
-          end
-        end
@@ -457 +463 @@
-        end
-        @logger.debug "Its time to deliver the ebXML message."
-
-
+
+
+
+
-
-      elsif command == 'encrypt ebXML message done' then
@@ -464 +472 @@
-        transaction.transition_to_new_state "encrypt ebXML message done"
-        @logger.debug "Its time to deliver the ebXML message."
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-      # if transaction still open and noone processed it ....... I may have to close it.
-      
-    end
-  
+    def get_ebMS_info ebXML_message_id, b2b_system_name
+      ebXML_message_parameters_file_path = "#{@config['MESSAGE_DIR']}/#{b2b_system_name}/#{ebXML_message_id}/ebXML_message_parameters.yml"
+      return read_ebXML_message_info( ebXML_message_parameters_file_path )
+    end
+
+    def store_ebMS_info ebMS_info
+      path = "#{ebMS_info['ebXML_message']['ebXML_message_dir']}/#{ebMS_info['ebXML_message']['ebXML_message_parameters_file_name']}"
+      file = File.new(path, "w")
+      YAML.dump ebMS_info, file
+      file.close
+      return true
+    end
+
-    def read_ebXML_message_info ebXML_message_parameters_file_path
-      if (FileTest.exists?(ebXML_message_parameters_file_path) && FileTest.readable?(ebXML_message_parameters_file_path)) then
@@ -482 +557 @@
-    end
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-      transaction.transition_to_new_state "ebXML message delivery process started"
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
-    end
-
@@ -500 +636 @@
-      begin
-        directive = HefeWeizen::HefeWeizenLibrary::HefeWeizenDirective.new(@config, command_hash['file'])
-#        transaction.remember_file_to_remove command_hash['file'] if command_hash['file']
-      rescue Exception => e
-
@@ -524 +659 @@
-        @logger.debug "Succesfully stored the directive as root cause"
-      end
-
+
+
-      if !b2b_system.supports_directive? directive then
-        @logger.warn "B2BSystem #{b2b_system.system_name} does not support the directive."
@@ -532 +668 @@
-      begin
-        # this creates a plain ebXML message
-metadata
+ebMS_info
-      rescue Exception => e
-        @logger.warn "B2BSystem #{b2b_system.system_name} is unable to create an ebXML message: #{e.to_s}; #{e.backtrace}"
-        return false
-      end
-
-
-
-
-
+
+
+
+
+
+
+
+
+
-      transaction.transition_to_new_state "plain ebXML message created"
+      @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.
+      # Continue with processing
-
-      # signing first
-tru
+fals
-        @logger.debug "ebXML message must be signed. Starting a signer tasker"
-        command, expectation = start_a_signing_tasker metadata, transaction.transaction_id, b2b_system.system_name
@@ -605 +750 @@
-    end
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
@@ -617 +822 @@
-
-
-
+
-
-
@@ -1165 +1370 @@
-    end
-
-    # This method validates an ebXML message.
-    def validate_ebXML_message command_hash, ebMS_message
-
-      b2b_system = @b2b_systems[command_hash['b2b_system_name']]
-      if b2b_system.nil? then
-        error = HefeWeizen::HefeWeizenLibrary::EBMSError.new "", "There is no party with the name #{command_hash['b2b_system_name']}."
-        @logger.warn error
-        return false, nil, [error]
-      end
-      
-      cpa = b2b_system.get_cpa ebMS_message.cpa_id
-      if cpa.nil? then
-        error = HefeWeizen::HefeWeizenLibrary::EBMSError.new "","There is no CPA with id #{ebMS_message.cpa_id} for b2b_system with the name #{b2b_system.system_name}."
-        @logger.warn error
-        return false, nil, [error]
-      end
-      
-      hash_value = ebMS_message.get_hash_value cpa
-      
-      info_structure = cpa.get_ebMS_info_structure_for_hash_value hash_value
-      if info_structure.nil? then
-        error = HefeWeizen::HefeWeizenLibrary::EBMSError.new "","There is no Service '#{ebMS_message.service}' and Action '#{ebMS_message.action}' for this two PartyId's (sender #{ebMS_message.from_name} with type #{ebMS_message.from_type} and receiver #{ebMS_message.to_name} with type #{ebMS_message.to_type} ) in the ebXML CPA with id #{ebMS_message.cpa_id}."
-        @logger.warn error
-        return false, nil, [error]
-      else
-        # checks:
-        # o from party and to party OK? 
-        # --> already checked when looking up possilble incoming messages
-        # o ack requested ?
-        # o signature requested ?
-        # o encryption requested ?
-        
-        error_messages = Array.new
-        
-        if !ebMS_message.is_ebMS_signal? then
-          if info_structure['info']['mc-ackRequested'] == 'always' and !ebMS_message.ack_requested? then
-            require 'pp'
-            pp info_structure['info']
-            pp ebMS_message.to_s
-            error_messages << ( HefeWeizen::HefeWeizenLibrary::EBMSError.new "", "CPA says message must acknowledged but ebXML message does not include the Request for an Acknowledgment. This is a contradiction." )
-          elsif info_structure['info']['mc-ackRequested'] == 'never' and ebMS_message.ack_requested? then
-            error_messages << ( HefeWeizen::HefeWeizenLibrary::EBMSError.new "", "CPA says message must not never be acknowledged but ebXML message does include the Request for an Acknowledgment. This is a conradiction." )
-          end
-        end
-        
-        # TODO
-        # Reliable Messaging
-        # o check duplicate elimination
-        #   --> lookup message id
-        # fill validation_errors
-        
-        # TODO
-        # Decrypt if encrypted $
-        # --> needs to be done in the EBMSMesage constructor? so that the payloads can be decrypted?
-        # --> maybe if the payloads are encrypted the EBMSMessage constructor should not unpackage the payloads but
-        #     have a special method for it and that method would be called now.
-        # fill validation_errors
-        
-        # TODO
-        # Validate signature if signed
-        # fill validation_errors
-        
-        @logger.debug "ebMS Message check not yet completely implemented."
-        if !error_messages.empty? then
-          msg = error_messages.join("\n")
-          @logger.warn msg
-          return false, nil, error_messages
-        end
-      end
-      return true, info_structure, []
-    end
-
-  end

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

@@ -174 +174 @@
-        end
-        
+        # create a plain ebXML message
-        @logger.debug "Creating plain (not signed not encrypted) ebXML message"
-plain_messag
+ebXML_message_fil
-        if metadata.nil? then
-          throw Exception.new( "Error creating ebXML message" )
@@ -181 +182 @@
-        @logger.debug "Creating ebXML message done. ebXML message is created."
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-      end
-
-      private 
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-      def has_identity? id
-        @parameters['identities'].each{ | identity_hash |

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

@@ -11 +11 @@
-    class HefeWeizenDirective
-      
-
+, :tags
-      
-      def initialize config, file_path

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

@@ -40 +40 @@
-      # A plain message is one that has not been signed and not been
-      # encrypted.
-plain_messag
+ebXML_message_fil
-        party_ids = get_party_ids directive, ebMS_message_info
-
+
+
+
-        # message id handling
-        message_id = directive.messageId.nil? ? create_message_id(ebMS_message_info['from']) : directive.messageId
-        ebXML_message_dir_path = "#{@message_store_directory}/#{message_id}"
-        if FileTest.exists? ebXML_message_dir_path then
-          @logger.debug "There is an already existing ebXML message with the message id #{message_id} for party #{@b2b_system_name}. Trying a new message id #{message_id}"
-          message_id = create_message_id(ebMS_message_info['from'])
-          ebXML_message_dir_path = "#{@message_store_directory}/#{message_id}"
-          if FileTest.exists? ebXML_message_dir_path then
-            @logger.warn "There is an already existing ebXML message with the message id #{message_id} for party #{@b2b_system_name}"
-            # TODO
-            # what to do if there is already an ebXML message with that id???
-            return nil
-          end
-        end
-
-        FileUtils.mkdir_p ebXML_message_dir_path
-
-        # conversation id handling
-        conversation_id = directive.conversationId.nil? ? create_conversation_id : directive.conversationId
-
-
-
-
-
-
-
+
-        # creating the ebXML message
-        ebXML_message_file_name = "ebXML_message.ebMS2"
-        complete_ebXML_message_file_path = "#{ebXML_message_dir_path}/#{ebXML_message_file_name}"
-        time = Time.now
-        success = TempEBMessage2.create_message( party_ids, directive, ebMS_message_info, 
-
-
-
+
+
-        if !success then
-          @logger.warn "Error creating ebXML message."
-ebXML_message_dir
-_rf ebXML_message_dir
+file
+ file
-          end
-          return nil
-        end
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
-          return nil
-        end
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-      private
-      
-      def create_ebXML_message_parameters_file file_path, ebMS_message_info
-        file = File.new(file_path, "w")
-        # what is multipart used for?
-        #        ebMS_message_info['is_multipart'] = is_multipart.to_s
-        YAML.dump ebMS_message_info, file
-        file.close
-        return true
-      end
-
-
-      #######################################
@@ -179 +223 @@
-      end
-      
+    end # ebXML Message Manager class
+
+
+    class EBMSError
+
+      attr_reader :severity, :description, :code
+
+      def initialize severity, description, code = "FUCKER CODE"
+        @severity = severity.empty? ? "Error" : severity 
+        @description = description
+        @code = code
+      end
+
+      def to_s
+        "Error code '#{@code}' with severity '#{@severity}'. Error description: #{description}."
+      end
-    end
-
+
-    class TempEBMessage2
-
+      attr_reader :message, :action, :service, :cpa_id, :message_timestamp, :from_name, :from_type, :to_name, :to_type
+      attr_reader :message_id, :conversation_id
+      attr_reader :from_role, :to_role
+      attr_reader :references, :payloads
+      attr_reader :errors
+      attr_reader :raw_message_file_path
-      
-      # TODO
@@ -198 +265 @@
-      end
-
-
-      # This method creates an ebXML Message based on directives and ebMS message infos.
-      def TempEBMessage2.create_message party_ids, directive, ebMS_message_info, complete_ebXML_message_file_path, 
@@ -207 +273 @@
-        
-        ebXML_message = File.new "#{complete_ebXML_message_file_path}", "w"
+        ebXML_message.sync = true
-
-        if ebMS_message_info['service'] == 'urn:oasis:names:tc:ebxml-msg:service' and ebMS_message_info['action'] == 'Ping' then
@@ -301 +368 @@
-      <eb:MessageData>
-        <eb:MessageId>#{message_id}</eb:MessageId>
-EBMessage2.
+
-      </eb:MessageData>#{duplicate_elimination}
-    </eb:MessageHeader>#{ack_requested}
@@ -347 +414 @@
-              # Possibly everything goes through memory.
-              #              my_command = "cat #{payload_path} >> #{file_path}"
-
+