Updates Node.js and refactors core utilities

Upgrades the minimum Node.js version from 22 to 24 (current LTS), allowing for the use of modern JavaScript features like `Promise.withResolvers`.

This change also includes significant internal refactoring:
- Consolidates `Task` and array utility modules.
- Adopts `import type` extensively for better tree-shaking and optimized bundle sizes.
- Enhances type safety with explicit annotations and assertions.
- Removes the deprecated `erasableSyntaxOnly` TypeScript configuration option.

Author: miccy

.changeset/gentle-pumas-eat.md

@@ -9,4 +9,6 @@
 "@evolu/relay": major
 ---
 
+# Update Node.js requirement
+
 Updated minimum Node.js version from 22 to 24 (current LTS)

.nvmrc

@@ -1 +1 @@
-lts/*
+v24

packages/common/src/Task.ts

@@ -1,8 +1,19 @@
-import { isNonEmptyArray, shiftArray } from "./Array.js";
-import { Result, err, ok } from "./Result.js";
+import { isNonEmptyArray, shiftFromArray } from "./Array.js";
+import { err, ok, type Result } from "./Result.js";
 import { Duration, durationToNonNegativeInt } from "./Time.js";
 import { NonNegativeInt, PositiveInt } from "./Type.js";
 
+
+declare global {
+  interface PromiseConstructor {
+    withResolvers<T>(): {
+      promise: Promise<T>;
+      resolve: (value: T | PromiseLike<T>) => void;
+      reject: (reason?: unknown) => void;
+    };
+  }
+}
+
 /**
  * `Task` is a function that creates and returns an optionally cancellable
  * Promise using {@link Result}.
@@ -144,6 +155,8 @@ import { NonNegativeInt, PositiveInt } from "./Type.js";
  * dependencies and `TaskContext` for execution context like cancellation. Usage
  * follows the pattern: deps → arguments → execution context.
  */
