chore: replace createTimeoutPromise with resolveAfter

trezor · Feb 10, 2025 · fd9f509 · fd9f509
1 parent dedff02
commit fd9f509
Show file tree

Hide file tree

Showing 12 changed files with 26 additions and 26 deletions.
diff --git a/packages/connect-popup/e2e/tests/popup-close.test.ts b/packages/connect-popup/e2e/tests/popup-close.test.ts
@@ -1,7 +1,7 @@
 import { BrowserContext, Page, test } from '@playwright/test';
 
 import { TrezorUserEnvLink } from '@trezor/trezor-user-env-link';
-import { addDashesToSpaces, createTimeoutPromise } from '@trezor/utils';
+import { addDashesToSpaces, resolveAfter } from '@trezor/utils';
 
 import {
     checkHasLogs,
@@ -146,7 +146,7 @@ test.afterEach(async ({ context: _context }, testInfo) => {
         await context.close();
         await new Promise(resolve => setTimeout(resolve, 1000));
     }
-    await createTimeoutPromise(WAIT_AFTER_TEST);
+    await resolveAfter(WAIT_AFTER_TEST);
 });
 
 test(`popup closed by user`, async ({ page, context }) => {

diff --git a/packages/connect/src/core/onCallFirmwareUpdate.ts b/packages/connect/src/core/onCallFirmwareUpdate.ts
@@ -1,6 +1,6 @@
 import { randomBytes } from 'crypto';
 
-import { createTimeoutPromise } from '@trezor/utils';
+import { resolveAfter } from '@trezor/utils';
 import { isEqual, isNewer } from '@trezor/utils/src/versionUtils';
 
 import {
@@ -90,7 +90,7 @@ const waitForReconnectedDevice = async (
             }),
         );
 
-        await createTimeoutPromise(2000);
+        await resolveAfter(2000);
         try {
             reconnectedDevice = deviceList.getOnlyDevice();
         } catch {
@@ -460,7 +460,7 @@ export const onCallFirmwareUpdate = async ({
 
         // This delay is crucial see https://github.com/trezor/trezor-firmware/issues/1983
         if (device.features.major_version === 1) {
-            await createTimeoutPromise(2000);
+            await resolveAfter(2000);
         }
         reconnectedDevice = await waitForReconnectedDevice(
             { bootloader: true, method: 'auto' },

diff --git a/packages/connect/src/device/Device.ts b/packages/connect/src/device/Device.ts
@@ -8,8 +8,8 @@ import {
     Deferred,
     TypedEmitter,
     createDeferred,
-    createTimeoutPromise,
     isArrayMember,
+    resolveAfter,
     serializeError,
     versionUtils,
 } from '@trezor/utils';
@@ -343,7 +343,7 @@ export class Device extends TypedEmitter<DeviceEvents> {
     // call only once, right after device creation
     async handshake(delay?: number) {
         if (delay) {
-            await createTimeoutPromise(501 + delay);
+            await resolveAfter(501 + delay);
         }
 
         while (true) {
@@ -384,7 +384,7 @@ export class Device extends TypedEmitter<DeviceEvents> {
                         this.unreadableError = error?.message;
                         this.emitLifecycle(DEVICE.CONNECT_UNACQUIRED);
                     } else {
-                        await createTimeoutPromise(501);
+                        await resolveAfter(501);
                         continue;
                     }
                 }

diff --git a/packages/connect/src/device/DeviceCommands.ts b/packages/connect/src/device/DeviceCommands.ts
@@ -3,7 +3,7 @@
 import { MessagesSchema as Messages } from '@trezor/protobuf';
 import { Assert } from '@trezor/schema-utils';
 import { Session, Transport } from '@trezor/transport';
-import { createTimeoutPromise, versionUtils } from '@trezor/utils';
+import { resolveAfter, versionUtils } from '@trezor/utils';
 
 import { ERRORS } from '../constants';
 import { Device } from './Device';
@@ -561,7 +561,7 @@ export class DeviceCommands {
              */
             try {
                 // UI_EVENT is send right before ButtonAck, make sure that ButtonAck is sent
-                await createTimeoutPromise(1);
+                await resolveAfter(1);
                 await this.device.acquire();
                 await cancelPrompt(this.device, false);
             } catch {

diff --git a/packages/suite-desktop-core/src/app.ts b/packages/suite-desktop-core/src/app.ts
@@ -6,7 +6,7 @@ import { isMacOs } from '@trezor/env-utils';
 import { validateIpcMessage } from '@trezor/ipc-proxy';
 import type { HandshakeClient } from '@trezor/suite-desktop-api';
 import { TimerId } from '@trezor/type-utils';
-import { createDeferred, createTimeoutPromise } from '@trezor/utils';
+import { createDeferred, resolveAfter } from '@trezor/utils';
 
 import { hangDetect } from './hang-detect';
 import { processStatePatch, restartApp } from './libs/app-utils';
@@ -300,7 +300,7 @@ const init = async () => {
             // await quitting all registered modules
             Promise.allSettled([quitModules(), quitTorModule(), quitBackgroundModules()]),
             // or timeout after 5s
-            createTimeoutPromise(5000),
+            resolveAfter(5000),
         ]);
 
         // global cleanup

diff --git a/packages/suite/src/components/suite/WordInput.tsx b/packages/suite/src/components/suite/WordInput.tsx
@@ -8,7 +8,7 @@ import styled from 'styled-components';
 import { Select, variables } from '@trezor/components';
 import TrezorConnect, { UI } from '@trezor/connect';
 import { bip39 } from '@trezor/crypto-utils';
-import { createTimeoutPromise } from '@trezor/utils';
+import { resolveAfter } from '@trezor/utils';
 
 import { useTranslation } from 'src/hooks/suite/useTranslation';
 
@@ -80,7 +80,7 @@ export const WordInput = memo(() => {
                     translationString('TR_WORD_DOES_NOT_EXIST', { word: inputValue })
                 }
                 onChange={async (item: Option, ref?: SelectInstance<Option, boolean> | null) => {
-                    await createTimeoutPromise(600);
+                    await resolveAfter(600);
                     TrezorConnect.uiResponse({ type: UI.RECEIVE_WORD, payload: item.value });
                     ref?.clearValue();
                 }}

diff --git a/packages/suite/src/components/suite/WordInputAdvanced.tsx b/packages/suite/src/components/suite/WordInputAdvanced.tsx
@@ -5,7 +5,7 @@ import styled from 'styled-components';
 import { Button, KEYBOARD_CODE, PinButton } from '@trezor/components';
 import TrezorConnect, { DeviceModelInternal, UI } from '@trezor/connect';
 import { HELP_CENTER_ADVANCED_RECOVERY_URL } from '@trezor/urls';
-import { createTimeoutPromise } from '@trezor/utils';
+import { resolveAfter } from '@trezor/utils';
 
 import { DeviceMatrixExplanation, Translation, TrezorLink } from 'src/components/suite';
 
@@ -40,7 +40,7 @@ interface WordInputAdvancedProps {
 
 export const WordInputAdvanced = ({ count }: WordInputAdvancedProps) => {
     const onSubmit = useCallback(async (value: string) => {
-        await createTimeoutPromise(600);
+        await resolveAfter(600);
         TrezorConnect.uiResponse({ type: UI.RECEIVE_WORD, payload: value });
     }, []);
 

diff --git a/...ReduxModal/UserContextModal/AddAccountModal/AddAccountButton/AddCoinjoinAccountButton.tsx b/...ReduxModal/UserContextModal/AddAccountModal/AddAccountButton/AddCoinjoinAccountButton.tsx
@@ -6,7 +6,7 @@ import { Network, NetworkAccount, NetworkSymbol } from '@suite-common/wallet-con
 import { selectSelectedDevice } from '@suite-common/wallet-core';
 import { UnavailableCapabilities } from '@trezor/connect';
 import { isDesktop } from '@trezor/env-utils';
-import { createTimeoutPromise } from '@trezor/utils';
+import { resolveAfter } from '@trezor/utils';
 
 import { openDeferredModal, openModal } from 'src/actions/suite/modalActions';
 import { toggleTor } from 'src/actions/suite/suiteActions';
@@ -111,7 +111,7 @@ export const AddCoinjoinAccountButton = ({ network, selectedAccount }: AddCoinjo
             // When Tor was not loaded it means there was an error or user canceled it, stop the coinjoin account activation.
             if (!isTorLoaded) return;
         }
-        await createTimeoutPromise(1000); // TODO fix properly: https://github.com/trezor/trezor-suite/issues/6902
+        await resolveAfter(1000); // TODO fix properly: https://github.com/trezor/trezor-suite/issues/6902
         await createAccount();
     };
 

diff --git a/packages/transport-bridge/tests/http.test.ts b/packages/transport-bridge/tests/http.test.ts
@@ -4,7 +4,7 @@ import { getFreePort } from '@trezor/node-utils';
 import { AbstractApi } from '@trezor/transport/src/api/abstract';
 import { UdpApi } from '@trezor/transport/src/api/udp';
 import { bridgeApiCall } from '@trezor/transport/src/utils/bridgeApiCall';
-import { createTimeoutPromise } from '@trezor/utils';
+import { resolveAfter } from '@trezor/utils';
 
 import { TrezordNode } from '../src/http';
 
@@ -703,7 +703,7 @@ describe('http', () => {
                 client.listen();
                 // it takes some tome for /listen request to propagate.
                 // todo: solve later
-                await createTimeoutPromise(1000);
+                await resolveAfter(1000);
 
                 return {
                     server,

diff --git a/packages/transport/src/api/udp.ts b/packages/transport/src/api/udp.ts
@@ -1,6 +1,6 @@
 import UDP from 'dgram';
 
-import { arrayPartition, createTimeoutPromise, isNotUndefined } from '@trezor/utils';
+import { arrayPartition, isNotUndefined, resolveAfter } from '@trezor/utils';
 
 import {
     AbstractApi,
@@ -36,7 +36,7 @@ export class UdpApi extends AbstractApi {
 
     private async listenLoop() {
         while (this.listening) {
-            await createTimeoutPromise(500);
+            await resolveAfter(500);
             if (!this.listening) break;
             await this.enumerate(this.listenAbortController.signal);
         }

diff --git a/packages/transport/src/api/usb.ts b/packages/transport/src/api/usb.ts
@@ -1,4 +1,4 @@
-import { createDeferred, createTimeoutPromise, getSynchronize } from '@trezor/utils';
+import { createDeferred, getSynchronize, resolveAfter } from '@trezor/utils';
 
 import { AbstractApi, AbstractApiConstructorParams, DEVICE_TYPE } from './abstract';
 import {
@@ -277,7 +277,7 @@ export class UsbApi extends AbstractApi {
                 return res;
             }
 
-            await createTimeoutPromise(100 * i);
+            await resolveAfter(100 * i);
         }
 
         return this.openInternal(path, first, signal);

diff --git a/packages/transport/src/transports/bridge.ts b/packages/transport/src/transports/bridge.ts
@@ -4,7 +4,7 @@ import {
     bridge as protocolBridge,
     v1 as protocolV1,
 } from '@trezor/protocol';
-import { createTimeoutPromise, versionUtils } from '@trezor/utils';
+import { resolveAfter, versionUtils } from '@trezor/utils';
 
 import {
     AbstractTransport,
@@ -146,7 +146,7 @@ export class BridgeTransport extends AbstractTransport {
                     this.emit('transport-error', response.error);
                     break;
                 }
-                await createTimeoutPromise(1000);
+                await resolveAfter(1000);
             } else {
                 this.handleDescriptorsChange(response.payload);
             }