Class: Telemetry::Api

Inherits:
Object
  • Object
show all
Defined in:
lib/telemetry/api.rb

Class Method Summary collapse

Class Method Details

.affiliate_send(affiliate_identifier, data) ⇒ Object

Raises:



88
89
90
91
92
93
 
# File 'lib/telemetry/api.rb', line 88

def self.affiliate_send(affiliate_identifier, data)
	raise Telemetry::AuthenticationFailed, "Please set your Telemetry.token" unless Telemetry.token
	raise RuntimeError, "Must supply data to send" unless data
	raise RuntimeError, "Must supply a unique affiliate identifier" unless affiliate_identifier
	return Telemetry::Api.send(:post, "/affiliates/#{affiliate_identifier}/data", {:data => data})
end

.delete(path) ⇒ Object 



72
73
74
 
# File 'lib/telemetry/api.rb', line 72

def self.delete(path)
	Telemetry::Api.send(:delete, path)
end

.delete_flow_data(id) ⇒ Object 



84
85
86
 
# File 'lib/telemetry/api.rb', line 84

def self.delete_flow_data(id)
	Telemetry::Api.send(:delete, "/flows/#{id}/data")
end

.flow_update(flow) ⇒ Object

Raises:



95
96
97
98
99
100
101
102
 
# File 'lib/telemetry/api.rb', line 95

def self.flow_update(flow)
	raise Telemetry::AuthenticationFailed, "Please set your Telemetry.token" unless Telemetry.token
	values = flow.to_hash
	tag = values.delete('tag')
	result = Telemetry::Api.send(:put, "/flows/#{tag}/data", values)
	raise ResponseError, "API Response: #{result['errors'].join(', ')}" unless result["updated"].include?(tag)
	result
end

.flow_update_batch(flows) ⇒ Object

Raises:



104
105
106
107
108
109
110
111
112
113
114
 
# File 'lib/telemetry/api.rb', line 104

def self.flow_update_batch(flows)
	raise Telemetry::AuthenticationFailed, "Please set your Telemetry.token" unless Telemetry.token
	raise RuntimeError, "Must supply flows to send" if flows == 0 || flows.count == 0
	data = {}
	flows.each do |flow|
		values = flow.to_hash
		tag = values.delete('tag')
		data[tag] = values
	end
	return Telemetry::Api.send(:post, "/data", {:data => data})
end

.get(path) ⇒ Object 



60
61
62
 
# File 'lib/telemetry/api.rb', line 60

def self.get(path)
	Telemetry::Api.send(:get, path)
end

.get_flow(id) ⇒ Object 



76
77
78
 
# File 'lib/telemetry/api.rb', line 76

def self.get_flow(id)
	Telemetry::Api.send(:get, "/flows/#{id}")
end

.get_flow_data(id) ⇒ Object 



80
81
82
 
# File 'lib/telemetry/api.rb', line 80

def self.get_flow_data(id)
	Telemetry::Api.send(:get, "/flows/#{id}/data")
end

.patch(path, body) ⇒ Object 



68
69
70
 
# File 'lib/telemetry/api.rb', line 68

def self.patch(path, body)
	Telemetry::Api.send(:patch, path, body)
end

.post(path, body) ⇒ Object 



64
65
66
 
# File 'lib/telemetry/api.rb', line 64

def self.post(path, body)
	Telemetry::Api.send(:post, path, body)
end

.send(method, endpoint, data = nil) ⇒ Object 



116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
 
# File 'lib/telemetry/api.rb', line 116