+
+
 export interface Task<T, E> {
   /**
    * Invoke the Task.
@@ -236,7 +249,11 @@ const combineSignal = (
   internalSignal: AbortSignal,
 ): AbortSignal =>
   context?.signal
-    ? AbortSignal.any([context.signal, internalSignal])
+    ? (
+        AbortSignal as unknown as {
+          any: (signals: Iterable<AbortSignal>) => AbortSignal;
+        }
+      ).any([context.signal, internalSignal])
     : internalSignal;
 
 /**
@@ -652,7 +669,7 @@ export const createSemaphore = (maxConcurrent: PositiveInt): Semaphore => {
 
   const release = (): void => {
     if (isNonEmptyArray(waitingQueue)) {
-      shiftArray(waitingQueue)();
+      shiftFromArray(waitingQueue)();
     } else {
       availablePermits++;
     }
@@ -689,7 +706,7 @@ export const createSemaphore = (maxConcurrent: PositiveInt): Semaphore => {
 
       // Release all waiting tasks so they can continue and check isDisposed
       while (isNonEmptyArray(waitingQueue)) {
-        shiftArray(waitingQueue)();
+        shiftFromArray(waitingQueue)();
       }
     },
   };

packages/common/src/WebSocket.ts

@@ -1,6 +1,6 @@
 import { constVoid } from "./Function.js";
 import { err, ok, Result } from "./Result.js";
-import { retry, RetryError, RetryOptions } from "./OldTask.js";
+import { retry, RetryError, type RetryOptions } from "./Task.js";
 import { maxPositiveInt } from "./Type.js";
 
 /** WebSocket with auto-reconnect and offline support. */

packages/common/src/local-first/Evolu.ts

@@ -2,74 +2,74 @@ import { pack } from "msgpackr";
 import { dedupeArray, isNonEmptyArray } from "../Array.js";
 import { assert, assertNonEmptyReadonlyArray } from "../Assert.js";
 import { createCallbacks } from "../Callbacks.js";
-import { ConsoleDep, createConsole } from "../Console.js";
-import { createRandomBytes, RandomBytesDep } from "../Crypto.js";
+import { createConsole, type ConsoleDep } from "../Console.js";
+import { createRandomBytes, type RandomBytesDep } from "../Crypto.js";
 import { eqArrayNumber } from "../Eq.js";
-import { FlushSyncDep, ReloadAppDep } from "../Platform.js";
+import type { FlushSyncDep, ReloadAppDep } from "../Platform.js";
 import {
   createDisposableDep,
-  DisposableDep,
-  DisposableStackDep,
+  type DisposableDep,
+  type DisposableStackDep,
 } from "../Resources.js";
-import { err, ok, Result } from "../Result.js";
+import { err, ok, type Result } from "../Result.js";
 import {
-  isSqlMutation,
-  SafeSql,
   SqliteBoolean,
+  isSqlMutation,
   sqliteBooleanToBoolean,
-  SqliteQuery,
+  type SafeSql,
+  type SqliteQuery,
 } from "../Sqlite.js";
-import { createStore, ReadonlyStore, Store, StoreSubscribe } from "../Store.js";
+import { createStore, type ReadonlyStore, type Store, type StoreSubscribe } from "../Store.js";
 import {
   createId,
-  Id,
-  InferErrors,
-  InferInput,
-  ObjectType,
-  SimpleName,
-  ValidMutationSize,
-  ValidMutationSizeError,
+  type Id,
+  type InferErrors,
+  type InferInput,
+  type ObjectType,
+  type SimpleName,
+  type ValidMutationSize,
+  type ValidMutationSizeError,
 } from "../Type.js";
-import { IntentionalNever } from "../Types.js";
-import { CreateMessageChannelDep } from "../Worker.js";
-import { EvoluError } from "./Error.js";
+import type { IntentionalNever } from "../Types.js";
+import type { CreateMessageChannelDep } from "../Worker.js";
+import type { EvoluError } from "./Error.js";
 import {
-  AppOwner,
   createOwnerWebSocketTransport,
-  OwnerId,
-  OwnerTransport,
+  type AppOwner,
+  type OwnerId,
+  type OwnerTransport,
 } from "./Owner.js";
 import {
   createSubscribedQueries,
   emptyRows,
-  Queries,
-  QueriesToQueryRowsPromises,
-  Query,
-  QueryRows,
-  QueryRowsMap,
-  Row,
   serializeQuery,
-  SubscribedQueries,
+  type Queries,
+  type QueriesToQueryRowsPromises,
+  type Query,
+  type QueryRows,
+  type QueryRowsMap,
+  type Row,
+  type SubscribedQueries,
 } from "./Query.js";
 import {
-  CreateQuery,
-  EvoluSchema,
-  IndexesConfig,
   insertable,
   kysely,
-  Mutation,
-  MutationChange,
-  MutationKind,
-  MutationMapping,
-  MutationOptions,
-  SystemColumns,
   updateable,
   upsertable,
-  ValidateSchema,
+  type CreateQuery,
+  type EvoluSchema,
+  type IndexesConfig,
+  type Mutation,
+  type MutationChange,
+  type MutationKind,
+  type MutationMapping,
+  type MutationOptions,
+  type SystemColumns,
+  type ValidateSchema,
 } from "./Schema.js";
-import { SharedWorkerDep } from "./SharedWorker.js";
+import type { SharedWorkerDep } from "./SharedWorker.js";
 import { DbChange } from "./Storage.js";
-import { SyncOwner } from "./Sync.js";
+import type { SyncOwner } from "./Sync.js";
 
 export interface EvoluConfig {
   /**
@@ -80,7 +80,7 @@ export interface EvoluConfig {
    * storage, ensuring that database files are separated and invisible to each
    * other.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * // name: SimpleName.orThrow("MyApp")
@@ -116,7 +116,7 @@ export interface EvoluConfig {
    *
    * `{ type: "WebSocket", url: "wss://free.evoluhq.com" }`.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * // Single WebSocket relay
@@ -154,7 +154,7 @@ export interface EvoluConfig {
    * For device-specific settings and account management state, we can use a
    * separate local-only Evolu instance via `transports: []`.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * const ConfigId = id("Config");
@@ -201,7 +201,7 @@ export interface EvoluConfig {
    *
    * https://medium.com/@JasonWyatt/squeezing-performance-from-sqlite-indexes-indexes-c4e175f3c346
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * const evolu = createEvolu(evoluReactDeps)(Schema, {
@@ -231,7 +231,7 @@ export interface Evolu<S extends EvoluSchema = EvoluSchema> extends Disposable {
   /**
    * Subscribe to {@link EvoluError} changes.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * const unsubscribe = evolu.subscribeError(() => {
@@ -257,7 +257,7 @@ export interface Evolu<S extends EvoluSchema = EvoluSchema> extends Disposable {
    * For mutations, use {@link Evolu.insert}, {@link Evolu.update}, or
    * {@link Evolu.upsert}.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * const allTodos = evolu.createQuery((db) =>
@@ -286,7 +286,7 @@ export interface Evolu<S extends EvoluSchema = EvoluSchema> extends Disposable {
    * To subscribe a query for automatic updates, use
    * {@link Evolu.subscribeQuery}.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * const allTodos = evolu.createQuery((db) =>
@@ -304,7 +304,7 @@ export interface Evolu<S extends EvoluSchema = EvoluSchema> extends Disposable {
    * {@link QueryRows} promises. It's like `queries.map(loadQuery)` but with
    * proper types for returned promises.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * evolu.loadQueries([allTodos, todoById(1)]);
@@ -317,7 +317,7 @@ export interface Evolu<S extends EvoluSchema = EvoluSchema> extends Disposable {
   /**
    * Subscribe to {@link Query} {@link QueryRows} changes.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * const unsubscribe = evolu.subscribeQuery(allTodos)(() => {
@@ -330,7 +330,7 @@ export interface Evolu<S extends EvoluSchema = EvoluSchema> extends Disposable {
   /**
    * Get {@link QueryRows}.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * const unsubscribe = evolu.subscribeQuery(allTodos)(() => {
@@ -346,7 +346,7 @@ export interface Evolu<S extends EvoluSchema = EvoluSchema> extends Disposable {
    * Note: With web-only deps, this promise will not resolve during SSR because
    * there is no AppOwner on the server.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * const owner = await evolu.appOwner;
@@ -370,7 +370,7 @@ export interface Evolu<S extends EvoluSchema = EvoluSchema> extends Disposable {
    * predictably merged without conflicts. Explicit mutations also allow Evolu
    * to automatically update {@link SystemColumns}.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * const result = evolu.insert("todo", {
@@ -415,7 +415,7 @@ export interface Evolu<S extends EvoluSchema = EvoluSchema> extends Disposable {
    * predictably merged without conflicts. Explicit mutations also allow Evolu
    * to automatically update {@link SystemColumns}.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * const result = evolu.update("todo", {
@@ -468,7 +468,7 @@ export interface Evolu<S extends EvoluSchema = EvoluSchema> extends Disposable {
    * predictably merged without conflicts. Explicit mutations also allow Evolu
    * to automatically update {@link SystemColumns}.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * // Use deterministic ID for stable upserts across devices
@@ -554,7 +554,7 @@ export interface Evolu<S extends EvoluSchema = EvoluSchema> extends Disposable {
    * Transport are automatically deduplicated and reference-counted, so multiple
    * owners using the same transport will share a single connection.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * // Use an owner (starts syncing).
@@ -592,7 +592,7 @@ export interface ErrorStoreDep {
    * Shared error store for all Evolu instances. Subscribe once to handle errors
    * globally across all instances.
    *
-   * ## Example
+   * ### Example
    *
    * ```ts
    * deps.evoluError.subscribe(() => {