require "json" require "./ipc.cr" class IPC::JSON include ::JSON::Serializable @[::JSON::Field(ignored: true)] getter type = -1 class_getter type = -1 property id : ::JSON::Any? macro message(id, type, &block) class {{id}} < ::IPC::JSON include ::JSON::Serializable @@type = {{type}} def type @@type end {{yield}} end end end class IPC::Connection def send(message : IPC::JSON) send message.type.to_u8, message.to_json end end # CAUTION: Only use this method on an Array(IPC::JSON.class) class Array(T) def parse_ipc_json(messages : Array(IPC::JSON.class), message : IPC::Message) : IPC::JSON? message_type = find &.type.==(message.utype) payload = String.new message.payload if message_type.nil? raise "invalid message type (#{message.utype})" end message_type.from_json payload end end