calimero_network/handlers/
commands.rs

1use actix::Handler;
2use calimero_network_primitives::messages::NetworkMessage;
3use calimero_utils_actix::adapters::ActorExt;
4
5use crate::NetworkManager;
6
7mod announce_blob;
8mod bootstrap;
9mod dial;
10mod listen;
11mod mesh_peer_count;
12mod mesh_peers;
13mod open_stream;
14mod peer_count;
15mod publish;
16mod query_blob;
17mod request_blob;
18mod send_specialized_node_invitation_response;
19mod send_specialized_node_verification_request;
20mod subscribe;
21mod unsubscribe;
22
23impl Handler<NetworkMessage> for NetworkManager {
24    type Result = ();
25
26    fn handle(&mut self, msg: NetworkMessage, ctx: &mut Self::Context) -> Self::Result {
27        match msg {
28            NetworkMessage::Dial { request, outcome } => {
29                self.forward_handler(ctx, request, outcome);
30            }
31            NetworkMessage::ListenOn { request, outcome } => {
32                self.forward_handler(ctx, request, outcome);
33            }
34            NetworkMessage::Bootstrap { request, outcome } => {
35                self.forward_handler(ctx, request, outcome);
36            }
37            NetworkMessage::Subscribe { request, outcome } => {
38                self.forward_handler(ctx, request, outcome);
39            }
40            NetworkMessage::Unsubscribe { request, outcome } => {
41                self.forward_handler(ctx, request, outcome);
42            }
43            NetworkMessage::Publish { request, outcome } => {
44                self.forward_handler(ctx, request, outcome);
45            }
46            NetworkMessage::OpenStream { request, outcome } => {
47                self.forward_handler(ctx, request, outcome);
48            }
49            NetworkMessage::PeerCount { request, outcome } => {
50                self.forward_handler(ctx, request, outcome);
51            }
52            NetworkMessage::MeshPeers { request, outcome } => {
53                self.forward_handler(ctx, request, outcome);
54            }
55            NetworkMessage::MeshPeerCount { request, outcome } => {
56                self.forward_handler(ctx, request, outcome);
57            }
58            NetworkMessage::AnnounceBlob { request, outcome } => {
59                self.forward_handler(ctx, request, outcome);
60            }
61            NetworkMessage::QueryBlob { request, outcome } => {
62                self.forward_handler(ctx, request, outcome);
63            }
64            NetworkMessage::RequestBlob { request, outcome } => {
65                self.forward_handler(ctx, request, outcome);
66            }
67            NetworkMessage::SendSpecializedNodeVerificationRequest { request, outcome } => {
68                self.forward_handler(ctx, request, outcome);
69            }
70            NetworkMessage::SendSpecializedNodeInvitationResponse { request, outcome } => {
71                self.forward_handler(ctx, request, outcome);
72            }
73        }
74    }
75}
calimero_network/handlers/commands.rs

calimero_network/handlers/
commands.rs
