Open Build Service

rubygem-tomte-core.changes Changed

rubygem-tomte-core.spec Changed

tomte-core-1.2.7.gem/checksums.yaml.gz -> tomte-core-1.2.1.gem/checksums.yaml.gz Changed

tomte-core-1.2.1.gem/data/.gitignore Added

tomte-core-1.2.1.gem/data/.rakeTasks Changed

tomte-core-1.2.1.gem/data/.rspec Changed

tomte-core-1.2.1.gem/data/.ruby-gemset Changed

tomte-core-1.2.1.gem/data/.ruby-version Changed

tomte-core-1.2.1.gem/data/Gemfile Changed

tomte-core-1.2.1.gem/data/Gemfile.lock Changed

tomte-core-1.2.1.gem/data/LICENSE Changed

tomte-core-1.2.1.gem/data/NOTICE Changed

tomte-core-1.2.1.gem/data/README Changed

tomte-core-1.2.1.gem/data/Rakefile Changed

tomte-core-1.2.1.gem/data/TODO Changed

tomte-core-1.2.1.gem/data/bin/tomte Changed

tomte-core-1.2.1.gem/data/config/tomte.yml Changed

tomte-core-1.2.1.gem/data/lib/crypto/CRYPTO.txt Changed

tomte-core-1.2.1.gem/data/lib/crypto/pki.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/binary.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/blankslate.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/cli.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/cli/base.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/cli/console.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/cli/misc.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/cli/plugin.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/configuration.rb Added

@@ -0,0 +1,475 @@
+
+# Tomte, a framework for distributed agents.
+# Copyright (c) 2010-2013, Lele Forzani, windmillmedia. All Rights Reserved.
+#
+# Author:: Lele Forzani <lele@windmill.it>
+# License:: You can redistribute it and/or modify it under the terms of the LICENSE file.
+
+require 'forwardable'
+require 'optparse'
+require 'compat/hash'
+require 'uuidtools'
+require 'socket'
+require 'yaml'
+require 'pp'
+require 'erb'
+
+module Tomte
+
+  class Configuration
+
+    SEPARATOR = ('-'*120).yellow
+
+    extend Forwardable
+
+    # delegate, for now, we will see if we need a semaphore
+    def_delegators :@config, :, :=
+
+    # where we got the core configuration
+    attr_reader :config_file
+
+    public
+    ######
+
+    DEFAULT_FILE_QUEUE = :main
+
+    DEFAULT_ENVIRONMENT_FILE = File.join('/etc', 'tomte', 'default_environment')
+
+    DEFAULT_CONFIG_FILES = 
+        {:path =>  File.join(Tomte::LIBRARY, '..', 'config'), :file =>  'tomte.yml', :queue => :before },
+        {:path =>  :system,                                   :file =>  'tomte.yml'},
+        {:path =>  File.join(Dir.getwd, 'config'),            :file =>  'tomte.yml'}
+    
+
+
+    DEFAULT_CORE_CONFIGURATION = {
+      :configured => false,
+      :environment => 'production',
+      :common_environment => '_common',
+      :log_level => nil,                  # nil means use the logger profile
+      :log_profile => :default,
+      :debug => false,
+      :interactive => false,
+      :application => 'tomte-app',
+      :system_configuration_path =>  File.expand_path('tomte', '/etc' )
+    }
+
+
+    def initialize(args = {})
+
+      @semaphore = Mutex.new
+      @additional_options_blocks = {}
+      @sections = 
+      @overrides = {}
+
+      @config = default_configuration
+
+      @options = {}
+      :core, :local.each { |s| add_section s }
+
+      @root = args:root
+
+      add_config_files(DEFAULT_CONFIG_FILES)
+      default_environment
+    end
+
+    #
+    # used for safe change of configuration
+    #
+    def change_configuration(&blk)
+      @semaphore.synchronize do
+        blk.call(@config) if blk
+      end
+    end
+
+    #
+    # used to apply a piece of configuration
+    #
+    def apply_configuration(ary)
+      change_configuration do |c|
+        c.recursive_merge! ary
+      end
+    end
+    alias :merge :apply_configuration
+
+
+    #
+    # returns a specific config file queue
+    #
+    def config_file_queue(queue = DEFAULT_FILE_QUEUE)
+      config_file_queuesqueue ||= 
+    end
+
+    #
+    # returns all the file queues
+    #
+    def config_file_queues
+      @config:core:config_file_queues ||= {}
+    end
+
+    #
+    # adds all the files matching glob in path
+    #
+    def add_config_files_matching(glob, options, queue = DEFAULT_FILE_QUEUE)
+      glob = expand_path_spec(glob, options:path)
+      files = Dir.glob(glob).sort.map { |f| options.merge(:file => f) }
+      add_config_files(files, queue)
+    end
+
+    #
+    # add one or more config files to a file queue
+    #
+    def add_config_files(fileinfo, queue = DEFAULT_FILE_QUEUE)
+      if fileinfo.is_a? Array
+        fileinfo.each { |f | add_config_file(f , queue) }
+      else
+        add_config_file(fileinfo, queue)
+      end
+    end
+
+    #
+    # adds one file to a file queue
+    #
+    def add_config_file(fileinfo, queue = DEFAULT_FILE_QUEUE)
+      case fileinfo
+        when Hash
+          queue = (fileinfo.delete(:queue) || queue ).to_sym
+          config_file_queue(queue).push fileinfo
+        else
+         config_file_queue(queue).push(:path => :system, :file => fileinfo.to_s)
+      end
+    end
+
+    #
+    #
+    #
+    def already_configured?
+      @config:core && @config:core:configured
+    end
+
+    def already_configured!
+      core:configured = true
+    end
+
+    def add_section(name)
+      @sections << name
+      @configname ||= {}
+      self.instance_eval %{
+        def #{name.to_s}
+          @config:#{name.to_s}
+        end
+      }
+    end
+
+    def add(section, hash)
+      add_section section
+      apply_configuration({ section => hash })
+      @config
+    end
+
+    #
+    # allow to set specific ovverides
+    #
+    def override(section, &block)
+      @overridessection = block
+    end
+
+    #
+    # this should be called _after_ the additional parse blocks have been defined
+    #
+    def configure!(options = {})
+
+      return if already_configured?
+
+      # process commandline opts
+      parse_options if options.delete(:parse_command_line)
+
+      if(@options && @options:core)
+        @config:core:environment = @options:core:environment if @options:core:environment
+        @config:core:config_file = @options:core:config_file if @options:core:config_file
+      end
+
+      env = @config:core:environment
+
+      #
+      # Tomte.config.add_config_files {
+      #   { :file => tomte-protocol.yml, :path => :system }
+      #   { :file => ...                 :path => :application
+      # }
+      #
+      config_file_queues.keys.sort.each do |queue|
+        config_file_queue(queue).each do |f|
+          @config:core:common_environment, env.each do |e|
+              apply_configuration load_configuration_from f, e
+          end
+        end
+      end
+
+      # also merge the command line options in
+      apply_configuration @options if @options
+      # and the local options
+      apply_configuration options
+
+      # apply overrides
+      apply_overrides
+
+      # a few defaults actually depends on the configuration given
+      post_configuration
+
+      already_configured!
+
+      tomte_debug do
+        puts "== parsed configuration ==".yellow.bold
+        ap @config
+      end
+
+      @config
+    end
+
+    # quickies
+#    def core
+#      self:core
+#    end
+
+#    def local
+#      self:local
+#    end
+
+    def to_s
+      @config.to_s
+    end
+
+    def debug
+      @config.ai.subindent
+    end
+
+    def debug?
+      !!@config:core:debug
+    end
+
+    #
+    # register additional options definitions
+    #
+    # config.additional_options(name) do |cf, opts|
+    #
+    #   opts.on("-d", "--daemonize", "Run  as a daemon") do |d|
+    #      cf:daemonize = d
+    #    end
+    #
+    # end
+    #
+    def additional_options(name, &blk)
+      @additional_options_blocksname = blk
+    end
+
+    def additional_commands(hash)
+      (@additional_commands ||= {}).merge! hash
+    end
+
+    def additional_help_text(text)
+      (@additional_help_text ||= ) << text
+    end
+
+    private
+    #######
+    #
+    #
+    #
+
+    def apply_overrides
+      @sections.each do |s|
+        @overridess.call(@configs) if(@overridess &&  @overridess.respond_to?(:call))
+      end
+    end
+
+
+    def default_environment
+      if !ENV'TOMTE_ENV'.blank?
+        core:environment = ENV'TOMTE_ENV'.strip
+      elsif File.exists?(DEFAULT_ENVIRONMENT_FILE)
+        core:environment = File.read(DEFAULT_ENVIRONMENT_FILE).match(/^\w+/)0
+      end
+
+    rescue
+      # do nothing
+    end
+
+    def default_configuration
+      { :core => DEFAULT_CORE_CONFIGURATION, :local => {} }
+    end
+
+    def post_configuration
+
+      # set it to a sensible default
+      core:application_root = File.expand_path('..', Tomte::LIBRARY ) unless core:application_root
+
+      local:uuid ||= UUIDTools::UUID.random_create.to_s
+      local:host ||= Socket.gethostname
+      local:identity  ||= core:application + '-' + local:host
+      begin
+        local:hostname ||= Socket.gethostbyname(Socket.gethostname).first
+      rescue
+        local:hostname ||= 'unknown'
+      end
+
+      # load the debugging extensions
+      if debug?
+        puts "== Debugging active. This is going to be slow!".important!
+        Object.__send__(:include, Tomte::Debug::Active)
+      end
+
+    end
+
+
+    def expand_path_spec(file, path)
+      cwd = Dir.getwd
+
+      case path
+        when :system
+          File.expand_path(file, core:system_configuration_path)
+        when :application
+          File.expand_path(file, File.join(core:application_root, 'config'))
+        when :cwd
+          File.expand_path(file, cwd)
+        when :nil
+          File.expand_path(file)
+        else
+          File.expand_path(file, path.to_s)
+        end
+    end
+
+    def load_configuration_from(file, environment = 'default', path = nil)
+
+      (file, path) = file:file, file:path if file.is_a? Hash
+      file = expand_path_spec(file, path)
+
+      puts "= Loading configuration file #{file}, for environment: #{environment}".blue if @options &&
+        @options:core && @options:core:debug
+
+      begin
+        config = {}
+        raw_config = if File.exists?(file) 
+          data = File.read file
+          tpl = ERB.new data
+          yaml = tpl.result binding
+          YAML.load(yaml) || {}
+        else
+          {}
+        end
+
+        config = raw_configenvironment if raw_config.has_key?(environment)
+        config.recursively!{|h| h.symbolize_keys }
+      rescue Exception => e
+        puts "Error while reading configuration file '#{file}'".important!
+        puts " - " + e.message
+        exit
+      end
+      config
+    end
+
+
+
+    def parse_options(&blk)
+
+      @argv = core:argv || ARGV
+      @options = {}
+      @sections.each {|s| @optionss = {}}
+
+      opts = OptionParser.new do |opts|
+
+        opts.banner = usage
+
+        opts.define_head(core:application_caption.green.bold) if core:application_caption
+
+        if @additional_help_text
+          opts.separator " "
+          @additional_help_text.each do |l|
+            opts.separator l.to_s
+          end
+        end
+
+        unless @additional_commands.blank?
+          opts.separator " "
+          opts.separator 'Commands'.blue.bold
+          opts.separator SEPARATOR
+          @additional_commands.each do |command, caption|
+            opts.separator sprintf("%-25s", command).yellow.bold + caption
+          end
+        end
+
+        opts.separator " "
+        opts.separator 'Tomte Options'.blue.bold
+        opts.separator SEPARATOR
+
+        opts.on("-e", "--environment ENV", "Framework environment " + "(default: #{@config:core:environment})") do |env|
+          @options:core:environment = env
+        end
+
+        opts.on("-i", "--identity ID", "Sets this endpoint identity") do |ident|
+          @options:local:identity = ident
+        end
+
+
+        opts.on("-D", "--debug", "Set debugging on (heavy and verbose!)") do
+          @options:core:debug = true
+          @options:core:log_profile = :debug
+          @options:core:log_level = :debug
+        end
+
+        opts.on("-l", "--log-level LEVEL", "Specify the log level (fatal, error, warn, info, debug). Default is '#{@config:log_level}'") do |level|
+          @options:core:log_level = level
+        end
+
+        opts.on("--log-path PATH", "Specify the log file path") do |dir|
+          @options:core:log_profile = :production
+          @options:core:log_path = dir
+        end
+
+        opts.on("--log-profile LEVEL", "Specify the log profile to use interactive | production | daemonized | ...") do |profile|
+          @options:core:log_profile = profile
+        end
+        opts.on("-h", "--help", "Show this message")                               { puts opts; exit }
+
+        opts.on("--version", "Show the Tomte version number") do |res|
+          puts "Tomte Version #{Tomte::VERSION}"
+          exit
+        end
+
+         # call additional blocks, usually additional options in the agent(s)
+        blk.call(@config, opts) if blk
+        @additional_options_blocks.each do |name, blk|
+          opts.separator " "
+          opts.separator name.blue.bold
+          opts.separator SEPARATOR
+          blk.call(@options, opts, @config)
+        end
+
+      end
+
+      opts.parse! @argv
+      @options:core:command = @argv.shift if @argv
+      @options:core:arguments = @argv
+
+      if (@additional_commands && @options:core:command && !@additional_commands.keys.include?(@options:core:command.to_sym))
+        puts "\nUnknown command '#{@options:core:command}'".important!
+        puts usage
+        exit
+      end
+    end
+
+    def usage
+      ("Usage: #{core:application} -flags --options " + "#{output_commands}\n").blue.bold
+    end
+
+    def output_commands
+      (!@additional_commands.blank? ? "#{@additional_commands.keys.join('|')} params" : '')
+    end
+
+    class << self
+      def relative_cfg(library_path)
+        File.expand_path(File.join(library_path, '..', 'config'))
+      end
+    end
+
+  end
+end

