cerc-io/watcher-ts
16
1
Fork 0
mirror of https://github.com/cerc-io/watcher-ts synced 2025-01-07 20:08:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add boolean flag to enable sending L2 txs from watcher peer (#354)

Browse Source
This commit is contained in:
Nabarun Gogoi 2023-04-10 09:56:55 +05:30 committed by GitHub
parent 754db311f0
commit 7dada71fa3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
packages/mobymask-v2-watcher/environments/local.toml
View File

@ -33,6 +33,7 @@
relayMultiaddr = '' relayMultiaddr = ''
pubSubTopic = 'mobymask' pubSubTopic = 'mobymask'
peerIdFile = '' peerIdFile = ''
enableL2Txs = false
[server.p2p.peer.l2TxConfig] [server.p2p.peer.l2TxConfig]
privateKey = '' privateKey = ''

10
packages/mobymask-v2-watcher/src/server.ts
View File

@ -4,6 +4,7 @@
import fs from 'fs'; import fs from 'fs';
import path from 'path'; import path from 'path';
import assert from 'assert';
import 'reflect-metadata'; import 'reflect-metadata';
import debug from 'debug'; import debug from 'debug';
import { ethers } from 'ethers'; import { ethers } from 'ethers';
@ -23,11 +24,12 @@ export const main = async (): Promise<any> => {
await serverCmd.initIndexer(Indexer); await serverCmd.initIndexer(Indexer);
let p2pMessageHandler = parseLibp2pMessage; let p2pMessageHandler = parseLibp2pMessage;
const { l2TxConfig } = serverCmd.config.server.p2p.peer; const { enableL2Txs, l2TxsConfig } = serverCmd.config.server.p2p.peer;
if (l2TxConfig) { if (enableL2Txs) {
const wallet = new ethers.Wallet(l2TxConfig.privateKey, serverCmd.ethProvider); assert(l2TxsConfig);
p2pMessageHandler = createMessageToL2Handler(wallet, l2TxConfig); const wallet = new ethers.Wallet(l2TxsConfig.privateKey, serverCmd.ethProvider);
p2pMessageHandler = createMessageToL2Handler(wallet, l2TxsConfig);
} }
const typeDefs = fs.readFileSync(path.join(__dirname, 'schema.gql')).toString(); const typeDefs = fs.readFileSync(path.join(__dirname, 'schema.gql')).toString();

7
packages/util/src/config.ts
View File

@ -70,7 +70,7 @@ export interface RelayConfig {
} }
// L2 tx config // L2 tx config
interface L2TxConfig { interface L2TxsConfig {
// Address of contract for which txs are sent // Address of contract for which txs are sent
contractAddress: string; contractAddress: string;
@ -113,8 +113,11 @@ export interface PeerConfig {
// Participate in exchange of debug info over floodsub // Participate in exchange of debug info over floodsub
enableDebugInfo?: boolean; enableDebugInfo?: boolean;
// Enable sending txs to L2 chain for every message received in P2P network
enableL2Txs: boolean;
// Config for sending txs to L2 // Config for sending txs to L2
l2TxConfig?: L2TxConfig; l2TxsConfig?: L2TxsConfig;
} }
// P2P config // P2P config