Open Build Service

rubygem-ygg_provisioner.spec Changed

ygg_provisioner-1.5.1.gem/checksums.yaml.gz -> ygg_provisioner-1.4.1.gem/checksums.yaml.gz Changed

ygg_provisioner-1.4.1.gem/data/README Added

ygg_provisioner-1.5.1.gem/data/lib/ygg/provisioner/model.rb -> ygg_provisioner-1.4.1.gem/data/lib/ygg/provisioner/model.rb Changed

@@ -8,18 +8,19 @@
 # License:: You can redistribute it and/or modify it under the terms of the LICENSE file.
 #
 
-require 'rufus/tokyo'
+require 'kyotocabinet'
 require 'ygg/provisioner/tools'
 require 'ygg/provisioner/file_switcher'
 
 module Ygg
 module Provisioner
 
-class Model
+class Model < OpenStruct
 
   class Error < StandardError ; end
   class DataError < Error ; end
   class ProcessError < Error ; end
+  class DatabaseError < Error ; end
 
   extend Tools
   include Tools
@@ -30,45 +31,37 @@
   class_attribute :config
   class_attribute :worker
 
+  class_attribute :state_persistant_keys
+  self.state_persistant_keys =  
+
   class_attribute :db_path
 
   attr_accessor :plog
+  attr_accessor :config_persistant_keys
+
+  def initialize(config)
 
-  attr_accessor :cfg
+    super(*)
 
-  # Config
-  attr_accessor :uuid # All models are supposed to have at least the uuid
+    self.cfg = agentcfg
 
-  def initialize(config = nil)
     if config:cfg
-      self.cfg = config:cfg
-      deserialize_config(config:cfg) if config:cfg
-      deserialize_state(config:state) if config:state
+      # We are being de-serialized
+      update_config(config:cfg)
+      update_state(config:state)
     else
-      self.cfg = config
-      deserialize_config(config)
+      update_config(config)
     end
   end
 
-  def deserialize_config(config)
-    config.each { |k,v| send("#{k}=", v) rescue nil }
+  def update_config(config)
+    self.config_persistant_keys = config.keys.map(&:to_sym)
+    self.config_persistant_keys -= self.state_persistant_keys
+    config.each { |k,v| send("#{k}=", v) if self.config_persistant_keys.include?(k.to_sym) }
   end
 
-  def deserialize_state(state)
-    state.each { |k,v| send("#{k}=", v) }
-  end
-
-  def serialize_config
-    cfg
-  end
-
-  def serialize_state
-    {}
-  end
-
-  def update(data, opts = {})
-    self.cfg = data
-    data.each { |k,v| send("#{k}=", v) rescue nil }
+  def update_state(state)
+    state.each { |k,v| send("#{k}=", v) if self.state_persistant_keys.include?(k.to_sym) }
   end
 
   def save!
@@ -77,9 +70,9 @@
 
   def serialize
    {
+    :cfg => self.marshal_dump.select { |k,v| config_persistant_keys.include?(k.to_sym) },
+    :state => self.marshal_dump.select { |k,v| state_persistant_keys.include?(k.to_sym) },
     :_type => self.class.name,
-    :cfg => serialize_config,
-    :state => serialize_state,
    }
   end
 
@@ -96,20 +89,26 @@
     if @@open_store
       yield @@open_store
     else
-      Rufus::Tokyo::Cabinet.open(db_path) do |store|
+      db = KyotoCabinet::DB::new
+      if db.open(db_path, KyotoCabinet::DB::OWRITER | KyotoCabinet::DB::OCREATE)
         begin
-          @@open_store = store
-          yield store
+          @@open_store = db
+          yield db
         ensure
+          unless db.close
+            raise DatabaseError.new("Cannot close database #{db_path}: #{db.error}")
+          end
           @@open_store = nil
         end
+      else
+        raise DatabaseError.new("Cannot open database #{db_path}: #{db.error}")
       end
     end
   end
 
   def self.save(model)
     with_open_store do |store|
