RubyGems - rugroupy - Versions diffs - 0.1.2 → 0.2.0 - Mend

rugroupy 0.1.2 → 0.2.0

This diff represents the content of publicly available package versions that have been released to one of the supported registries. The information contained in this diff is provided for informational purposes only and reflects changes between package versions as they appear in their respective public registries.

Files changed (6) hide show

checksums.yaml ADDED Viewed

@@ -0,0 +1,7 @@
+---
+SHA1:
+  metadata.gz: 7b69371b6c1ce1614240f1004dec002198a2bdce
+  data.tar.gz: 445979aee0419c7afd6b75c15f85c70dd64613a4
+SHA512:
+  metadata.gz: 11db4f7986672bbe6593e684545bb1062fb221b3b8a31ce113aef3ae11b437b943ddfce638884c4df05c0461ef2a297a5849fc1bc7baeab2c0a3c12c8278853b
+  data.tar.gz: 74d42da682eb28216a8c19f8fad109bfdf6479ef8639cf35ce570277c5be4c87d10a0aa351a9499d0ccfa167ddf8881653fca11ce87e8f132fba5d2d9b712e82

data/README.rdoc CHANGED Viewed

@@ -25,6 +25,15 @@ See http://github.com/rwynn/rugroupy/tree/master/test
 * sudo gem install rugroupy
+== Install from the GitHub source
+The source code is available at http://github.com/rwynn/rugroupy.
+You can either clone the git repository or download a tarball or zip file.
+Once you have the source, you can use it from wherever you downloaded it or
+you can install it as a gem from the source by typing
+* sudo rake install
 == Contributing to rugroupy
 * Check out the latest master to make sure the feature hasn't been implemented or the bug hasn't been fixed yet

data/lib/rugroupy.rb CHANGED Viewed

@@ -1,2 +1,2 @@
 require 'rugroupy/entity'
-require 'rugroupy/group'
+require 'rugroupy/group'

data/lib/rugroupy/entity.rb CHANGED Viewed

@@ -2,85 +2,89 @@ require 'mongo'
 require 'bson'
 module Groupy
   class Entity
-    def initialize(database, name, entity_id, create=true)
-      @database, @name, @entity_id = database, name, entity_id
-      @database.create_collection(@name) if not @database.collection_names.member?(@name)
-      @database["#{@name}_count"].ensure_index([['_id.e', Mongo::DESCENDING],
-        ['_id.tag', Mongo::DESCENDING],
-        ['value.count', Mongo::DESCENDING]], :background => false)
+    def initialize(database, name, entity_id, create = true)
+      @database = database
+      @name = name
+      @entity_id = entity_id
+      @database[@name].create unless @database.collection_names.member?(@name)
+      @database["#{@name}_count"].indexes.create_many([
+                                                        { key: { '_id.e' => -1 }, background: false },
+                                                        { key: { '_id.tag' => -1 }, background: false },
+                                                        { key: { 'value.count' => -1 }, background: false }
+                                                      ])
       if create
         begin
-          doc = Hash["_id"=>@entity_id, "tags"=>Hash.new]
-          @database[@name].insert(doc, :safe=>true)
-        rescue Mongo::MongoDBError => e
+          doc = Hash['_id' => @entity_id, 'tags' => {}]
+          @database[@name].insert_one(doc, safe: true)
+        rescue Mongo::Error => e
         end
       end
     end
     def get
-      @database[@name].find_one({ "_id" => @entity_id })
+      @database[@name].find('_id' => @entity_id).first
     end
     def delete
-      @database[@name].remove({"_id" => @entity_id}, :safe => true)
+      @database[@name].delete_one({ '_id' => @entity_id }, safe: true)
       nil
     end
     def clear_tags
-      spec = {"_id" => @entity_id }
-      doc = {"$set" => { "tags" => Hash.new } }
-      @database[@name].update(spec, doc, :safe=>true)
+      spec = { '_id' => @entity_id }
+      doc = { '$set' => { 'tags' => {} } }
+      @database[@name].update_one(spec, doc, safe: true)
       nil
     end
     def has_tag(tag, value)
