Class: Droid::JSONServer

Inherits:
EM::Connection
  • Object
show all
Includes:
EM::HttpServer
Defined in:
lib/droid/json_server.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.hash_to_metrics(hash) ⇒ Object

utility method to convert a ruby hash to a metrics format that can be consumed by cloudkick



84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
 
# File 'lib/droid/json_server.rb', line 84

def self.hash_to_metrics(hash)
	hash.collect do |k,v|
		name = k.to_s
		value = v
		type = if v.kind_of?(Integer)
			'int'
		elsif v.kind_of?(Float)
			'float'
		else
			'string'
		end

		# bool -> int conversion
		if [TrueClass, FalseClass].include?(v.class)
			value = v ? 1 : 0
			type = 'int'
		end

		# if type is really string then it should respond to .to_s
		value = value.to_s if type == 'string'

		{ 'name' => name, 'type' => type, 'value' => value }
	end
end

Instance Method Details

#default_response ⇒ Object 



38
39
40
41
42
43
44
 
# File 'lib/droid/json_server.rb', line 38

def default_response
	response = ::EM::DelegatedHttpResponse.new(self)
	response.status = 200
	response.content_type 'application/json'
	response.content = {"status" => "OK"}.to_json
	response.send_response
end

#generate_response(method_name) ⇒ Object 



28
29
30
31
32
33
34
35
36
 
# File 'lib/droid/json_server.rb', line 28

def generate_response(method_name)
	status, data, content_type = self.send(method_name)

	response = ::EM::DelegatedHttpResponse.new(self)
	response.status = status
	response.content_type content_type
	response.content = data
	response.send_response
end

#get_droid ⇒ Object 



54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
 
# File 'lib/droid/json_server.rb', line 54

def get_droid
	report_data = Droid::Utilization.report_data

	metrics = {}
	report_data.each do |topic, data|
		metrics[topic] = data['msgs']
	end
	metrics['latency'] = Droid::Utilization.latency

	summary = Droid::Utilization.report_summary(report_data)

	metrics['total_msgs'] = summary['msgs']

	status = "AMQP: #{summary['msgs']} msgs processed since #{Droid::Utilization.start.utc}"

	# reset metrics data
	Droid::Utilization.reinit

	data = {
		'status' => status,
		'state' => 'ok',
		'metrics' => hash_to_metrics(metrics)
	}
	[200, data.to_json, "application/json"]
end

#hash_to_metrics(hash) ⇒ Object 



80
 
# File 'lib/droid/json_server.rb', line 80

def hash_to_metrics(hash); self.class.hash_to_metrics(hash); end

#not_found_response ⇒ Object 



46
47
48
49
50
51
52
 
# File 'lib/droid/json_server.rb', line 46

def not_found_response
	response = ::EM::DelegatedHttpResponse.new(self)
	response.status = 404
	response.content_type 'text/plain'
	response.content = "Not Found"
	response.send_response
end

#post_init ⇒ Object 



8
9
10
11
 
# File 'lib/droid/json_server.rb', line 8

def post_init
	super
	no_environment_strings
end

#process_http_request ⇒ Object 



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

def process_http_request
	return not_found_response if @http_request_method != "GET"

	if @http_request_uri == "/"
		default_response
	else
		method_name = "get_#{@http_request_uri.split("/")[1]}".gsub(/[^\d\w_]/,'').downcase
		if public_methods.include?(method_name)
			generate_response(method_name)
		else
			not_found_response
		end
	end
end