use actix::Message;
use calimero_primitives::context::ContextId;
use calimero_primitives::identity::PublicKey;
use tokio::sync::oneshot;
pub mod get_blob_bytes;
use get_blob_bytes::GetBlobBytesRequest;
#[derive(Clone, Debug)]
pub struct RegisterPendingSpecializedNodeInvite {
pub nonce: [u8; 32],
pub context_id: ContextId,
pub inviter_id: PublicKey,
}
#[derive(Clone, Debug)]
pub struct RemovePendingSpecializedNodeInvite {
pub nonce: [u8; 32],
}
#[derive(Debug, Message)]
#[rtype("()")]
pub enum NodeMessage {
GetBlobBytes {
request: GetBlobBytesRequest,
outcome: oneshot::Sender<<GetBlobBytesRequest as Message>::Result>,
},
RegisterPendingSpecializedNodeInvite {
request: RegisterPendingSpecializedNodeInvite,
},
RemovePendingSpecializedNodeInvite {
request: RemovePendingSpecializedNodeInvite,
},
}