37 lines
1.2 KiB
TypeScript
37 lines
1.2 KiB
TypeScript
import { JsonRpcResponse, RPCRequest } from '../rpc/types';
|
|
import { IWeb3Provider } from './types';
|
|
import RPCClient from '../rpc/client';
|
|
|
|
export default class Web3Client extends RPCClient {
|
|
private provider: IWeb3Provider;
|
|
|
|
constructor() {
|
|
super('web3'); // initialized with fake endpoint
|
|
this.provider = (window as any).web3.currentProvider;
|
|
}
|
|
|
|
public decorateRequest = (req: RPCRequest) => ({
|
|
...req,
|
|
id: this.id(),
|
|
jsonrpc: '2.0',
|
|
params: req.params || [] // default to empty array so MetaMask doesn't error
|
|
});
|
|
|
|
public call = (request: RPCRequest | any): Promise<JsonRpcResponse> =>
|
|
this.sendAsync(this.decorateRequest(request)) as Promise<JsonRpcResponse>;
|
|
|
|
public batch = (requests: RPCRequest[] | any): Promise<JsonRpcResponse[]> =>
|
|
this.sendAsync(requests.map(this.decorateRequest)) as Promise<JsonRpcResponse[]>;
|
|
|
|
private sendAsync = (request: any): Promise<JsonRpcResponse | JsonRpcResponse[]> => {
|
|
return new Promise((resolve, reject) => {
|
|
this.provider.sendAsync(request, (error, result: JsonRpcResponse | JsonRpcResponse[]) => {
|
|
if (error) {
|
|
return reject(error);
|
|
}
|
|
resolve(result);
|
|
});
|
|
});
|
|
};
|
|
}
|