-type bridge_data_msg() :: #{payload := term(), source_node_id => binary(), metadata => map()}.

-type bridge_rpc_msg() ::
          #{procedure := binary(),
            args := map(),
            call_id := binary(),
            source_level := atom(),
            timeout => integer()}.

-type call_msg() ::
          #{procedure := binary(), args := binary(), call_id := binary(), timeout => integer()}.

-type cast_msg() :: #{procedure := binary(), args := binary()}.

-type connect_msg() ::
          #{version := binary(),
            node_id := binary(),
            realm_id := binary(),
            capabilities := [atom()],
            endpoint => binary()}.

-type disconnect_msg() :: #{reason := atom(), message := binary()}.

-type message() ::
          {connect, connect_msg()} |
          {disconnect, disconnect_msg()} |
          {ping, ping_msg()} |
          {pong, pong_msg()} |
          {publish, publish_msg()} |
          {subscribe, subscribe_msg()} |
          {unsubscribe, unsubscribe_msg()} |
          {pubsub_route, pubsub_route_msg()} |
          {call, call_msg()} |
          {reply, reply_msg()} |
          {cast, cast_msg()} |
          {rpc_route, rpc_route_msg()}.

-type message_type() ::
          connect | disconnect | ping | pong | publish | subscribe | unsubscribe | pubsub_route | call |
          reply | cast | rpc_route | rpc_request | rpc_reply | swim_ping | swim_ack | swim_ping_req |
          find_node | find_node_reply | store | find_value | find_value_reply | nat_probe |
          nat_probe_reply | punch_request | punch_coordinate | punch_execute | punch_result |
          relay_request | relay_data | bridge_rpc | bridge_data.

-type ping_msg() :: #{timestamp := integer()}.

-type pong_msg() :: #{timestamp := integer(), server_time := integer()}.

-type publish_msg() ::
          #{topic := binary(),
            payload := binary(),
            qos := 0 | 1 | 2,
            retain := boolean(),
            message_id := binary()}.

-type pubsub_route_msg() :: #{binary() => term()}.

-type reply_msg() ::
          #{call_id := binary(), result => binary(), error => #{code := binary(), message := binary()}}.

-type rpc_route_msg() :: #{binary() => term()}.

-type subscribe_msg() :: #{topics := [binary()], qos := 0 | 1 | 2}.

-type unsubscribe_msg() :: #{topics := [binary()]}.