achingbrain · achingbrain · Mar 2, 2023 · Feb 21, 2023 · Mar 2, 2023 · Mar 2, 2023
diff --git a/package.json b/package.json
@@ -17,20 +17,17 @@
   },
   "private": true,
   "scripts": {
-    "postinstall": "lerna bootstrap",
-    "reset": "rm -rf packages/*/dist packages/*/node_modules packages/*/package-lock.json node_modules package-lock.json",
-    "test": "lerna run test",
-    "coverage": "lerna run coverage",
-    "generate": "lerna run generate",
-    "build": "lerna exec -- tsc && lerna run build",
-    "start": "NODE_ENV=development lerna run start",
-    "clean": "lerna run clean",
-    "lint": "lerna run lint",
-    "dep-check": "lerna run dep-check",
-    "release": "lerna run --concurrency 1 release -- --"
+    "reset": "aegir run clean && aegir clean ./node_modules ./package-lock.json packages/*/node_modules packages/*/package-lock.json packages/*/dist",
+    "test": "aegir run test",
+    "generate": "aegir run generate",
+    "build": "aegir run build",
+    "clean": "aegir run clean",
+    "lint": "aegir run lint",
+    "dep-check": "aegir run dep-check",
+    "release": "aegir run release"
   },
-  "dependencies": {
-    "lerna": "^6.0.0"
+  "devDependencies": {
+    "aegir": "^38.1.7"
   },
   "workspaces": [
     "packages/*"

diff --git a/packages/blob-to-it/package.json b/packages/blob-to-it/package.json
@@ -137,7 +137,7 @@
     "browser-readablestream-to-it": "^2.0.0"
   },
   "devDependencies": {
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "it-all": "^2.0.0"
   }
 }
diff --git a/packages/browser-readablestream-to-it/package.json b/packages/browser-readablestream-to-it/package.json
@@ -134,7 +134,7 @@
     "release": "aegir release"
   },
   "devDependencies": {
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "it-all": "^2.0.0"
   }
 }
diff --git a/packages/it-all/package.json b/packages/it-all/package.json
@@ -135,6 +135,6 @@
     "release": "aegir release"
   },
   "devDependencies": {
-    "aegir": "^37.5.0"
+    "aegir": "^38.1.7"
   }
 }
diff --git a/packages/it-all/src/index.ts b/packages/it-all/src/index.ts
@@ -2,7 +2,7 @@
 /**
  * Collects all values from an (async) iterable and returns them as an array
  */
-export default async function all <T> (source: AsyncIterable<T>|Iterable<T>): Promise<T[]> {
+export default async function all <T> (source: AsyncIterable<T> | Iterable<T>): Promise<T[]> {
   const arr = []
 
   for await (const entry of source) {

diff --git a/packages/it-batch/package.json b/packages/it-batch/package.json
@@ -135,7 +135,7 @@
     "release": "aegir release"
   },
   "devDependencies": {
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "it-all": "^2.0.0"
   }
 }
diff --git a/packages/it-batched-bytes/package.json b/packages/it-batched-bytes/package.json
@@ -140,7 +140,7 @@
     "uint8arraylist": "^2.4.1"
   },
   "devDependencies": {
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "it-all": "^2.0.0"
   }
 }
diff --git a/packages/it-batched-bytes/src/index.ts b/packages/it-batched-bytes/src/index.ts
@@ -3,7 +3,7 @@ import defer from 'p-defer'
 import type { Source } from 'it-stream-types'
 
 const DEFAULT_BATCH_SIZE = 1024 * 1024
