59 lines
1.1 KiB
Crystal
59 lines
1.1 KiB
Crystal
require "cbor"
|
|
|
|
require "./ipc.cr"
|
|
|
|
class IPC::CBOR
|
|
include ::CBOR::Serializable
|
|
|
|
#@[::CBOR::Field(ignored: true)]
|
|
#getter type = -1
|
|
class_getter type = -1
|
|
|
|
property id : ::CBOR::Any?
|
|
def type
|
|
@@type
|
|
end
|
|
|
|
macro message(id, type, &block)
|
|
class {{id}} < ::IPC::CBOR
|
|
include ::CBOR::Serializable
|
|
|
|
@@type = {{type}}
|
|
|
|
{{yield}}
|
|
end
|
|
end
|
|
end
|
|
|
|
class IPC::Context
|
|
def send(fd : Int32, message : IPC::CBOR)
|
|
send fd, message.type.to_u8, message.to_cbor
|
|
end
|
|
def send_now(fd : Int32, message : IPC::CBOR)
|
|
send_now fd, message.type.to_u8, message.to_cbor
|
|
end
|
|
end
|
|
|
|
class IPC::Client
|
|
def send(message : IPC::CBOR)
|
|
send @server_fd.not_nil!, message.type.to_u8, message.to_cbor
|
|
end
|
|
def send_now(message : IPC::CBOR)
|
|
send_now @server_fd.not_nil!, message.type.to_u8, message.to_cbor
|
|
end
|
|
end
|
|
|
|
# CAUTION: Only use this method on an Array(IPC::CBOR.class)
|
|
class Array(T)
|
|
def parse_ipc_cbor(message : IPC::Message) : IPC::CBOR?
|
|
message_type = find &.type.==(message.utype)
|
|
|
|
if message_type.nil?
|
|
raise "invalid message type (#{message.utype})"
|
|
end
|
|
|
|
message_type.from_cbor message.payload
|
|
end
|
|
end
|
|
|