Struct PubsubMessage 

pub struct PubsubMessage {
    pub from: String,
    pub data: Vec<u8>,
    pub seqno: Vec<u8>,
    pub topic_ids: Vec<String>,
    pub topic: String,
}

A message received from or published to a pubsub topic.

Kubo Equivalent

Corresponds to the message format used in ipfs pubsub sub output. See core/commands/pubsub.go:pubsubSubCmd.

Example

use ferripfs_network::PubsubMessage;

// Create a simple message with just sender, topic, and data
let msg = PubsubMessage::simple(
    "QmPeerID".to_string(),
    "my-topic".to_string(),
    b"Hello, world!".to_vec(),
);
assert_eq!(msg.topic, "my-topic");

// Or create a message with all fields
let msg_full = PubsubMessage::new(
    "QmPeerID".to_string(),
    b"Hello!".to_vec(),
    vec![1, 2, 3, 4],  // seqno
    vec!["my-topic".to_string()],  // topic_ids
    "my-topic".to_string(),
);
assert_eq!(msg_full.seqno, vec![1, 2, 3, 4]);

Fields

from: String

Peer ID of the message sender.

data: Vec<u8>

Data payload (base64 encoded in JSON).

seqno: Vec<u8>

Sequence number for ordering.

topic_ids: Vec<String>

Topic IDs the message was received on.

topic: String

Primary topic (convenience field).

Implementations

impl PubsubMessage

pub fn new( from: String, data: Vec<u8>, seqno: Vec<u8>, topic_ids: Vec<String>, topic: String, ) -> Self

Create a new pubsub message with all fields.

Arguments

• from - Peer ID of the sender
• data - Message payload
• seqno - Sequence number bytes
• topic_ids - List of topic IDs
• topic - Primary topic

pub fn simple(from: String, topic: String, data: Vec<u8>) -> Self

Create a simple message for a single topic.

This is a convenience method that sets seqno to empty and derives topic_ids from the single topic.

pub fn with_seqno( from: String, topic: String, data: Vec<u8>, seqno: Vec<u8>, ) -> Self

Create a message with a sequence number.

pub fn data_string(&self) -> Option<String>

Get the message data as a UTF-8 string (if valid).

Trait Implementations

impl Clone for PubsubMessage

fn clone(&self) -> PubsubMessage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PubsubMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PubsubMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PubsubMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.