cerc-io/watcher-ts
11
1
Fork 0
mirror of https://github.com/cerc-io/watcher-ts synced 2026-09-08 08:54:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Support payments to upstream ETH server for RPC requests (#418)

Browse Source 
* Add config option for upstream RPC mutation endpoint

* Use mutation endpoint as chain URL for Nitro node

* Add a method to setup an upstream payment channel

* Add a method to send payments to upstream Nitro node

* Upgrade package versions
This commit is contained in:
prathamesh0
2023-09-28 15:24:45 +05:30
committed by GitHub
parent 32c78a907c
commit e203154ac7
16 changed files with 145 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/cli/package.json
+6 -6
View File
@@ -1,6 +1,6 @@
{
"name": "@cerc-io/cli",
"version": "0.2.60",
"version": "0.2.61",
"main": "dist/index.js",
"license": "AGPL-3.0",
"scripts": {
@@ -12,13 +12,13 @@
},
"dependencies": {
"@apollo/client": "^3.7.1",
"@cerc-io/cache": "^0.2.60",
"@cerc-io/ipld-eth-client": "^0.2.60",
"@cerc-io/cache": "^0.2.61",
"@cerc-io/ipld-eth-client": "^0.2.61",
"@cerc-io/libp2p": "^0.42.2-laconic-0.1.4",
"@cerc-io/nitro-node": "^0.1.11",
"@cerc-io/peer": "^0.2.60",
"@cerc-io/rpc-eth-client": "^0.2.60",
"@cerc-io/util": "^0.2.60",
"@cerc-io/peer": "^0.2.61",
"@cerc-io/rpc-eth-client": "^0.2.61",
"@cerc-io/util": "^0.2.61",
"@ethersproject/providers": "^5.4.4",
"@graphql-tools/utils": "^9.1.1",
"@ipld/dag-cbor": "^8.0.0",
packages/cli/src/server.ts
+19 -9
View File
@@ -38,7 +38,7 @@ import type {
Peer
// @ts-expect-error https://github.com/microsoft/TypeScript/issues/49721#issuecomment-1319854183
} from '@cerc-io/peer';
import { Node as NitroNode, utils } from '@cerc-io/nitro-node';
import { utils } from '@cerc-io/nitro-node';
// @ts-expect-error TODO: Resolve (Not able to find the type declarations)
import type { Libp2p } from '@cerc-io/libp2p';
@@ -55,7 +55,7 @@ export class ServerCmd {
_argv?: Arguments;
_baseCmd: BaseCmd;
_peer?: Peer;
_nitro?: NitroNode;
_nitro?: utils.Nitro;
_consensus?: Consensus;
constructor () {
@@ -82,7 +82,7 @@ export class ServerCmd {
return this._peer;
}
get nitro (): NitroNode | undefined {
get nitro (): utils.Nitro | undefined {
return this._nitro;
}
@@ -235,7 +235,7 @@ export class ServerCmd {
return this._consensus;
}
async initNitro (nitroContractAddresses: { [key: string]: string }): Promise<NitroNode | undefined> {
async initNitro (nitroContractAddresses: { [key: string]: string }): Promise<utils.Nitro | undefined> {
// Start a Nitro node
const {
server: {
@@ -246,7 +246,8 @@ export class ServerCmd {
},
upstream: {
ethServer: {
rpcProviderEndpoint
rpcProviderEndpoint,
rpcProviderMutationEndpoint
}
}
} = this._baseCmd.config;
@@ -257,17 +258,26 @@ export class ServerCmd {
}
assert(this.peer);
const nitro = await utils.Nitro.setupNode(
let chainUrl: string;
if (rpcProviderMutationEndpoint) {
log('Using rpcProviderMutationEndpoint as chain URL for Nitro node');
chainUrl = rpcProviderMutationEndpoint;
} else {
log('Using rpcProviderEndpoint as chain URL for Nitro node');
chainUrl = rpcProviderEndpoint;
}
this._nitro = await utils.Nitro.setupNode(
nitroConfig.privateKey,
rpcProviderEndpoint,
chainUrl,
nitroConfig.chainPrivateKey,
nitroContractAddresses,
this.peer,
path.resolve(nitroConfig.store)
);
this._nitro = nitro.node;
log(`Nitro node started with address: ${this._nitro.address}`);
log(`Nitro node started with address: ${this._nitro.node.address}`);
return this._nitro;
}