Changeset 223

Timestamp:

12/07/06 11:02:01 (2 years ago)

Author:

sacha

Message:

some api helpers.
closing transaction adds time and date.
closing transaciton removes temporary state pointer.

Files:

• branches/message-handling-refactor-branch/src/hefeweizen_library_transactions.rb (modified) (9 diffs)

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

@@ -15 +15 @@
-      public 
-      
-, transaction_directory
+
-        if @@instance.nil? then
-, transaction_directory
+
-        end
-        
@@ -29 +29 @@
-      private 
-      
-, transaction_directory
+
-        @config = config
-transaction_directory
+@config['TRANSACTION_DIR']
-        @logger = @config['LOGGER']
-        
@@ -135 +135 @@
-      end
-
+      def open_and_new?
+        (is_open? and (@state.name == 'new'))
+      end
+
+
-      def is_open?
-        @type == "OPEN" ? true : false
@@ -162 +167 @@
-            cause.payloads.each{ | payload_path |
-              uuid = HefeWeizen::HefeWeizenLibrary::HefeWeizenUUID.uuid
-
-
+
-              FileUtils.cp(payload_path, target)
-            }
@@ -193 +197 @@
-        files_path = files_path.class == String ? [files_path] : files_path
-        files_path.each{| file_path |
-file_path.gsub(/\//,"_")
+Time.now.to_f.to_s
-          file = File.open(file, "w")
-          file << file_path
@@ -206 +210 @@
-          files.each{ | file |
-            if FileTest.exists?(file) and FileTest.owned?(file) then
-
+puts 
-              @logger.debug "Removing file: #{file}"
-              if FileTest.exists?(file_to_delete) and FileTest.owned?(file_to_delete) then
@@ -236 +240 @@
-      end
-      
+      def succeed comment
+        return close_transaction "succeeded", comment
+      end
+
+      def fail comment
+        return close_transaction "failed", comment
+      end
+
-      # this method closes an open transaction.
-      def close_transaction final_state, comment
@@ -248 +260 @@
-          FileUtils.ln_s("states/#{@state.name}", "#{@transaction_path}/current_state", :force => true)
-          FileUtils.touch("#{@transaction_path}/final_state__#{final_state}")
-          
-          if !comment.nil? then
-            FileUtils.touch("#{@state.full_path}/comment__#{comment.gsub(/ /,"_") }")
@@ -259 +270 @@
-          remove_remembered_files_to_remove
-
+          # time and date when the transaction was closed
+          FileUtils.touch("#{@transaction_path}/transaction_closed_date_time__#{Time.now.to_s}")
+
+          # removing temporary state pointer
+          FileUtils.rm("#{@transaction_path}/current_state")
+
-          from = "#{@transaction_path}"
-          to = "#{@base_dir}/closed_transactions/#{@transaction_id}"
-          FileUtils.mv(from, to)
+
+
-          return true
-        else