Add a method to send messages on the network using pubsub (#293)

* Add a method to send messages using pubsub on a topic * Update version to 0.2.22
cerc-io · Jan 11, 2023 · 38daa31 · 38daa31
1 parent 55884a8
commit 38daa31
Show file tree

Hide file tree

Showing 22 changed files with 134 additions and 68 deletions.
diff --git a/lerna.json b/lerna.json
@@ -2,7 +2,7 @@
   "packages": [
     "packages/*"
   ],
-  "version": "0.2.21",
+  "version": "0.2.22",
   "npmClient": "yarn",
   "useWorkspaces": true,
   "command": {

diff --git a/packages/address-watcher/package.json b/packages/address-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/address-watcher",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "Address Watcher",
   "private": true,
   "scripts": {
@@ -26,11 +26,11 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cache": "^0.2.21",
-    "@cerc-io/ipld-eth-client": "^0.2.21",
-    "@cerc-io/solidity-mapper": "^0.2.21",
-    "@cerc-io/tracing-client": "^0.2.21",
-    "@cerc-io/util": "^0.2.21",
+    "@cerc-io/cache": "^0.2.22",
+    "@cerc-io/ipld-eth-client": "^0.2.22",
+    "@cerc-io/solidity-mapper": "^0.2.22",
+    "@cerc-io/tracing-client": "^0.2.22",
+    "@cerc-io/util": "^0.2.22",
     "@types/lodash": "^4.14.168",
     "debug": "^4.3.1",
     "ethers": "^5.4.4",

diff --git a/packages/cache/package.json b/packages/cache/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/cache",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "Generic object cache",
   "main": "dist/index.js",
   "scripts": {

diff --git a/packages/cli/package.json b/packages/cli/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/cli",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "main": "dist/index.js",
   "license": "AGPL-3.0",
   "scripts": {
@@ -11,8 +11,8 @@
     "chat": "node dist/chat.js"
   },
   "dependencies": {
-    "@cerc-io/peer": "^0.2.21",
-    "@cerc-io/util": "^0.2.21",
+    "@cerc-io/peer": "^0.2.22",
+    "@cerc-io/util": "^0.2.22",
     "@ethersproject/providers": "^5.4.4",
     "@graphql-tools/utils": "^9.1.1",
     "@ipld/dag-cbor": "^8.0.0",

diff --git a/packages/codegen/package.json b/packages/codegen/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/codegen",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "Code generator",
   "private": true,
   "main": "index.js",
@@ -20,7 +20,7 @@
   },
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
-    "@cerc-io/util": "^0.2.21",
+    "@cerc-io/util": "^0.2.22",
     "@graphql-tools/load-files": "^6.5.2",
     "@poanet/solidity-flattener": "https://github.com/vulcanize/solidity-flattener.git",
     "@solidity-parser/parser": "^0.13.2",

diff --git a/packages/codegen/src/templates/package-template.handlebars b/packages/codegen/src/templates/package-template.handlebars
@@ -41,12 +41,12 @@
   "dependencies": {
     "@apollo/client": "^3.3.19",
     "@ethersproject/providers": "^5.4.4",
-    "@cerc-io/cli": "^0.2.21",
-    "@cerc-io/ipld-eth-client": "^0.2.21",
-    "@cerc-io/solidity-mapper": "^0.2.21",
-    "@cerc-io/util": "^0.2.21",
+    "@cerc-io/cli": "^0.2.22",
+    "@cerc-io/ipld-eth-client": "^0.2.22",
+    "@cerc-io/solidity-mapper": "^0.2.22",
+    "@cerc-io/util": "^0.2.22",
     {{#if (subgraphPath)}}
-    "@cerc-io/graph-node": "^0.2.21",
+    "@cerc-io/graph-node": "^0.2.22",
     {{/if}}
     "apollo-type-bigint": "^0.1.3",
     "debug": "^4.3.1",

diff --git a/packages/eden-watcher/package.json b/packages/eden-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/eden-watcher",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "eden-watcher",
   "private": true,
   "main": "dist/index.js",
@@ -38,11 +38,11 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cli": "^0.2.21",
-    "@cerc-io/graph-node": "^0.2.21",
-    "@cerc-io/ipld-eth-client": "^0.2.21",
-    "@cerc-io/solidity-mapper": "^0.2.21",
-    "@cerc-io/util": "^0.2.21",
+    "@cerc-io/cli": "^0.2.22",
+    "@cerc-io/graph-node": "^0.2.22",
+    "@cerc-io/ipld-eth-client": "^0.2.22",
+    "@cerc-io/solidity-mapper": "^0.2.22",
+    "@cerc-io/util": "^0.2.22",
     "@ethersproject/providers": "^5.4.4",
     "apollo-type-bigint": "^0.1.3",
     "debug": "^4.3.1",

diff --git a/packages/erc20-watcher/package.json b/packages/erc20-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/erc20-watcher",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "ERC20 Watcher",
   "private": true,
   "main": "dist/index.js",
@@ -42,10 +42,10 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cli": "^0.2.21",
-    "@cerc-io/ipld-eth-client": "^0.2.21",
-    "@cerc-io/solidity-mapper": "^0.2.21",
-    "@cerc-io/util": "^0.2.21",
+    "@cerc-io/cli": "^0.2.22",
+    "@cerc-io/ipld-eth-client": "^0.2.22",
+    "@cerc-io/solidity-mapper": "^0.2.22",
+    "@cerc-io/util": "^0.2.22",
     "@ethersproject/providers": "^5.4.4",
     "apollo-type-bigint": "^0.1.3",
     "debug": "^4.3.1",

diff --git a/packages/erc721-watcher/package.json b/packages/erc721-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/erc721-watcher",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "erc721-watcher",
   "private": true,
   "main": "dist/index.js",
@@ -47,10 +47,10 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cli": "^0.2.21",
-    "@cerc-io/ipld-eth-client": "^0.2.21",
-    "@cerc-io/solidity-mapper": "^0.2.21",
-    "@cerc-io/util": "^0.2.21",
+    "@cerc-io/cli": "^0.2.22",
+    "@cerc-io/ipld-eth-client": "^0.2.22",
+    "@cerc-io/solidity-mapper": "^0.2.22",
+    "@cerc-io/util": "^0.2.22",
     "@ethersproject/providers": "^5.4.4",
     "apollo-type-bigint": "^0.1.3",
     "debug": "^4.3.1",

diff --git a/packages/graph-node/package.json b/packages/graph-node/package.json
@@ -1,10 +1,10 @@
 {
   "name": "@cerc-io/graph-node",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "main": "dist/index.js",
   "license": "AGPL-3.0",
   "devDependencies": {
-    "@cerc-io/solidity-mapper": "^0.2.21",
+    "@cerc-io/solidity-mapper": "^0.2.22",
     "@ethersproject/providers": "^5.4.4",
     "@graphprotocol/graph-ts": "^0.22.0",
     "@nomiclabs/hardhat-ethers": "^2.0.2",
@@ -50,9 +50,9 @@
   "dependencies": {
     "@apollo/client": "^3.3.19",
     "@cerc-io/assemblyscript": "0.19.10-watcher-ts-0.1.2",
-    "@cerc-io/cache": "^0.2.21",
-    "@cerc-io/ipld-eth-client": "^0.2.21",
-    "@cerc-io/util": "^0.2.21",
+    "@cerc-io/cache": "^0.2.22",
+    "@cerc-io/ipld-eth-client": "^0.2.22",
+    "@cerc-io/util": "^0.2.22",
     "@types/json-diff": "^0.5.2",
     "bn.js": "^4.11.9",
     "debug": "^4.3.1",

diff --git a/packages/graph-test-watcher/package.json b/packages/graph-test-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/graph-test-watcher",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "graph-test-watcher",
   "private": true,
   "main": "dist/index.js",
@@ -38,11 +38,11 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cli": "^0.2.21",
-    "@cerc-io/graph-node": "^0.2.21",
-    "@cerc-io/ipld-eth-client": "^0.2.21",
-    "@cerc-io/solidity-mapper": "^0.2.21",
-    "@cerc-io/util": "^0.2.21",
+    "@cerc-io/cli": "^0.2.22",
+    "@cerc-io/graph-node": "^0.2.22",
+    "@cerc-io/ipld-eth-client": "^0.2.22",
+    "@cerc-io/solidity-mapper": "^0.2.22",
+    "@cerc-io/util": "^0.2.22",
     "@ethersproject/providers": "^5.4.4",
     "apollo-type-bigint": "^0.1.3",
     "debug": "^4.3.1",

diff --git a/packages/ipld-eth-client/package.json b/packages/ipld-eth-client/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/ipld-eth-client",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "IPLD ETH Client",
   "main": "dist/index.js",
   "scripts": {
@@ -20,7 +20,7 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.7.1",
-    "@cerc-io/cache": "^0.2.21",
+    "@cerc-io/cache": "^0.2.22",
     "cross-fetch": "^3.1.4",
     "debug": "^4.3.1",
     "ethers": "^5.4.4",

diff --git a/packages/mobymask-watcher/package.json b/packages/mobymask-watcher/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/mobymask-watcher",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "mobymask-watcher",
   "private": true,
   "main": "dist/index.js",
@@ -37,10 +37,10 @@
   "homepage": "https://github.com/cerc-io/watcher-ts#readme",
   "dependencies": {
     "@apollo/client": "^3.3.19",
-    "@cerc-io/cli": "^0.2.21",
-    "@cerc-io/ipld-eth-client": "^0.2.21",
-    "@cerc-io/solidity-mapper": "^0.2.21",
-    "@cerc-io/util": "^0.2.21",
+    "@cerc-io/cli": "^0.2.22",
+    "@cerc-io/ipld-eth-client": "^0.2.22",
+    "@cerc-io/solidity-mapper": "^0.2.22",
+    "@cerc-io/util": "^0.2.22",
     "@ethersproject/providers": "^5.4.4",
     "apollo-type-bigint": "^0.1.3",
     "debug": "^4.3.1",

diff --git a/packages/peer-test-app/package.json b/packages/peer-test-app/package.json
@@ -1,10 +1,10 @@
 {
   "name": "@cerc-io/peer-test-app",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "private": true,
   "dependencies": {
-    "@cerc-io/peer": "^0.2.21",
-    "@cerc-io/react-peer": "^0.2.21",
+    "@cerc-io/peer": "^0.2.22",
+    "@cerc-io/react-peer": "^0.2.22",
     "@emotion/react": "^11.10.5",
     "@emotion/styled": "^11.10.5",
     "@mui/material": "^5.11.3",

diff --git a/packages/peer-test-app/src/App.tsx b/packages/peer-test-app/src/App.tsx
@@ -8,8 +8,13 @@ import { AppBar, Box, CssBaseline, Paper, Table, TableBody, TableCell, TableCont
 import './App.css';
 import { useForceUpdate } from './hooks/forceUpdate';
 
+const TEST_TOPIC = 'test';
+
 declare global {
-  interface Window { broadcast: (message: string) => void; }
+  interface Window {
+    broadcast: (message: string) => void;
+    flood: (message: string) => void;
+  }
 }
 
 const theme = createTheme();
@@ -33,6 +38,14 @@ function App() {
       peer.broadcastMessage(message)
     }
 
+    const unsubscribeTopic = peer.subscribeTopic(TEST_TOPIC, (data) => {
+      console.log(`> ${data}`)
+    })
+
+    window.flood = (message: string) => {
+      peer.floodMessage(TEST_TOPIC, message)
+    }
+
     peer.node.peerStore.addEventListener('change:multiaddrs', forceUpdate)
     peer.node.connectionManager.addEventListener('peer:connect', forceUpdate)
 
@@ -50,6 +63,7 @@ function App() {
 
     return () => {
       unsubscribeMessage()
+      unsubscribeTopic()
       peer.node?.peerStore.removeEventListener('change:multiaddrs', forceUpdate)
       peer.node?.connectionManager.removeEventListener('peer:connect', forceUpdate)
       peer.node?.connectionManager.removeEventListener('peer:disconnect', disconnectHandler)
@@ -64,7 +78,7 @@ function App() {
           <Typography variant="h6" color="inherit" noWrap>
             Peer Test App
           </Typography>
-        </Toolbar>  
+        </Toolbar>
       </AppBar>
       <main>
         <Box

diff --git a/packages/peer/package.json b/packages/peer/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@cerc-io/peer",
-  "version": "0.2.21",
+  "version": "0.2.22",
   "description": "libp2p module",
   "main": "dist/index.js",
   "exports": "./dist/index.js",