spacecruft
/
Farmbot-Web-App
1
0
Fork 0
Code Issues Pull Requests Releases Activity

Add throttle policy to Telemetry channel

pull/1532/head
Rick Carlino 2019-10-24 15:51:40 -05:00
parent 4cbb463a23
commit dec4f8ffb1
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
app/lib/telemetry_service.rb
View File

@ -4,6 +4,11 @@
class TelemetryService < AbstractServiceRunner
MESSAGE = "TELEMETRY MESSAGE FROM %s"
FAILURE = "FAILED TELEMETRY MESSAGE FROM %s"
THROTTLE_POLICY = ThrottlePolicy.new({
ThrottlePolicy::TimePeriod.new(1.minute) => 25,
ThrottlePolicy::TimePeriod.new(1.hour) => 250,
ThrottlePolicy::TimePeriod.new(1.day) => 1500,
})
def process(delivery_info, payload)
device_key = delivery_info
@ -13,7 +18,11 @@ class TelemetryService < AbstractServiceRunner
other_stuff = { device: device_key,
is_telemetry: true,
message: MESSAGE % device_key }
puts json.merge(other_stuff).to_json
THROTTLE_POLICY.track(device_key)
violation = THROTTLE_POLICY.is_throttled(device_key)
unless violation
puts json.merge(other_stuff).to_json
end
rescue JSON::ParserError
puts ({ device: device_key,
is_telemetry: true,