Changeset 614

Timestamp:

05/03/07 10:27:53 (2 years ago)

Author:

sacha

Message:

more information (new methods) about failed messages.

Files:

• trunk/src/hefeweizen_library_message_state.rb (modified) (7 diffs)

trunk/src/hefeweizen_library_message_state.rb

@@ -116 +116 @@
-        @ack_signal_message_states = [ 'received', 'created', 'processed', 'failed_to_process' ]
-        @error_signal_message_states = [ 'received', 'created', 'processed', 'failed_to_process' ]
+        
+        @signals_failure = ['failed_to_process', 'ping_IPY_failed', 'ping_YPM_failed', 'failed_to_process']
-
-        @all_states.concat @ack_signal_message_states
-        @all_states.concat @error_signal_message_states
+
-
-        @final_states.concat ['processed', 'failed_to_process']
@@ -217 +220 @@
-      public 
-      
+      def get_failed_messages_information
+        result = Hash.new
+        result['number_failed_user_messages'] = get_number_of_failed_user_messages
+        result['number_failed_signal_messages'] = get_number_of_failed_signal_messages
+        user_failed_ids = Array.new
+        signal_failed_ids = Array.new
+        @user_message_failure.each{ | state |
+          puts state
+          user_failed_ids.concat Dir.glob("#{@states_path}/#{state}/*").collect{|path| File.basename path}
+        }
+        @signals_failure.each{ | state |
+          puts state
+          signal_failed_ids.concat Dir.glob("#{@states_path}/#{state}/*").collect{|path| File.basename path}
+        }
+        result['user_failed_ids'] = user_failed_ids
+        result['signal_failed_ids'] = signal_failed_ids
+        return result
+      end
+
-      def get_number_times_resent message_id
-        files = "#{@messages_dir}/#{message_id}/resends/[a-z][a-z]__*"
@@ -312 +334 @@
-      end
-      
+
-      def get_number_of_failed_user_messages
-        a = Dir.glob("#{@states_path}/failed_to_send/*").size
@@ -324 +347 @@
-      end
-
+      def get_number_of_failed_signal_messages
+        total = 0
+        @signals_failure.each{ | state |
+          total += Dir.glob("#{@states_path}/state/*").size
+        }
+        total
+      end
+
-      def get_number_of_received_and_accepted_user_messages
-        Dir.glob("#{@states_path}/received_and_accepted/*").size
@@ -330 +361 @@
-      def current_situation_report
-        # categories of states
-
-
-
-
-
-
-
+
+
+
+
+
+
-
-        hash = Hash.new
@@ -380 +410 @@
-        FileUtils.mkdir "#{dir}/resends"
-        
-
-        # initializing the counter for the history.
-        counter_file = File.new "#{dir}/message_history/counter", "w"
@@ -696 +725 @@
-
-      ############################# message received (typed)
-fucker
+method
-
-      def ebXML_message_received_at message_id, time