waku-org/js-waku
1
0
Fork 0
mirror of https://github.com/waku-org/js-waku.git synced 2025-01-12 21:44:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

Only the result property is ever used

Browse Source
This commit is contained in:
Franck Royer 2021-05-03 15:54:40 +10:00
parent 656227d431
commit de57b2691e
No known key found for this signature in database
GPG Key ID: A82ED75A8DFC50A4
1 changed files with 8 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/test_utils/nim_waku.ts
View File

@ -137,20 +137,13 @@ export class NimWaku {
async peers(): Promise<string[]> {
this.checkProcess();
const res = await this.rpcCall<string[]>('get_waku_v2_admin_v1_peers', []);
return res.result;
return this.rpcCall<string[]>('get_waku_v2_admin_v1_peers', []);
}
async info(): Promise<RpcInfoResponse> {
this.checkProcess();
const res = await this.rpcCall<RpcInfoResponse>(
'get_waku_v2_debug_v1_info',
[]
);
return res.result;
return this.rpcCall<RpcInfoResponse>('get_waku_v2_debug_v1_info', []);
}
async sendMessage(message: WakuMessage): Promise<boolean> {
@ -165,23 +158,18 @@ export class NimWaku {
contentTopic: message.contentTopic,
};
const res = await this.rpcCall<boolean>('post_waku_v2_relay_v1_message', [
return this.rpcCall<boolean>('post_waku_v2_relay_v1_message', [
RelayDefaultTopic,
rpcMessage,
]);
return res.result;
}
async messages(): Promise<WakuMessage[]> {
this.checkProcess();
const res = await this.rpcCall<WakuMessage[]>(
'get_waku_v2_relay_v1_messages',
[RelayDefaultTopic]
);
return res.result;
return this.rpcCall<WakuMessage[]>('get_waku_v2_relay_v1_messages', [
RelayDefaultTopic,
]);
}
async getPeerId(): Promise<PeerId> {
@ -220,7 +208,7 @@ export class NimWaku {
private async rpcCall<T>(
method: string,
params: Array<string | number | unknown>
): Promise<{ result: T }> {
): Promise<T> {
const res = await axios.post(
this.rpcUrl,
{
@ -234,7 +222,7 @@ export class NimWaku {
}
);
return res.data;
return res.data.result;
}
private checkProcess(): void {