P2P

.vscode/settings.json

@@ -0,0 +1,5 @@
+{
+	"cSpell.words": [
+		"unhandle"
+	]
+}

package.json

@@ -14,26 +14,35 @@
         "build": "tsc -p ."
     },
     "dependencies": {
+        "@chainsafe/libp2p-noise": "^5.0.3",
+        "@fluxprotocol/oracle-vm": "^2.0.0",
         "big.js": "^6.1.1",
         "bn.js": "^5.2.0",
         "dotenv": "^15.0.0",
         "ethers": "^5.5.4",
+        "libp2p": "^0.36.2",
+        "libp2p-mplex": "^0.10.7",
+        "libp2p-tcp": "^0.17.2",
         "express": "^4.17.3",
         "jsonpath-plus": "^6.0.1",
         "lodash.topath": "^4.5.2",
+        "multiaddr": "^10.0.1",
         "near-api-js": "^0.44.2",
+        "uint8arrays": "^3.0.0",
         "web3": "^1.7.0",
         "winston-daily-rotate-file": "^4.6.0",
         "winston-transport-sentry-node": "^2.3.0"
     },
     "devDependencies": {
         "@types/big.js": "^6.1.2",
+        "@types/bl": "^5.0.2",
+        "@types/debug": "^4.1.7",
         "@types/express": "^4.17.13",
         "@types/jest": "^27.4.0",
         "@types/lodash.topath": "^4.5.6",
-        "@types/node": "^17.0.14",
+        "@types/node": "^17.0.21",
         "jest": "^27.4.7",
         "ts-jest": "^27.1.3",
-        "typescript": "^4.5.5"
+        "typescript": "^4.6.2"
     }
 }

src/main.ts

@@ -4,7 +4,6 @@ import { PROJECT_NAME, PROJECT_VERSION } from './config';
 
 async function main() {
     logger.info(`🧙 Starting ${PROJECT_NAME} v${PROJECT_VERSION}`);
-
     try {
         const appConfig = await parseAppConfig();
 

src/models/AppConfig.ts

@@ -1,3 +1,5 @@
+import { CreateOptions } from "libp2p";
+
 import { Healthcheck } from '../healthCheck/Healthcheck';
 import { IModule } from './IModule';
 import { ModuleConfig } from './IModule';
@@ -9,9 +11,13 @@ export interface AppConfig {
     networks: INetwork[];
     modules: IModule[];
     jobs: IJob[];
+    p2p_node: CreateOptions;
+    peers_file: string;
 }
 
 export interface UnparsedAppConfig {
     networks?: Partial<NetworkConfig>[];
     modules?: Partial<ModuleConfig>[];
+    p2p_node: CreateOptions,
+    peers_file: string,
 }