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

Pass vouchers for RPC requests in header (#429)

Browse Source 
* Send voucher in request header instead of url params

* Handle review changes

* Update package versions

---------

Co-authored-by: Shreerang Kale <shreerangkale@gmail.com>
This commit is contained in:
prathamesh0
2023-10-12 17:42:19 +05:30
committed by GitHub
co-authored by Shreerang Kale
parent 2b83f38ab6
commit e6767c3aca
14 changed files with 45 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/util/src/payments.ts
+10 -12
View File
@@ -13,7 +13,7 @@ import { Response as HTTPResponse } from 'apollo-server-env';
import Channel from '@cerc-io/ts-channel';
import type { ReadWriteChannel } from '@cerc-io/ts-channel';
import type { Voucher } from '@cerc-io/nitro-node';
import { utils as nitroUtils, ChannelStatus, Destination } from '@cerc-io/nitro-node';
import { utils as nitroUtils, ChannelStatus } from '@cerc-io/nitro-node';
import { deepCopy } from '@ethersproject/properties';
import { fetchJson } from '@ethersproject/web';
@@ -267,18 +267,15 @@ export class PaymentsManager {
}
async sendPayment (destChannelId: string, amount: string): Promise<{
channelId: string,
amount: string,
signature: string
vhash:string,
vsig:string
}> {
const dest = new Destination(destChannelId);
const voucher = await this.nitro.node.createVoucher(dest, BigInt(amount ?? 0));
const voucher = await this.nitro.pay(destChannelId, Number(amount));
assert(voucher.amount);
return {
channelId: voucher.channelId.string(),
amount: voucher.amount.toString(),
signature: voucher.signature.toHexString()
vhash: voucher.hash(),
vsig: voucher.signature.toHexString()
};
}
@@ -492,13 +489,14 @@ export const setupProviderWithPayments = (
}
// Send a payment to upstream Nitro node and add details to the request URL
let updatedURL = provider.connection.url;
let headers = {};
if (paidRPCMethods.includes(method)) {
const voucher = await paymentsManager.sendPayment(paymentChannelId, paymentAmount);
updatedURL = `${updatedURL}?channelId=${voucher.channelId}&amount=${voucher.amount}&signature=${voucher.signature}`;
headers = { 'X-Payment': `vhash:${voucher.vhash},vsig:${voucher.vsig}` };
}
const result = fetchJson({ ...provider.connection, url: updatedURL }, JSON.stringify(request), getResult).then((result) => {
const result = fetchJson({ ...provider.connection, headers }, JSON.stringify(request), getResult).then((result) => {
provider.emit('debug', {
action: 'response',
request: request,