From 4c1710969a555dffc81dc88b89ce5bb8a6a02d08 Mon Sep 17 00:00:00 2001
From: Petko <pavlovskipetko@gmail.com>
Date: Mon, 7 Nov 2022 17:39:13 +0100
Subject: [PATCH] Start ping pong example.

---
 examples/ping-pong/Cargo.toml  | 15 ++++++
 examples/ping-pong/src/main.rs | 98 ++++++++++++++++++++++++++++++++++
 2 files changed, 113 insertions(+)
 create mode 100644 examples/ping-pong/Cargo.toml
 create mode 100644 examples/ping-pong/src/main.rs

diff --git a/examples/ping-pong/Cargo.toml b/examples/ping-pong/Cargo.toml
new file mode 100644
index 0000000..7203ccd
--- /dev/null
+++ b/examples/ping-pong/Cargo.toml
@@ -0,0 +1,15 @@
+[package]
+name = "ping-pong"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+waku = { path = "../../waku-bindings" }
+prost = "0.11"
+once_cell = "1.15"
+chrono = "0.4"
+serde = "1.0.147"
+serde_json = "1.0.87"
+
diff --git a/examples/ping-pong/src/main.rs b/examples/ping-pong/src/main.rs
new file mode 100644
index 0000000..9a75993
--- /dev/null
+++ b/examples/ping-pong/src/main.rs
@@ -0,0 +1,98 @@
+use chrono::Utc;
+use once_cell::sync::Lazy;
+use prost::Message;
+
+use std::{error::Error, str::FromStr, thread::sleep, time::Duration};
+use waku::{
+    waku_new, waku_set_event_callback, Encoding, Multiaddr, ProtocolId, Running, Signal,
+    WakuContentTopic, WakuMessage, WakuNodeHandle, WakuPubSubTopic,
+};
+
+#[derive(Clone, Message)]
+pub struct BasicMessage {
+    #[prost(string, tag = "1")]
+    payload: String,
+}
+
+impl BasicMessage {
+    fn new(payload: String) -> Self {
+        BasicMessage { payload }
+    }
+}
+
+fn setup_node_handle() -> std::result::Result<WakuNodeHandle<Running>, Box<dyn Error>> {
+    const NODES: &[&str] = &[
+    "/dns4/node-01.ac-cn-hongkong-c.wakuv2.test.statusim.net/tcp/30303/p2p/16Uiu2HAkvWiyFsgRhuJEb9JfjYxEkoHLgnUQmr1N5mKWnYjxYRVm",
+    "/dns4/node-01.do-ams3.wakuv2.test.statusim.net/tcp/30303/p2p/16Uiu2HAmPLe7Mzm8TsYUubgCAW1aJoeFScxrLj8ppHFivPo97bUZ",
+    "/dns4/node-01.gc-us-central1-a.wakuv2.test.statusim.net/tcp/30303/p2p/16Uiu2HAmJb2e28qLXxT5kZxVUUoJt72EMzNGXB47Rxx5hw3q4YjS"
+];
+
+    let node_handle = waku_new(None)?;
+    let node_handle = node_handle.start()?;
+    for address in NODES
+        .iter()
+        .map(|a| Multiaddr::from_str(a).expect("Could not parse address"))
+    {
+        let peerid = node_handle.add_peer(&address, ProtocolId::Relay)?;
+        node_handle.connect_peer_with_id(peerid, None)?;
+    }
+    node_handle.relay_subscribe(Some(WakuPubSubTopic {
+        topic_name: String::from("ping-pong"),
+        encoding: Encoding::Proto,
+    }))?;
+    Ok(node_handle)
+}
+
+pub static BASIC_TOPIC: Lazy<WakuContentTopic> = Lazy::new(|| WakuContentTopic {
+    application_name: String::from("waku"),
+    version: 2,
+    content_topic_name: String::from("ping-pong"),
+    encoding: Encoding::Proto,
+});
+
+fn main() {
+    let node_handle = setup_node_handle().unwrap();
+
+    waku_set_event_callback(move |signal: Signal| match signal.event() {
+        // waku::Event::WakuMessage(event) => {
+        //     match <BasicMessage as Message>::decode(event.waku_message().payload()) {
+        //         Ok(basic_message) => {
+        //             println!("New message received! \n{:?}", basic_message);
+        //         }
+        //         Err(e) => {
+        //             println!("Error occurred!\n {:?}", e);
+        //         }
+        //     }
+        // }
+        // waku::Event::Unrecognized(data) => {
+        //     println!("Unrecognized event!\n {:?}", data);
+        // }
+        _ => {
+            println!("signal! {:?}", serde_json::to_string(&signal));
+        }
+    });
+
+    let payload = String::from("This is the message payload");
+    let message = BasicMessage::new(payload);
+    let mut buff = Vec::new();
+    Message::encode(&message, &mut buff).expect("Could not encode :(");
+
+    let waku_message = WakuMessage::new(
+        buff,
+        BASIC_TOPIC.clone(),
+        2,
+        Utc::now().timestamp() as usize,
+    );
+
+    println!("{:?}", waku_message);
+
+    let res = node_handle
+        .relay_publish_message(&waku_message, None, None)
+        .expect("Could not send message.");
+
+    println!("{:?}", res);
+
+    loop {
+        sleep(Duration::new(1, 0));
+    }
+}