Skip to content

Propagate signature verification and peer kinds to behaviour #46

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 12 commits into from
Aug 12, 2020
Merged

Propagate signature verification and peer kinds to behaviour #46

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
0dd61d7
Merge remote-tracking branch 'origin/gossip-cache-update' into gossip…
blacktemplar Aug 7, 2020
9dcaef3
Propagate signature verification and peer kinds to behaviour
AgeManning Aug 10, 2020
a06edc3
Propagate validation errors to the behaviour
AgeManning Aug 10, 2020
b249840
handle peer kind + fix flaky test
blacktemplar Aug 10, 2020
ad8d311
Inform the behaviour of invalid messages
AgeManning Aug 11, 2020
53d0ed2
Correct duplicate cache
AgeManning Aug 11, 2020
089427a
penalize invalid messages
blacktemplar Aug 11, 2020
25c78c9
Merge branch '1.1-peer-ident' into gossipsub-v1.1-my-cache-adaptions
blacktemplar Aug 11, 2020
f952359
generalize DuplicateCache to TimeCache + implement minimalistic Entry…
blacktemplar Aug 11, 2020
6561a3d
fix warnings in test
blacktemplar Aug 11, 2020
1736a04
remove accidentally added benchmark functions
blacktemplar Aug 11, 2020
c1a403c
Handle peers that do not support the protocol
AgeManning Aug 12, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 6 additions & 2 deletions examples/gossipsub-chat.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@
use async_std::{io, task};
use env_logger::{Builder, Env};
use futures::prelude::*;
use libp2p::gossipsub::protocol::MessageId;
use libp2p::gossipsub::MessageId;
use libp2p::gossipsub::{
GossipsubEvent, GossipsubMessage, IdentTopic as Topic, MessageAuthenticity,
};
Expand Down Expand Up @@ -142,7 +142,11 @@ fn main() -> Result<(), Box<dyn Error>> {
loop {
match swarm.poll_next_unpin(cx) {
Poll::Ready(Some(gossip_event)) => match gossip_event {
GossipsubEvent::Message(peer_id, id, message) => println!(
GossipsubEvent::Message{
propagation_source: peer_id,
message_id: id,
message
} => println!(
"Got message: {} with id: {} from peer: {:?}",
String::from_utf8_lossy(&message.data),
id,
Expand Down
6 changes: 5 additions & 1 deletion examples/ipfs-private.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -189,7 +189,11 @@ fn main() -> Result<(), Box<dyn Error>> {
// Called when `gossipsub` produces an event.
fn inject_event(&mut self, event: GossipsubEvent) {
match event {
GossipsubEvent::Message(peer_id, id, message) => println!(
GossipsubEvent::Message {
propagation_source: peer_id,
message_id: id,
message
} => println!(
"Got message: {} with id: {} from peer: {:?}",
String::from_utf8_lossy(&message.data),
id,
Expand Down
Loading