Merge in promise-utils repo

.eslintrc.json

@@ -3,6 +3,25 @@
   "rules": {
     "lodash/import-scope": ["error", "method"]
   },
+  "overrides": [
+    {
+      "files": ["**/*.test.ts"],
+      "rules": {
+        "jest/prefer-ending-with-an-expect": [
+          "error",
+          {
+            "assertFunctionNames": ["expect*", "assertGoSuccess", "assertGoError", "assertType"]
+          }
+        ],
+        "jest/expect-expect": [
+          "warn",
+          {
+            "assertFunctionNames": ["expect*", "assertGoSuccess", "assertGoError", "assertType"]
+          }
+        ]
+      }
+    }
+  ],
   "parserOptions": {
     "project": ["./tsconfig.json"]
   }

README.md

@@ -25,6 +25,7 @@ Read the documentation and sources of each module how to use it in the project.
 - [http](./src/http/README.md)
 - [logger](./src/logger/README.md)
 - [processing](./src/processing/README.md)
+- [promises](./src/promises/README.md)
 - [release-scripts](./src/release-scripts/README.md)
 - [run-in-loop](./src/run-in-loop/README.md)
 - [utils](./src/utils/README.md)
@@ -52,7 +53,6 @@ manually, by adding the following to your `tsconfig.json`:
 - [contracts](https://github.com/api3dao/contracts)
 - [eslint-plugin-commons](https://github.com/api3dao/eslint-plugin-commons)
 - [ois](https://github.com/api3dao/ois)
-- [promise-utils](https://github.com/api3dao/promise-utils)
 
 ## For developers
 

package.json

@@ -39,7 +39,6 @@
   },
   "dependencies": {
     "@api3/ois": "^3.0.0",
-    "@api3/promise-utils": "^0.4.0",
     "@octokit/rest": "^20.1.1",
     "axios": "^1.18.1",
     "dotenv": "^17.4.2",
@@ -60,6 +59,7 @@
     "prettier": "^3.8.1",
     "ts-jest": "^29.4.9",
     "ts-node": "^10.9.2",
+    "type-plus": "^7.6.2",
     "typescript": "^5.9.3"
   }
 }

src/blockchain-utilities/schema.ts

@@ -1,7 +1,8 @@
-import { goSync } from '@api3/promise-utils';
 import { ethers } from 'ethers';
 import { z } from 'zod';
 
+import { goSync } from '../promises';
+
 export const hexSchema = z
   .string()
   .regex(/^0x[\dA-Fa-f]+$/, 'Invalid hex string format')

src/config-parsing/index.test.ts

@@ -1,6 +1,7 @@
-import { goSync } from '@api3/promise-utils';
 import { ZodError } from 'zod';
 
+import { goSync } from '../promises';
+
 import { interpolateSecretsIntoConfig } from './index';
 
 const rawConfig = {

src/http/index.ts

@@ -1,6 +1,7 @@
-import { go, type GoAsyncOptions } from '@api3/promise-utils';
 import axios, { type Method, type AxiosError, type AxiosResponse } from 'axios';
 
+import { go, type GoAsyncOptions } from '../promises';
+
 const DEFAULT_TIMEOUT_MS = 10_000;
 
 export interface Request {

src/processing/processing.test.ts

@@ -1,8 +1,8 @@
 /* eslint-disable jest/prefer-strict-equal */ // Because the errors are thrown from the "vm" module (different context), they are not strictly equal.
-import { go } from '@api3/promise-utils';
 import { ZodError } from 'zod';
 
 import { createEndpoint } from '../../test/fixtures/processing';
+import { go } from '../promises';
 
 import {
   addReservedParameters,
@@ -59,7 +59,7 @@ describe(preProcessEndpointParametersV1.name, () => {
 
     const throwingFunc = async () => preProcessEndpointParametersV1(preProcessingSpecifications, parameters);
 
-    await expect(throwingFunc).rejects.toThrow('SyntaxError: Unexpected identifier');
+    await expect(throwingFunc).rejects.toThrow('Unexpected identifier');
   });
 
   it('demonstrates access to endpointParameters, but reserved parameters are inaccessible', async () => {
@@ -193,7 +193,7 @@ describe(postProcessResponseV1.name, () => {
 
     const throwingFunc = async () => postProcessResponseV1({ price: 1000 }, postProcessingSpecifications, parameters);
 
-    await expect(throwingFunc).rejects.toThrow('SyntaxError: Unexpected identifier');
+    await expect(throwingFunc).rejects.toThrow('Unexpected identifier');
   });
 });
 
@@ -299,7 +299,7 @@ describe(preProcessEndpointParametersV2.name, () => {
 
       const throwingFunc = async () => preProcessEndpointParametersV2(preProcessingSpecificationV2, parameters);
 
-      await expect(throwingFunc).rejects.toThrow('SyntaxError: Unexpected identifier');
+      await expect(throwingFunc).rejects.toThrow('Unexpected identifier');
     });
 
     it('reserved parameters are inaccessible', async () => {
@@ -452,7 +452,7 @@ describe(postProcessResponseV2.name, () => {
       const throwingFunc = async () =>
         postProcessResponseV2({ price: 1000 }, postProcessingSpecificationV2, parameters);
 
-      await expect(throwingFunc).rejects.toThrow('SyntaxError: Unexpected identifier');
+      await expect(throwingFunc).rejects.toThrow('Unexpected identifier');
     });
   });
 

src/processing/processing.ts

@@ -1,5 +1,6 @@
 import { type Endpoint, RESERVED_PARAMETERS } from '@api3/ois';
-import { type GoAsyncOptions, go } from '@api3/promise-utils';
+
+import { type GoAsyncOptions, go } from '../promises';
 
 import {
   type EndpointParameters,

src/processing/unsafe-evaluate.ts

@@ -35,7 +35,7 @@ import vm from 'node:vm';
 import worker_threads from 'node:worker_threads';
 import zlib from 'node:zlib';
 
-import { type GoWrappedError, go } from '@api3/promise-utils';
+import { type GoWrappedError, go } from '../promises';
 
 import { createTimers } from './vm-timers';