lint

.yarn/versions/4de70976.yml

@@ -0,0 +1,34 @@
+releases:
+  "@xylabs/api": patch
+  "@xylabs/array": patch
+  "@xylabs/arraybuffer": patch
+  "@xylabs/assert": patch
+  "@xylabs/axios": patch
+  "@xylabs/bignumber": patch
+  "@xylabs/buffer": patch
+  "@xylabs/crypto": patch
+  "@xylabs/decimal-precision": patch
+  "@xylabs/delay": patch
+  "@xylabs/error": patch
+  "@xylabs/eth-address": patch
+  "@xylabs/exists": patch
+  "@xylabs/forget": patch
+  "@xylabs/function-name": patch
+  "@xylabs/hex": patch
+  "@xylabs/jest-helpers": patch
+  "@xylabs/libauth": patch
+  "@xylabs/lodash": patch
+  "@xylabs/log": patch
+  "@xylabs/logger": patch
+  "@xylabs/object": patch
+  "@xylabs/platform": patch
+  "@xylabs/profile": patch
+  "@xylabs/promise": patch
+  "@xylabs/retry": patch
+  "@xylabs/sdk-js": patch
+  "@xylabs/set": patch
+  "@xylabs/static-implements": patch
+  "@xylabs/threads": patch
+  "@xylabs/timer": patch
+  "@xylabs/typeof": patch
+  "@xylabs/url": patch

packages/threads/observable.js

@@ -1 +1,2 @@
+/* eslint-disable @typescript-eslint/no-require-imports */
 module.exports = require('./dist/observable')

packages/threads/register.js

@@ -1 +1,2 @@
+/* eslint-disable @typescript-eslint/no-require-imports */
 require('./dist/master/register')

packages/threads/rollup.config.js

@@ -1,4 +1,6 @@
+/* eslint-disable @typescript-eslint/no-require-imports */
 const commonjs = require('@rollup/plugin-commonjs')
