class Groupy::Entity
Public Class Methods
new(database, name, entity_id, create = true)
click to toggle source
# File lib/rugroupy/entity.rb, line 6 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' => {}] @database[@name].insert_one(doc, safe: true) rescue Mongo::Error => e end end end
Public Instance Methods
apply_tag(tag, value, add = true)
click to toggle source
# File lib/rugroupy/entity.rb, line 58 def apply_tag(tag, value, add = true) op = add ? '$addToSet' : '$pull' doc = {} field = "tags.#{tag}" if value.is_a?(Array) op = '$pullAll' unless add doc[op] = add ? { field => { '$each' => value } } : { field => value } else doc[op] = { field => value } end spec = Hash['_id' => @entity_id] @database[@name].update_one(spec, doc, safe: true) nil end
delete()
click to toggle source
# File lib/rugroupy/entity.rb, line 31 def delete @database[@name].delete_one({ '_id' => @entity_id }, safe: true) nil end
get()
click to toggle source
# File lib/rugroupy/entity.rb, line 27 def get @database[@name].find('_id' => @entity_id).first end
has_tag(tag, value)
click to toggle source
# File lib/rugroupy/entity.rb, line 43 def has_tag(tag, value) e = get e['tags'].member?(tag) && e['tags'][tag].member?(value) end
similiar(tag = nil, skip = nil, limit = nil, reverse = false)
click to toggle source
# File lib/rugroupy/entity.rb, line 73 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[0] == @entity_id ? pair[1] : pair[0] end end
tag(tag, value)
click to toggle source
# File lib/rugroupy/entity.rb, line 48 def tag(tag, value) apply_tag(tag, value) nil end
untag(tag, value)
click to toggle source
# File lib/rugroupy/entity.rb, line 53 def untag(tag, value) apply_tag(tag, value, add = false) nil end