PHP WebShell
Текущая директория: /usr/lib/node_modules/bitgo/node_modules/viem/_esm/clients/transports
Просмотр файла: ipc.js
import { RpcRequestError } from '../../errors/request.js';
import { getIpcRpcClient, } from '../../utils/rpc/ipc.js';
import { createTransport, } from './createTransport.js';
/**
* @description Creates an IPC transport that connects to a JSON-RPC API.
*/
export function ipc(path, config = {}) {
const { key = 'ipc', methods, name = 'IPC JSON-RPC', reconnect, retryDelay, } = config;
return ({ retryCount: retryCount_, timeout: timeout_ }) => {
const retryCount = config.retryCount ?? retryCount_;
const timeout = timeout_ ?? config.timeout ?? 10_000;
return createTransport({
key,
methods,
name,
async request({ method, params }) {
const body = { method, params };
const rpcClient = await getIpcRpcClient(path, { reconnect });
const { error, result } = await rpcClient.requestAsync({
body,
timeout,
});
if (error)
throw new RpcRequestError({
body,
error,
url: path,
});
return result;
},
retryCount,
retryDelay,
timeout,
type: 'ipc',
}, {
getRpcClient() {
return getIpcRpcClient(path);
},
async subscribe({ params, onData, onError }) {
const rpcClient = await getIpcRpcClient(path);
const { result: subscriptionId } = await new Promise((resolve, reject) => rpcClient.request({
body: {
method: 'eth_subscribe',
params,
},
onResponse(response) {
if (response.error) {
reject(response.error);
onError?.(response.error);
return;
}
if (typeof response.id === 'number') {
resolve(response);
return;
}
if (response.method !== 'eth_subscription')
return;
onData(response.params);
},
}));
return {
subscriptionId,
async unsubscribe() {
return new Promise((resolve) => rpcClient.request({
body: {
method: 'eth_unsubscribe',
params: [subscriptionId],
},
onResponse: resolve,
}));
},
};
},
});
};
}
//# sourceMappingURL=ipc.js.mapВыполнить команду
Для локальной разработки. Не используйте в интернете!