+/* eslint-disable @typescript-eslint/no-require-imports */
 const { nodeResolve } = require('@rollup/plugin-node-resolve')
 
 module.exports = {

packages/threads/src/common.ts

@@ -1,5 +1,7 @@
 /* eslint-disable @typescript-eslint/no-explicit-any */
-import type { JsonSerializable, Serializer, SerializerImplementation } from './serializers'
+import type {
+  JsonSerializable, Serializer, SerializerImplementation,
+} from './serializers'
 import { DefaultSerializer, extendSerializer } from './serializers'
 
 let registeredSerializer: Serializer<JsonSerializable> = DefaultSerializer

packages/threads/src/index.ts

@@ -3,6 +3,8 @@ export { registerSerializer } from './common'
 export * from './master/index'
 export { QueuedTask } from './master/pool'
 export { ExposedToThreadType as ExposedAs } from './master/spawn'
-export { DefaultSerializer, JsonSerializable, Serializer, SerializerImplementation } from './serializers'
+export {
+  DefaultSerializer, JsonSerializable, Serializer, SerializerImplementation,
+} from './serializers'
 export { Transfer, TransferDescriptor } from './transferable'
 export { expose } from './worker/index'

packages/threads/src/master/implementation.browser.ts

@@ -1,3 +1,4 @@
+/* eslint-disable @stylistic/max-len */
 /* eslint-disable import-x/no-internal-modules */
 // tslint:disable max-classes-per-file
 

packages/threads/src/master/implementation.node.ts

@@ -18,7 +18,9 @@ import { fileURLToPath } from 'node:url'
 import type { CallSite } from 'callsites-3-1-0'
 import getCallsites from 'callsites-3-1-0'
 
-import type { ImplementationExport, ThreadsWorkerOptions, WorkerImplementation } from '../types/master'
+import type {
+  ImplementationExport, ThreadsWorkerOptions, WorkerImplementation,
+} from '../types/master'
 
 interface WorkerGlobalScope {
   addEventListener(eventName: string, listener: (event: Event) => void): void

packages/threads/src/master/invocation-proxy.ts

@@ -13,13 +13,16 @@ import { multicast, Observable } from 'observable-fns'
 import { deserialize, serialize } from '../common'
 import { ObservablePromise } from '../observable-promise'
 import { isTransferDescriptor } from '../transferable'
-import type { ModuleMethods, ModuleProxy, ProxyableFunction, Worker as WorkerType } from '../types/master'
+import type {
+  ModuleMethods, ModuleProxy, ProxyableFunction, Worker as WorkerType,
+} from '../types/master'
 import type {
   MasterJobCancelMessage,
   MasterJobRunMessage,
   WorkerJobErrorMessage,
   WorkerJobResultMessage,
-  WorkerJobStartMessage } from '../types/messages'
+  WorkerJobStartMessage,
+} from '../types/messages'
 import {
   MasterMessageType,
   WorkerMessageType,

packages/threads/src/master/pool.ts

@@ -8,11 +8,15 @@
 /* eslint-disable @typescript-eslint/no-namespace */
 /* eslint-disable @typescript-eslint/no-floating-promises */
 import DebugLogger from 'debug'
-import { multicast, Observable, Subject } from 'observable-fns'
+import {
+  multicast, Observable, Subject,
+} from 'observable-fns'
 
 import { allSettled } from '../ponyfills'
 import { defaultPoolSize } from './implementation'
-import type { PoolEvent, QueuedTask, TaskRunFunction, WorkerDescriptor } from './pool-types'
+import type {
+  PoolEvent, QueuedTask, TaskRunFunction, WorkerDescriptor,
+} from './pool-types'
 import { PoolEventType } from './pool-types'
 import { Thread } from './thread'
 
@@ -389,5 +393,7 @@ function PoolConstructor<ThreadType extends Thread>(spawnWorker: () => Promise<T
  */
 export const Pool = PoolConstructor as typeof PoolConstructor & { EventType: typeof PoolEventType }
 
-export { PoolEvent, PoolEventType, QueuedTask } from './pool-types'
+export {
+  PoolEvent, PoolEventType, QueuedTask,
+} from './pool-types'
 export { Thread } from './thread'

packages/threads/src/master/spawn.ts

@@ -6,7 +6,9 @@ import { Observable } from 'observable-fns'
 
 import { deserialize } from '../common'
 import { createPromiseWithResolver } from '../promise'
-import { $errors, $events, $terminate, $worker } from '../symbols'
+import {
+  $errors, $events, $terminate, $worker,
+} from '../symbols'
 import type {
   FunctionThread,
   ModuleThread,
@@ -16,10 +18,9 @@ import type {
   WorkerEvent,
   WorkerInternalErrorEvent,
   WorkerMessageEvent,
-  WorkerTerminationEvent } from '../types/master'
-import {
-  WorkerEventType,
+  WorkerTerminationEvent,
 } from '../types/master'
+import { WorkerEventType } from '../types/master'
 import type { WorkerInitMessage, WorkerUncaughtErrorMessage } from '../types/messages'
 import type { WorkerFunction, WorkerModule } from '../types/worker'
 import { createProxyFunction, createProxyModule } from './invocation-proxy'
@@ -94,9 +95,7 @@ function createEventObservable(worker: WorkerType, workerTermination: Promise<an
     worker.addEventListener('unhandledrejection', rejectionHandler)
 
     workerTermination.then(() => {
-      const terminationEvent: WorkerTerminationEvent = {
-        type: WorkerEventType.termination,
-      }
+      const terminationEvent: WorkerTerminationEvent = { type: WorkerEventType.termination }
       worker.removeEventListener('message', messageHandler)
       worker.removeEventListener('unhandledrejection', rejectionHandler)
       observer.next(terminationEvent)

packages/threads/src/master/thread.ts

@@ -1,7 +1,9 @@
 /* eslint-disable import-x/no-internal-modules */
 import type { Observable } from 'observable-fns'
 
-import { $errors, $events, $terminate } from '../symbols'
+import {
+  $errors, $events, $terminate,
+} from '../symbols'
 import type { Thread as ThreadType, WorkerEvent } from '../types/master'
 
 function fail(message: string): never {

packages/threads/src/types/master.ts

@@ -7,7 +7,9 @@
 import type { Observable } from 'observable-fns'
 
 import type { ObservablePromise } from '../observable-promise'
-import type { $errors, $events, $terminate, $worker } from '../symbols'
+import type {
+  $errors, $events, $terminate, $worker,
+} from '../symbols'
 import type { TransferDescriptor } from '../transferable'
 
 interface ObservableLikeSubscription {

packages/threads/src/worker/index.ts

@@ -15,7 +15,8 @@ import type {
   WorkerJobErrorMessage,
   WorkerJobResultMessage,
   WorkerJobStartMessage,
-  WorkerUncaughtErrorMessage } from '../types/messages'
+  WorkerUncaughtErrorMessage,
+} from '../types/messages'
 import {
   MasterMessageType,
   WorkerMessageType,
@@ -52,9 +53,7 @@ function deconstructTransfer(thing: any) {
 
 function postFunctionInitMessage() {
   const initMessage: WorkerInitMessage = {
-    exposed: {
-      type: 'function',
-    },
+    exposed: { type: 'function' },
     type: WorkerMessageType.init,
   }
   Implementation.postMessageToMaster(initMessage)

packages/threads/test-tooling/rollup/app.js

@@ -1,5 +1,7 @@
 /* eslint-disable no-restricted-imports */
-import { spawn, Thread, Worker } from '../..'
+import {
+  spawn, Thread, Worker,
+} from '../..'
 
 async function run() {
   const add = await spawn(new Worker('./worker.js'))

packages/threads/test-tooling/tsconfig/minimal.ts

@@ -1,6 +1,8 @@
 /* eslint-disable no-restricted-imports */
 /* eslint-disable @typescript-eslint/no-floating-promises */
-import { spawn, Thread, Worker } from '../..'
+import {
+  spawn, Thread, Worker,
+} from '../..'
 
 async function main() {
   const helloWorld = await spawn(new Worker('./workers/hello-world'))

packages/threads/test-tooling/webpack/app.ts

@@ -1,6 +1,8 @@
 /* eslint-disable @typescript-eslint/no-explicit-any */
 
-import { isWorkerRuntime, Pool, spawn, Worker } from '../../src/index'
+import {
+  isWorkerRuntime, Pool, spawn, Worker,
+} from '../../src/index'
 
 type AdditionWorker = (a: number, b: number) => number
 type HelloWorker = (text: string) => string

packages/threads/test-tooling/webpack/webpack.node.config.js

@@ -1,23 +1,18 @@
+/* eslint-disable @typescript-eslint/no-require-imports */
 const path = require('node:path')
 const ThreadsPlugin = require('threads-plugin')
 
 module.exports = {
   context: __dirname,
   devtool: false,
   entry: require.resolve('./app.ts'),
-  externals: {
-    'tiny-worker': 'tiny-worker',
-  },
+  externals: { 'tiny-worker': 'tiny-worker' },
   mode: 'development',
   module: {
     rules: [
       {
         loader: 'ts-loader',
-        options: {
-          compilerOptions: {
-            module: 'esnext',
-          },
-        },
+        options: { compilerOptions: { module: 'esnext' } },
         test: /\.ts$/,
       },
     ],
@@ -29,8 +24,6 @@ module.exports = {
     path: path.resolve(__dirname, './dist/app.node'),
   },
   plugins: [new ThreadsPlugin()],
-  resolve: {
-    extensions: ['.js', '.ts'],
-  },
+  resolve: { extensions: ['.js', '.ts'] },
   target: 'node',
 }

packages/threads/test-tooling/webpack/webpack.web.config.js

@@ -1,3 +1,4 @@
+/* eslint-disable @typescript-eslint/no-require-imports */
 const path = require('node:path')
 const ThreadsPlugin = require('threads-plugin')
 
@@ -10,11 +11,7 @@ module.exports = {
     rules: [
       {
         loader: 'ts-loader',
-        options: {
-          compilerOptions: {
-            module: 'esnext',
-          },
-        },
+        options: { compilerOptions: { module: 'esnext' } },
         test: /\.ts$/,
       },
     ],
@@ -26,8 +23,6 @@ module.exports = {
     path: path.resolve(__dirname, './dist/app.web'),
   },
   plugins: [new ThreadsPlugin()],
-  resolve: {
-    extensions: ['.js', '.ts'],
-  },
+  resolve: { extensions: ['.js', '.ts'] },
   target: 'web',
 }

packages/threads/test/pool.test.ts

@@ -6,7 +6,9 @@
 // eslint-disable import-x/no-internal-modules
 import test from 'ava'
 
-import { Pool, spawn, Worker } from '../src/index'
+import {
+  Pool, spawn, Worker,
+} from '../src/index'
 import type { QueuedTask } from '../src/master/pool'
 import { PoolEventType } from '../src/master/pool'
 
@@ -65,9 +67,7 @@ test.serial('thread pool basics work and events are emitted', async (t) => {
       type: Pool.EventType.taskCompleted,
       workerID: 1,
     },
-    {
-      type: Pool.EventType.taskQueueDrained,
-    },
+    { type: Pool.EventType.taskQueueDrained },
     {
       remainingQueue: [],
       type: Pool.EventType.terminated,

packages/threads/test/serialization.test.ts

@@ -1,7 +1,9 @@
 /* eslint-disable import-x/no-internal-modules */
 import test from 'ava'
 
-import { registerSerializer, spawn, Thread, Worker } from '../src/index'
+import {
+  registerSerializer, spawn, Thread, Worker,
+} from '../src/index'
 import { Foo, fooSerializer } from './lib/serialization'
 
 registerSerializer(fooSerializer)

packages/threads/test/spawn.chromium.mocha.ts

@@ -11,7 +11,9 @@ import '../src/master/register'
 
 import { expect } from 'chai'
 
-import { BlobWorker, spawn, Thread } from '..'
+import {
+  BlobWorker, spawn, Thread,
+} from '..'
 
 describe('threads in browser', function () {
   it('can spawn and terminate a thread', async function () {

packages/threads/test/spawn.test.ts

@@ -4,7 +4,9 @@
 import test from 'ava'
 import type { Observable } from 'observable-fns'
 
-import { spawn, Thread, Worker } from '../src/index'
+import {
+  spawn, Thread, Worker,
+} from '../src/index'
 import type { Counter } from './workers/counter'
 
 test('can spawn and terminate a thread', async (t) => {

packages/threads/test/streaming.test.ts

@@ -1,6 +1,8 @@
 import test from 'ava'
 
-import { spawn, Thread, Worker } from '../src/index'
+import {
+  spawn, Thread, Worker,
+} from '../src/index'
 
 test('can use worker returning an observable subject', async (t) => {
   const captured: Array<{ max: number; min: number }> = []

packages/threads/test/transferables.test.ts

@@ -4,7 +4,9 @@
 
 import test from 'ava'
 
-import { spawn, Thread, Transfer, Worker } from '../src/index'
+import {
+  spawn, Thread, Transfer, Worker,
+} from '../src/index'
 import type { XorBuffer } from './workers/arraybuffer-xor'
 
 type SpyInit<Args extends any[], OriginalReturn, NewReturn> = (originalFn: (...args: Args) => OriginalReturn) => (...args: Args) => NewReturn

packages/threads/worker.js

@@ -1 +1,2 @@
+// eslint-disable-next-line @typescript-eslint/no-require-imports
 module.exports = require('./dist/worker/index')