Module: Seabright::ObjectBase::ClassMethods

Defined in:
lib/redis_object/base.rb

Constant Summary collapse

NilPattern = 
'nilpattern:'

Instance Method Summary collapse

Instance Method Details

#_new_id_sym(cls = self.name) ⇒ Object 



560
561
562
 
# File 'lib/redis_object/base.rb', line 560

def _new_id_sym(cls=self.name)
	(cls || self.name).foreign_key.to_sym
end

#_old_id_sym(cls = self.name) ⇒ Object 



575
576
577
 
# File 'lib/redis_object/base.rb', line 575

def _old_id_sym(cls=self.name)
	"#{(cls || self.name).split('::').last.downcase}_id".to_sym
end

#all ⇒ Object 



247
248
249
250
251
252
253
254
255
256
257
258
259
 
# File 'lib/redis_object/base.rb', line 247

def all
	kys = store.smembers(plname)
	ListEnumerator.new(kys) do |y|
		kys.each do |member|
			if a = find_by_key(hkey(member))
				y << a
			else
				Log.debug "[#{name}] Object listed but not found: #{member}"
				store.srem(plname,member)
			end
		end
	end
end

#cname ⇒ Object 



239
240
241
 
# File 'lib/redis_object/base.rb', line 239

def cname
	name
end

#convert_old_id_syms! ⇒ Object 



564
565
566
567
568
569
570
571
572
573
 
# File 'lib/redis_object/base.rb', line 564

def convert_old_id_syms!
	ol = _old_id_sym
	nw = id_sym
	each do |obj|
		if obj.is_set?(ol)
			obj.set(nw,get(ol))
			obj.unset(ol)
		end
	end
end

#convert_regex_to_lua(reg) ⇒ Object 



476
477
478
 
# File 'lib/redis_object/base.rb', line 476

def convert_regex_to_lua(reg)
	"#{reg.casefold? ? "i" : ""}pattern:#{reg.source.gsub("\\","")}"
end

#create(ident = {}) ⇒ Object 



510
511
512
513
514
 
# File 'lib/redis_object/base.rb', line 510

def create(ident={})
	obj = new(ident)
	obj.save
	obj
end

#dbnum ⇒ Object 



528
529
530
 
# File 'lib/redis_object/base.rb', line 528

def dbnum
	@dbnum ||= 0
end

#deep_const_get(const, base = nil) ⇒ Object 



539
540
541
542
543
544
545
546
547
 
# File 'lib/redis_object/base.rb', line 539

def deep_const_get(const,base=nil)
	if Symbol === const
		const = const.to_s
	else
		const = const.to_str.dup
	end
	base ||= const.sub!(/^::/, '') ? Object : self
	const.split(/::/).inject(base) { |mod, name| mod.const_get(name) }
end

#describe ⇒ Object 



579
580
581
582
583
584
585
 
# File 'lib/redis_object/base.rb', line 579

def describe
	all_keys.inject({}) do |acc,(k,v)|
		acc[k.to_sym] ||= [:string, 0]
		acc[k.to_sym][1] += 1
		acc
	end
end

#each ⇒ Object 



275
276
277
278
279
 
# File 'lib/redis_object/base.rb', line 275

def each
	all.each do |o|
		yield o
	end
end

#exists?(k) ⇒ Boolean

Returns:

  • (Boolean) 


506
507
508
 
# File 'lib/redis_object/base.rb', line 506

def exists?(k)
	store.exists(self.hkey(k)) || store.exists(self.reserve_key(k))
end

#find(ident) ⇒ Object 



498
499
500
 
# File 'lib/redis_object/base.rb', line 498

def find(ident)
	grab(ident)
end

#find_by_key(k) ⇒ Object 



532
533
534
535
536
537
 
# File 'lib/redis_object/base.rb', line 532

def find_by_key(k)
	if store.exists(k) && (cls = store.hget(k,:class))
		return deep_const_get(cls.to_sym,Object).new(store.hget(k,id_sym(cls)))
	end
	nil
end

