Module: Droid::Utils

Defined in:
lib/droid/utils.rb,
lib/droid/heroku.rb

Class Method Summary collapse

Class Method Details

.create_event_hash ⇒ Object 



28
29
30
31
 
# File 'lib/droid/utils.rb', line 28

def self.create_event_hash
	s = Time.now.to_s + self.object_id.to_s + rand(100).to_s
	'd' + Digest::MD5.hexdigest(s)
end

.data_summary(json) ⇒ Object 



90
91
92
93
94
95
96
97
98
 
# File 'lib/droid/utils.rb', line 90

def self.data_summary(json)
	return '-> (empty)' if json.empty?
	summary = json.map do |k,v|
		v = v.to_s
		v = v[0..37] + '...' if v.size > 40
		"#{k}=#{v}"
	end.join(', ')
	"-> #{summary}"
end

.extract_custom_headers(hash, opts = {}, popts = {}) ⇒ Object 



33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/droid/utils.rb', line 33

def self.extract_custom_headers(hash, opts={}, popts={})
	popts[:headers] ||= {}
	headers = popts[:headers]

	headers[:published_on] ||= hash.delete('published_on') || opts[:published_on] || Time.now.getgm.to_i
	headers[:ttl] ||= hash.delete('ttl') || (opts[:ttl] || Droid::DEFAULT_TTL).to_i
	headers[:reply_to] ||= opts[:reply_to] if opts[:reply_to]

	# this is the event hash that gets transferred through various publish/reply actions
	headers[:event_hash] ||= hash.delete('event_hash') || opts[:event_hash] || create_event_hash

	# this value should be unique for each published/received message pair
	headers[:message_id] ||= create_event_hash

	# some strange behavior with integers makes it better to
	# convert all amqp headers to strings to avoid any problems
	headers.each { |k,v| headers[k] = v.to_s }

	[hash, headers]
end

.format_data_summary(data, headers) ⇒ Object 



100
101
102
 
# File 'lib/droid/utils.rb', line 100

def self.format_data_summary(data, headers)
	"(data) " + Droid::Utils.data_summary(data) + " (headers) " + Droid::Utils.data_summary(headers)
end

.format_publish(data, opts = {}, popts = {}) ⇒ Object

Raises:



54
55
56
57
58
59
60
61
62
 
# File 'lib/droid/utils.rb', line 54

def self.format_publish(data, opts={}, popts={})
	raise Droid::BadPayload unless data.is_a?(Hash)

	hash, headers = extract_custom_headers(data, opts, popts)

	popts[:content_type] ||= 'application/json'

	[hash.to_json, popts]
end

.generate_name_for_instance(name) ⇒ Object 



69
70
71
 
# File 'lib/droid/utils.rb', line 69

def self.generate_name_for_instance(name)
	"#{name}.#{Socket.gethostname}"
end

.generate_queue(exchange_name, second_name = nil) ⇒ Object 



64
65
66
67
 
# File 'lib/droid/utils.rb', line 64

def self.generate_queue(exchange_name, second_name=nil)
	second_name ||= $$
	"#{generate_name_for_instance(exchange_name)}.#{second_name}"
end

.generate_reply_to(name) ⇒ Object 



73
74
75
 
# File 'lib/droid/utils.rb', line 73

def self.generate_reply_to(name)
	"temp.reply.#{name}.#{self.generate_sym}"
end

.generate_sym ⇒ Object 



77
78
79
80
81
82
83
84
85
86
87
88
 
# File 'lib/droid/utils.rb', line 77

def self.generate_sym
	values = [
		rand(0x0010000),
		rand(0x0010000),
		rand(0x0010000),
		rand(0x0010000),
		rand(0x0010000),
		rand(0x1000000),
		rand(0x1000000),
	]
	"%04x%04x%04x%04x%04x%06x%06x" % values
end

.parse_custom_headers(headers) ⇒ Object 



15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/droid/utils.rb', line 15

def self.parse_custom_headers(headers)
	return { } unless headers

	h = headers.dup

	h[:published_on] = h[:published_on].to_i

	h[:ttl] = h[:ttl].to_i rescue -1
	h[:ttl] = -1 if h[:ttl] == 0

	h
end

.parse_message(raw) ⇒ Object 



10
11
12
13
 
# File 'lib/droid/utils.rb', line 10

def self.parse_message(raw)
	return { } unless raw
	JSON.parse(raw)
end