Sha256: d953cef93af5fe1d3edbc7286ceb72bb41e5ac77067af7d3766ea69331526b54
Contents?: true
Size: 970 Bytes
Versions: 22
Compression:
Stored size: 970 Bytes
Contents
module Helium
class DataPoint < Resource
attr_reader :timestamp, :value, :port
def initialize(opts = {})
super(opts)
@timestamp = @params.dig("attributes", "timestamp")
@value = @params.dig("attributes", "value")
@port = @params.dig("attributes", "port")
end
def timestamp
DateTime.parse(@timestamp)
end
def max
return nil unless @value.is_a?(Hash)
@value["max"]
end
def min
return nil unless @value.is_a?(Hash)
@value["min"]
end
def avg
return nil unless @value.is_a?(Hash)
@value["avg"]
end
def aggregate?
[max, min, avg].none? { |agg_value| agg_value.nil? }
end
def as_json
j = super.merge({
timestamp: timestamp,
port: port
})
if aggregate?
j[:max] = max
j[:min] = min
j[:avg] = avg
else
j[:value] = value
end
j
end
end
end
Version data entries
22 entries across 22 versions & 1 rubygems