Remove production logger
parent
586d83a236
commit
19809e7388
|
@ -3,25 +3,21 @@
|
|||
# Also handles throttling.
|
||||
class LogService
|
||||
T = ThrottlePolicy::TimePeriod
|
||||
THROTTLE_POLICY = ThrottlePolicy.new T.new(1.minute) => 0.5 * 1_000,
|
||||
T.new(1.hour) => 0.5 * 10_000,
|
||||
T.new(1.day) => 0.5 * 100_000
|
||||
THROTTLE_POLICY = ThrottlePolicy.new T.new(1.minute) => 0.5 * 1_000,
|
||||
T.new(1.hour) => 0.5 * 10_000,
|
||||
T.new(1.day) => 0.5 * 100_000
|
||||
|
||||
def self.process(delivery_info, payload)
|
||||
params = { routing_key: delivery_info.routing_key, payload: payload }
|
||||
data = AmqpLogParser.run!(params)
|
||||
if Rails.env.production?
|
||||
msg = data.payload["message"]
|
||||
l = "#{delivery_info.routing_key} => #{msg}"
|
||||
puts l if !msg.starts_with?("R") # Filter GCode
|
||||
end
|
||||
THROTTLE_POLICY.track(data.device_id)
|
||||
maybe_deliver(data)
|
||||
m = AmqpLogParser.run!(params)
|
||||
puts "#{m.device_id}: #{m.payload["message"]}" if Rails.env.production?
|
||||
THROTTLE_POLICY.track(m.device_id)
|
||||
maybe_deliver(m)
|
||||
end
|
||||
|
||||
def self.maybe_deliver(data)
|
||||
violation = THROTTLE_POLICY.is_throttled(data.device_id)
|
||||
ok = data.valid? && !violation
|
||||
ok = data.valid? && !violation
|
||||
|
||||
data.device.auto_sync_transaction do
|
||||
ok ? deliver(data) : warn_user(data, violation)
|
||||
|
|
Loading…
Reference in New Issue