Merge branch 'feat/pub-sub' into 'dev'

feat(rosenet-node): add pubsub methods

Closes #65

See merge request ergo/rosen-bridge/rosenet!27

.changeset/neat-hotels-accept.md

@@ -0,0 +1,6 @@
+---
+'@rosen-bridge/rosenet-relay': minor
+'@rosen-bridge/rosenet-node': minor
+---
+
+add pubsub apis

.github/workflows/scaling-test-docker-release.yml

@@ -10,7 +10,7 @@ jobs:
     strategy:
       matrix:
         role: [node, relay]
-        test-name: ['', peer-discovery]
+        test-name: ['', peer-discovery, pubsub]
 
     name: Build and Push Scaling Test Docker Image
     permissions: write-all

.gitignore

@@ -135,3 +135,5 @@ dist
 tests/*/.terraform
 tests/*/*.tfstate*
 tests/*/terraform.tfvars
+
+.vscode/settings.json

packages/rosenet-node/lib/createRoseNetNode.ts

@@ -69,8 +69,18 @@ const createRoseNetNode = async ({
       tcp(),
     ],
     addresses: {
-      listen: [`/ip4/0.0.0.0/tcp/${port}`],
-      announce: [announceMultiaddr],
+      listen: [
+        `/ip4/0.0.0.0/tcp/${port}`,
+        ...config.relayMultiaddrs.map(
+          (multiaddr) => `${multiaddr}/p2p-circuit`,
+        ),
+      ],
+      announce: [
+        announceMultiaddr,
+        ...config.relayMultiaddrs.map(
+          (multiaddr) => `${multiaddr}/p2p-circuit`,
+        ),
+      ],
     },
     connectionEncryption: [noise()],
     connectionGater: {
@@ -97,7 +107,10 @@ const createRoseNetNode = async ({
     },
     services: {
       identify: identify(),
-      pubsub: gossipsub({ allowPublishToZeroPeers: true }),
+      pubsub: gossipsub({
+        allowPublishToZeroPeers: true,
+        runOnTransientConnection: true,
+      }),
     },
   });
   RoseNetNodeContext.logger.debug('RoseNet node created');
@@ -151,6 +164,19 @@ const createRoseNetNode = async ({
         `handler for ${ROSENET_DIRECT_PROTOCOL_V1} protocol set`,
       );
     },
+    publish: async (topic: string, message: string) => {
+      const textEncoder = new TextEncoder();
+      node.services.pubsub.publish(topic, textEncoder.encode(message));
+    },
+    subscribe: async (topic: string, handler: (message: string) => void) => {
+      node.services.pubsub.subscribe(topic);
+      node.services.pubsub.addEventListener('message', (event) => {
+        if (event.detail.topic === topic) {
+          const textDecoder = new TextDecoder();
+          handler(textDecoder.decode(event.detail.data));
+        }
+      });
+    },
   };
 };
 

packages/rosenet-relay/lib/createRoseNetRelay.ts

@@ -72,7 +72,10 @@ const createRoseNetRelay = async ({
           applyDefaultLimit: false,
         },
       }),
-      pubsub: gossipsub({ allowPublishToZeroPeers: true }),
+      pubsub: gossipsub({
+        allowPublishToZeroPeers: true,
+        runOnTransientConnection: true,
+      }),
       identify: identify(),
     },
     peerDiscovery: [pubsubPeerDiscovery()],

tests/scaling-pubsub/.eslintignore

@@ -0,0 +1 @@
+dist

tests/scaling-pubsub/README.md

@@ -0,0 +1,23 @@
+# RoseNet scaling pubsub test
+
+## Table of contents
+
+- [Introduction](#introduction)
+- [Usage](#usage)
+
+## Introduction
+
+RoseNet scaling pubsub test
+
+## Usage
+
+You need to have [OpenTofu](https://opentofu.org/) installed. Then, after
+[passing required variables](https://opentofu.org/docs/language/values/variables/#assigning-values-to-root-module-variables) (defined in [`variables.tf`](./variables.tf)),
+run the following commands. It should complete with no errors.
+
+```bash
+tofu init
+tofu apply
+```
+
+Finally run `tofu destroy` to destroy the infrastructure.