tomte-core-1.2.1.gem/data/lib/tomte/console.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/core.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/core_structures.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/core_structures/priority_queue.README Changed

tomte-core-1.2.1.gem/data/lib/tomte/core_structures/priority_queue.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/core_structures/ring_buffer.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/data.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/debug.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/accessible.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/bson_serialize.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/clone.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/doctype.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/enumerable.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/equality.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensibility.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensible.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/array.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/binary.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/boolean.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/date.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/exception.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/float.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/hash.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/integer.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/kernel.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/nil_class.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/object.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/object_id.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/set.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/string.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/extensions/time.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/inspect.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/keys.rb Added

@@ -0,0 +1,255 @@
+# encoding: UTF-8
+require 'tomte/document/keys/key'
+
+module Tomte
+  module Document
+    module Keys
+      extend ActiveSupport::Concern
+
+      included do
+        extend ActiveSupport::DescendantsTracker
+        key :_id, Tomte::ObjectId, :default => lambda { Tomte::ObjectId.new }
+      end
+
+      module ClassMethods
+        def inherited(descendant)
+          descendant.instance_variable_set(:@keys, keys.dup)
+          super
+        end
+
+        def keys
+          @keys ||= {}
+        end
+
+        def key(*args)
+          Key.new(*args).tap do |key|
+            keyskey.name = key
+            create_accessors_for(key)
+            create_key_in_descendants(*args)
+          end
+        end
+
+        def key?(key)
+          keys.keys.include?(key.to_s)
+        end
+
+        def using_object_id?
+          object_id_key?(:_id)
+        end
+
+        def object_id_keys
+          keys.keys.select { |key| keyskey.type == Tomte::ObjectId }.map { |k| k.to_sym }
+        end
+
+        def object_id_key?(name)
+          object_id_keys.include?(name.to_sym)
+        end
+
+        def to_tomte(instance)
+          return nil if instance.nil?
+          instance.to_tomte
+        end
+
+        def from_tomte(value)
+          return nil if value.nil?
+          value.is_a?(self) ? value : load(value)
+        end
+
+        def load(attrs)
+          return nil if attrs.nil?
+          res =
+            begin
+              attrs'_doctype'.present? ? attrs'_doctype'.constantize : self
+            rescue NameError
+              self
+            end.allocate.initialize_from_data(attrs)
+          res.__send__(:document_initialize, attrs) if res.respond_to?(:document_initialize)
+          res
+        end
+
+        private
+        def key_accessors_module_defined?
+          if method(:const_defined?).arity == 1 # Ruby 1.9 compat check
+            const_defined?('TomteDocumentKeys')
+          else
+            const_defined?('TomteDocumentKeys', false)
+          end
+        end
+
+        def accessors_module
+          if key_accessors_module_defined?
+            const_get 'TomteDocumentKeys'
+          else
+            const_set 'TomteDocumentKeys', Module.new
+          end
+        end
+
+        def create_accessors_for(key)
+          accessors_module.module_eval <<-end_eval
+            def #{key.name}
+              read_key(:#{key.name})
+            end
+
+            def #{key.name}_before_typecast
+              read_key_before_typecast(:#{key.name})
+            end
+
+            def #{key.name}=(value)
+              write_key(:#{key.name}, value)
+            end
+
+            def #{key.name}?
+              read_key(:#{key.name}).present?
+            end
+          end_eval
+
+          include accessors_module
+        end
+
+        def create_key_in_descendants(*args)
+          descendants.each { |descendant| descendant.key(*args) }
+        end
+      end
+
+      def initialize(attrs={})
+        @_new = true
+        self.attributes = attrs
+      end
+
+      def initialize_from_data(attrs={})
+        @_new = false
+        load_from_data(attrs)
+        self
+      end
+
+      def attributes=(attrs)
+        return if attrs.blank?
+
+        attrs.each_pair do |key, value|
+          if respond_to?(:"#{key}=")
+            self.send(:"#{key}=", value)
+          else
+            selfkey = value
+          end
+        end
+      end
+
+      def attributes
+        HashWithIndifferentAccess.new.tap do |attrs|
+          keys.select { |name, key| !selfkey.name.nil? || key.type == ObjectId }.each do |name, key|
+            value = key.set(selfkey.name)
+            attrsname = value
+          end
+
+          #embedded_associations.each do |association|
+          #  if documents = instance_variable_get(association.ivar)
+          #    if association.one?
+          #      attrsassociation.name = documents.to_tomte
+          #    else
+          #      attrsassociation.name = documents.map { |document| document.to_tomte }
+          #    end
+          #  end
+          #end
+        end
+      end
+      #alias :to_tomte :attributes
+
+      def to_tomte
+        HashWithIndifferentAccess.new.tap do |attrs|
+          keys.select { |name, key| !selfkey.name.nil? || key.type == ObjectId }.each do |name, key|
+            value =
+              (selfkey.name.respond_to?(:to_tomte) ? selfkey.name.to_tomte : key.set(selfkey.name))
+            attrsname = value
+          end
+        end
+      end
+
+
+      def update_attributes(attrs={})
+        assign(attrs)
+      end
+
+      def update_attributes!(attrs={})
+        assign(attrs)
+      end
+
+      def update_attribute(name, value)
+        update_attributes(name.to_sym => value)
+      end
+
+      def assign(attrs={})
+        self.attributes = attrs
+      end
+
+      def id
+        _id
+      end
+
+      def id=(value)
+        if self.class.using_object_id?
+          value = ObjectId.to_to_tomte(value)
+        end
+
+        self:_id = value
+      end
+
+      def (name)
+        read_key(name)
+      end
+
+      def =(name, value)
+        ensure_key_exists(name)
+        write_key(name, value)
+      end
+
+      def keys
+        self.class.keys
+      end
+
+      def key_names
+        keys.keys
+      end
+
+      def new?
+        @_new ||= true
+      end
+
+      private
+      def load_from_data(attrs)
+        return if attrs.blank?
+        attrs.each do |key, value|
+          if respond_to?(:"#{key}=") && !self.class.key?(key)
+            self.send(:"#{key}=", value)
+          else
+            selfkey = value
+          end
+        end
+      end
+
+      def ensure_key_exists(name)
+        self.class.key(name) unless respond_to?("#{name}=")
+      end
+
+      def read_key(key_name)
+        if key = keyskey_name.to_s
+          value = key.get(instance_variable_get(:"@#{key_name}"))
+          instance_variable_set(:"@#{key_name}", value)
+        end
+      end
+
+      def read_key_before_typecast(name)
+        instance_variable_get(:"@#{name}_before_typecast")
+      end
+
+      def write_key(name, value)
+        key = keysname.to_s
+        casted_value = key.try_cast(value)
+
+        instance_variable_set :"@#{name}_before_typecast", casted_value
+        instance_variable_set :"@#{name}", key.set(casted_value)
+      end
+
+    end
+  end
+end
+

tomte-core-1.2.1.gem/data/lib/tomte/document/keys/key.rb Added

@@ -0,0 +1,87 @@
+# encoding: UTF-8
+
+# this comes (almost) verbatim from MongoMapper
+module Tomte
+  module Document
+    module Keys
+      class Key
+        attr_accessor :name, :type, :options, :default_value
+
+        def initialize(*args)
+          options = args.extract_options!
+          @name, @type = args.shift.to_s, args.shift
+          self.options = (options || {}).symbolize_keys
+          self.default_value = self.options:default
+        end
+
+        def ==(other)
+          @name == other.name && @type == other.type
+        end
+
+        def embeddable?
+          return false unless type.respond_to?(:embeddable?)
+          type.embeddable?
+        end
+
+        def can_default_id?
+          type && (type == Tomte::ObjectId || type == BSON::ObjectId || type == String)
+        end
+
+        def number?
+          type == Integer || type == Float
+        end
+
+        def get(value)
+          if value.nil? && !default_value.nil?
+            if default_value.respond_to?(:call)
+              return default_value.call
+            else
+              # Using Marshal is easiest way to get a copy of mutable objects
+              # without getting an error on immutable objects
+              return Marshal.load(Marshal.dump(default_value))
+            end
+          end
+
+          if options:typecast.present?
+            type.from_tomte(value).map! { |v| typecast_class.from_tomte(v) }
+          elsif value.is_a? Array
+            Array.from_tomte(value)
+          elsif type
+            type.from_tomte(value)
+          else
+            value
+          end
+        end
+
+        def try_cast(value)
+          if options:as_object.present? && Tomte::Document::Parser.parseable?(value)
+            Tomte::Document::Parser.load(value)
+          elsif options:as_document.present? && Tomte::Document::Parser.is_document?(value)
+            Tomte::Document::Parser.load_document(value)
+          elsif options:cast.present? && type && type.respond_to?(:from_tomte) && !value.is_a?(type)
+            type.from_tomte(value)
+          else
+            value
+          end
+        end
+
+        def set(value)
+          if type
+            type.to_tomte(value).tap do |values|
+              if options:typecast.present?
+                values.map! { |v| typecast_class.to_tomte(v) }
+              end
+            end
+          else
+            value
+          end
+        end
+
+        private
+        def typecast_class
+          @typecast_class ||= options:typecast.constantize
+        end
+      end
+    end
+  end
+end

tomte-core-1.2.1.gem/data/lib/tomte/document/log.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/parser.rb Added

@@ -0,0 +1,122 @@
+# encoding: UTF-8
+#
+# Tomte, a framework for distributed agents.
+# Copyright (c) 2010-2013, Lele Forzani, windmillmedia. All Rights Reserved.
+#
+# Author:: Lele Forzani <lele@windmill.it>
+# License:: You can redistribute it and/or modify it under the terms of the LICENSE file.
+
+class GenericError < StandardError
+
+  attr_reader :type
+  attr_reader :attributes
+end
+
+
+module Tomte
+  module Document
+    module Parser
+
+      class << self
+        def from_bson(data)
+          load(BSON.deserialize(data))
+        end
+
+        def is_document?(attrs)
+          return false unless attrs.kind_of? Hash
+          attrs'_doctype'.present? || attrs:_doctype.present?
+        end
+
+        def is_generic_object?(attrs)
+          return false unless attrs.kind_of? Hash
+          attrs'_type'.present? || attrs:_type.present?
+        end
+
+        def load_generic_object(attrs)
+          if is_generic_object? attrs
+            (attrs'_type' || attrs:_type).constantize.from_tomte(attrs)
+          else
+            attrs
+          end
+        rescue NameError
+          OpenStruct.new(attrs)
+        end
+
+        def parseable?(attrs)
+          is_document?(attrs) || is_generic_object?(attrs) || attrs.is_a?(::Hash)
+        end
+
+        def load_document(attrs)
+          if is_document? attrs
+            (attrs'_doctype' || attrs:_doctype).constantize.from_tomte(attrs)
+          else
+            attrs
+          end
+
+        rescue NameError
+          Tomte::OpenDocument.new(attrs)
+        end
+
+        #
+        # returns an exception with the given message, backtrace and attributes hash
+        #
+        def load_exception(klass, message = '', backtrace = , attributes = {})
+
+          e = begin
+                klass.constantize
+              rescue NameError
+                GenericError
+              end
+          exc =
+            begin
+              raise(e.allocate, message)
+            rescue e => exception
+              exception.set_backtrace(backtrace)
+              exception
+            end
+
+          if exc.is_a?(GenericError)
+            exc.instance_variable_set(:@type, klass) if exc.is_a?(GenericError)
+            exc.instance_variable_set(:@attributes, OpenStruct.new(attributes.inject_hash { |h,(k,v)| hk = load(v) }))
+          else
+            attributes.each do |k,v|
+              exc.instance_variable_set("@#{k}".to_sym, load(v))
+            end
+          end
+          exc
+        end
+
+        def load(attrs)
+          if is_document? attrs
+            load_document(attrs)
+          elsif is_generic_object? attrs
+            load_generic_object(attrs)
+          elsif attrs.is_a? ::Hash
+            ActiveSupport::HashWithIndifferentAccess.from_tomte(attrs)
+          elsif attrs.is_a? ::Array
+            Array.from_tomte(attrs)
+          else
+            attrs
+          end
+        end
+        alias_method :from_tomte, :load
+
+        def to_tomte_hash(obj)
+          return(obj) unless obj.respond_to?(:to_tomte)
+
+          klass = obj.class
+          res = obj.to_tomte
+
+          if res.is_a?(::Hash) &&
+                       !Tomte::Document::Parser.is_document?(res) &&
+                       !Tomte::Document::Parser.is_generic_object?(res) &&
+                       !klass.ancestors.include?(::Hash)
+
+            res:_type = klass.name
+          end
+          res
+        end
+      end
+    end
+  end
+end
\ No newline at end of file

tomte-core-1.2.1.gem/data/lib/tomte/document/serialization.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/document/to_human.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/logger.rb Added

@@ -0,0 +1,239 @@
+
+# Tomte, a framework for distributed agents.
+# Copyright (c) 2010-2013, Lele Forzani, windmillmedia. All Rights Reserved.
+#
+# Author:: Lele Forzani <lele@windmill.it>
+# License:: You can redistribute it and/or modify it under the terms of the LICENSE file.
+
+require 'fileutils'
+
+# Defines the log level for a Tomte project.
+TOMTE_LOG_LEVEL = ENV'TOMTE_LOG_LEVEL' unless defined?(TOMTE_LOG_LEVEL)
+# Defines the logger used for a Tomte project.
+TOMTE_LOGGER_CONFIG = ENV'TOMTE_LOGGER_CONFIG' unless defined?(TOMTE_LOGGER_CONFIG)
+
+module Tomte
+
+#  def self.logger
+#    Tomte::Logger.new(config.core.merge(config.local)) if Thread.current:_logger.nil?
+#    Thread.current:_logger
+#  end
+
+#  def self.logger=(value)
+#    Thread.current:_logger = value
+#  end
+  
+  #
+  # Extensions to the built in Ruby logger.
+  #
+  class Logger
+    include Logging::LoggingExtensions
+
+    attr_accessor :level
+    attr_accessor :auto_flush
+    attr_reader   :buffer
+    attr_reader   :log
+    attr_reader   :init_args
+
+    attr_accessor :identity
+    attr_accessor :environment
+
+    @@mutex = {}
+
+    #
+    # Configuration for a given environment, possible options are:
+    #
+    # :log_level:: One of :fatal, :error, :warn, :info, :debug
+    # :stream:: One of :to_file, :null, :stdout, :stderr a string representing a path name
+    #   our your custom stream
+    # :log_level::
+    #   The log level from, e.g. :fatal or :info. Defaults to :warn in the
+    #   production environment and :debug otherwise.
+    # :auto_flush::
+    #   Whether the log should automatically flush after new messages are
+    #   added. Defaults to true.
+    # :format_datetime:: Format of datetime. Defaults to: "%d/%b/%Y %H:%M:%S"
+    # :format_message:: Format of message. Defaults to: ""%s - - %s \"%s\"""
+    #
+    # @example
+    #   Logger::Config:development = { :log_level => :debug, :stream => :to_file }
+    #   # or you can edit our defaults
+    #   Logger::Config:development:log_level = :error
+    #   # or you can use your stream
+    #   Logger::Config:development:stream = StringIO.new
+    #
+    # Defaults are:
+    #
+    #   :production  => { :log_level => :warn,  :stream => :to_file },
+    #   :daemonized  => { :log_level => :info, :stream => :stdout },
+    #   :interactive => { :log_level => :debug, :stream => :stdout, :format_datetime => ' ' },
+    #   :development => { :log_level => :debug, :stream => :stdout, :format_datetime => ' ' },
+    #   :unknown     => { :log_level => :debug, :stream => :stdout, :format_datetime => ' ' },
+    #   :test        => { :log_level => :debug, :stream => :null }
+    #
+    # In some cases, configuring the loggers before loading the framework is necessary.
+    # You can do so by setting TOMTE_LOGGER:
+    #
+    #   TOMTE_LOGGER = { :staging => { :log_level => :debug, :stream => :to_file }}
+    #
+
+    Config = {
+      :production  => { :color => true,  :log_level => :warn,  :stream => :to_file },
+      :daemonized  => { :color => false, :log_level => :info,  :stream => :to_file },
+      :default     => { :color => true,  :log_level => :info,  :stream => :stdout, :format_datetime => ' ' },
+      :debug       => { :color => true,  :log_level => :debug, :stream => :stdout, :format_datetime => ' ' },
+      :interactive => { :color => true,  :log_level => :warn,  :stream => :stderr, :format_datetime => ' ' },
+      :nocolor     => { :color => false, :log_level => :info,  :stream => :stdout, :format_datetime => ' ' },
+      :unknown     => { :color => false, :log_level => :debug, :stream => :stdout, :format_datetime => ' ' },
+      :test        => { :color => true,  :log_level => :debug, :stream => :null }
+    }
+    Config.merge!(TOMTE_LOGGER_CONFIG) if  (defined?(TOMTE_LOGGER_CONFIG) && !TOMTE_LOGGER_CONFIG.nil?)
+    
+
+
+    def self.setup!(options)
+
+      environment, identity = (Tomte.env || :test).to_sym, (options:identity || 'unknown')
+      profile = options:profile.to_sym || environment
+      options.delete(:log_level) if options:log_level.nil?
+
+      config = Configprofile
+
+      unless config
+        warn("No logging configuration for :#{profile} found, falling back to :unknown")
+        config = Config:unknown
+      end
+
+      stream = case config:stream
+        when String
+          dir = File.dirname(config:stream)
+          FileUtils.mkdir_p(dir) unless File.exists?(dir)
+          File.new(config:stream, "a+")
+        when :to_file
+          raise ArgumentError, "Log path not given." if options:log_path.blank?
+          FileUtils.mkdir_p(options:log_path)
+          File.new(File.join(options:log_path, "%s-%s.log" % identity, environment), "a+")
+        when :null   then StringIO.new
+        when :stdout then $stdout
+        when :stderr then $stderr
+        else config:stream
+      end
+
+      Thread.current:_logger = new(config.merge(options.merge(:stream => stream, :environment => environment)))
+    end
+
+
+    ##
+    # To initialize the logger you create a new object, proxies to set_log.
+    #
+    # @param Hash options
+    #
+    # @option options Symbol :stream ($stdout)
+    #   Either an IO object or a name of a logfile. Defaults to $stdout
+    #
+    # @option options Symbol :log_level (:production in the production environment and :debug otherwise)
+    #   The log level from, e.g. :fatal or :info.
+    #
+    # @option options Symbol :auto_flush (true)
+    #   Whether the log should automatically flush after new messages are
+    #   added. Defaults to true.
+    #
+    # @option options Symbol :format_datetime (" %d/%b/%Y %H:%M:%S ")
+    #   Format of datetime
+    #
+    # @option options Symbol :format_message ("%s -%s%s")
+    #    Format of message
+    #
+    # @option options Symbol :log_static (false)
+    #   Whether or not to show log messages for static files.
+    #
+    def initialize(options={})
+
+      @buffer          = 
+      @color           = options:color
+      @auto_flush      = options.has_key?(:auto_flush) ? options:auto_flush : true
+      @level           = options:log_level ? Logging::Levelsoptions:log_level.to_sym : Logging::Levels:debug
+      @log             = options:stream  || $stdout
+      @log.sync        = true
+      @mutex           = @@mutex@log ||= Mutex.new
+      @format_datetime = options:format_datetime || "%d/%b/%Y %H:%M:%S"
+      @format_message  = options:format_message  || "%s - %s %s"
+
+      @identity = options:identity || 'unknown'
+      @environment = options:environment || Tomte.env || 'unknown'
+
+      colorize! if @color
+
+      tomte_debug do
+        puts "== logger configuration ==".yellow.bold
+        ap options
+      end
+
+      debug "+ Logger for '#{identity}:#{environment}' started, level is #{level}."
+    end
+
+
+    ##
+    # Changes the log level by symbol
+    #
+    # @param String, Symbol level
+    #
+    #
+    def set_level(loglevel)
+      @level =  Logging::Levelsloglevel
+    end
+
+    ##
+    # Adds a message to the log - for compatibility with other loggers.
+    #
+    def add(level, message = nil)
+      write(message)
+    end
+
+
+    ##
+    # Flush the entire buffer to the log object.
+    #
+    def flush
+      return unless @buffer.size > 0
+      @mutex.synchronize do
+        @log.write(@buffer.slice!(0..-1).join(''))
+      end
+    end
+
+    ##
+    # Close and remove the current log object.
+    #
+    # @return NilClass
+    #
+    def close
+      flush
+      @log.close if @log.respond_to?(:close) && !@log.tty?
+      @log = nil
+    end
+
+    ##
+    # Directly append message to the log.
+    #
+    # @param String message
+    #   The message
+    #
+    def <<(message = nil)
+      message << "\n" unless message-1 == ?\n
+      @buffer << message
+      flush if @auto_flush
+      message
+    end
+    alias :write :<<
+
+    ##
+    # Formats the log.
+    #
+    def format(message, level)
+      @format_message % stylized_level(level), colorize(Time.now.strftime(@format_datetime), :yellow), filter(message.to_s.strip)
+    end
+
+  end
+end
+
+

tomte-core-1.2.1.gem/data/lib/tomte/logging.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/object_id.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/open_document.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/plugins.rb Added

tomte-core-1.2.1.gem/data/lib/tomte/timer.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/utils.rb Changed

tomte-core-1.2.1.gem/data/lib/tomte/version.rb Added

tomte-core-1.2.1.gem/data/spec/functional/document/document_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/helpers/document_spec_helper.rb Changed

tomte-core-1.2.1.gem/data/spec/helpers/document_spec_models.rb Changed

tomte-core-1.2.1.gem/data/spec/tomte_spec_helper.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/arrays_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/as_document_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/basic_document_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/bson_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/clone_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/document_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/equality_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/exceptions_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/generic_object_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/hashes_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/inheritance_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/inspect_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/key_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/keys_spec.rb Changed

tomte-core-1.2.1.gem/data/spec/unit/document/reg_open_document_cast_spec.rb Changed

tomte-core-1.2.1.gem/data/tmp/subdoc.rb Changed

tomte-core-1.2.1.gem/data/tomte-core.gemspec Added

@@ -0,0 +1,42 @@
+# -*- encoding: utf-8 -*-
+lib = File.expand_path('../lib', __FILE__)
+$LOAD_PATH.unshift(lib) unless $LOAD_PATH.include?(lib)
+require 'tomte/version'
+
+Gem::Specification.new do |gem|
+  gem.name          = "tomte-core"
+  gem.version       = Tomte::VERSION
+  gem.authors       = "Lele Forzani"
+  gem.email         = "lele@windmill.it"
+  gem.description   = %q{A ruby framework for designing distributed, message oriented, agents}
+  gem.summary       = %q{A ruby framework for designing distributed, message oriented, agents}
+  gem.homepage      = "http://git.windmill.it/tomte"
+  gem.required_ruby_version = '>= 1.9.3'
+
+  gem.files         = `git ls-files`.split($/)
+  gem.executables   = %w(tomte)
+  gem.test_files    = gem.files.grep(%r{^(test|spec|features)/})
+  gem.require_paths = "lib"
+
+  gem.add_runtime_dependency 'rake'
+
+  gem.add_runtime_dependency 'wml-compat',  '>= 0.8.6'
+  gem.add_runtime_dependency 'uuidtools',   '>= 2.1.5'
+  gem.add_runtime_dependency 'case',        '>= 0.5.2'
+  gem.add_runtime_dependency 'json',        '>= 2.2.0'
+  gem.add_runtime_dependency 'bson',        '>= 1.12.5'
+  gem.add_runtime_dependency 'bson_ext',    '>= 1.12.5'
+
+  gem.add_runtime_dependency 'activesupport',    '>= 5.0.0'
+
+  gem.add_runtime_dependency 'thor',    '>= 0.20.3'
+  gem.add_runtime_dependency 'pry',     '>= 0.12.2'
+
+
+  gem.add_runtime_dependency 'mime-types'
+
+
+  gem.add_development_dependency "rspec"
+  gem.add_development_dependency "rspec-mocks"
+end
+

tomte-core-1.2.7.gem/metadata.gz -> tomte-core-1.2.1.gem/metadata.gz Changed

@@ -1,14 +1,14 @@
 --- !ruby/object:Gem::Specification
 name: tomte-core
 version: !ruby/object:Gem::Version
-  version: 1.2.7
+  version: 1.2.1
 platform: ruby
 authors:
 - Lele Forzani
 autorequire: 
 bindir: bin
 cert_chain: 
-date: 2024-11-25 00:00:00.000000000 Z
+date: 2021-08-28 00:00:00.000000000 Z
 dependencies:
 - !ruby/object:Gem::Dependency
   name: rake
@@ -115,9 +115,6 @@
     - - ">="
       - !ruby/object:Gem::Version
         version: 5.0.0
-    - - "<"
-      - !ruby/object:Gem::Version
-        version: 7.2.0
   type: :runtime
   prerelease: false
   version_requirements: !ruby/object:Gem::Requirement
@@ -125,9 +122,6 @@
     - - ">="
       - !ruby/object:Gem::Version
         version: 5.0.0
-    - - "<"
-      - !ruby/object:Gem::Version
-        version: 7.2.0
 - !ruby/object:Gem::Dependency
   name: thor
   requirement: !ruby/object:Gem::Requirement
@@ -201,153 +195,104 @@
 description: A ruby framework for designing distributed, message oriented, agents
 email:
 - lele@windmill.it
-executables: 
+executables:
+- tomte
 extensions: 
 extra_rdoc_files: 
 files:
-- "./.git/FETCH_HEAD"
-- "./.git/HEAD"
-- "./.git/config"
-- "./.git/index"
-- "./.git/logs/HEAD"
-- "./.git/logs/refs/remotes/origin/1-2"
-- "./.git/logs/refs/remotes/origin/bson4"
-- "./.git/logs/refs/remotes/origin/master"
-- "./.git/logs/refs/remotes/origin/next"
-- "./.git/objects/pack/pack-d673f7546bb050eb292d6a5ff4814bee06e1bc30.idx"
-- "./.git/objects/pack/pack-d673f7546bb050eb292d6a5ff4814bee06e1bc30.pack"
-- "./.git/refs/pipelines/5735"
-- "./.git/refs/remotes/origin/1-2"
-- "./.git/refs/remotes/origin/bson4"
-- "./.git/refs/remotes/origin/master"
-- "./.git/refs/remotes/origin/next"
-- "./.git/refs/tags/v0.7.1"
-- "./.git/refs/tags/v0.7.9"
-- "./.git/refs/tags/v0.7.9.1"
-- "./.git/refs/tags/v0.7.9.3"
-- "./.git/refs/tags/v0.7.9.4"
-- "./.git/refs/tags/v0.7.9.5"
-- "./.git/refs/tags/v0.7.9.6"
-- "./.git/refs/tags/v0.7.9.7"
-- "./.git/refs/tags/v0.8.0"
-- "./.git/refs/tags/v0.8.1"
-- "./.git/refs/tags/v0.8.1.1"
-- "./.git/refs/tags/v0.8.10"
-- "./.git/refs/tags/v0.8.10.1"
-- "./.git/refs/tags/v0.8.11"
-- "./.git/refs/tags/v0.8.12"
-- "./.git/refs/tags/v0.8.12.10"
-- "./.git/refs/tags/v0.8.13.0"
-- "./.git/refs/tags/v0.8.2"
-- "./.git/refs/tags/v0.8.2.2"
-- "./.git/refs/tags/v0.8.3"
-- "./.git/refs/tags/v0.8.3.1"
-- "./.git/refs/tags/v0.8.3.2"
-- "./.git/refs/tags/v0.8.4"
-- "./.git/refs/tags/v0.8.5"
-- "./.git/refs/tags/v0.8.6"
-- "./.git/refs/tags/v0.8.7"
-- "./.git/refs/tags/v0.8.8"
-- "./.git/refs/tags/v0.9.0"
-- "./.git/refs/tags/v1.0.0"
-- "./.git/refs/tags/v1.0.1"
-- "./.git/refs/tags/v1.2.7"
-- "./.gitignore"
-- "./.gitlab-ci.yml"
-- "./.rakeTasks"
-- "./.rspec"
-- "./.ruby-gemset"
-- "./.ruby-version"
-- "./Gemfile"
-- "./Gemfile.lock"
-- "./LICENSE"
-- "./NOTICE"
-- "./README"
-- "./Rakefile"
-- "./TODO"
-- "./bin/tomte"
-- "./config/tomte.yml"
-- "./lib/crypto/CRYPTO.txt"
-- "./lib/crypto/pki.rb"
-- "./lib/tomte.rb"
-- "./lib/tomte/binary.rb"
-- "./lib/tomte/blankslate.rb"
-- "./lib/tomte/cli.rb"
-- "./lib/tomte/cli/base.rb"
-- "./lib/tomte/cli/console.rb"
-- "./lib/tomte/cli/misc.rb"
-- "./lib/tomte/cli/plugin.rb"
-- "./lib/tomte/configuration.rb"
-- "./lib/tomte/console.rb"
-- "./lib/tomte/core.rb"
-- "./lib/tomte/core_structures.rb"
-- "./lib/tomte/core_structures/priority_queue.README"
-- "./lib/tomte/core_structures/priority_queue.rb"
-- "./lib/tomte/core_structures/ring_buffer.rb"
-- "./lib/tomte/data.rb"
-- "./lib/tomte/debug.rb"
-- "./lib/tomte/descendants_tracker.rb"
-- "./lib/tomte/document.rb"
-- "./lib/tomte/document/accessible.rb"
-- "./lib/tomte/document/bson_serialize.rb"
-- "./lib/tomte/document/clone.rb"
-- "./lib/tomte/document/doctype.rb"
-- "./lib/tomte/document/enumerable.rb"
-- "./lib/tomte/document/equality.rb"
-- "./lib/tomte/document/extensibility.rb"
-- "./lib/tomte/document/extensible.rb"
-- "./lib/tomte/document/extensions/array.rb"
-- "./lib/tomte/document/extensions/binary.rb"
-- "./lib/tomte/document/extensions/boolean.rb"
-- "./lib/tomte/document/extensions/date.rb"
-- "./lib/tomte/document/extensions/exception.rb"
-- "./lib/tomte/document/extensions/float.rb"
-- "./lib/tomte/document/extensions/hash.rb"
-- "./lib/tomte/document/extensions/integer.rb"
-- "./lib/tomte/document/extensions/kernel.rb"
-- "./lib/tomte/document/extensions/nil_class.rb"
-- "./lib/tomte/document/extensions/object.rb"
-- "./lib/tomte/document/extensions/object_id.rb"
-- "./lib/tomte/document/extensions/set.rb"
-- "./lib/tomte/document/extensions/string.rb"
-- "./lib/tomte/document/extensions/time.rb"
-- "./lib/tomte/document/inspect.rb"
-- "./lib/tomte/document/keys.rb"
-- "./lib/tomte/document/keys/key.rb"
-- "./lib/tomte/document/log.rb"
-- "./lib/tomte/document/parser.rb"
-- "./lib/tomte/document/serialization.rb"
-- "./lib/tomte/document/to_human.rb"
-- "./lib/tomte/logger.rb"
-- "./lib/tomte/logging.rb"
-- "./lib/tomte/object_id.rb"
-- "./lib/tomte/open_document.rb"
-- "./lib/tomte/plugins.rb"
-- "./lib/tomte/timer.rb"
-- "./lib/tomte/utils.rb"
-- "./lib/tomte/version.rb"
-- "./package.json"
-- "./spec/functional/document/document_spec.rb"
-- "./spec/helpers/document_spec_helper.rb"
-- "./spec/helpers/document_spec_models.rb"
-- "./spec/tomte_spec_helper.rb"
-- "./spec/unit/document/arrays_spec.rb"
-- "./spec/unit/document/as_document_spec.rb"
-- "./spec/unit/document/basic_document_spec.rb"
-- "./spec/unit/document/bson_spec.rb"
-- "./spec/unit/document/clone_spec.rb"
-- "./spec/unit/document/document_spec.rb"
-- "./spec/unit/document/equality_spec.rb"
-- "./spec/unit/document/exceptions_spec.rb"
-- "./spec/unit/document/generic_object_spec.rb"
-- "./spec/unit/document/hashes_spec.rb"
-- "./spec/unit/document/inheritance_spec.rb"
-- "./spec/unit/document/inspect_spec.rb"
-- "./spec/unit/document/key_spec.rb"
-- "./spec/unit/document/keys_spec.rb"
-- "./spec/unit/document/reg_open_document_cast_spec.rb"
-- "./tmp/subdoc.rb"
-- "./tomte-core.gemspec"
+- ".gitignore"
+- ".rakeTasks"
+- ".rspec"
+- ".ruby-gemset"
+- ".ruby-version"
+- Gemfile
+- Gemfile.lock
+- LICENSE
+- NOTICE
+- README
+- Rakefile
+- TODO
+- bin/tomte
+- config/tomte.yml
+- lib/crypto/CRYPTO.txt
+- lib/crypto/pki.rb
+- lib/tomte.rb
+- lib/tomte/binary.rb
+- lib/tomte/blankslate.rb
+- lib/tomte/cli.rb
+- lib/tomte/cli/base.rb
+- lib/tomte/cli/console.rb
+- lib/tomte/cli/misc.rb
+- lib/tomte/cli/plugin.rb
+- lib/tomte/configuration.rb
+- lib/tomte/console.rb
+- lib/tomte/core.rb
+- lib/tomte/core_structures.rb
+- lib/tomte/core_structures/priority_queue.README
+- lib/tomte/core_structures/priority_queue.rb
+- lib/tomte/core_structures/ring_buffer.rb
+- lib/tomte/data.rb
+- lib/tomte/debug.rb
+- lib/tomte/document.rb
+- lib/tomte/document/accessible.rb
+- lib/tomte/document/bson_serialize.rb
+- lib/tomte/document/clone.rb
+- lib/tomte/document/doctype.rb
+- lib/tomte/document/enumerable.rb
+- lib/tomte/document/equality.rb
+- lib/tomte/document/extensibility.rb
+- lib/tomte/document/extensible.rb
+- lib/tomte/document/extensions/array.rb
+- lib/tomte/document/extensions/binary.rb
+- lib/tomte/document/extensions/boolean.rb
+- lib/tomte/document/extensions/date.rb
+- lib/tomte/document/extensions/exception.rb
+- lib/tomte/document/extensions/float.rb
+- lib/tomte/document/extensions/hash.rb
+- lib/tomte/document/extensions/integer.rb
+- lib/tomte/document/extensions/kernel.rb
+- lib/tomte/document/extensions/nil_class.rb
+- lib/tomte/document/extensions/object.rb
+- lib/tomte/document/extensions/object_id.rb
+- lib/tomte/document/extensions/set.rb
+- lib/tomte/document/extensions/string.rb
+- lib/tomte/document/extensions/time.rb
+- lib/tomte/document/inspect.rb
+- lib/tomte/document/keys.rb
+- lib/tomte/document/keys/key.rb
+- lib/tomte/document/log.rb
+- lib/tomte/document/parser.rb
+- lib/tomte/document/serialization.rb
+- lib/tomte/document/to_human.rb
+- lib/tomte/logger.rb
+- lib/tomte/logging.rb
+- lib/tomte/object_id.rb
+- lib/tomte/open_document.rb
+- lib/tomte/plugins.rb
+- lib/tomte/timer.rb
+- lib/tomte/utils.rb
+- lib/tomte/version.rb
+- spec/functional/document/document_spec.rb
+- spec/helpers/document_spec_helper.rb
+- spec/helpers/document_spec_models.rb
+- spec/tomte_spec_helper.rb
+- spec/unit/document/arrays_spec.rb
+- spec/unit/document/as_document_spec.rb
+- spec/unit/document/basic_document_spec.rb
+- spec/unit/document/bson_spec.rb
+- spec/unit/document/clone_spec.rb
+- spec/unit/document/document_spec.rb
+- spec/unit/document/equality_spec.rb
+- spec/unit/document/exceptions_spec.rb
+- spec/unit/document/generic_object_spec.rb
+- spec/unit/document/hashes_spec.rb
+- spec/unit/document/inheritance_spec.rb
+- spec/unit/document/inspect_spec.rb
+- spec/unit/document/key_spec.rb
+- spec/unit/document/keys_spec.rb
+- spec/unit/document/reg_open_document_cast_spec.rb
+- tmp/subdoc.rb
+- tomte-core.gemspec
 homepage: http://git.windmill.it/tomte
 licenses: 
 metadata: {}
@@ -366,8 +311,27 @@
     - !ruby/object:Gem::Version
       version: '0'
 requirements: 
-rubygems_version: 3.0.3
+rubygems_version: 3.2.5
 signing_key: 
 specification_version: 4
 summary: A ruby framework for designing distributed, message oriented, agents
-test_files: 
+test_files:
+- spec/functional/document/document_spec.rb
+- spec/helpers/document_spec_helper.rb
+- spec/helpers/document_spec_models.rb
+- spec/tomte_spec_helper.rb
+- spec/unit/document/arrays_spec.rb
+- spec/unit/document/as_document_spec.rb
+- spec/unit/document/basic_document_spec.rb
+- spec/unit/document/bson_spec.rb
+- spec/unit/document/clone_spec.rb
+- spec/unit/document/document_spec.rb
+- spec/unit/document/equality_spec.rb
+- spec/unit/document/exceptions_spec.rb
+- spec/unit/document/generic_object_spec.rb
+- spec/unit/document/hashes_spec.rb
+- spec/unit/document/inheritance_spec.rb
+- spec/unit/document/inspect_spec.rb
+- spec/unit/document/key_spec.rb
+- spec/unit/document/keys_spec.rb
+- spec/unit/document/reg_open_document_cast_spec.rb

tomte-core-1.2.7.gem/data/./.git/FETCH_HEAD Deleted

@@ -1,36 +0,0 @@
-dd5810eaa71084ce1c565169e43a078b23ad2384		'refs/pipelines/5735' of https://lab.intercom.it/tomte/tomte-core
-dd5810eaa71084ce1c565169e43a078b23ad2384		branch '1-2' of https://lab.intercom.it/tomte/tomte-core
-6dbfc8039cd52c85eef2cfc9f6ff23f9e1b80260		branch 'bson4' of https://lab.intercom.it/tomte/tomte-core
-cc994053a39fd0d95eec464e3ec3ccc905b237fe		branch 'master' of https://lab.intercom.it/tomte/tomte-core
-aa3478ee53a64ffc9fc640fd9881a6b59ba14ccb		branch 'next' of https://lab.intercom.it/tomte/tomte-core
-f60efee019e27121f74718f6722a438ffbc816fd		tag 'v0.7.1' of https://lab.intercom.it/tomte/tomte-core
-bf35ed543313e87c25e5581709cd849e55d38e0a		tag 'v0.7.9' of https://lab.intercom.it/tomte/tomte-core
-f8fd180ac6f62afc72ea99137eb63caaee715d9e		tag 'v0.7.9.1' of https://lab.intercom.it/tomte/tomte-core
-3b329ec70f9fd8e9a58301cf6fd483a86f2973f4		tag 'v0.7.9.3' of https://lab.intercom.it/tomte/tomte-core
-c0871bba8a43ec994ef694f1685f1365e8804d84		tag 'v0.7.9.4' of https://lab.intercom.it/tomte/tomte-core
-f39ff03b9f5b2b36ccddc44e684c21f4d8fd9c17		tag 'v0.7.9.5' of https://lab.intercom.it/tomte/tomte-core
-aec0af696e2b34caa55be313dc0b674a45645bda		tag 'v0.7.9.6' of https://lab.intercom.it/tomte/tomte-core
-9a9ec50c076177dce5e692bdf94bdd891bc06322		tag 'v0.7.9.7' of https://lab.intercom.it/tomte/tomte-core
-3ddbf486917c3f0078a62cd762dd534938830e64		tag 'v0.8.0' of https://lab.intercom.it/tomte/tomte-core
-d79eee624aa7ae9eae2b3c0885148cbb0ecf4d58		tag 'v0.8.1' of https://lab.intercom.it/tomte/tomte-core
-81e01a380bf6e823a6b8589f701e9299d84a69e3		tag 'v0.8.1.1' of https://lab.intercom.it/tomte/tomte-core
-e912145e065c19f412dbd19d0045dd466a999806		tag 'v0.8.10' of https://lab.intercom.it/tomte/tomte-core
-689beb3d84dae6899912fb8831a9c450ec0bc8ba		tag 'v0.8.10.1' of https://lab.intercom.it/tomte/tomte-core
-3ee41c9b6a38070b169fc547a1d98d2e4ee69281		tag 'v0.8.11' of https://lab.intercom.it/tomte/tomte-core
-c8e328673235b681093e19af2b89aa4a0a6daf78		tag 'v0.8.12' of https://lab.intercom.it/tomte/tomte-core
-9ae77e0152d61e0be54fb62b3c07a7dc6a702604		tag 'v0.8.12.10' of https://lab.intercom.it/tomte/tomte-core
-75cfc6eb42f8fff2c47141dc4736d404ceb5e86f		tag 'v0.8.13.0' of https://lab.intercom.it/tomte/tomte-core
-dadcd4eb0868044f35889a7db957acb1d83e63a1		tag 'v0.8.2' of https://lab.intercom.it/tomte/tomte-core
-36ce4fe6f618b89a39e5ce95beb276ee7037eea9		tag 'v0.8.2.2' of https://lab.intercom.it/tomte/tomte-core
-f344195596b513658b88d274c7b9c6c10922e251		tag 'v0.8.3' of https://lab.intercom.it/tomte/tomte-core
-f3c3c765ead395d2b7633ebc1bb54d5b96e6354c		tag 'v0.8.3.1' of https://lab.intercom.it/tomte/tomte-core
-8cc0097cfe0831afda9bb190c2c3a18a7e875f84		tag 'v0.8.3.2' of https://lab.intercom.it/tomte/tomte-core
-3ee50da784c58c71414a40491796cab7627e9253		tag 'v0.8.4' of https://lab.intercom.it/tomte/tomte-core
-d30b1a5d5bde0eadcd03b236e37e7667c324bba7		tag 'v0.8.5' of https://lab.intercom.it/tomte/tomte-core
-d30b1a5d5bde0eadcd03b236e37e7667c324bba7		tag 'v0.8.6' of https://lab.intercom.it/tomte/tomte-core
-3e4b95572302ba3207e5352654e38ddae63a01f2		tag 'v0.8.7' of https://lab.intercom.it/tomte/tomte-core
-409db9488ead37c55750d1e94a7b0eb6aed40f6c		tag 'v0.8.8' of https://lab.intercom.it/tomte/tomte-core
-7b24593925a59499452d82a0ef95dcce66571119		tag 'v0.9.0' of https://lab.intercom.it/tomte/tomte-core
-c343cab84b00905d35b3601d20e119e071524c81		tag 'v1.0.0' of https://lab.intercom.it/tomte/tomte-core
-1aea681926fcc08af08157395638c5ea51182742		tag 'v1.0.1' of https://lab.intercom.it/tomte/tomte-core
-8704ed4d523a44f30024d3d6186f8b7f7990fdef		tag 'v1.2.7' of https://lab.intercom.it/tomte/tomte-core

tomte-core-1.2.7.gem/data/./.git/HEAD Deleted

tomte-core-1.2.7.gem/data/./.git/config Deleted

tomte-core-1.2.7.gem/data/./.git/index Deleted

tomte-core-1.2.7.gem/data/./.git/logs/HEAD Deleted

tomte-core-1.2.7.gem/data/./.git/logs/refs/remotes/origin/1-2 Deleted

tomte-core-1.2.7.gem/data/./.git/logs/refs/remotes/origin/bson4 Deleted

tomte-core-1.2.7.gem/data/./.git/logs/refs/remotes/origin/master Deleted

tomte-core-1.2.7.gem/data/./.git/logs/refs/remotes/origin/next Deleted

tomte-core-1.2.7.gem/data/./.git/objects/pack/pack-d673f7546bb050eb292d6a5ff4814bee06e1bc30.idx Deleted

tomte-core-1.2.7.gem/data/./.git/objects/pack/pack-d673f7546bb050eb292d6a5ff4814bee06e1bc30.pack Deleted

tomte-core-1.2.7.gem/data/./.git/refs/pipelines/5735 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/remotes/origin/1-2 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/remotes/origin/bson4 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/remotes/origin/master Deleted

tomte-core-1.2.7.gem/data/./.git/refs/remotes/origin/next Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.7.1 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.7.9 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.7.9.1 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.7.9.3 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.7.9.4 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.7.9.5 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.7.9.6 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.7.9.7 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.0 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.1 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.1.1 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.10 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.10.1 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.11 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.12 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.12.10 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.13.0 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.2 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.2.2 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.3 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.3.1 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.3.2 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.4 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.5 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.6 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.7 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.8.8 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v0.9.0 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v1.0.0 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v1.0.1 Deleted

tomte-core-1.2.7.gem/data/./.git/refs/tags/v1.2.7 Deleted

tomte-core-1.2.7.gem/data/./.gitignore Deleted

tomte-core-1.2.7.gem/data/./.gitlab-ci.yml Deleted

tomte-core-1.2.7.gem/data/./lib/tomte/configuration.rb Deleted

@@ -1,475 +0,0 @@
-
-# Tomte, a framework for distributed agents.
-# Copyright (c) 2010-2013, Lele Forzani, windmillmedia. All Rights Reserved.
-#
-# Author:: Lele Forzani <lele@windmill.it>
-# License:: You can redistribute it and/or modify it under the terms of the LICENSE file.
-
-require 'forwardable'
-require 'optparse'
-require 'compat/hash'
-require 'uuidtools'
-require 'socket'
-require 'yaml'
-require 'pp'
-require 'erb'
-
-module Tomte
-
-  class Configuration
-
-    SEPARATOR = ('-'*120).yellow
-
-    extend Forwardable
-
-    # delegate, for now, we will see if we need a semaphore
-    def_delegators :@config, :, :=
-
-    # where we got the core configuration
-    attr_reader :config_file
-
-    public
-    ######
-
-    DEFAULT_FILE_QUEUE = :main
-
-    DEFAULT_ENVIRONMENT_FILE = File.join('/etc', 'tomte', 'default_environment')
-
-    DEFAULT_CONFIG_FILES = 
-        {:path =>  File.join(Tomte::LIBRARY, '..', 'config'), :file =>  'tomte.yml', :queue => :before },
-        {:path =>  :system,                                   :file =>  'tomte.yml'},
-        {:path =>  File.join(Dir.getwd, 'config'),            :file =>  'tomte.yml'}
-    
-
-
-    DEFAULT_CORE_CONFIGURATION = {
-      :configured => false,
-      :environment => 'production',
-      :common_environment => '_common',
-      :log_level => nil,                  # nil means use the logger profile
-      :log_profile => :default,
-      :debug => false,
-      :interactive => false,
-      :application => 'tomte-app',
-      :system_configuration_path =>  File.expand_path('tomte', '/etc' )
-    }
-
-
-    def initialize(args = {})
-
-      @semaphore = Mutex.new
-      @additional_options_blocks = {}
-      @sections = 
-      @overrides = {}
-
-      @config = default_configuration
-
-      @options = {}
-      :core, :local.each { |s| add_section s }
-
-      @root = args:root
-
-      add_config_files(DEFAULT_CONFIG_FILES)
-      default_environment
-    end
-
-    #
-    # used for safe change of configuration
-    #
-    def change_configuration(&blk)
-      @semaphore.synchronize do
-        blk.call(@config) if blk
-      end
-    end
-
-    #
-    # used to apply a piece of configuration
-    #
-    def apply_configuration(ary)
-      change_configuration do |c|
-        c.recursive_merge! ary
-      end
-    end
-    alias :merge :apply_configuration
-
-
-    #
-    # returns a specific config file queue
-    #
-    def config_file_queue(queue = DEFAULT_FILE_QUEUE)
-      config_file_queuesqueue ||= 
-    end
-
-    #
-    # returns all the file queues
-    #
-    def config_file_queues
-      @config:core:config_file_queues ||= {}
-    end
-
-    #
-    # adds all the files matching glob in path
-    #
-    def add_config_files_matching(glob, options, queue = DEFAULT_FILE_QUEUE)
-      glob = expand_path_spec(glob, options:path)
-      files = Dir.glob(glob).sort.map { |f| options.merge(:file => f) }
-      add_config_files(files, queue)
-    end
-
-    #
-    # add one or more config files to a file queue
-    #
-    def add_config_files(fileinfo, queue = DEFAULT_FILE_QUEUE)
-      if fileinfo.is_a? Array
-        fileinfo.each { |f | add_config_file(f , queue) }
-      else
-        add_config_file(fileinfo, queue)
-      end
-    end
-
-    #
-    # adds one file to a file queue
-    #
-    def add_config_file(fileinfo, queue = DEFAULT_FILE_QUEUE)
-      case fileinfo
-        when Hash
-          queue = (fileinfo.delete(:queue) || queue ).to_sym
-          config_file_queue(queue).push fileinfo
-        else
-         config_file_queue(queue).push(:path => :system, :file => fileinfo.to_s)
-      end
-    end
-
-    #
-    #
-    #
-    def already_configured?
-      @config:core && @config:core:configured
-    end
-
-    def already_configured!
-      core:configured = true
-    end
-
-    def add_section(name)
-      @sections << name
-      @configname ||= {}
-      self.instance_eval %{
-        def #{name.to_s}
-          @config:#{name.to_s}
-        end
-      }
-    end
-
-    def add(section, hash)
-      add_section section
-      apply_configuration({ section => hash })
-      @config
-    end
-
-    #
-    # allow to set specific ovverides
-    #
-    def override(section, &block)
-      @overridessection = block
-    end
-
-    #
-    # this should be called _after_ the additional parse blocks have been defined
-    #
-    def configure!(options = {})
-
-      return if already_configured?
-
-      # process commandline opts
-      parse_options if options.delete(:parse_command_line)
-
-      if(@options && @options:core)
-        @config:core:environment = @options:core:environment if @options:core:environment
-        @config:core:config_file = @options:core:config_file if @options:core:config_file
-      end
-
-      env = @config:core:environment
-
-      #
-      # Tomte.config.add_config_files {
-      #   { :file => tomte-protocol.yml, :path => :system }
-      #   { :file => ...                 :path => :application
-      # }
-      #
-      config_file_queues.keys.sort.each do |queue|
-        config_file_queue(queue).each do |f|
-          @config:core:common_environment, env.each do |e|
-              apply_configuration load_configuration_from f, e
-          end
-        end
-      end
-
-      # also merge the command line options in
-      apply_configuration @options if @options
-      # and the local options
-      apply_configuration options
-
-      # apply overrides
-      apply_overrides
-
-      # a few defaults actually depends on the configuration given
-      post_configuration
-
-      already_configured!
-
-      tomte_debug do
-        puts "== parsed configuration ==".yellow.bold
-        ap @config
-      end
-
-      @config
-    end
-
-    # quickies
-#    def core
-#      self:core
-#    end
-
-#    def local
-#      self:local
-#    end
-
-    def to_s
-      @config.to_s
-    end
-
-    def debug
-      @config.ai.subindent
-    end
-
-    def debug?
-      !!@config:core:debug
-    end
-
-    #
-    # register additional options definitions
-    #
-    # config.additional_options(name) do |cf, opts|
-    #
-    #   opts.on("-d", "--daemonize", "Run  as a daemon") do |d|
-    #      cf:daemonize = d
-    #    end
-    #
-    # end
-    #
-    def additional_options(name, &blk)
-      @additional_options_blocksname = blk
-    end
-
-    def additional_commands(hash)
-      (@additional_commands ||= {}).merge! hash
-    end
-
-    def additional_help_text(text)
-      (@additional_help_text ||= ) << text
-    end
-
-    private
-    #######
-    #
-    #
-    #
-
-    def apply_overrides
-      @sections.each do |s|
-        @overridess.call(@configs) if(@overridess &&  @overridess.respond_to?(:call))
-      end
-    end
-
-
-    def default_environment
-      if !ENV'TOMTE_ENV'.blank?
-        core:environment = ENV'TOMTE_ENV'.strip
-      elsif File.exist?(DEFAULT_ENVIRONMENT_FILE)
-        core:environment = File.read(DEFAULT_ENVIRONMENT_FILE).match(/^\w+/)0
-      end
-
-    rescue
-      # do nothing
-    end
-
-    def default_configuration
-      { :core => DEFAULT_CORE_CONFIGURATION, :local => {} }
-    end
-
-    def post_configuration
-
-      # set it to a sensible default
-      core:application_root = File.expand_path('..', Tomte::LIBRARY ) unless core:application_root
-
-      local:uuid ||= UUIDTools::UUID.random_create.to_s
-      local:host ||= Socket.gethostname
-      local:identity  ||= core:application + '-' + local:host
-      begin
-        local:hostname ||= Socket.gethostbyname(Socket.gethostname).first
-      rescue
-        local:hostname ||= 'unknown'
-      end
-
-      # load the debugging extensions
-      if debug?
-        puts "== Debugging active. This is going to be slow!".important!
-        Object.__send__(:include, Tomte::Debug::Active)
-      end
-
-    end
-
-
-    def expand_path_spec(file, path)
-      cwd = Dir.getwd
-
-      case path
-        when :system
-          File.expand_path(file, core:system_configuration_path)
-        when :application
-          File.expand_path(file, File.join(core:application_root, 'config'))
-        when :cwd
-          File.expand_path(file, cwd)
-        when :nil
-          File.expand_path(file)
-        else
-          File.expand_path(file, path.to_s)
-        end
-    end
-
-    def load_configuration_from(file, environment = 'default', path = nil)
-
-      (file, path) = file:file, file:path if file.is_a? Hash
-      file = expand_path_spec(file, path)
-
-      puts "= Loading configuration file #{file}, for environment: #{environment}".blue if @options &&
-        @options:core && @options:core:debug
-
-      begin
-        config = {}
-        raw_config = if File.exist?(file)
-          data = File.read file
-          tpl = ERB.new data
-          yaml = tpl.result binding
-          YAML.load(yaml) || {}
-        else
-          {}
-        end
-
-        config = raw_configenvironment if raw_config.has_key?(environment)
-        config.recursively!{|h| h.symbolize_keys }
-      rescue Exception => e
-        puts "Error while reading configuration file '#{file}'".important!
-        puts " - " + e.message
-        exit
-      end
-      config
-    end
-
-
-
-    def parse_options(&blk)
-
-      @argv = core:argv || ARGV
-      @options = {}
-      @sections.each {|s| @optionss = {}}
-
-      opts = OptionParser.new do |opts|
-
-        opts.banner = usage
-
-        opts.define_head(core:application_caption.green.bold) if core:application_caption
-
-        if @additional_help_text
-          opts.separator " "
-          @additional_help_text.each do |l|
-            opts.separator l.to_s
-          end
-        end
-
-        unless @additional_commands.blank?
-          opts.separator " "
-          opts.separator 'Commands'.blue.bold
-          opts.separator SEPARATOR
-          @additional_commands.each do |command, caption|
-            opts.separator sprintf("%-25s", command).yellow.bold + caption
-          end
-        end
-
-        opts.separator " "
-        opts.separator 'Tomte Options'.blue.bold
-        opts.separator SEPARATOR
-
-        opts.on("-e", "--environment ENV", "Framework environment " + "(default: #{@config:core:environment})") do |env|
-          @options:core:environment = env
-        end
-
-        opts.on("-i", "--identity ID", "Sets this endpoint identity") do |ident|
-          @options:local:identity = ident
-        end
-
-
-        opts.on("-D", "--debug", "Set debugging on (heavy and verbose!)") do
-          @options:core:debug = true
-          @options:core:log_profile = :debug
-          @options:core:log_level = :debug
-        end
-
-        opts.on("-l", "--log-level LEVEL", "Specify the log level (fatal, error, warn, info, debug). Default is '#{@config:log_level}'") do |level|
-          @options:core:log_level = level
-        end
-
-        opts.on("--log-path PATH", "Specify the log file path") do |dir|
-          @options:core:log_profile = :production
-          @options:core:log_path = dir
-        end
-
-        opts.on("--log-profile LEVEL", "Specify the log profile to use interactive | production | daemonized | ...") do |profile|
-          @options:core:log_profile = profile
-        end
-        opts.on("-h", "--help", "Show this message")                               { puts opts; exit }
-
-        opts.on("--version", "Show the Tomte version number") do |res|
-          puts "Tomte Version #{Tomte::VERSION}"
-          exit
-        end
-
-         # call additional blocks, usually additional options in the agent(s)
-        blk.call(@config, opts) if blk
-        @additional_options_blocks.each do |name, blk|
-          opts.separator " "
-          opts.separator name.blue.bold
-          opts.separator SEPARATOR
-          blk.call(@options, opts, @config)
-        end
-
-      end
-
-      opts.parse! @argv
-      @options:core:command = @argv.shift if @argv
-      @options:core:arguments = @argv
-
-      if (@additional_commands && @options:core:command && !@additional_commands.keys.include?(@options:core:command.to_sym))
-        puts "\nUnknown command '#{@options:core:command}'".important!
-        puts usage
-        exit
-      end
-    end
-
-    def usage
-      ("Usage: #{core:application} -flags --options " + "#{output_commands}\n").blue.bold
-    end
-
-    def output_commands
-      (!@additional_commands.blank? ? "#{@additional_commands.keys.join('|')} params" : '')
-    end
-
-    class << self
-      def relative_cfg(library_path)
-        File.expand_path(File.join(library_path, '..', 'config'))
-      end
-    end
-
-  end
-end

tomte-core-1.2.7.gem/data/./lib/tomte/descendants_tracker.rb Deleted

@@ -1,139 +0,0 @@
-# frozen_string_literal: true
-
-require "weakref"
-require "active_support/ruby_features"
-
-# support #subclasses for modules in ruby >= 3.1
-
-module Tomte
-  # This module provides an internal implementation to track descendants
-  # which is faster than iterating through ObjectSpace.
-  module DescendantsTracker
-
-    if ActiveSupport::RubyFeatures::CLASS_SUBCLASSES
-      @clear_disabled = false
-      @@direct_descendants = {}
-
-      class << self
-        def disable_clear! # :nodoc:
-          @clear_disabled = true
-        end
-
-        def subclasses(klass)
-          descendants = @@direct_descendantsklass
-          descendants ? descendants.to_a : 
-        end
-
-        def descendants(klass)
-          arr = 
-          accumulate_descendants(klass, arr)
-          arr
-        end
-
-        def clear(classes) # :nodoc:
-          raise "DescendantsTracker.clear was disabled because config.cache_classes = true" if @clear_disabled
-
-          @@direct_descendants.each do |klass, direct_descendants_of_klass|
-            if classes.member?(klass)
-              @@direct_descendants.delete(klass)
-            else
-              direct_descendants_of_klass.reject! do |direct_descendant_of_class|
-                classes.member?(direct_descendant_of_class)
-              end
-            end
-          end
-        end
-
-        def native? # :nodoc:
-          false
-        end
-
-        # This is the only method that is not thread safe, but is only ever called
-        # during the eager loading phase.
-        def store_inherited(klass, descendant)
-          (@@direct_descendantsklass ||= DescendantsArray.new) << descendant
-        end
-
-        private
-          def accumulate_descendants(klass, acc)
-            if direct_descendants = @@direct_descendantsklass
-              direct_descendants.each do |direct_descendant|
-                acc << direct_descendant
-                accumulate_descendants(direct_descendant, acc)
-              end
-            end
-          end
-      end
-
-      def inherited(base)
-        DescendantsTracker.store_inherited(self, base)
-        super
-      end
-
-      def direct_descendants
-        ActiveSupport::Deprecation.warn(<<~MSG)
-          ActiveSupport::DescendantsTracker#direct_descendants is deprecated and will be removed in Rails 7.1.
-          Use #subclasses instead.
-        MSG
-        DescendantsTracker.subclasses(self)
-      end
-
-      def subclasses
-        DescendantsTracker.subclasses(self)
-      end
-
-      def descendants
-        DescendantsTracker.descendants(self)
-      end
-
-      # DescendantsArray is an array that contains weak references to classes.
-      class DescendantsArray # :nodoc:
-        include Enumerable
-
-        def initialize
-          @refs = 
-        end
-
-        def initialize_copy(orig)
-          @refs = @refs.dup
-        end
-
-        def <<(klass)
-          @refs << WeakRef.new(klass)
-        end
-
-        def each
-          @refs.reject! do |ref|
-            yield ref.__getobj__
-            false
-          rescue WeakRef::RefError
-            true
-          end
-          self
-        end
-
-        def refs_size
-          @refs.size
-        end
-
-        def cleanup!
-          @refs.delete_if { |ref| !ref.weakref_alive? }
-        end
-
-        def reject!
-          @refs.reject! do |ref|
-            yield ref.__getobj__
-          rescue WeakRef::RefError
-            true
-          end
-        end
-      end
-    else
-      def self.included(base)
-        base.class_eval do
-          include ActiveSupport::DescendantsTracker
-        end
-      end
-    end
-  end
-end

tomte-core-1.2.7.gem/data/./lib/tomte/document/keys.rb Deleted

@@ -1,255 +0,0 @@
-# encoding: UTF-8
-require 'tomte/document/keys/key'
-
-module Tomte
-  module Document
-    module Keys
-      extend ActiveSupport::Concern
-
-      included do
-        extend ActiveSupport::DescendantsTracker
-        key :_id, Tomte::ObjectId, :default => lambda { Tomte::ObjectId.new }
-      end
-
-      module ClassMethods
-        def inherited(descendant)
-          descendant.instance_variable_set(:@keys, keys.dup)
-          super
-        end
-
-        def keys
-          @keys ||= {}
-        end
-
-        def key(*args)
-          Key.new(*args).tap do |key|
-            keyskey.name = key
-            create_accessors_for(key)
-            create_key_in_descendants(*args)
-          end
-        end
-
-        def key?(key)
-          keys.keys.include?(key.to_s)
-        end
-
-        def using_object_id?
-          object_id_key?(:_id)
-        end
-
-        def object_id_keys
-          keys.keys.select { |key| keyskey.type == Tomte::ObjectId }.map { |k| k.to_sym }
-        end
-
-        def object_id_key?(name)
-          object_id_keys.include?(name.to_sym)
-        end
-
-        def to_tomte(instance)
-          return nil if instance.nil?
-          instance.to_tomte
-        end
-
-        def from_tomte(value)
-          return nil if value.nil?
-          value.is_a?(self) ? value : load(value)
-        end
-
-        def load(attrs)
-          return nil if attrs.nil?
-          res =
-            begin
-              attrs'_doctype'.present? ? attrs'_doctype'.constantize : self
-            rescue NameError
-              self
-            end.allocate.initialize_from_data(attrs)
-          res.__send__(:document_initialize, attrs) if res.respond_to?(:document_initialize)
-          res
-        end
-
-        private
-        def key_accessors_module_defined?
-          if method(:const_defined?).arity == 1 # Ruby 1.9 compat check
-            const_defined?('TomteDocumentKeys')
-          else
-            const_defined?('TomteDocumentKeys', false)
-          end
-        end
-
-        def accessors_module
-          if key_accessors_module_defined?
-            const_get 'TomteDocumentKeys'
-          else
-            const_set 'TomteDocumentKeys', Module.new
-          end
-        end
-
-        def create_accessors_for(key)
-          accessors_module.module_eval <<-end_eval
-            def #{key.name}
-              read_key(:#{key.name})
-            end
-
-            def #{key.name}_before_typecast
-              read_key_before_typecast(:#{key.name})
-            end
-
-            def #{key.name}=(value)
-              write_key(:#{key.name}, value)
-            end
-
-            def #{key.name}?
-              read_key(:#{key.name}).present?
-            end
-          end_eval
-
-          include accessors_module
-        end
-
-        def create_key_in_descendants(*args)
-          descendants.each { |descendant| descendant.key(*args) }
-        end
-      end
-
-      def initialize(attrs={})
-        @_new = true
-        self.attributes = attrs
-      end
-
-      def initialize_from_data(attrs={})
-        @_new = false
-        load_from_data(attrs)
-        self
-      end
-
-      def attributes=(attrs)
-        return if attrs.blank?
-
-        attrs.each_pair do |key, value|
-          if respond_to?(:"#{key}=")
-            self.send(:"#{key}=", value)
-          else
-            selfkey = value
-          end
-        end
-      end
-
-      def attributes
-        HashWithIndifferentAccess.new.tap do |attrs|
-          keys.select { |name, key| !selfkey.name.nil? || key.type == ObjectId }.each do |name, key|
-            value = key.set(selfkey.name)
-            attrsname = value
-          end
-
-          #embedded_associations.each do |association|
-          #  if documents = instance_variable_get(association.ivar)
-          #    if association.one?
-          #      attrsassociation.name = documents.to_tomte
-          #    else
-          #      attrsassociation.name = documents.map { |document| document.to_tomte }
-          #    end
-          #  end
-          #end
-        end
-      end
-      #alias :to_tomte :attributes
-
-      def to_tomte
-        HashWithIndifferentAccess.new.tap do |attrs|
-          keys.select { |name, key| !selfkey.name.nil? || key.type == ObjectId }.each do |name, key|
-            value =
-              (selfkey.name.respond_to?(:to_tomte) ? selfkey.name.to_tomte : key.set(selfkey.name))
-            attrsname = value
-          end
-        end
-      end
-
-
-      def update_attributes(attrs={})
-        assign(attrs)
-      end
-
-      def update_attributes!(attrs={})
-        assign(attrs)
-      end
-
-      def update_attribute(name, value)
-        update_attributes(name.to_sym => value)
-      end
-
-      def assign(attrs={})
-        self.attributes = attrs
-      end
-
-      def id
-        _id
-      end
-
-      def id=(value)
-        if self.class.using_object_id?
-          value = ObjectId.to_to_tomte(value)
-        end
-
-        self:_id = value
-      end
-
-      def (name)
-        read_key(name)
-      end
-
-      def =(name, value)
-        ensure_key_exists(name)
-        write_key(name, value)
-      end
-
-      def keys
-        self.class.keys
-      end
-
-      def key_names
-        keys.keys
-      end
-
-      def new?
-        @_new ||= true
-      end
-
-      private
-      def load_from_data(attrs)
-        return if attrs.blank?
-        attrs.each do |key, value|
-          if respond_to?(:"#{key}=") && !self.class.key?(key)
-            self.send(:"#{key}=", value)
-          else
-            selfkey = value
-          end
-        end
-      end
-
-      def ensure_key_exists(name)
-        self.class.key(name) unless respond_to?("#{name}=")
-      end
-
-      def read_key(key_name)
-        if key = keyskey_name.to_s
-          value = key.get(instance_variable_get(:"@#{key_name}"))
-          instance_variable_set(:"@#{key_name}", value)
-        end
-      end
-
-      def read_key_before_typecast(name)
-        instance_variable_get(:"@#{name}_before_typecast")
-      end
-
-      def write_key(name, value)
-        key = keysname.to_s
-        casted_value = key.try_cast(value)
-        
-        instance_variable_set :"@#{name}_before_typecast", casted_value
-        instance_variable_set :"@#{name}", key.set(casted_value)
-      end
-
-    end
-  end
-end
-

tomte-core-1.2.7.gem/data/./lib/tomte/document/keys/key.rb Deleted

@@ -1,87 +0,0 @@
-# encoding: UTF-8
-
-# this comes (almost) verbatim from MongoMapper
-module Tomte
-  module Document
-    module Keys
-      class Key
-        attr_accessor :name, :type, :options, :default_value
-
-        def initialize(*args)
-          options = args.extract_options!
-          @name, @type = args.shift.to_s, args.shift
-          self.options = (options || {}).symbolize_keys
-          self.default_value = self.options:default
-        end
-
-        def ==(other)
-          @name == other.name && @type == other.type
-        end
-
-        def embeddable?
-          return false unless type.respond_to?(:embeddable?)
-          type.embeddable?
-        end
-
-        def can_default_id?
-          type && (type == Tomte::ObjectId || type == BSON::ObjectId || type == String)
-        end
-
-        def number?
-          type == Integer || type == Float
-        end
-
-        def get(value)
-          if value.nil? && !default_value.nil?
-            if default_value.respond_to?(:call)
-              return default_value.call
-            else
-              # Using Marshal is easiest way to get a copy of mutable objects
-              # without getting an error on immutable objects
-              return Marshal.load(Marshal.dump(default_value))
-            end
-          end
-
-          if options:typecast.present?
-            type.from_tomte(value).map! { |v| typecast_class.from_tomte(v) }
-          elsif value.is_a? Array
-            Array.from_tomte(value)
-          elsif type && !value.is_a?(type)
-            type.from_tomte(value)
-          else
-            value
-          end
-        end
-
-        def try_cast(value)
-          if options:as_object.present? && Tomte::Document::Parser.parseable?(value)
-            Tomte::Document::Parser.load(value)
-          elsif options:as_document.present? && Tomte::Document::Parser.is_document?(value)
-            Tomte::Document::Parser.load_document(value)
-          elsif options:cast.present? && type && type.respond_to?(:from_tomte) && !value.is_a?(type)
-            type.from_tomte(value)
-          else
-            value
-          end
-        end
-
-        def set(value)
-          if type
-            type.to_tomte(value).tap do |values|
-              if options:typecast.present?
-                values.map! { |v| typecast_class.to_tomte(v) }
-              end
-            end
-          else
-            value
-          end
-        end
-
-        private
-        def typecast_class
-          @typecast_class ||= options:typecast.constantize
-        end
-      end
-    end
-  end
-end

tomte-core-1.2.7.gem/data/./lib/tomte/document/parser.rb Deleted

@@ -1,128 +0,0 @@
-# encoding: UTF-8
-#
-# Tomte, a framework for distributed agents.
-# Copyright (c) 2010-2013, Lele Forzani, windmillmedia. All Rights Reserved.
-#
-# Author:: Lele Forzani <lele@windmill.it>
-# License:: You can redistribute it and/or modify it under the terms of the LICENSE file.
-
-class GenericError < StandardError
-
-  attr_reader :type
-  attr_reader :attributes
-end
-
-
-module Tomte
-  module Document
-    module Parser
-
-      class << self
-        def from_bson(data)
-          load(BSON.deserialize(data))
-        end
-
-        def is_document?(attrs)
-          return false unless attrs.kind_of? Hash
-          attrs'_doctype'.present? || attrs:_doctype.present?
-        end
-
-        def is_generic_object?(attrs)
-          return false unless attrs.kind_of? Hash
-          attrs'_type'.present? || attrs:_type.present?
-        end
-
-        def load_generic_object(attrs)
-          if is_generic_object? attrs
-            (attrs'_type' || attrs:_type).constantize.from_tomte(attrs)
-          else
-            attrs
-          end
-        rescue NameError => ex
-          Tomte::logger.try(:error, ex)
-          Tomte::logger.try(:error, "\t" + ex.backtrace.join("\n\t"))
-          raise ex if ex.is_a?(NoMethodError) 
-          OpenStruct.new(attrs)
-        end
-
-        def parseable?(attrs)
-          is_document?(attrs) || is_generic_object?(attrs) || attrs.is_a?(::Hash)
-        end
-
-        def load_document(attrs)
-          if is_document? attrs
-            (attrs'_doctype' || attrs:_doctype).constantize.from_tomte(attrs)
-          else
-            attrs
-          end
-
-        rescue NameError => ex
-          Tomte::logger.try(:error, ex)
-          Tomte::logger.try(:error, "\t" + ex.backtrace.join("\n\t"))
-          raise ex if ex.is_a?(NoMethodError) 
-          Tomte::OpenDocument.new(attrs)
-        end
-
-        #
-        # returns an exception with the given message, backtrace and attributes hash
-        #
-        def load_exception(klass, message = '', backtrace = , attributes = {})
- 
-          e = begin
-                klass.constantize
-              rescue NameError
-                GenericError
-              end
-          exc =
-            begin
-              raise(e.allocate, message)
-            rescue e => exception
-              exception.set_backtrace(backtrace)
-              exception
-            end
-
-          if exc.is_a?(GenericError)
-            exc.instance_variable_set(:@type, klass) if exc.is_a?(GenericError)
-            exc.instance_variable_set(:@attributes, OpenStruct.new(attributes.inject_hash { |h,(k,v)| hk = load(v) }))
-          else
-            attributes.each do |k,v|
-              exc.instance_variable_set("@#{k}".to_sym, load(v))
-            end
-          end
-          exc
-        end
-
-        def load(attrs)
-          if is_document? attrs
-            load_document(attrs)
-          elsif is_generic_object? attrs
-            load_generic_object(attrs)
-          elsif attrs.is_a? ::Hash
-            ActiveSupport::HashWithIndifferentAccess.from_tomte(attrs)
-          elsif attrs.is_a? ::Array
-            Array.from_tomte(attrs)
-          else
-            attrs
-          end
-        end
-        alias_method :from_tomte, :load
-
-        def to_tomte_hash(obj)
-          return(obj) unless obj.respond_to?(:to_tomte)
-
-          klass = obj.class
-          res = obj.to_tomte
-
-          if res.is_a?(::Hash) &&
-                       !Tomte::Document::Parser.is_document?(res) &&
-                       !Tomte::Document::Parser.is_generic_object?(res) &&
-                       !klass.ancestors.include?(::Hash)
-
-            res:_type = klass.name
-          end
-          res
-        end
-      end
-    end
-  end
-end
\ No newline at end of file

tomte-core-1.2.7.gem/data/./lib/tomte/logger.rb Deleted

@@ -1,239 +0,0 @@
-
-# Tomte, a framework for distributed agents.
-# Copyright (c) 2010-2013, Lele Forzani, windmillmedia. All Rights Reserved.
-#
-# Author:: Lele Forzani <lele@windmill.it>
-# License:: You can redistribute it and/or modify it under the terms of the LICENSE file.
-
-require 'fileutils'
-
-# Defines the log level for a Tomte project.
-TOMTE_LOG_LEVEL = ENV'TOMTE_LOG_LEVEL' unless defined?(TOMTE_LOG_LEVEL)
-# Defines the logger used for a Tomte project.
-TOMTE_LOGGER_CONFIG = ENV'TOMTE_LOGGER_CONFIG' unless defined?(TOMTE_LOGGER_CONFIG)
-
-module Tomte
-
-#  def self.logger
-#    Tomte::Logger.new(config.core.merge(config.local)) if Thread.current:_logger.nil?
-#    Thread.current:_logger
-#  end
-
-#  def self.logger=(value)
-#    Thread.current:_logger = value
-#  end
-
-  #
-  # Extensions to the built in Ruby logger.
-  #
-  class Logger
-    include Logging::LoggingExtensions
-
-    attr_accessor :level
-    attr_accessor :auto_flush
-    attr_reader   :buffer
-    attr_reader   :log
-    attr_reader   :init_args
-
-    attr_accessor :identity
-    attr_accessor :environment
-
-    @@mutex = {}
-
-    #
-    # Configuration for a given environment, possible options are:
-    #
-    # :log_level:: One of :fatal, :error, :warn, :info, :debug
-    # :stream:: One of :to_file, :null, :stdout, :stderr a string representing a path name
-    #   our your custom stream
-    # :log_level::
-    #   The log level from, e.g. :fatal or :info. Defaults to :warn in the
-    #   production environment and :debug otherwise.
-    # :auto_flush::
-    #   Whether the log should automatically flush after new messages are
-    #   added. Defaults to true.
-    # :format_datetime:: Format of datetime. Defaults to: "%d/%b/%Y %H:%M:%S"
-    # :format_message:: Format of message. Defaults to: ""%s - - %s \"%s\"""
-    #
-    # @example
-    #   Logger::Config:development = { :log_level => :debug, :stream => :to_file }
-    #   # or you can edit our defaults
-    #   Logger::Config:development:log_level = :error
-    #   # or you can use your stream
-    #   Logger::Config:development:stream = StringIO.new
-    #
-    # Defaults are:
-    #
-    #   :production  => { :log_level => :warn,  :stream => :to_file },
-    #   :daemonized  => { :log_level => :info, :stream => :stdout },
-    #   :interactive => { :log_level => :debug, :stream => :stdout, :format_datetime => ' ' },
-    #   :development => { :log_level => :debug, :stream => :stdout, :format_datetime => ' ' },
-    #   :unknown     => { :log_level => :debug, :stream => :stdout, :format_datetime => ' ' },
-    #   :test        => { :log_level => :debug, :stream => :null }
-    #
-    # In some cases, configuring the loggers before loading the framework is necessary.
-    # You can do so by setting TOMTE_LOGGER:
-    #
-    #   TOMTE_LOGGER = { :staging => { :log_level => :debug, :stream => :to_file }}
-    #
-
-    Config = {
-      :production  => { :color => true,  :log_level => :warn,  :stream => :to_file },
-      :daemonized  => { :color => false, :log_level => :info,  :stream => :to_file },
-      :default     => { :color => true,  :log_level => :info,  :stream => :stdout, :format_datetime => ' ' },
-      :debug       => { :color => true,  :log_level => :debug, :stream => :stdout, :format_datetime => ' ' },
-      :interactive => { :color => true,  :log_level => :warn,  :stream => :stderr, :format_datetime => ' ' },
-      :nocolor     => { :color => false, :log_level => :info,  :stream => :stdout, :format_datetime => ' ' },
-      :unknown     => { :color => false, :log_level => :debug, :stream => :stdout, :format_datetime => ' ' },
-      :test        => { :color => true,  :log_level => :debug, :stream => :null }
-    }
-    Config.merge!(TOMTE_LOGGER_CONFIG) if  (defined?(TOMTE_LOGGER_CONFIG) && !TOMTE_LOGGER_CONFIG.nil?)
-
-
-
-    def self.setup!(options)
-
-      environment, identity = (Tomte.env || :test).to_sym, (options:identity || 'unknown')
-      profile = options:profile.to_sym || environment
-      options.delete(:log_level) if options:log_level.nil?
-
-      config = Configprofile
-
-      unless config
-        warn("No logging configuration for :#{profile} found, falling back to :unknown")
-        config = Config:unknown
-      end
-
-      stream = case config:stream
-        when String
-          dir = File.dirname(config:stream)
-          FileUtils.mkdir_p(dir) unless File.exist?(dir)
-          File.new(config:stream, "a+")
-        when :to_file
-          raise ArgumentError, "Log path not given." if options:log_path.blank?
-          FileUtils.mkdir_p(options:log_path)
-          File.new(File.join(options:log_path, "%s-%s.log" % identity, environment), "a+")
-        when :null   then StringIO.new
-        when :stdout then $stdout
-        when :stderr then $stderr
-        else config:stream
-      end
-
-      Thread.current:_logger = new(config.merge(options.merge(:stream => stream, :environment => environment)))
-    end
-
-
-    ##
-    # To initialize the logger you create a new object, proxies to set_log.
-    #
-    # @param Hash options
-    #
-    # @option options Symbol :stream ($stdout)
-    #   Either an IO object or a name of a logfile. Defaults to $stdout
-    #
-    # @option options Symbol :log_level (:production in the production environment and :debug otherwise)
-    #   The log level from, e.g. :fatal or :info.
-    #
-    # @option options Symbol :auto_flush (true)
-    #   Whether the log should automatically flush after new messages are
-    #   added. Defaults to true.
-    #
-    # @option options Symbol :format_datetime (" %d/%b/%Y %H:%M:%S ")
-    #   Format of datetime
-    #
-    # @option options Symbol :format_message ("%s -%s%s")
-    #    Format of message
-    #
-    # @option options Symbol :log_static (false)
-    #   Whether or not to show log messages for static files.
-    #
-    def initialize(options={})
-
-      @buffer          = 
-      @color           = options:color
-      @auto_flush      = options.has_key?(:auto_flush) ? options:auto_flush : true
-      @level           = options:log_level ? Logging::Levelsoptions:log_level.to_sym : Logging::Levels:debug
-      @log             = options:stream  || $stdout
-      @log.sync        = true
-      @mutex           = @@mutex@log ||= Mutex.new
-      @format_datetime = options:format_datetime || "%d/%b/%Y %H:%M:%S"
-      @format_message  = options:format_message  || "%s - %s %s"
-
-      @identity = options:identity || 'unknown'
-      @environment = options:environment || Tomte.env || 'unknown'
-
-      colorize! if @color
-
-      tomte_debug do
-        puts "== logger configuration ==".yellow.bold
-        ap options
-      end
-
-      debug "+ Logger for '#{identity}:#{environment}' started, level is #{level}."
-    end
-
-
-    ##
-    # Changes the log level by symbol
-    #
-    # @param String, Symbol level
-    #
-    #
-    def set_level(loglevel)
-      @level =  Logging::Levelsloglevel
-    end
-
-    ##
-    # Adds a message to the log - for compatibility with other loggers.
-    #
-    def add(level, message = nil)
-      write(message)
-    end
-
-
-    ##
-    # Flush the entire buffer to the log object.
-    #
-    def flush
-      return unless @buffer.size > 0
-      @mutex.synchronize do
-        @log.write(@buffer.slice!(0..-1).join(''))
-      end
-    end
-
-    ##
-    # Close and remove the current log object.
-    #
-    # @return NilClass
-    #
-    def close
-      flush
-      @log.close if @log.respond_to?(:close) && !@log.tty?
-      @log = nil
-    end
-
-    ##
-    # Directly append message to the log.
-    #
-    # @param String message
-    #   The message
-    #
-    def <<(message = nil)
-      message << "\n" unless message-1 == ?\n
-      @buffer << message
-      flush if @auto_flush
-      message
-    end
-    alias :write :<<
-
-    ##
-    # Formats the log.
-    #
-    def format(message, level)
-      @format_message % stylized_level(level), colorize(Time.now.strftime(@format_datetime), :yellow), filter(message.to_s.strip)
-    end
-
-  end
-end
-
-

tomte-core-1.2.7.gem/data/./lib/tomte/plugins.rb Deleted

tomte-core-1.2.7.gem/data/./lib/tomte/version.rb Deleted

tomte-core-1.2.7.gem/data/./package.json Deleted

tomte-core-1.2.7.gem/data/./tomte-core.gemspec Deleted

@@ -1,41 +0,0 @@
-# -*- encoding: utf-8 -*-
-lib = File.expand_path('../lib', __FILE__)
-$LOAD_PATH.unshift(lib) unless $LOAD_PATH.include?(lib)
-require 'tomte/version'
-
-Gem::Specification.new do |gem|
-  gem.name          = "tomte-core"
-  gem.version       = Tomte::VERSION
-  gem.authors       = "Lele Forzani"
-  gem.email         = "lele@windmill.it"
-  gem.description   = %q{A ruby framework for designing distributed, message oriented, agents}
-  gem.summary       = %q{A ruby framework for designing distributed, message oriented, agents}
-  gem.homepage      = "http://git.windmill.it/tomte"
-  gem.required_ruby_version = '>= 1.9.3'
-
-  gem.files         = `find ./ -type f`.split($/)
-  gem.executables   = gem.files.grep(%r{^bin/}).map{ |f| File.basename(f) }
-  gem.test_files    = gem.files.grep(%r{^(test|spec|features)/})
-  gem.require_paths = "lib"
-
-  gem.add_runtime_dependency 'rake'
-
-  gem.add_runtime_dependency 'wml-compat',  '>= 0.8.6'
-  gem.add_runtime_dependency 'uuidtools',   '>= 2.1.5'
-  gem.add_runtime_dependency 'case',        '>= 0.5.2'
-  gem.add_runtime_dependency 'json',        '>= 2.2.0'
-  gem.add_runtime_dependency 'bson',        '>= 1.12.5'
-  gem.add_runtime_dependency 'bson_ext',    '>= 1.12.5'
-
-  gem.add_runtime_dependency 'activesupport',    '>= 5.0.0', "< 7.2.0"
-
-  gem.add_runtime_dependency 'thor',    '>= 0.20.3'
-  gem.add_runtime_dependency 'pry',     '>= 0.12.2'
-
-
-  gem.add_runtime_dependency 'mime-types'
-
-
-  gem.add_development_dependency "rspec"
-  gem.add_development_dependency "rspec-mocks"
-end

Changes of Revision 2