namedSeriesAll (#24)

* fix seriesAll test type error

* update docs command pnpm bump -> pnpm release

* namedSeriesAll

CHANGELOG.md

@@ -1,5 +1,13 @@
 # deverything
 
+## 1.9.0
+
+### Minor Changes
+
+- namedSeriesAll
+- update docs command pnpm bump -> pnpm release
+- fix seriesAll test type error
+
 ## 1.8.1
 
 ### Patch Changes

README.md

@@ -214,7 +214,7 @@ These functions are optimized for low entropy random data generation useful for
 After changes, run
 
 ```
-pnpm bump
+pnpm release
 ```
 
 To bump the version. CI will take care of publishing the package when merged.

package.json

@@ -1,6 +1,6 @@
 {
   "name": "deverything",
-  "version": "1.8.1",
+  "version": "1.9.0",
   "description": "Everything you need for Dev",
   "main": "./dist/index.js",
   "module": "./dist/index.mjs",

src/helpers/namedSeriesAll.test.ts

@@ -0,0 +1,52 @@
+import { describe, expect, test } from '@jest/globals'
+import { namedSeriesAll } from './namedSeriesAll'
+import { sleep } from './sleep'
+
+describe('namedSeriesAll', () => {
+  test('simple', async () => {
+    expect(
+      await namedSeriesAll({
+        a: Promise.resolve(true),
+        b: sleep(1).then(() => 42),
+        c: () => Promise.resolve('foo'),
+        d: async () => [69],
+        e: async () => {
+          await sleep(1)
+          return null
+        },
+        f: async () => {
+          return sleep(1).then(() => {})
+        },
+      }),
+    ).toStrictEqual({
+      a: true,
+      b: 42,
+      c: 'foo',
+      d: [69],
+      e: null,
+      f: undefined,
+    })
+  })
+
+  test('throw new Error', () => {
+    expect(
+      namedSeriesAll({
+        first: () => {
+          throw new Error('1')
+        },
+        second: () => {
+          throw new Error('2')
+        },
+      }),
+    ).rejects.toThrowError('1')
+  })
+
+  test('Promise.reject', () => {
+    expect(
+      namedSeriesAll({
+        first: Promise.reject('3'),
+        second: () => Promise.reject('4'),
+      }),
+    ).rejects.toEqual('3')
+  })
+})

src/helpers/namedSeriesAll.ts

@@ -0,0 +1,32 @@
+import { isFunction, isPromise } from '../validators'
+
+type NamedSeriesResult<T extends Record<string, unknown>> = {
+  [K in keyof T]: T[K] extends Promise<infer U>
+    ? U
+    : T[K] extends () => Promise<infer U>
+    ? U
+    : never
+} & {}
+
+/**
+ * @description Run a series of (async) functions in order and return the results as an object with the same keys.
+ * @example
+ * const { foo, bar } = await namedSeriesAll({
+ *   foo: Promise.resolve(1),
+ *   bar: async () => 2,
+ * }); // => { foo: 1, bar: 2 }
+ */
+export const namedSeriesAll = async <T extends Record<string, unknown>>(
+  series: T,
+): Promise<NamedSeriesResult<T>> => {
+  const results = {} as NamedSeriesResult<T>
+
+  for (const key of Object.keys(series) as (keyof T)[]) {
+    const fn = series[key]
+    if (isPromise(fn))
+      results[key] = (await fn) as NamedSeriesResult<T>[typeof key]
+    else if (isFunction(fn)) results[key] = await fn()
+    else throw new Error('namedSeriesAll: invalid type')
+  }
+  return results
+}

src/helpers/seriesAll.test.ts

@@ -5,7 +5,7 @@ import { sleep } from "./sleep";
 describe("seriesAll", () => {
   test("simple", async () => {
     expect(
-      await seriesAll<number>([
+      await seriesAll([
         Promise.resolve(1),
         sleep(1).then(() => 2),
         () => Promise.resolve(3),