Changeset 227

Timestamp:

12/07/06 14:45:06 (2 years ago)

Author:

sacha

Message:

first part of refactoring the way big ania processes files.
message has no states. currently this is done in ebMSMessage2
not sending message yet. all circumvented per now
not receiving message yet. all circumvented per now

Files:

• branches/message-handling-refactor-branch/defaults/hefeweizen-defaults (modified) (1 diff)
• branches/message-handling-refactor-branch/src/hefeweizen_big_ania.rb (modified) (11 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_b2b_system.rb (modified) (4 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_directive.rb (modified) (3 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_ebMS_message2.rb (added)
• branches/message-handling-refactor-branch/src/hefeweizen_library_integration_point.rb (modified) (2 diffs)
• branches/message-handling-refactor-branch/src/hefeweizen_library_transactions.rb (modified) (4 diffs)
• branches/message-handling-refactor-branch/src/taskers/hefeweizen_tasker_application_dir_observer.rb (modified) (1 diff)
• branches/message-handling-refactor-branch/test/test-systems/Coronation/infrastructure/integration-points/filebased-integration.conf (modified) (3 diffs)
• branches/message-handling-refactor-branch/test/test-systems/Gnaraloo/infrastructure/integration-points/filebased-integration.conf (modified) (3 diffs)

branches/message-handling-refactor-branch/defaults/hefeweizen-defaults

@@ -33 +33 @@
-
-
-tru
+fals
-TEST_LIB_NAME=hefeweizen_library_big_ania_test_logic.rb
-

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

@@ -32 +32 @@
-        require "#{@config['LIB_DIR']}/hefeweizen_library_b2b_system"
-        require "#{@config['LIB_DIR']}/hefeweizen_library_directive"
-
+2
-
-        begin
@@ -71 +71 @@
-    def run
-      
-$
+@
-        if configure then
-          @logger.info "Successfully setup hefeweizen_big_ania"
@@ -112 +112 @@
-        begin
-          require @config['LIB_DIR'].strip + "/" + @config['TEST_LIB_NAME'].strip
-$
-$
+@
+@
-        rescue Exception => e
-          @logger.error "Error loading test library."
@@ -119 +119 @@
-          return false
-        end
+      else
+        @test_library = nil
-      end
-      
@@ -215 +217 @@
-      # transaction manager
-      begin
-
+
+
+
+
+
-      rescue Exception => e
-        @logger.error "Unable to load HefeWeizen Transaction Manager: #{e.to_s}"
-        return false
-      end
-      if @transaction_manager.nil? then
-        @logger.error "Unable to load HefeWeizen Transaction Manager"
-        return false
-      end
-
-      # configured
-      @logger.info 'HefeWeizen Big Ania configured.'
-$
+@
-      return true
-    end
-
+
-    # This method starts big_ania
-    # This method calls individual start methods.
@@ -339 +341 @@
-          puts "BIG ANIA PIPE ERROR: #{error.to_s}XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX"
-          puts "XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX"
-(0.1)
+0.1
-        end
-      end
@@ -365 +367 @@
-              if transaction then
-                # test library first (is less complex)
-$
-$
+@
+@
-                  if processed then
-                    transaction.close_transaction(close_transaction, "Test message.") if close_transaction
@@ -397 +399 @@
-    ############################################################
-
+    ################# rewrite
+    ################# rewrite
+    ################# rewrite
+    ################# rewrite
+
+
+
-    # This method executes on the commands
-    # Must return a true in case some code did deal with the command.
-    def process_command_with_transaction transaction, command, command_hash
-      @logger.debug "Transaction state: #{transaction.get_current_state_name}"
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-      #########################################
-      # the commands below are related to:
@@ -560 +781 @@
-    end
-
+    
-    # This method handles a new directive.
-    # --> includes the creation of a new HefeWeizenDirective object. 
@@ -572 +794 @@
-          # do compensation/rollback
-          transaction.remember_file_to_remove command_hash['file']
-error
+"Unable to process Directive"
-          return true
-        end
@@ -1022 +1244 @@
-  big_ania.run
-else
- -1
+(-1)
-end

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

@@ -159 +159 @@
-      end
-
+      def get_error_directory
+        @parameters['integration-points'].first.get_error_directory
+      end
+
+
+      # This message processes a directive. This typically invloves to create an ebXML message.
+      def process_directive directive
+        # get the ebXML Message information
+        # this will hold all the required information about what has to be
+        # in the ebXML message plus how it has to be sent.
+        ebMS_message_info = get_ebMS_message_info directive
+        if ebMS_message_info.nil? then
+          throw Exception.new( "CPA Manager could not provide a valid ebXML Message information." )
+        end
+        
+        @logger.debug "Creating plain (not signed not encrypted) ebXML message"
+        metadata = @ebMS_message_manager.create_plain_message directive, ebMS_message_info
+        if metadata.nil? then
+          throw Exception.new( "Error creating ebXML message" )
+        end
+        @logger.debug "Creating ebXML message done. ebXML message is created."
+
+        return metadata
+      end
+
-      private 
+
-      
-      def has_identity? id
@@ -179 +205 @@
-        @system_name = File.basename(system_path)
-        @system_name.freeze
-
+
-        @logger = @config['LOGGER']
-
+
-        @cpa_manager = nil
-
+
-        require @config['LIB_DIR'].strip + "/hefeweizen_library_cpa"
-
+
+
-        result = load_parameters
-        if result.nil? then
-
-
+
+
+
+
+
+
-        end
-
@@ -221 +252 @@
-      #   validating a signature will be done by a tasker.
-      def load_parameters
- == nil
+.nil?
-          @parameters = Hash.new
-        else
@@ -403 +434 @@
-      # - implementation
-      def validate
-end
-
+  return true
+
-
-    end

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

@@ -90 +90 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<Error>
-CpaId
+Type
-  <DateTime>#{Time.now.to_s}</DateTime>
-  <Description>#{common_error_description}</Description>
@@ -99 +99 @@
-
-          error += "<ErrorFileContent>"
-
+
+
+
+
+
+
+
+
+
-          error += "</ErrorFileContent>"
-        end
@@ -111 +119 @@
-        file.sync = true
-        file.close
+
+        return true
-      end
-

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

@@ -31 +31 @@
-                  line =~ /^(outgoing: directive-directory:)\s*(.*)$/ or 
-                  line =~ /^(outgoing: payload-directory:)\s*(.*)$/ or 
- 
+
-                @logger.debug "Integration point: #{$1} with value #{$2}."
-                integration_point_config[$1] = $2
@@ -64 +64 @@
-        @integration_config.each_pair{ | usage, path |
-          path = "#{@config['SPOOL_DIR']}/#{path}"
-(path) and FileTest.executable?(path) and FileTest.readable?(path)
-(path)
+ path and FileTest.executable? path and FileTest.readable? path
+ path
-            @logger.info "Integration Point: path directory (#{path} does already exist. Nothing to do."
-          else
-(path)
-(0.2)
+ path
+0.2
-            @logger.info "Integration Point: created directory #{path} for #{usage}."
-          end

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

@@ -156 +156 @@
-      end
-      
+      def add_comment comment
+        get_state.add_comment comment
+      end
+
-      def set_root_cause cause
-        path = "#{@transaction_path}/root_cause"
-(path) and FileTest.directory?(path) and FileTest.owned?(path)
-(path)
+ path  and FileTest.directory? path  and FileTest.owned? path
+ path
-        end
-        if cause.class == HefeWeizenDirective then
-(cause.file, path, :force => true)
+ cause.file, path, :force => true
-          if !cause.payloads.nil? and !cause.payloads.empty? then
-            @logger.debug "Also copying referenced payloads as root causes. Number of payloads in directives are #{cause.payloads.size.to_s}."
@@ -168 +172 @@
-              uuid = HefeWeizen::HefeWeizenLibrary::HefeWeizenUUID.uuid
-              target = "#{path}/payload_#{payload_path.gsub(/\//, "@@@@")}_uuid_#{uuid}"
-(payload_path, target)
+ payload_path, target
-            }
-          end
-          return true
-        elsif cause.class == String then
-(cause, path)
+ cause, path
-          return true
-        else
@@ -241 +245 @@
-      
-      def succeed comment
- "succeeded", comment
+( "succeeded", comment )
-      end
-
-      def fail comment
- "failed", comment
+( "failed", comment )
-      end
-
@@ -346 +350 @@
-      end
-
+      def add_comment comment
+        FileUtils.touch "#{@directory}/#{@name}/comment__#{comment}"
+      end
+
-    end
-

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

@@ -133 +133 @@
-          
-              command = HefeWeizen::HefeWeizenLibrary::HefeWeizenCommand.hash_to_command command_hash
+              puts command
-              write_to_ania command
-

branches/message-handling-refactor-branch/test/test-systems/Coronation/infrastructure/integration-points/filebased-integration.conf

@@ -1 +1 @@
-# This file defines one or multiple file and directory based integration points.
-wo main types and each type has 2 subtypes:
+hree main types. These types are incoming, outgoing, and errors
-
-# incoming:   -> An incoming ebXML message will get unpacked. Metadata will be written to
@@ -14 +14 @@
-#                as well as to read and remove the payload files.
-#                
-
-
+ectory
+ectory
-#
-# the directory is added to the SPOOL_DIR definition in the HefeWeizen configuration file.
-#
-# so:
-
+ectory
-# becomes:
-outgoing: directive-dir
+incoming: directive-directory
-#
-
-
-
+ectory
+ectory
-
-# outgoing:   -> The backend application has to write the payload (the business documents,
@@ -43 +43 @@
-
-# there are three configurations required
-
-
-
+
+
-#
-# the directory is added to the SPOOL_DIR definition in the HefeWeizen configuration file.
-#
-# so:
-
+ectory
-# becomes:
-
+ectory
-#
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+

branches/message-handling-refactor-branch/test/test-systems/Gnaraloo/infrastructure/integration-points/filebased-integration.conf

@@ -1 +1 @@
-# This file defines one or multiple file and directory based integration points.
-wo main types and each type has 2 subtypes:
+hree main types. These types are incoming, outgoing, and errors
-
-# incoming:   -> An incoming ebXML message will get unpacked. Metadata will be written to
@@ -14 +14 @@
-#                as well as to read and remove the payload files.
-#                
-
-
+ectory
+ectory
-#
-# the directory is added to the SPOOL_DIR definition in the HefeWeizen configuration file.
-#
-# so:
-
+ectory
-# becomes:
-outgoing: directive-dir
+incoming: directive-directory
-#
-
-
-
+ectory
+ectory
-
-# outgoing:   -> The backend application has to write the payload (the business documents,
@@ -43 +43 @@
-
-# there are three configurations required
-
-
-
+
+
-#
-# the directory is added to the SPOOL_DIR definition in the HefeWeizen configuration file.
-#
-# so:
-
+ectory
-# becomes:
-
+ectory
-#
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+