Changeset 569

Show
Ignore:
Timestamp:
03/25/07 15:07:44 (2 years ago)
Author:
sacha
Message:

added common logger for debug etc.
Trac ticket #18

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • trunk/src/taskers/hefeweizen_tasker_application_decrypt_ebXML_message.rb

    r556 r569  
    3030############################################################################## 
    3131 
    32 $stdout.puts "#{$0}: HefeWeizen Tasker Decrypt ebXML message Starting with Process ID #{$$}." 
     32# $stdout.puts "#{$0}: HefeWeizen Tasker Decrypt ebXML message Starting with Process ID #{$$}." 
    3333 
    3434require 'getoptlong' 
    …… 
    4646    class Decrypt 
    4747       
     48      def me 
     49        "XMLEncryptionDecryptingTasker" 
     50      end 
     51 
    4852      def initialize 
    4953        # parse script arguments 
    …… 
    101105        require "#{@config['LIB_DIR']}/hefeweizen_library_utils" 
    102106        require "#{@config['LIB_DIR']}/hefeweizen_library_ebMS_message2" 
    103 #        require "../hefeweizen_library_ebMS_message2" 
     107 
     108        @debug = @info = @warn = @error = true 
     109        case @config['LOG_LEVEL'] 
     110        when 'debug' then 
     111          @debug = @info = @warn = @error = true 
     112        when 'info' then 
     113          @info = @warn = @error = true  
     114          @debug = nil 
     115        when 'warn' then 
     116          @warn = @error = true 
     117          @debug = @info = nil  
     118        when 'error' then 
     119          @error = true 
     120          @debug = @info = @warn = nil 
     121        end 
     122 
     123        begin 
     124          @logger = HefeWeizen::HefeWeizenLibrary::HefeWeizenLogger.new "#{@config['LOG_DIR']}/#{@config['LOG_FILE']}", @config['LOG_LEVEL'] 
     125          @logger.info "#{me}: #{$0}: HefeWeizen Tasker Decrypt ebXML Message Starting with Process ID #{$$}." 
     126        rescue Exception => e 
     127          $stderr.puts "Error creating logger. #{e.to_s}" 
     128          $stderr.puts "Exitting." 
     129          return -1 
     130        end 
     131 
    104132      end 
    105133 
    …… 
    110138          @ebXML_message_parameters = YAML.load(File.open(@parameters_file_path)) 
    111139        else 
    112           puts "Error with file permissions and or parameters file." 
     140          @logger.error "#{me}: Error with file permissions and or parameters file." if @error 
    113141          return -1 
    114142        end 
    …… 
    117145 
    118146        # get content 
     147        @logger.debug "#{me}: Get the content of the ebXML message." if @debug 
    119148        content_hash = get_content_hash_of_ebXML_message 
    120149 
    121150        # decrypt 
     151        @logger.debug "#{me}: Decrypting the contents of the ebXML message." if @debug 
    122152        decrypted_file_path = decrypt content_hash, files_to_delete 
    123153 
    124154        # repackage 
     155        @logger.debug "#{me}: Repackaging the contents of the ebXML message into a new ebXML message." if @debug 
    125156        new_ebXML_message_file_path = repackage decrypted_file_path 
    126157 
    127158        command_hash = { 
    128           "from" => "hefeweizen_tasker_application_sign_ebXML_message",  
     159          "from" => "hefeweizen_tasker_application_decrypt_ebXML_message",  
    129160          "to" => "big ania",  
    130161          "b2b_system_name" => @b2b_system_name, 
    …… 
    145176 
    146177        my_command = "echo \"#{HefeWeizen::HefeWeizenLibrary::HefeWeizenCommand.hash_to_command command_hash}\" > #{@pipe_to_ania}" 
     178        @logger.debug "#{me}: Sending result to Big Ania: #{my_command}" if @debug 
    147179        system my_command 
    148180 
    …… 
    225257          # xmlsec1 decrypt --privkey-pem coronation_encryption_cert/Coronation_encryption_private_key.pem --output debian-logo-2.png out2.xml 
    226258          command = "xmlsec1 decrypt --privkey-pem #{@private_key_file_path} --output #{output_file_path} #{content_file_path}" 
    227           # puts command 
     259          @logger.debug "#{me}: Calling decryption code: #{command}" if @debug 
    228260          system command 
    229261          if $? == 0 then 
    …… 
    231263            files_for_repackage[content_id] = output_file_path 
    232264          else 
    233             puts "ERROR encryption" 
     265            @logger.error "#{me}: ERROR encryption" if @error 
    234266          end 
    235267        } 

  • trunk/src/taskers/hefeweizen_tasker_application_dir_observer.rb

    r568 r569  
    3030############################################################################## 
    3131 
    32 $stdout.puts "#{$0}: HefeWeizen Tasker DirObserver Starting with Process ID #{$$}." 
     32#$stdout.puts "#{$0}: HefeWeizen Tasker DirObserver Starting with Process ID #{$$}." 
    3333 
    3434require 'getoptlong' 
    …… 
    112112        begin 
    113113          @logger = HefeWeizen::HefeWeizenLibrary::HefeWeizenLogger.new "#{@config['LOG_DIR']}/#{@config['LOG_FILE']}", @config['LOG_LEVEL'] 
    114           @logger.info "#{$0}: HefeWeizen Tasker HTTP Sender Starting with Process ID #{$$}." 
     114          @logger.info "#{me}: #{$0}: HefeWeizen Tasker HTTP Sender Starting with Process ID #{$$}." if @info 
    115115        rescue Exception => e 
    116116          $stderr.puts "Error creating logger. #{e.to_s}" 
    …… 
    122122 
    123123      def run 
    124 #        puts command = "echo hello > #{@pipe_to_ania}" 
    125 #        system  command 
    126 #        return 0 
    127124        return monitor_dir( @dir_to_monitor ) 
    128125      end 

  • trunk/src/taskers/hefeweizen_tasker_application_encrypt_ebXML_message.rb

    r556 r569  
    3030############################################################################## 
    3131 
    32 $stdout.puts "#{$0}: HefeWeizen Tasker Encrypt ebXML message Starting with Process ID #{$$}." 
     32# $stdout.puts "#{$0}: HefeWeizen Tasker Encrypt ebXML message Starting with Process ID #{$$}." 
    3333 
    3434require 'getoptlong' 
    …… 
    4545 
    4646    class Encrypt 
    47        
     47 
     48      def me 
     49        "XMLEncryptionEncryptingTasker" 
     50      end 
     51 
    4852      def initialize 
    4953        # parse script arguments 
    …… 
    106110        require "#{@config['LIB_DIR']}/hefeweizen_library_utils" 
    107111        require "#{@config['LIB_DIR']}/hefeweizen_library_ebMS_message2" 
    108 #        require "../hefeweizen_library_ebMS_message2" 
     112 
     113        @debug = @info = @warn = @error = true 
     114        case @config['LOG_LEVEL'] 
     115        when 'debug' then 
     116          @debug = @info = @warn = @error = true 
     117        when 'info' then 
     118          @info = @warn = @error = true  
     119          @debug = nil 
     120        when 'warn' then 
     121          @warn = @error = true 
     122          @debug = @info = nil  
     123        when 'error' then 
     124          @error = true 
     125          @debug = @info = @warn = nil 
     126        end 
     127 
     128        begin 
     129          @logger = HefeWeizen::HefeWeizenLibrary::HefeWeizenLogger.new "#{@config['LOG_DIR']}/#{@config['LOG_FILE']}", @config['LOG_LEVEL'] 
     130          @logger.info "#{me}: #{$0}: HefeWeizen Tasker Encrypt ebXML Message Starting with Process ID #{$$}." 
     131        rescue Exception => e 
     132          $stderr.puts "Error creating logger. #{e.to_s}" 
     133          $stderr.puts "Exitting." 
     134          return -1 
     135        end 
     136 
    109137      end 
    110138 
    …… 
    128156        files_to_delete = Array.new 
    129157         
     158        @logger.debug "#{me}: Getting xmlencoding template" if @debug 
    130159        template_filename = get_xmlenc_template 
    131160        files_to_delete << template_filename 
    132161 
    133162        # get content 
     163        @logger.debug "#{me}: Getting the content of the ebXML message." if @debug 
    134164        content_hash = get_content_hash_of_ebXML_message 
    135165         
    136166        # encrypt 
     167        @logger.debug "#{me}: Encrypting the content of the ebXML message." if @debug 
    137168        files_to_delete, files_to_repackage = encrypt content_hash, template_filename, files_to_delete 
    138169 
    139170        # repackage 
     171        @logger.debug "#{me}: Repackaging the encrypted content of the ebXML message into a new ebXML message." if @debug 
    140172        new_ebXML_message_file_path = repackage files_to_repackage 
    141173 
    142174        command_hash = { 
    143           "from" => "hefeweizen_tasker_application_sign_ebXML_message",  
     175          "from" => "hefeweizen_tasker_application_encrypt_ebXML_message",  
    144176          "to" => "big ania",  
    145177          "b2b_system_name" => @b2b_system_name, 
    …… 
    160192 
    161193        my_command = "echo \"#{HefeWeizen::HefeWeizenLibrary::HefeWeizenCommand.hash_to_command command_hash}\" > #{@pipe_to_ania}" 
     194        @logger.debug "#{me}: Sending result back to Big Ania: #{my_command}" if @debug 
    162195        system my_command 
    163196 

  • trunk/src/taskers/hefeweizen_tasker_application_http_server.rb

    r557 r569  
    3030############################################################################## 
    3131 
    32 $stdout.puts "#{$0}: HefeWeizen Tasker HTTP Server Starting with Process ID #{$$}." 
     32# $stdout.puts "#{$0}: HefeWeizen Tasker HTTP Server Starting with Process ID #{$$}." 
    3333 
    3434require 'getoptlong' 
    …… 
    6666 
    6767      def me 
    68         "EBMSServlet" 
     68        "EBMSHTTPServlet" 
    6969      end 
    7070 
    …… 
    277277    class HTTPServer 
    278278       
     279      def me 
     280        "HTTPServerTasker" 
     281      end 
     282 
    279283      def initialize 
    280284        # parse script arguments 
    …… 
    331335        } 
    332336 
    333         log_file = "#{@config['LOG_DIR']}/#{@config['LOG_FILE']}" 
    334         log_level = @config['LOG_LEVEL'] 
     337        require "#{@config['LIB_DIR']}/hefeweizen_library_utils" 
    335338        @debug = @info = @warn = @error = true 
    336339        case @config['LOG_LEVEL'] 
    …… 
    348351        end 
    349352 
    350         if !FileTest.exists?(log_file) then 
    351           file = FileUtils.touch(log_file) 
    352         end 
    353          
    354         if  FileTest.exists?(log_file) and FileTest.writable?(log_file) and FileTest.owned?(log_file) then 
    355           @logger = Logger.new(log_file) 
    356           @logger.level = string_to_logger_level log_level 
    357         else 
    358           @logger = Logger.new(STDOUT) 
    359         end 
    360  
    361         require "#{@config['LIB_DIR']}/hefeweizen_library_utils" 
    362  
     353        begin 
     354          @logger = HefeWeizen::HefeWeizenLibrary::HefeWeizenLogger.new "#{@config['LOG_DIR']}/#{@config['LOG_FILE']}", @config['LOG_LEVEL'] 
     355          @logger.info "#{me}: #{$0}: HefeWeizen Tasker HTTP Server Starting with Process ID #{$$}." if @info 
     356        rescue Exception => e 
     357          $stderr.puts "Error creating logger. #{e.to_s}" 
     358          $stderr.puts "Exitting." 
     359          return -1 
     360        end 
    363361         
    364362        if @is_https then 
    …… 
    397395 
    398396      private 
    399  
    400       def me 
    401         "HefeWeizen HTTP(S) Server" 
    402       end 
    403397 
    404398      def http_server_serve 

  • trunk/src/taskers/hefeweizen_tasker_application_sign_ebXML_message.rb

    r514 r569  
    3030############################################################################## 
    3131 
    32 $stdout.puts "#{$0}: HefeWeizen Tasker Signing ebXML message Starting with Process ID #{$$}." 
     32# $stdout.puts "#{$0}: HefeWeizen Tasker Signing ebXML message Starting with Process ID #{$$}." 
    3333 
    3434require 'getoptlong' 
    …… 
    4545 
    4646    class Signing 
    47        
     47 
     48      def me 
     49        "XMLDigitalSignatureSigningTasker" 
     50      end 
     51 
    4852      def initialize 
    4953        # parse script arguments 
    …… 
    108112        require 'yaml' 
    109113        require "#{@config['LIB_DIR']}/hefeweizen_library_utils" 
     114 
     115        @debug = @info = @warn = @error = true 
     116        case @config['LOG_LEVEL'] 
     117        when 'debug' then 
     118          @debug = @info = @warn = @error = true 
     119        when 'info' then 
     120          @info = @warn = @error = true  
     121          @debug = nil 
     122        when 'warn' then 
     123          @warn = @error = true 
     124          @debug = @info = nil  
     125        when 'error' then 
     126          @error = true 
     127          @debug = @info = @warn = nil 
     128        end 
     129 
     130        begin 
     131          @logger = HefeWeizen::HefeWeizenLibrary::HefeWeizenLogger.new "#{@config['LOG_DIR']}/#{@config['LOG_FILE']}", @config['LOG_LEVEL'] 
     132          @logger.info "#{me}: #{$0}: HefeWeizen Tasker XML Digital Signature Signing Starting with Process ID #{$$}." if @info 
     133        rescue Exception => e 
     134          $stderr.puts "Error creating logger. #{e.to_s}" 
     135          $stderr.puts "Exitting." 
     136          return -1 
     137        end 
     138 
    110139      end 
    111140 
    …… 
    124153        # differentiate between user message and ebsignal. 
    125154        if @ebXML_message_parameters['service'] == 'urn:oasis:names:tc:ebxml-msg:service' then 
     155          @logger.debug "#{me}: Signing of an ebXML signal message." if @debug 
    126156          ################################################# 
    127157          #### Signal Message          
    128158          ################################################# 
    129159          temp_file_path = "#{@config['TEMP_FILE_DIR']}/temp_file_#{get_id}" 
    130           puts command = "hefeweizen_sign_ebXML_signal_message \"#{@ebXML_message_file_path}\" \"#{@private_key_file_path}\" \"#{@password_file_path}\" \"#{@certificate_file_path}\" \"#{temp_file_path}\"" 
     160          command = "hefeweizen_sign_ebXML_signal_message \"#{@ebXML_message_file_path}\" \"#{@private_key_file_path}\" \"#{@password_file_path}\" \"#{@certificate_file_path}\" \"#{temp_file_path}\"" 
    131161           
    132162          # blocking call 
     163          @logger.debug "#{me}: Calling command to sign signal message: #{command}" if @debug 
    133164          system command 
    134165          if $? == 0 then 
    135166            msg = "#{me}: digital signing ebXML signal worked." 
    136             puts msg 
     167            @logger.debug "#{me}: #{msg}" if @debug 
    137168          else 
    138169            msg = "#{me}: Error digitally sign ebXML signal message." 
     170            @logger.error "#{me}: #{msg}" if @debug 
    139171            error = true 
    140172            error_comment = msg 
    …… 
    148180          #### User Message          
    149181          ################################################# 
     182          @logger.debug "#{me}: Signing of an ebXML user message." if @debug 
    150183 
    151184          # hack alert! 
    …… 
    153186          fixed_ebXML_user_message_path, target_signed_soap_message_path = get_user_message_ready_for_signing @ebXML_message_file_path 
    154187          # transaction.remember_file_to_remove fixed_ebXML_user_message_path 
    155           puts command = "hefeweizen_sign_ebXML_user_message \"#{fixed_ebXML_user_message_path}\" \"#{@private_key_file_path}\" \"#{@password_file_path}\" \"#{@certificate_file_path}\" \"#{@config['TEMP_FILE_DIR']}\" \"#{target_signed_soap_message_path}\"" 
     188          command = "hefeweizen_sign_ebXML_user_message \"#{fixed_ebXML_user_message_path}\" \"#{@private_key_file_path}\" \"#{@password_file_path}\" \"#{@certificate_file_path}\" \"#{@config['TEMP_FILE_DIR']}\" \"#{target_signed_soap_message_path}\"" 
    156189           
    157190          # blocking call 
     191          @logger.debug "#{me}: Calling command to sign user message: #{command}" if @debug 
    158192          system command 
    159193          if $? == 0 then 
    160             puts "#{me}: digital signing ebXML user message worked." 
     194            @logger.debug "#{me}: digital signing ebXML user message worked." if @debug 
    161195          else 
    162196            msg = "#{me}: Error digitally sign ebXML user message." 
    163             puts msg 
     197            @logger.error "#{me}: #{msg}" if @error 
    164198            error = true 
    165199            error_comment = msg 
    …… 
    169203            # hack alert! 
    170204            # Lots of ROOM for optimisation 
     205            @logger.debug "#{me}: Updating the user message with the signed soap message." if @debug 
    171206            update_ebXML_user_message_with_signed_soap_message @ebXML_message_file_path, target_signed_soap_message_path 
    172207          end   
    …… 
    197232 
    198233        my_command = "echo \"#{HefeWeizen::HefeWeizenLibrary::HefeWeizenCommand.hash_to_command command_hash}\" > #{@pipe_to_ania}" 
     234        @logger.debug "#{me}: Sending result back to Big Ania: #{my_command}" if @debug 
    199235        system my_command 
    200236 
    …… 
    203239 
    204240      private 
    205  
    206       def me 
    207         "HefeWeizen Tasker Sign" 
    208       end 
    209241 
    210242      def get_id 

  • trunk/src/taskers/hefeweizen_tasker_application_wake_up_call.rb

    r461 r569  
    4343  module Tasker 
    4444 
    45             class WakeUpCall 
     45    class WakeUpCall 
    4646       
     47      def me 
     48        "WakeUpCallTasker" 
     49      end 
     50 
    4751      def initialize 
    4852        # parse script arguments 
    …… 
    105109        } 
    106110        require "#{@config['LIB_DIR']}/hefeweizen_library_utils" 
     111        @debug = @info = @warn = @error = true 
     112        case @config['LOG_LEVEL'] 
     113        when 'debug' then 
     114          @debug = @info = @warn = @error = true 
     115        when 'info' then 
     116          @info = @warn = @error = true  
     117          @debug = nil 
     118        when 'warn' then 
     119          @warn = @error = true 
     120          @debug = @info = nil  
     121        when 'error' then 
     122          @error = true 
     123          @debug = @info = @warn = nil 
     124        end 
     125 
     126        begin 
     127          @logger = HefeWeizen::HefeWeizenLibrary::HefeWeizenLogger.new "#{@config['LOG_DIR']}/#{@config['LOG_FILE']}", @config['LOG_LEVEL'] 
     128          @logger.info "#{me}: #{$0}: HefeWeizen Tasker Wake-Up Call Starting with Process ID #{$$}." if @info 
     129        rescue Exception => e 
     130          $stderr.puts "Error creating logger. #{e.to_s}" 
     131          $stderr.puts "Exitting." 
     132          return -1 
     133        end 
    107134 
    108135      end 
    …… 
    110137      def run 
    111138         
    112         # puts "WakeUpCall instance is going to deep sleep for '#{@sleep_time}' seconds." 
    113         # puts "Time before going to sleep: #{Time.now}" 
     139        @logger.debug "#{me}: WakeUpCall instance is going to deep sleep for '#{@sleep_time}' seconds." if @debug 
     140        @logger.debug "#{me}: Time before going to sleep: #{Time.now}" if @debug 
    114141        sleep @sleep_time 
    115         # puts "Time after going to sleep: #{Time.now}" 
    116         # puts "WakeUpCall instance woken up after '#{@sleep_time}' seconds of deep sleep." 
     142        @logger.debug "#{me}: Time after going to sleep: #{Time.now}" if @debug 
     143        @logger.debug "#{me}: WakeUpCall instance woken up after '#{@sleep_time}' seconds of deep sleep." if @debug 
    117144 
    118145        command_hash = { 
    …… 
    137164 
    138165        my_command = "echo \"#{HefeWeizen::HefeWeizenLibrary::HefeWeizenCommand.hash_to_command command_hash}\" > #{@pipe_to_ania}" 
     166        @logger.debug "#{me}: Sending result back to Big Ania: #{my_command}" if @debug 
    139167        system my_command 
    140168