-      e = self.get()
-      e['tags'].member?(tag) and e['tags'][tag].member?(value)
+      e = get
+      e['tags'].member?(tag) && e['tags'][tag].member?(value)
     end
     def tag(tag, value)
-      self.apply_tag(tag, value)
+      apply_tag(tag, value)
       nil
     end
     def untag(tag, value)
-      self.apply_tag(tag, value, add=false)
+      apply_tag(tag, value, add = false)
       nil
     end
-    def apply_tag(tag, value, add=true)
-      op = add ? "$addToSet" : "$pull"
-      doc = Hash.new
+    def apply_tag(tag, value, add = true)
+      op = add ? '$addToSet' : '$pull'
+      doc = {}
       field = "tags.#{tag}"
-      unless value.is_a?(Array)
-        doc[op] = { field => value }
+      if value.is_a?(Array)
+        op = '$pullAll' unless add
+        doc[op] = add ? { field => { '$each' => value } } : { field => value }
       else
-        op = "$pullAll" unless add
-        doc[op] = add ? {field => {"$each" => value}} : {field => value}
+        doc[op] = { field => value }
       end
-      spec = Hash["_id" => @entity_id]
-      @database[@name].update(spec, doc, :safe=>true)
+      spec = Hash['_id' => @entity_id]
+      @database[@name].update_one(spec, doc, safe: true)
       nil
     end
-    def similiar(tag=nil, skip=nil, limit=nil, reverse=false)
-      q = BSON::OrderedHash.new
-      q["_id.e"] = @entity_id
-      q["_id.tag"] = tag ? tag : {"$exists" => false}
-      cursor = @database["#{@name}_count"].find(q, :fields => {"_id.e" => 1})
-      cursor.skip(skip) if skip
-      cursor.limit(limit) if limit
-      cursor.sort("value.count", reverse ? Mongo::ASCENDING : Mongo::DESCENDING)
+    def similiar(tag = nil, skip = nil, limit = nil, reverse = false)
+      q = BSON::Document.new
+      q['_id.e'] = @entity_id
+      q['_id.tag'] = tag ? tag : { '$exists' => false }
+      opts = {
+        projection: { '_id.e' => 1 },
+        sort: { 'value.count' => reverse ? 1 : -1 }
+      }
+      opts[:skip] = skip if skip
+      opts[:limit] = limit if limit
+      cursor = @database["#{@name}_count"].find(q, opts)
       cursor.collect do |r|
-        pair = r["_id"]["e"]
+        pair = r['_id']['e']
         pair[0] == @entity_id ? pair[1] : pair[0]
       end
     end
   end
 end

data/lib/rugroupy/group.rb CHANGED Viewed

@@ -2,100 +2,102 @@ require 'mongo'
 require 'bson'
 module Groupy
   class EntityGrouper
-    @@defaultScoreFunction = "function(tag) { return 1; }"
-    @@defaultIncludeFunction = "function(tag) { return true; }"
-    @@dynamicTagFunction = "function(doc) {}"
+    @@defaultScoreFunction = 'function(tag) { return 1; }'
+    @@defaultIncludeFunction = 'function(tag) { return true; }'
+    @@dynamicTagFunction = 'function(doc) {}'
     def initialize(database, entity)
-      @database, @entity = database, entity
-      @database["#{@entity}_count"].ensure_index([['_id.tag', Mongo::DESCENDING],
-        ['value.count', Mongo::DESCENDING]], :background => false)
+      @database = database
+      @entity = entity
+      @database["#{@entity}_count"].indexes.create_many([
+                                                          { key: { '_id.tag' => -1 }, background: false },
+                                                          { key: { 'value.count' => -1 }, background: false }
+                                                        ])
     end