-const DEFAULT_SERIALIZE = (buf: Uint8Array | Uint8ArrayList, list: Uint8ArrayList) => list.append(buf)
+const DEFAULT_SERIALIZE = (buf: Uint8Array | Uint8ArrayList, list: Uint8ArrayList): void => { list.append(buf) }
 
 export interface BatchedBytesOptions {
   /**

diff --git a/packages/it-batched-bytes/test/index.spec.ts b/packages/it-batched-bytes/test/index.spec.ts
@@ -94,7 +94,7 @@ describe('it-batched-bytes', () => {
     const batchSize = 2.5
     const res = await all(batch(values, {
       size: batchSize,
-      serialize: (obj, list) => list.append(Uint8Array.of(obj))
+      serialize: (obj, list) => { list.append(Uint8Array.of(obj)) }
     }))
 
     expect(res).to.deep.equal([Uint8Array.of(0, 1, 2), Uint8Array.of(3, 4)])

diff --git a/packages/it-buffer-stream/package.json b/packages/it-buffer-stream/package.json
@@ -138,7 +138,7 @@
     "iso-random-stream": "^2.0.2"
   },
   "devDependencies": {
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "uint8arrays": "^4.0.2"
   }
 }
diff --git a/packages/it-buffer-stream/src/index.ts b/packages/it-buffer-stream/src/index.ts
@@ -15,7 +15,7 @@ const defaultOptions: Required<BufferStreamOptions> = {
 /**
  * An async iterable that emits buffers containing bytes up to a certain length
  */
-export default async function * bufferStream (limit: number, options: BufferStreamOptions = {}) {
+export default async function * bufferStream (limit: number, options: BufferStreamOptions = {}): AsyncGenerator<Uint8Array, void, unknown> {
   const opts: Required<BufferStreamOptions> = Object.assign({}, defaultOptions, options)
   let emitted = 0
 

diff --git a/packages/it-drain/package.json b/packages/it-drain/package.json
@@ -135,6 +135,6 @@
     "release": "aegir release"
   },
   "devDependencies": {
-    "aegir": "^37.5.0"
+    "aegir": "^38.1.7"
   }
 }
diff --git a/packages/it-drain/src/index.ts b/packages/it-drain/src/index.ts
@@ -2,6 +2,6 @@
  * Drains an (async) iterable discarding its' content and does not return
  * anything
  */
-export default async function drain (source: AsyncIterable<unknown>|Iterable<unknown>): Promise<void> {
+export default async function drain (source: AsyncIterable<unknown> | Iterable<unknown>): Promise<void> {
   for await (const _ of source) { } // eslint-disable-line no-unused-vars,no-empty,@typescript-eslint/no-unused-vars
 }
diff --git a/packages/it-drain/test/index.spec.ts b/packages/it-drain/test/index.spec.ts
@@ -4,7 +4,7 @@ import drain from '../src/index.js'
 describe('it-drain', () => {
   it('should empty an async iterator', async () => {
     let done = false
-    const iter = function * () {
+    const iter = function * (): Generator<number, void, unknown> {
       yield 1
       yield 2
       yield 3

diff --git a/packages/it-filter/package.json b/packages/it-filter/package.json
@@ -135,7 +135,7 @@
     "release": "aegir release"
   },
   "devDependencies": {
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "it-all": "^2.0.0"
   }
 }
diff --git a/packages/it-filter/src/index.ts b/packages/it-filter/src/index.ts
@@ -2,7 +2,7 @@
 /**
  * Filters the passed (async) iterable by using the filter function
  */
-export default async function * filter <T> (source: AsyncIterable<T>|Iterable<T>, fn: (val: T) => boolean|Promise<boolean>): AsyncGenerator<T, void, undefined> {
+export default async function * filter <T> (source: AsyncIterable<T> | Iterable<T>, fn: (val: T) => boolean | Promise<boolean>): AsyncGenerator<T, void, undefined> {
   for await (const entry of source) {
     if (await fn(entry)) {
       yield entry

diff --git a/packages/it-first/package.json b/packages/it-first/package.json
@@ -135,6 +135,6 @@
     "release": "aegir release"
   },
   "devDependencies": {
-    "aegir": "^37.5.0"
+    "aegir": "^38.1.7"
   }
 }
diff --git a/packages/it-first/src/index.ts b/packages/it-first/src/index.ts
@@ -3,7 +3,7 @@
  * Returns the first result from an (async) iterable, unless empty, in which
  * case returns `undefined`
  */
-export default async function first <T> (source: AsyncIterable<T>|Iterable<T>): Promise<T | undefined> {
+export default async function first <T> (source: AsyncIterable<T> | Iterable<T>): Promise<T | undefined> {
   for await (const entry of source) { // eslint-disable-line no-unreachable-loop
     return entry
   }

diff --git a/packages/it-flat-batch/package.json b/packages/it-flat-batch/package.json
@@ -135,7 +135,7 @@
     "release": "aegir release"
   },
   "devDependencies": {
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "it-all": "^2.0.0"
   }
 }
diff --git a/packages/it-flat-batch/src/index.ts b/packages/it-flat-batch/src/index.ts
@@ -3,7 +3,7 @@
  * Takes an (async) iterable that emits variable length arrays of things and
  * returns an async iterable that emits those things in fixed-size batches
  */
-export default async function * batch <T> (source: AsyncIterable<T[]>|Iterable<T[]>, batchSize: number = 1): AsyncGenerator<T[], void, undefined> {
+export default async function * batch <T> (source: AsyncIterable<T[]> | Iterable<T[]>, batchSize: number = 1): AsyncGenerator<T[], void, undefined> {
   // @ts-expect-error - expects string not a number
   let size = parseInt(batchSize)
 

diff --git a/packages/it-foreach/package.json b/packages/it-foreach/package.json
@@ -135,7 +135,7 @@
     "release": "aegir release"
   },
   "devDependencies": {
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "it-all": "^2.0.0"
   }
 }
diff --git a/packages/it-foreach/src/index.ts b/packages/it-foreach/src/index.ts
@@ -2,7 +2,7 @@
 /**
  * Invokes the passed function for each item in an iterable
  */
-export default async function * forEach <T> (source: AsyncIterable<T>|Iterable<T>, fn: (thing: T) => void | Promise<void>): AsyncGenerator<T, void, undefined> {
+export default async function * forEach <T> (source: AsyncIterable<T> | Iterable<T>, fn: (thing: T) => void | Promise<void>): AsyncGenerator<T, void, undefined> {
   for await (const thing of source) {
     await fn(thing)
     yield thing

diff --git a/packages/it-glob/package.json b/packages/it-glob/package.json
@@ -134,7 +134,7 @@
     "minimatch": "^5.1.0"
   },
   "devDependencies": {
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "it-all": "^2.0.0"
   },
   "browser": {

diff --git a/packages/it-last/package.json b/packages/it-last/package.json
@@ -135,6 +135,6 @@
     "release": "aegir release"
   },
   "devDependencies": {
-    "aegir": "^37.5.0"
+    "aegir": "^38.1.7"
   }
 }
diff --git a/packages/it-last/src/index.ts b/packages/it-last/src/index.ts
@@ -2,7 +2,7 @@
  * Returns the last item of an (async) iterable, unless empty, in which case
  * return `undefined`
  */
-export default async function last <T> (source: AsyncIterable<T>|Iterable<T>): Promise<T | undefined> {
+export default async function last <T> (source: AsyncIterable<T> | Iterable<T>): Promise<T | undefined> {
   let res
 
   for await (const entry of source) {

diff --git a/packages/it-length/package.json b/packages/it-length/package.json
@@ -135,6 +135,6 @@
     "release": "aegir release"
   },
   "devDependencies": {
-    "aegir": "^37.5.0"
+    "aegir": "^38.1.7"
   }
 }
diff --git a/packages/it-map/package.json b/packages/it-map/package.json
@@ -135,6 +135,6 @@
     "release": "aegir release"
   },
   "devDependencies": {
-    "aegir": "^37.5.0"
+    "aegir": "^38.1.7"
   }
 }
diff --git a/packages/it-map/src/index.ts b/packages/it-map/src/index.ts
@@ -2,7 +2,7 @@
  * Takes an (async) iterable and returns one with each item mapped by the passed
  * function
  */
-export default async function * map <I, O> (source: AsyncIterable<I>|Iterable<I>, func: (val: I) => O | Promise<O>): AsyncGenerator<O, void, undefined> {
+export default async function * map <I, O> (source: AsyncIterable<I> | Iterable<I>, func: (val: I) => O | Promise<O>): AsyncGenerator<O, void, undefined> {
   for await (const val of source) {
     yield func(val)
   }

diff --git a/packages/it-map/test/index.spec.ts b/packages/it-map/test/index.spec.ts
@@ -3,7 +3,7 @@ import map from '../src/index.js'
 
 describe('it-map', () => {
   it('should map an async iterator', async () => {
-    const iter = function * () {
+    const iter = function * (): Generator<number, void, unknown> {
       yield 1
     }
 
@@ -13,7 +13,7 @@ describe('it-map', () => {
   })
 
   it('should map an async iterator to a promise', async () => {
-    const iter = function * () {
+    const iter = function * (): Generator<number, void, unknown> {
       yield 1
     }
 

diff --git a/packages/it-merge/package.json b/packages/it-merge/package.json
@@ -138,7 +138,7 @@
     "it-pushable": "^3.1.0"
   },
   "devDependencies": {
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "it-all": "^2.0.0"
   }
 }
diff --git a/packages/it-merge/src/index.ts b/packages/it-merge/src/index.ts
@@ -6,7 +6,7 @@ import { pushable } from 'it-pushable'
  * Nb. sources are iterated over in parallel so the
  * order of emitted items is not guaranteed.
  */
-export default async function * merge <T> (...sources: Array<AsyncIterable<T>|Iterable<T>>): AsyncGenerator<T, void, undefined> {
+export default async function * merge <T> (...sources: Array<AsyncIterable<T> | Iterable<T>>): AsyncGenerator<T, void, undefined> {
   const output = pushable<T>({
     objectMode: true
   })

diff --git a/packages/it-multipart/package.json b/packages/it-multipart/package.json
@@ -136,7 +136,7 @@
   },
   "devDependencies": {
     "@types/formidable": "^2.0.5",
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "form-data": "^4.0.0",
     "it-drain": "^2.0.0",
     "node-fetch": "^3.2.10",

diff --git a/packages/it-multipart/test/index.spec.ts b/packages/it-multipart/test/index.spec.ts
@@ -12,7 +12,7 @@ describe('it-multipart', () => {
   let server: Server
 
   before(async () => {
-    async function echo (req: IncomingMessage) {
+    async function echo (req: IncomingMessage): Promise<string> {
       const files: Record<string, string> = {}
 
       for await (const part of handler(req)) {

diff --git a/packages/it-ndjson/package.json b/packages/it-ndjson/package.json
@@ -124,7 +124,7 @@
   "scripts": {
     "build": "aegir build",
     "lint": "aegir lint",
-    "dep-check": "aegir dep-check",
+    "dep-check": "aegir dep-check -i buffer",
     "clean": "aegir clean",
     "test": "aegir test",
     "test:node": "aegir test -t node --cov",
@@ -135,7 +135,7 @@
     "release": "aegir release"
   },
   "devDependencies": {
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "buffer": "^6.0.3",
     "it-all": "^2.0.0"
   }

diff --git a/packages/it-ndjson/test/index.spec.ts b/packages/it-ndjson/test/index.spec.ts
@@ -5,7 +5,7 @@ import all from 'it-all'
 
 async function * toAsyncIterator <T> (array: T[]): AsyncIterable<T> {
   for (let i = 0; i < array.length; i++) {
-    await new Promise<void>(resolve => setTimeout(() => resolve()))
+    await new Promise<void>(resolve => setTimeout(() => { resolve() }))
     yield array[i]
   }
 }

diff --git a/packages/it-parallel-batch/package.json b/packages/it-parallel-batch/package.json
@@ -138,7 +138,7 @@
     "it-batch": "^2.0.0"
   },
   "devDependencies": {
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "delay": "^5.0.0",
     "it-all": "^2.0.0"
   }

diff --git a/packages/it-parallel-batch/src/index.ts b/packages/it-parallel-batch/src/index.ts
@@ -15,9 +15,9 @@ interface Failure {
  * invokes them in parallel and emits the results as they become available but
  * in the same order as the input
  */
-export default async function * parallelBatch <T> (source: AsyncIterable<() => Promise<T>>|Iterable<() => Promise<T>>, size: number = 1): AsyncGenerator<T, void, undefined> {
+export default async function * parallelBatch <T> (source: AsyncIterable<() => Promise<T>> | Iterable<() => Promise<T>>, size: number = 1): AsyncGenerator<T, void, undefined> {
   for await (const tasks of batch(source, size)) {
-    const things: Array<Promise<Success<T>|Failure>> = tasks.map(
+    const things: Array<Promise<Success<T> | Failure>> = tasks.map(
       async (p: () => Promise<T>) => {
         return await p().then(value => ({ ok: true, value }), err => ({ ok: false, err }))
       })

diff --git a/packages/it-parallel/package.json b/packages/it-parallel/package.json
@@ -138,7 +138,7 @@
     "p-defer": "^4.0.0"
   },
   "devDependencies": {
-    "aegir": "^37.5.0",
+    "aegir": "^38.1.7",
     "delay": "^5.0.0",
     "it-all": "^2.0.0"
   }