-      storemodel.uuid = Marshal.dump(model.serialize)
+      storemodel.id = Marshal.dump(model.serialize)
     end
 
     model
@@ -124,7 +123,7 @@
 
   def self.each
     with_open_store do |store|
-      store.each do |obj_uuid,obj|
+      store.each do |obj_id,obj|
         begin
           obj = new_from_serialized(Marshal.load(obj))
 
@@ -132,16 +131,16 @@
 
 #        rescue
 #          # Ignore corrupted obj data
-#          # plog.warn "Site #{obj_uuid} configuration is corrupted"
+#          # plog.warn "Site #{obj_id} configuration is corrupted"
         end
       end
     end
   end
 
-  def self.find(uuid)
+  def self.find(id)
     obj = nil
     with_open_store do |store|
-      obj = storeuuid
+      obj = storeid
       raise NotFound if !obj
       obj = new_from_serialized(Marshal.load(obj))
     end
@@ -149,12 +148,12 @@
     obj
   end
 
-  def self.delete(uuid)
+  def self.delete(id)
     obj = nil
     with_open_store do |store|
-      obj = storeuuid
+      obj = storeid
       raise NotFound if !obj
-      store.delete uuid
+      store.delete id
     end
   end
 
@@ -173,14 +172,14 @@
     good_count = 0
 
     with_open_store do |store|
-      store.each do |obj_uuid,obj_marshalled|
+      store.each do |obj_id,obj_marshalled|
         begin
           obj_unmarshalled = nil
 
           begin
             obj_unmarshalled = Marshal.load(obj_marshalled)
           rescue Exception => e
-            corrupted_objsobj_uuid = { :reason => 'Unmarshal failed', :data => Base64.encode64(obj_marshalled) }
+            corrupted_objsobj_id = { :reason => 'Unmarshal failed', :data => Base64.encode64(obj_marshalled) }
             raise
           end
 
@@ -188,7 +187,7 @@
           begin
             obj = new_from_serialized(obj_unmarshalled)
           rescue Exception => e
