rod,mmalmi

Keep assets/iris updated

The current version of Iris served by rod is 6 months old. Would be cool to add a script that keeps it updated.

https://github.com/mmalmi/rod/tree/master/assets/iris

Is it possible to do this with gun-rs?

I want to make a collaborative, crowd-sourced, distributed database of metadata, something like a distributed musicbrainz. When a user changes his metadata the change can be approved by voting on it by the other users, and when changes are approved they propagate to the other databases.

Motivation

What was your motivation to implement gun in Rust?
Maybe you can add a short sentence in the README.

Stats endpoint is not showing data and not sure node is peering

Running rod node on https://cosmic.rocks/stats

running with the following env vars:

env:
        - name: PEERS
          value: wss://gun-rs.iris.to/gun,wss://gun-us.herokuapp.com/gun
        - name: RUST_LOG
          value: debug

logs:

[2022-07-18T19:27:55Z INFO  rod::adapters::ws_conn] WsConn starting
[2022-07-18T19:27:55Z DEBUG rod::adapters::ws_conn] ws_conn in {"#":"LaZLAY3UnNEPjX0n","dam":"hi"}
[2022-07-18T19:27:55Z DEBUG rod::router] incoming message {"#":"LaZLAY3UnNEPjX0n","dam":"hi"}
[2022-07-18T19:27:55Z DEBUG rod::message] get node_id ~Eg13rRFEo6SfRJvOJQBMG_hTzHzuU2bLRU-dxvfDT6Q.C8ogs_7SHyFdjgGXeMhp8ugI8J0zsR8RwzuI6xJO_BA
[2022-07-18T19:27:55Z DEBUG rod::adapters::ws_conn] ws_conn in {"get":{"#":"~Eg13rRFEo6SfRJvOJQBMG_hTzHzuU2bLRU-dxvfDT6Q.C8ogs_7SHyFdjgGXeMhp8ugI8J0zsR8RwzuI6xJO_BA"},"#":"9zViFZ3Ei"}
[2022-07-18T19:27:55Z DEBUG rod::router] incoming message {"get":{"#":"~Eg13rRFEo6SfRJvOJQBMG_hTzHzuU2bLRU-dxvfDT6Q.C8ogs_7SHyFdjgGXeMhp8ugI8J0zsR8RwzuI6xJO_BA"},"#":"9zViFZ3Ei"}
[2022-07-18T19:27:55Z DEBUG rod::router] actor:XLyCBxqpa7LfnFG7cDHNIM2PtNWBqyc0 subscribed to ~Eg13rRFEo6SfRJvOJQBMG_hTzHzuU2bLRU-dxvfDT6Q.C8ogs_7SHyFdjgGXeMhp8ugI8J0zsR8RwzuI6xJO_BA
[2022-07-18T19:27:55Z DEBUG rod::router] send to server peer
[2022-07-18T19:27:55Z DEBUG rod::router] sent get to a random sample of subscribers of size 0
[2022-07-18T19:27:55Z DEBUG rod::adapters::sled_storage] SledStorage incoming message Get(Get { id: "9zViFZ3Ei", from: Addr { id: "XLyCBxqpa7LfnFG7cDHNIM2PtNWBqyc0", sender: UnboundedSender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7ff16c0f11c0, tail_position: 0 }, semaphore: 0, rx_waker: AtomicWaker, tx_count: 11, rx_fields: "..." } } } }, recipients: None, node_id: "~Eg13rRFEo6SfRJvOJQBMG_hTzHzuU2bLRU-dxvfDT6Q.C8ogs_7SHyFdjgGXeMhp8ugI8J0zsR8RwzuI6xJO_BA", checksum: None, child_key: None, json_str: Some("{\"get\":{\"#\":\"~Eg13rRFEo6SfRJvOJQBMG_hTzHzuU2bLRU-dxvfDT6Q.C8ogs_7SHyFdjgGXeMhp8ugI8J0zsR8RwzuI6xJO_BA\"},\"#\":\"9zViFZ3Ei\"}") })
[2022-07-18T19:27:55Z DEBUG rod::adapters::sled_storage] have not ~Eg13rRFEo6SfRJvOJQBMG_hTzHzuU2bLRU-dxvfDT6Q.C8ogs_7SHyFdjgGXeMhp8ugI8J0zsR8RwzuI6xJO_BA
[2022-07-18T19:27:55Z DEBUG rod::message] valid sig
[2022-07-18T19:27:55Z DEBUG rod::message] valid sig
[2022-07-18T19:27:55Z DEBUG rod::adapters::ws_conn] ws_conn in {"put":{"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI":{"_":{"#":"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI",">":{"activity":1658172475585.001}},"activity":"{\":\":{\"#\":\"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity\"},\"~\":\"ArVHRYYfnwow5kTto8gFqRTZ30b5Dx67TebR5Wymc1/bkmKl6Yr+UoP4quHLq9Dz5bNYiV9e83aCE+UFlxuNtg==\"}"},"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity":{"_":{"#":"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity",">":{"status":1658172475585.001,"time":1658172475585.001}},"status":"{\":\":\"online\",\"~\":\"s+g7KzJ6SD9hbi6qpWSiJLyafEKPrlxc2fS2y1ymMCbwmfjqsE4EzKRXiTkTBIuoUCX1QDsxk/ZWE+bW33D2Fw==\"}","time":"{\":\":\"2022-07-18T19:27:55.585Z\",\"~\":\"OglRdaCIZfbs5TCSyU8zo6v4SdkJPEycfwDYI7I+q7SYoHr6ZehnB8MVuylv7WAiQU17RdIovqFtw44v7ll5zw==\"}"}},"#":"5aJIIpVvw"}
[2022-07-18T19:27:55Z DEBUG rod::router] incoming message {"put":{"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI":{"_":{"#":"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI",">":{"activity":1658172475585.001}},"activity":"{\":\":{\"#\":\"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity\"},\"~\":\"ArVHRYYfnwow5kTto8gFqRTZ30b5Dx67TebR5Wymc1/bkmKl6Yr+UoP4quHLq9Dz5bNYiV9e83aCE+UFlxuNtg==\"}"},"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity":{"_":{"#":"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity",">":{"status":1658172475585.001,"time":1658172475585.001}},"status":"{\":\":\"online\",\"~\":\"s+g7KzJ6SD9hbi6qpWSiJLyafEKPrlxc2fS2y1ymMCbwmfjqsE4EzKRXiTkTBIuoUCX1QDsxk/ZWE+bW33D2Fw==\"}","time":"{\":\":\"2022-07-18T19:27:55.585Z\",\"~\":\"OglRdaCIZfbs5TCSyU8zo6v4SdkJPEycfwDYI7I+q7SYoHr6ZehnB8MVuylv7WAiQU17RdIovqFtw44v7ll5zw==\"}"}},"#":"5aJIIpVvw"}
[2022-07-18T19:27:55Z DEBUG rod::router] sent put to 1 subscribers
[2022-07-18T19:27:55Z DEBUG rod::adapters::sled_storage] SledStorage incoming message Put(Put { id: "5aJIIpVvw", from: Addr { id: "XLyCBxqpa7LfnFG7cDHNIM2PtNWBqyc0", sender: UnboundedSender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7ff16c0f11c0, tail_position: 0 }, semaphore: 0, rx_waker: AtomicWaker, tx_count: 12, rx_fields: "..." } } } }, recipients: None, in_response_to: None, updated_nodes: {"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI": {"activity": NodeData { value: Text("{\":\":{\"#\":\"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity\"},\"~\":\"ArVHRYYfnwow5kTto8gFqRTZ30b5Dx67TebR5Wymc1/bkmKl6Yr+UoP4quHLq9Dz5bNYiV9e83aCE+UFlxuNtg==\"}"), updated_at: 1658172475585.001 }}, "~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity": {"status": NodeData { value: Text("{\":\":\"online\",\"~\":\"s+g7KzJ6SD9hbi6qpWSiJLyafEKPrlxc2fS2y1ymMCbwmfjqsE4EzKRXiTkTBIuoUCX1QDsxk/ZWE+bW33D2Fw==\"}"), updated_at: 1658172475585.001 }, "time": NodeData { value: Text("{\":\":\"2022-07-18T19:27:55.585Z\",\"~\":\"OglRdaCIZfbs5TCSyU8zo6v4SdkJPEycfwDYI7I+q7SYoHr6ZehnB8MVuylv7WAiQU17RdIovqFtw44v7ll5zw==\"}"), updated_at: 1658172475585.001 }}}, checksum: None, json_str: Some("{\"put\":{\"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI\":{\"_\":{\"#\":\"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI\",\">\":{\"activity\":1658172475585.001}},\"activity\":\"{\\\":\\\":{\\\"#\\\":\\\"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity\\\"},\\\"~\\\":\\\"ArVHRYYfnwow5kTto8gFqRTZ30b5Dx67TebR5Wymc1/bkmKl6Yr+UoP4quHLq9Dz5bNYiV9e83aCE+UFlxuNtg==\\\"}\"},\"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity\":{\"_\":{\"#\":\"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity\",\">\":{\"status\":1658172475585.001,\"time\":1658172475585.001}},\"status\":\"{\\\":\\\":\\\"online\\\",\\\"~\\\":\\\"s+g7KzJ6SD9hbi6qpWSiJLyafEKPrlxc2fS2y1ymMCbwmfjqsE4EzKRXiTkTBIuoUCX1QDsxk/ZWE+bW33D2Fw==\\\"}\",\"time\":\"{\\\":\\\":\\\"2022-07-18T19:27:55.585Z\\\",\\\"~\\\":\\\"OglRdaCIZfbs5TCSyU8zo6v4SdkJPEycfwDYI7I+q7SYoHr6ZehnB8MVuylv7WAiQU17RdIovqFtw44v7ll5zw==\\\"}\"}},\"#\":\"5aJIIpVvw\"}") })
[2022-07-18T19:27:55Z DEBUG rod::adapters::sled_storage] saving k-v ~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity: {"status": NodeData { value: Text("{\":\":\"online\",\"~\":\"s+g7KzJ6SD9hbi6qpWSiJLyafEKPrlxc2fS2y1ymMCbwmfjqsE4EzKRXiTkTBIuoUCX1QDsxk/ZWE+bW33D2Fw==\"}"), updated_at: 1658172475585.001 }, "time": NodeData { value: Text("{\":\":\"2022-07-18T19:27:55.585Z\",\"~\":\"OglRdaCIZfbs5TCSyU8zo6v4SdkJPEycfwDYI7I+q7SYoHr6ZehnB8MVuylv7WAiQU17RdIovqFtw44v7ll5zw==\"}"), updated_at: 1658172475585.001 }}
[2022-07-18T19:27:55Z DEBUG sled::meta] allocated pid 11 for root of new_tree [126, 107, 74, 98, 117, 105, 107, 69, 100, 50, 84, 97, 84, 55, 51, 75, 55, 73, 106, 79, 65, 121, 71, 113, 82, 101, 101, 49, 108, 101, 88, 45, 66, 49, 108, 85, 52, 106, 54, 74, 80, 89, 51, 69, 46, 102, 78, 121, 118, 108, 54, 80, 107, 105, 112, 78, 81, 68, 101, 99, 106, 110, 117, 121, 118, 106, 80, 112, 79, 73, 106, 87, 122, 98, 80, 71, 54, 110, 110, 45, 119, 122, 89, 98, 69, 45, 100, 73, 47, 97, 99, 116, 105, 118, 105, 116, 121]
[2022-07-18T19:27:55Z DEBUG rod::adapters::sled_storage] ~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity.status new priority 103
[2022-07-18T19:27:55Z DEBUG rod::adapters::sled_storage] old 0000000001 new 0000001031
[2022-07-18T19:27:55Z DEBUG rod::adapters::sled_storage] ~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity.time new priority 103
[2022-07-18T19:27:55Z DEBUG rod::adapters::sled_storage] old 0000000002 new 0000001032
[2022-07-18T19:27:55Z DEBUG rod::adapters::sled_storage] saving k-v ~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI: {"activity": NodeData { value: Text("{\":\":{\"#\":\"~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI/activity\"},\"~\":\"ArVHRYYfnwow5kTto8gFqRTZ30b5Dx67TebR5Wymc1/bkmKl6Yr+UoP4quHLq9Dz5bNYiV9e83aCE+UFlxuNtg==\"}"), updated_at: 1658172475585.001 }}
[2022-07-18T19:27:55Z DEBUG sled::meta] allocated pid 13 for root of new_tree [126, 107, 74, 98, 117, 105, 107, 69, 100, 50, 84, 97, 84, 55, 51, 75, 55, 73, 106, 79, 65, 121, 71, 113, 82, 101, 101, 49, 108, 101, 88, 45, 66, 49, 108, 85, 52, 106, 54, 74, 80, 89, 51, 69, 46, 102, 78, 121, 118, 108, 54, 80, 107, 105, 112, 78, 81, 68, 101, 99, 106, 110, 117, 121, 118, 106, 80, 112, 79, 73, 106, 87, 122, 98, 80, 71, 54, 110, 110, 45, 119, 122, 89, 98, 69, 45, 100, 73]
[2022-07-18T19:27:55Z DEBUG rod::adapters::sled_storage] ~kJbuikEd2TaT73K7IjOAyGqRee1leX-B1lU4j6JPY3E.fNyvl6PkipNQDecjnuyvjPpOIjWzbPG6nn-wzYbE-dI.activity new priority 103
[2022-07-18T19:27:55Z DEBUG rod::adapters::sled_storage] old 0000000003 new 0000001033
[2022-07-18T19:27:55Z DEBUG rod::message] get node_id ~ms8w_jIFxdB-WVv3Ds7YfOtK_EfTQoW4vBnzWhVwOIc.JwgUO4mMKT42NhWh9MmVFCIeRGBqp0PmQ9ck2scU3oQ
[2022-07-18T19:27:55Z DEBUG rod::adapters::ws_conn] ws_conn in {"get":{"#":"~ms8w_jIFxdB-WVv3Ds7YfOtK_EfTQoW4vBnzWhVwOIc.JwgUO4mMKT42NhWh9MmVFCIeRGBqp0PmQ9ck2scU3oQ"},"#":"kbW9T6RvM"}
[2022-07-18T19:27:55Z DEBUG rod::router] incoming message {"get":{"#":"~ms8w_jIFxdB-WVv3Ds7YfOtK_EfTQoW4vBnzWhVwOIc.JwgUO4mMKT42NhWh9MmVFCIeRGBqp0PmQ9ck2scU3oQ"},"#":"kbW9T6RvM"}
[2022-07-18T19:27:55Z DEBUG rod::router] actor:XLyCBxqpa7LfnFG7cDHNIM2PtNWBqyc0 subscribed to ~ms8w_jIFxdB-WVv3Ds7YfOtK_EfTQoW4vBnzWhVwOI

