From cb4184d1343ca8e4e6e5c856722787f6b7574253 Mon Sep 17 00:00:00 2001 From: Lawrence Forooghian Date: Fri, 8 Dec 2023 16:49:16 -0300 Subject: [PATCH] Convert withAuthDetails to use promises for failure --- src/common/lib/client/resource.ts | 21 ++++++++------------- 1 file changed, 8 insertions(+), 13 deletions(-) diff --git a/src/common/lib/client/resource.ts b/src/common/lib/client/resource.ts index 834988d1d0..f934f0cf70 100644 --- a/src/common/lib/client/resource.ts +++ b/src/common/lib/client/resource.ts @@ -8,23 +8,18 @@ import BaseClient from './baseclient'; import { MsgPack } from 'common/types/msgpack'; import { RequestCallbackHeaders } from 'common/types/http'; -function withAuthDetails( +async function withAuthDetails( client: BaseClient, headers: RequestCallbackHeaders | undefined, params: Record, - errCallback: Function, opCallback: Function -) { +): Promise { if (client.http.supportsAuthHeaders) { - Utils.whenPromiseSettles(client.auth.getAuthHeaders(), function (err: Error, authHeaders: Record) { - if (err) errCallback(err); - else opCallback(Utils.mixin(authHeaders, headers), params); - }); + const authHeaders = await client.auth.getAuthHeaders(); + opCallback(Utils.mixin(authHeaders, headers), params); } else { - Utils.whenPromiseSettles(client.auth.getAuthParams(), function (err: Error, authParams: Record) { - if (err) errCallback(err); - else opCallback(headers, Utils.mixin(authParams, params)); - }); + const authParams = await client.auth.getAuthParams(); + opCallback(headers, Utils.mixin(authParams, params)); } } @@ -254,7 +249,7 @@ class Resource { return; } /* retry ... */ - withAuthDetails(client, headers, params, callback, doRequest); + withAuthDetails(client, headers, params, doRequest).catch((err) => callback(err)); }); return; } @@ -262,7 +257,7 @@ class Resource { }); } - withAuthDetails(client, headers, params, callback, doRequest); + withAuthDetails(client, headers, params, doRequest).catch((err) => callback(err)); } }