-            corrupted_objsobj_uuid = {
+            corrupted_objsobj_id = {
               :reason => "Loading failed: #{e.to_s}",
               :data => obj_unmarshalled
             }
@@ -199,7 +198,7 @@
             obj.save!
             good_count += 1
           rescue Exception => e
-            corrupted_objsobj_uuid = {
+            corrupted_objsobj_id = {
               :reason => "Saving failed: #{e.to_s}",
               :data => obj_unmarshalled
             }
@@ -207,8 +206,8 @@
           end
         rescue
           if opts:delete_corrupted
-            store.delete obj_uuid
-            corrupted_objsobj_uuid:deleted = true
+            store.delete obj_id
+            corrupted_objsobj_id:deleted = true
           end
         end
       end

ygg_provisioner-1.5.1.gem/data/lib/ygg/provisioner/task.rb -> ygg_provisioner-1.4.1.gem/data/lib/ygg/provisioner/task.rb Changed

@@ -27,7 +27,7 @@
 
   def log(level, msg)
     @text << msg + "\n"
-    @other_log.info msg
+    @other_log.send level, msg
   end
 
   def debug(msg) ; log :debug, msg ; end
@@ -135,7 +135,6 @@
 
   def execute(opts = {}, &block)
     op = self.class.operationsoperation
-    errback = opts:errback || Proc.new { yield nil }
 
     report_started(op.supports_percent ? { :percent => 0 } : {}) do
       @fiber = Fiber.new do
@@ -149,14 +148,14 @@
           end
         rescue PermanentFailure => e
           plog.error e.message
-          report_event(:PERMANENT_FAILURE, plog.text) { errback.call(e) }
+          report_event(:PERMANENT_FAILURE, plog.text) { yield nil }
         rescue TemporaryFailure, PublishError => e
           plog.error e.message
-          report_event(:TEMPORARY_FAILURE, plog.text) { errback.call(e) }
+          report_event(:TEMPORARY_FAILURE, plog.text) { yield nil }
         rescue Exception => e
           log.exception e
           plog.error e.message
-          report_event(:TEMPORARY_FAILURE, plog.text) { errback.call(e) }
+          report_event(:TEMPORARY_FAILURE, plog.text) { yield nil }
         else
           report_event(:COMPLETED, plog.text, result_data) { yield result_data }
         end

ygg_provisioner-1.5.1.gem/data/lib/ygg/provisioner/tools.rb -> ygg_provisioner-1.4.1.gem/data/lib/ygg/provisioner/tools.rb Changed

ygg_provisioner-1.5.1.gem/data/lib/ygg/provisioner/version.rb -> ygg_provisioner-1.4.1.gem/data/lib/ygg/provisioner/version.rb Changed

ygg_provisioner-1.5.1.gem/data/lib/ygg/provisioner/worker.rb -> ygg_provisioner-1.4.1.gem/data/lib/ygg/provisioner/worker.rb Changed

ygg_provisioner-1.5.1.gem/data/ygg_provisioner.gemspec -> ygg_provisioner-1.4.1.gem/data/ygg_provisioner.gemspec Changed

ygg_provisioner-1.5.1.gem/metadata.gz -> ygg_provisioner-1.4.1.gem/metadata.gz Changed

@@ -1,14 +1,14 @@
 --- !ruby/object:Gem::Specification
 name: ygg_provisioner
 version: !ruby/object:Gem::Version
-  version: 1.5.1
+  version: 1.4.1
 platform: ruby
 authors:
 - Daniele Orlandi
 autorequire: 
 bindir: bin
 cert_chain: 
-date: 2014-04-28 00:00:00.000000000 Z
+date: 2020-06-04 00:00:00.000000000 Z
 dependencies:
 - !ruby/object:Gem::Dependency
   name: tomte-agents
@@ -25,35 +25,35 @@
       - !ruby/object:Gem::Version
         version: '0'
 - !ruby/object:Gem::Dependency
-  name: rufus-tokyo
+  name: kyotocabinet
   requirement: !ruby/object:Gem::Requirement
     requirements:
-    - - "~>"
+    - - ">="
       - !ruby/object:Gem::Version
-        version: 11.0.0
+        version: '0'
   type: :runtime
   prerelease: false
   version_requirements: !ruby/object:Gem::Requirement
     requirements:
-    - - "~>"
+    - - ">="
       - !ruby/object:Gem::Version
-        version: 11.0.0
+        version: '0'
 - !ruby/object:Gem::Dependency
   name: eventmachine
   requirement: !ruby/object:Gem::Requirement
     requirements:
     - - "~>"
       - !ruby/object:Gem::Version
-        version: 1.0.3
+        version: 1.2.3
   type: :runtime
   prerelease: false
   version_requirements: !ruby/object:Gem::Requirement
     requirements:
     - - "~>"
       - !ruby/object:Gem::Version
-        version: 1.0.3
+        version: 1.2.3
 - !ruby/object:Gem::Dependency
-  name: vihai-publisher
+  name: publisher
   requirement: !ruby/object:Gem::Requirement
     requirements:
     - - ">="
@@ -75,6 +75,7 @@
 files:
 - ".gitignore"
 - Gemfile
+- README
 - Rakefile
 - lib/tomte/agents/skel_provisioner.rb
 - lib/ygg/provisioner.rb
@@ -106,10 +107,8 @@
     - !ruby/object:Gem::Version
       version: '0'
 requirements: 
-rubyforge_project: ygg_provisioner
-rubygems_version: 2.2.2
+rubygems_version: 3.1.2
 signing_key: 
 specification_version: 4
 summary: Provisioner base classes and helpers
 test_files: 
-has_rdoc:

Changes of Revision 5