We now need to implement a custom protocol which defines how our chat program interacts with the p2p network.
We've already interacted with several protocols already. Protocols are automatically activated when nodes connect to eachother on the p2p network. Here are examples of two protocols that every node runs continuously in the background:
ProtocolPing: sends ping, receives pong ProtocolAddress: receives a get_address message, sends an address message
Under the hood, these protocols have a few similarities:
This introduces several generic interfaces that we must use to build our custom protocol. In particular:
MessageSubsystem is a generic publish/subscribe class that can dispatch any kind of message to a list of dispatchers. This is how we can send and receive custom messages on the p2p network.
A subscription to a message type.
ProtocolRegistry takes any kind of generic protocol and initializes it. We use it through the method register() which passes a protocol constructor and a session bitflag which determines which sessions (outbound, inbound, or seed) will run our protocol.
An asynchronous job manager that spawns and stops tasks created by protocols across the network.
A generic protocol trait that all protocols must implement.