#first ⇒ Object 



267
268
269
270
271
272
273
 
# File 'lib/redis_object/base.rb', line 267

def first
	if m = store.smembers(plname)
	 self.grab(m.first)
	else
		nil
	end
end

#generate_id ⇒ Object 



220
221
222
223
224
225
226
227
228
229
 
# File 'lib/redis_object/base.rb', line 220

def generate_id
	v = new_id
	while exists?(v) do
		Log.verbose "[RedisObject] Collision at id: #{v}"
		v = new_id
	end
	Log.verbose "[RedisObject] Reserving key: #{v}"
	reserve(v)
	v
end

#grab(ident) ⇒ Object 



480
481
482
483
484
485
486
487
488
 
# File 'lib/redis_object/base.rb', line 480

def grab(ident)
	case ident
	when String, Symbol
		return store.exists(self.hkey(ident.to_s)) ? self.new(ident.to_s) : nil
	when Hash
		return match(ident)
	end
	nil
end

#id_sym(cls = nil) ⇒ Object 



556
557
558
 
# File 'lib/redis_object/base.rb', line 556

def id_sym(cls=nil)
	_old_id_sym(cls)
end

#inject_key(key, list) ⇒ Object 



463
464
465
466
467
468
469
470
471
472
473
474
 
# File 'lib/redis_object/base.rb', line 463

def inject_key(key,list)
	out = []
	list.each do |i|
		if i == list.first
			out << i
		else
			out << key
			out << i
		end
	end
	out
end

#match(pkt, use_or = false) ⇒ Object 



434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
 
# File 'lib/redis_object/base.rb', line 434

def match(pkt, use_or=false)
	if use_or
		mtchr = :OrMatcher
	else
		mtchr = pkt.keys.count > 1 ? :MultiMatcher : :Matcher
	end
	pkt = pkt.flatten.reduce([]) do |i,v|
		x = case v
		when Regexp
			convert_regex_to_lua(v)
		when Array
			raise ArgumentError.new("An array can only be used with the find_or method") unless use_or
			inject_key(i.last, v)
		when NilClass
			NilPattern
		else
			v.to_s
		end
		i << x
		i
	end
	kys = run_script(mtchr,[plname],pkt.flatten)
	ListEnumerator.new(kys) do |y|
		kys.each do |k|
			y << find(k)
		end
	end
end

#new_id(complexity = 8) ⇒ Object 



235
236
237
 
# File 'lib/redis_object/base.rb', line 235

def new_id(complexity = 8)
	rand(36**complexity).to_s(36)
end

#or_find(ident) ⇒ Object 



502
503
504
 
# File 'lib/redis_object/base.rb', line 502

def or_find(ident)
	or_grab(ident)
end

#or_grab(ident) ⇒ Object 



490
491
492
493
494
495
496
 
# File 'lib/redis_object/base.rb', line 490

def or_grab(ident)
	case ident
	when Hash
		return match(ident, true)
	end
	nil
end

#plname ⇒ Object 



243
244
245
 
# File 'lib/redis_object/base.rb', line 243

def plname
	cname.pluralize
end

#recollect! ⇒ Object 



261
262
263
264
265
 
# File 'lib/redis_object/base.rb', line 261

def recollect!
	store.keys("#{name}:*_h").each do |ky|
		store.sadd(plname,ky.gsub(/_h$/,''))
	end
end

#reserve(k) ⇒ Object 



231
232
233
 
# File 'lib/redis_object/base.rb', line 231

def reserve(k)
	store.set(reserve_key(k),Time.now.to_s)
end

#save_all ⇒ Object 



549
550
551
552
553
554
 
# File 'lib/redis_object/base.rb', line 549

def save_all
	all.each do |obj|
		obj.save
	end
	true
end

#use_dbnum(db = 0) ⇒ Object

def dump out = [] each do |obj| out << obj.dump end out.join(“n”) end



524
525
526
 
# File 'lib/redis_object/base.rb', line 524

def use_dbnum(db=0)
	@dbnum = db
end