module Riffer::Rig::Headless::Ndjson

# File lib/riffer/rig/headless/ndjson.rb, line 22
def envelope(event)
  json_hash(event.to_h).merge('type' => event_type(event))
end

# File lib/riffer/rig/headless/ndjson.rb, line 16
def error(message)
  "#{JSON.generate({ 'type' => 'error', 'message' => message })}\n"
end

# File lib/riffer/rig/headless/ndjson.rb, line 34
def event_type(event)
  event.class.name.to_s.split('::').last.to_s.gsub(/(?<=[a-z\d])(?=[A-Z])|(?<=[A-Z])(?=[A-Z][a-z])/, '_').downcase
end

# File lib/riffer/rig/headless/ndjson.rb, line 28
def json_hash(hash)
  hash.to_h { |key, item| [key.to_s, json_value(item)] }
end

# File lib/riffer/rig/headless/ndjson.rb, line 40
def json_value(value)
  case value
  when String, Integer, Float, true, false, nil then value
  when Symbol then value.to_s
  when Hash then value.to_h { |key, item| [key.to_s, json_value(item)] }
  when Enumerable then value.map { |item| json_value(item) }
  else value.respond_to?(:to_h) ? json_value(value.to_h) : value.to_s
  end
end

# File lib/riffer/rig/headless/ndjson.rb, line 10
def line(event)
  "#{JSON.generate(envelope(event))}\n"
end