-    def similiar(tag=nil, skip=nil, limit=nil, reverse=false)
-      q = BSON::OrderedHash.new
-      q["_id.tag"] = tag ? tag : {"$exists" => false}
-      cursor = @database["#{@entity}_count"].find(q, :fields => {"_id.e" => 1})
-      cursor.skip(skip) if skip
-      cursor.limit(limit) if limit
-      cursor.sort("value.count", reverse ? Mongo::ASCENDING : Mongo::DESCENDING)
-      cursor.collect { |r| r["_id"]["e"] }
+    def similiar(tag = nil, skip = nil, limit = nil, reverse = false)
+      q = BSON::Document.new
+      q['_id.tag'] = tag ? tag : { '$exists' => false }
+      opts = {
+        projection: { '_id.e' => 1 },
+        sort: { 'value.count' => reverse ? 1 : -1 }
+      }
+      opts[:skip] = skip if skip
+      opts[:limit] = limit if limit
+      cursor = @database["#{@entity}_count"].find(q, opts)
+      cursor.collect { |r| r['_id']['e'] }
     end
-    def group(options={})
-      self.invert_entities(options[:includeFunction] || @@defaultIncludeFunction,
-        options[:dynamicTagFunction] || @@dynamicTagFunction)
-      self.count_entities(options[:scoreFunction] || @@defaultScoreFunction)
+    def group(options = {})
+      invert_entities(options[:includeFunction] || @@defaultIncludeFunction,
+                      options[:dynamicTagFunction] || @@dynamicTagFunction)
+      count_entities(options[:scoreFunction] || @@defaultScoreFunction)
     end
     def count_entities(scoreFunction)
       map = BSON::Code.new(<<eos)
-        function() {
-          score = #{scoreFunction};
-          tag = this._id.tag;
-          tagScore = score(tag);
-          entities = this.value.entities.slice(0).sort();
-          for (x in entities) {
-            for (y in entities) {
-              if (x < y) {
-                emit({tag:tag, e:[entities[x], entities[y]]}, {count:tagScore});
-                emit({e:[entities[x], entities[y]]}, {count:tagScore});
-              }
-            }
-          }
-        }
+        function() {
+          var score = #{scoreFunction},
+              tag = this._id.tag,
+              tagScore = score(tag),
+              entities = this.value.entities.slice(0).sort();
+          for (x in entities) {
+            for (y in entities) {
+              if (x < y) {
+                emit({tag:tag, e:[entities[x], entities[y]]}, {count:tagScore});
+                emit({e:[entities[x], entities[y]]}, {count:tagScore});
+              }
+            }
+          }
+        }
 eos
       reduce = BSON::Code.new(<<eos)
-        function(key, values) {
-          result = {count:0};
-          values.forEach(function(value) {
-            result.count += value.count;
-          });
-          return result;
-        }
+        function(key, values) {
+          var result = {count:0};
+          values.forEach(function(value) {
+            result.count += value.count;
+          });
+          return result;
+        }
 eos
-      @database["#{@entity}_invert"].map_reduce(map, reduce, :out => "#{@entity}_count")
+      @database["#{@entity}_invert"].find.map_reduce(map, reduce, out: "#{@entity}_count").execute
       nil
     end
     def invert_entities(includeFunction, dynamicTagFunction)
       map = BSON::Code.new(<<eos)