Plan for implementing encryption?

I’m wondering if there is a plan in place for implementing encryption (and using it for Iris messaging).

I know Rust has a couple really mature encryption crates. Have they been assessed or chosen for this yet?

Idea: Couple this with rust-lightning?

I noticed that this new Lightning SDK is agnostic about storage. https://lightningdevkit.org/

Our API's let you choose how to backup channel state. This gives you multi-wallet device access and lets you save state locally, to the cloud or an alternative backup scheme.

Wondering if it would make sense to combine gun-rs with https://github.com/lightningdevkit as one deployable solution for messaging/social + storage and money. Iris would provide the context around the economy because you could then also use the Iris pubkey as the identifier for who to open channels with as well (although Iris need not be included to just leverage gun-rs as Lightning state storage).

send before subscribe

question - in node.on() the subscribed receiver is created after message send, here:

https://github.com/mmalmi/rod/blob/aa987583d9ea7d47157fbb3ed69bc3dc59e503dc/src/node.rs#L198C23-L202

if let Some(router) = self.router.read().unwrap().clone() {
    let _ = router.send(Message::Get(get));
}
self.on_sender.subscribe()

The broadcast docs even put in bold the word after for some reason

I know router.send will reach more indirection, more channels, more messages - but it's theoretically possible the race flips and we lose the first value, right?

Any reason not to flip the subscribe before the send?

let subscriber = self.on_sender.subscribe();
if let Some(router) = self.router.read().unwrap().clone() {
    let _ = router.send(Message::Get(get));
}
subscriber

rust library: how to get node value?

In rust, using this as a library, we got get(), put(), on(), map(), but no val().

There's no way to get the value from a node, other than subscribing to it and overwriting something else, thus losing the initial value.

mmalmi / rod Goto Github PK

rod's Introduction

Rod

Use

Install & run

Library

Status

Issues

Develop

Run on Heroku

rod's People

Contributors

Stargazers

Watchers

Forkers

rod's Issues

Recommend Projects

Recommend Topics

Recommend Org