From 0f52ca1b2a94a8f51e4f35a780cad4d73be0d420 Mon Sep 17 00:00:00 2001 From: Luka Vandervelden Date: Thu, 14 May 2020 17:35:37 +0200 Subject: [PATCH] WIP ipc/json. --- src/json.cr | 48 ++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 48 insertions(+) create mode 100644 src/json.cr diff --git a/src/json.cr b/src/json.cr new file mode 100644 index 0000000..d657e27 --- /dev/null +++ b/src/json.cr @@ -0,0 +1,48 @@ +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 +