-        function() {
-          include = #{includeFunction};
-          dynamicTagFunction = #{dynamicTagFunction};
-          entity_id = this._id;
-          if (this.tags) {
-            for (tag in this.tags) {
-              if (!include(tag)) continue;
-              this.tags[tag].forEach(function(z) {
-                emit({tag:tag, value:z}, {entities: [entity_id]});
+        function() {
+          var include = #{includeFunction},
+              dynamicTagFunction = #{dynamicTagFunction},
+              entity_id = this._id;
+          if (this.tags) {
+            for (tag in this.tags) {
+              if (!include(tag)) continue;
+              this.tags[tag].forEach(function(z) {
+                emit({tag:tag, value:z}, {entities: [entity_id]});
               });
             }
             dynamicTagFunction(this);
-          }
+          }
         }
 eos
       reduce = BSON::Code.new(<<eos)
-        function(key, values) {
-          result = {entities:[]};
-          values.forEach(function(value) {
-            value['entities'].forEach(function(entity_id) {
-              result['entities'].push( entity_id );
-            });
-          });
-          return result;
+        function(key, values) {
+          var result = {entities:[]};
+          values.forEach(function(value) {
+            value['entities'].forEach(function(entity_id) {
+              result['entities'].push( entity_id );
+            });
+          });
+          return result;
         }
 eos
-      @database[@entity].map_reduce(map, reduce, :out => "#{@entity}_invert")
+      @database[@entity].find.map_reduce(map, reduce, out: "#{@entity}_invert").execute
       nil
     end
   end
-end
+end

metadata CHANGED Viewed

@@ -1,193 +1,121 @@
---- !ruby/object:Gem::Specification
+--- !ruby/object:Gem::Specification
 name: rugroupy
-version: !ruby/object:Gem::Version
-  hash: 31
-  prerelease:
-  segments:
-  - 0
-  - 1
-  - 2
-  version: 0.1.2
+version: !ruby/object:Gem::Version
+  version: 0.2.0
 platform: ruby
-authors:
+authors:
 - Ryan Wynn
 autorequire:
 bindir: bin
 cert_chain: []
-date: 2011-08-22 00:00:00 Z
-dependencies:
-- !ruby/object:Gem::Dependency
-  requirement: &id001 !ruby/object:Gem::Requirement
-    none: false
-    requirements:
+date: 2018-03-08 00:00:00.000000000 Z
+dependencies:
+- !ruby/object:Gem::Dependency
+  name: bson
+  requirement: !ruby/object:Gem::Requirement
+    requirements:
     - - ">="
-      - !ruby/object:Gem::Version
-        hash: 25
-        segments:
-        - 1
-        - 3
-        - 1
-        version: 1.3.1
-  version_requirements: *id001
-  name: mongo
-  prerelease: false
+      - !ruby/object:Gem::Version
+        version: '0'
   type: :runtime
-- !ruby/object:Gem::Dependency
-  requirement: &id002 !ruby/object:Gem::Requirement
-    none: false
-    requirements:
-    - - ">="
-      - !ruby/object:Gem::Version
-        hash: 25
-        segments:
-        - 1
-        - 3
-        - 1
-        version: 1.3.1
-  version_requirements: *id002
-  name: bson
   prerelease: false
-  type: :runtime
-- !ruby/object:Gem::Dependency
-  requirement: &id003 !ruby/object:Gem::Requirement
-    none: false
-    requirements:
+  version_requirements: !ruby/object:Gem::Requirement
+    requirements:
     - - ">="
-      - !ruby/object:Gem::Version
-        hash: 25
-        segments:
-        - 1
-        - 3
-        - 1
-        version: 1.3.1
-  version_requirements: *id003
-  name: bson_ext
-  prerelease: false
-  type: :runtime
-- !ruby/object:Gem::Dependency
-  requirement: &id004 !ruby/object:Gem::Requirement
-    none: false
-    requirements:
+      - !ruby/object:Gem::Version
+        version: '0'
+- !ruby/object:Gem::Dependency
+  name: mongo
+  requirement: !ruby/object:Gem::Requirement
+    requirements:
     - - ">="
-      - !ruby/object:Gem::Version
-        hash: 25
-        segments:
-        - 1
-        - 2
-        - 3
-        version: 1.2.3
-  version_requirements: *id004
-  name: SystemTimer
-  prerelease: false
+      - !ruby/object:Gem::Version
+        version: '0'
   type: :runtime
-- !ruby/object:Gem::Dependency
-  requirement: &id005 !ruby/object:Gem::Requirement
-    none: false
-    requirements:
-    - - ">="
-      - !ruby/object:Gem::Version
-        hash: 3
-        segments:
-        - 0
-        version: "0"
-  version_requirements: *id005
-  name: shoulda
   prerelease: false
-  type: :development
-- !ruby/object:Gem::Dependency
-  requirement: &id006 !ruby/object:Gem::Requirement
-    none: false
-    requirements:
-    - - ~>
-      - !ruby/object:Gem::Version
-        hash: 23
-        segments:
-        - 1
-        - 0
-        - 0
-        version: 1.0.0
-  version_requirements: *id006
+  version_requirements: !ruby/object:Gem::Requirement
+    requirements:
+    - - ">="
+      - !ruby/object:Gem::Version
+        version: '0'
+- !ruby/object:Gem::Dependency
   name: bundler
-  prerelease: false
+  requirement: !ruby/object:Gem::Requirement
+    requirements:
+    - - ">="
+      - !ruby/object:Gem::Version
+        version: '0'
   type: :development
-- !ruby/object:Gem::Dependency
-  requirement: &id007 !ruby/object:Gem::Requirement
-    none: false
-    requirements:
-    - - ~>
-      - !ruby/object:Gem::Version
-        hash: 7
-        segments:
-        - 1
-        - 6
-        - 4
-        version: 1.6.4
-  version_requirements: *id007
-  name: jeweler
   prerelease: false
-  type: :development
-- !ruby/object:Gem::Dependency
-  requirement: &id008 !ruby/object:Gem::Requirement
-    none: false
-    requirements:
+  version_requirements: !ruby/object:Gem::Requirement
+    requirements:
+    - - ">="
+      - !ruby/object:Gem::Version
+        version: '0'
+- !ruby/object:Gem::Dependency
+  name: jeweler
+  requirement: !ruby/object:Gem::Requirement
+    requirements:
     - - ">="
-      - !ruby/object:Gem::Version
-        hash: 3
-        segments:
-        - 0
-        version: "0"
-  version_requirements: *id008
-  name: rcov
+      - !ruby/object:Gem::Version
+        version: '0'
+  type: :development
   prerelease: false
+  version_requirements: !ruby/object:Gem::Requirement
+    requirements:
+    - - ">="
+      - !ruby/object:Gem::Version
+        version: '0'
+- !ruby/object:Gem::Dependency
+  name: shoulda
+  requirement: !ruby/object:Gem::Requirement
+    requirements:
+    - - ">="
+      - !ruby/object:Gem::Version
+        version: '0'
   type: :development
-description: a library which uses the map-reduce capabilities of mongodb to group entities based on tags.
+  prerelease: false
+  version_requirements: !ruby/object:Gem::Requirement
+    requirements:
+    - - ">="
+      - !ruby/object:Gem::Version
+        version: '0'
+description: a library which uses the map-reduce capabilities of mongodb to group
+  entities based on tags.
 email: [email protected]
 executables: []
 extensions: []
-extra_rdoc_files:
+extra_rdoc_files:
+- LICENSE.txt
+- README.rdoc
+files:
 - LICENSE.txt
 - README.rdoc
-files:
 - lib/rugroupy.rb
 - lib/rugroupy/entity.rb
 - lib/rugroupy/group.rb
-- LICENSE.txt
-- README.rdoc
 homepage: http://github.com/rwynn/rugroupy
-licenses:
+licenses:
 - MIT
+metadata: {}
 post_install_message:
 rdoc_options: []
-require_paths:
+require_paths:
 - lib
-required_ruby_version: !ruby/object:Gem::Requirement
-  none: false
-  requirements:
+required_ruby_version: !ruby/object:Gem::Requirement
+  requirements:
   - - ">="
-    - !ruby/object:Gem::Version
-      hash: 3
-      segments:
-      - 0
-      version: "0"
-required_rubygems_version: !ruby/object:Gem::Requirement
-  none: false
-  requirements:
+    - !ruby/object:Gem::Version
+      version: '0'
+required_rubygems_version: !ruby/object:Gem::Requirement
+  requirements:
   - - ">="
-    - !ruby/object:Gem::Version
-      hash: 3
-      segments:
-      - 0
-      version: "0"
+    - !ruby/object:Gem::Version
+      version: '0'
 requirements: []
 rubyforge_project:
-rubygems_version: 1.8.6
+rubygems_version: 2.2.2
 signing_key:
-specification_version: 3
+specification_version: 4
 summary: find things that are similiar to things
 test_files: []