def self.send(method, endpoint, data = nil)

	http = Net::HTTP::Persistent.new 'telemetry_api'
	uri = URI("#{Telemetry.api_host}#{endpoint}")

	Telemetry::logger.debug "REQ #{uri} - #{MultiJson.dump(data)}"

	if method == :post
		request = Net::HTTP::Post.new(uri.path)
		request.body = MultiJson.dump(data) 
	elsif method == :put
		request = Net::HTTP::Put.new(uri.path)
		request.body = MultiJson.dump(data) 
	elsif method == :patch
		request = Net::HTTP::Patch.new(uri.path)
		request.body = MultiJson.dump(data) 
	elsif method == :get 
		request = Net::HTTP::Get.new(uri.path)
	elsif method == :delete
		request = Net::HTTP::Delete.new(uri.path)
	end

	request.basic_auth(Telemetry.token, "") if Telemetry.token
	request['Content-Type'] = 'application/json'
	request['Accept-Version'] = '~ 1'
	request['User-Agent'] = "Telemetry Ruby Gem (#{Telemetry::TELEMETRY_VERSION})"
		
	start_time = Time.now

	begin
		ssl = true if Telemetry.api_host.match(/^https/)

		response = http.request uri, request

		code = response.code

		Telemetry::logger.debug "RESP (#{((Time.now-start_time)*1000).to_i}ms): #{response.code}:#{response.body}"

		case response.code
		when "200"
			Telemetry::logger.debug response.body
			return MultiJson.load(response.body)
		when "201"
			Telemetry::logger.debug response.body
			return MultiJson.load(response.body)
		when "204"
			return "No Body"
		when "400"
			json = MultiJson.load(response.body)
			error = "#{Time.now} (HTTP 400): #{json['code'] if json} #{json['message'] if json}"
			Telemetry::logger.debug response.body
			Telemetry::logger.error error
			raise Telemetry::FormatError, error
		when "401"
			if Telemetry.token == nil
				error = "#{Time.now} (HTTP 401): Authentication failed, please set Telemetry.token to your API Token. #{method.upcase} #{uri}"
				Telemetry::logger.error error
				raise Telemetry::AuthenticationFailed, error
			else
				error = "#{Time.now} (HTTP 401): Authentication failed, please verify your token. #{method.upcase} #{uri}"
				Telemetry::logger.error error
				raise Telemetry::AuthenticationFailed, error
			end
		when "403"
			error = "#{Time.now} (HTTP 403): Authorization failed, please check your account access. #{method.upcase} #{uri}"
			Telemetry::logger.error error
			raise Telemetry::AuthorizationError, error
		when "404"
			error = "#{Time.now} (HTTP 404): Requested object not found. #{method.upcase} #{uri}"
			Telemetry::logger.error error
			raise Telemetry::FlowNotFound, error
		when "405"
			error = "#{Time.now} (HTTP 405): Method not allowed. #{method.upcase} #{uri}"
			Telemetry::logger.error error
			raise Telemetry::MethodNotAllowed, error
		when "429"
			error = "#{Time.now} (HTTP 429): Rate limited. Please reduce your update interval. #{method.upcase} #{uri}"
			Telemetry::logger.error error
			raise Telemetry::RateLimited, error
		when "500"
			error = "#{Time.now} (HTTP 500): API server error. #{method.upcase} #{uri}"
			Telemetry::logger.error error
			Telemetry::logger.error response.body
			raise Telemetry::ServerException, error
		when "502"
			error = "#{Time.now} (HTTP 502): API server is down. #{method.upcase} #{uri}"
			Telemetry::logger.error error
			raise Telemetry::Unavailable, error
		when "503"
			error = "#{Time.now} (HTTP 503): API server is down. #{method.upcase} #{uri}"
			Telemetry::logger.error error
			raise Telemetry::Unavailable, error
		else
			error = "#{Time.now} ERROR UNK: #{method.upcase} #{uri} #{response.body}."
			raise Telemetry::UnknownError, error
		end

	rescue Errno::ETIMEDOUT => e
		error = "#{Time.now} ERROR #{e}"
		Telemetry::logger.error error
		raise Telemetry::ConnectionError, error

	rescue Errno::ECONNREFUSED => e 
		error = "#{Time.now} ERROR #{e}"
		Telemetry::logger.error error
		raise Telemetry::ConnectionError, error

	rescue Exception => e
		raise e
	end
end