Sha256: 58bc93706cf2e94ab27808438f13ee95496b7827ff189191f59cf05501c53f4d
Contents?: true
Size: 1.64 KB
Versions: 12
Compression:
Stored size: 1.64 KB
Contents
require "json"
require "sinatra"
class Chef
class Node
# dummy class for JSON parsing
end
end
module ApiHelpers
def self.payload_type(payload)
message_type = payload["message_type"]
status = payload["status"]
message_type == "run_converge" ? "#{message_type}.#{status}" : message_type
end
end
class Counter
class << self
attr_accessor :counters
def counters
@counters ||= Hash.new { |h, k| h[k] = 0 }
end
def reset
@counters = nil
end
def increment(payload)
counter_name = ApiHelpers.payload_type(payload)
counters[counter_name] += 1
end
def to_json
counters.to_json
end
end
end
class MessageCache
include ApiHelpers
class << self
attr_accessor :message_cache
def message_cache
@message_cache ||= {}
end
def reset
@message_cache = nil
end
def store(payload)
cache_key = ApiHelpers.payload_type(payload)
message_cache[cache_key] = payload
end
def fetch(cache_key)
message_cache[cache_key].to_json
end
end
end
Counter.reset
get "/" do
"Data Collector API server"
end
get "/reset-counters" do
Counter.reset
"counters reset"
end
get "/counters" do
Counter.to_json
end
get "/cache/:key" do |cache_key|
MessageCache.fetch(cache_key)
end
get "/reset-cache" do
MessageCache.reset
"cache reset"
end
post "/data-collector/v0" do
body = request.body.read
payload = JSON.load(body)
Counter.increment(payload)
MessageCache.store(payload)
status 201
"message received"
end
Version data entries
12 entries across 12 versions & 1 rubygems