chore: fmt

Author: marcus-pousette

chai-global.js

@@ -46,8 +46,7 @@ if (
 
 		const now = () => Date.now();
 
-		const intervalMsRaw =
-			process.env.PEERBIT_MOCHA_LOG_INTERVAL_MS ?? "30000";
+		const intervalMsRaw = process.env.PEERBIT_MOCHA_LOG_INTERVAL_MS ?? "30000";
 		const intervalMs = Number(intervalMsRaw);
 		let interval;
 		if (Number.isFinite(intervalMs) && intervalMs > 0) {

docs/modules/program/document-store/document-store.ts

@@ -206,14 +206,14 @@ export class Channel extends Program<ChannelArgs> {
 			},
 		});
 
-			await this.reactions.open({
-				type: Reaction,
-				replicate: properties?.replicate,
+		await this.reactions.open({
+			type: Reaction,
+			replicate: properties?.replicate,
 
-				// we don't provide an index here, which means we will index all fields of Reaction
-			});
-		}
+			// we don't provide an index here, which means we will index all fields of Reaction
+		});
 	}
+}
 /// [definition]
 
 /// [insert]

packages/clients/canonical/client/src/auto.ts

@@ -48,7 +48,9 @@ export type CanonicalOpenAdapter<
 	}): Promise<CanonicalOpenResult<T>>;
 };
 
-export const getProgramVariant = (program: Program<any>): string | undefined => {
+export const getProgramVariant = (
+	program: Program<any>,
+): string | undefined => {
 	if (!program || typeof program !== "object") return undefined;
 	try {
 		const schema = getSchema((program as any).constructor);

packages/clients/canonical/client/src/peerbit.ts

@@ -282,8 +282,10 @@ export class PeerbitCanonicalClient {
 		);
 		if (!adapter) {
 			const knownVariants = state.adapters
-				.flatMap((candidate) =>
-					candidate.variants ?? (candidate.variant ? [candidate.variant] : []),
+				.flatMap(
+					(candidate) =>
+						candidate.variants ??
+						(candidate.variant ? [candidate.variant] : []),
 				)
 				.filter((x): x is string => typeof x === "string" && x.length > 0);
 			throw new Error(
@@ -293,7 +295,10 @@ export class PeerbitCanonicalClient {
 			);
 		}
 
-		const key = adapter.getKey?.(program as any, openOptions as OpenOptions<any>);
+		const key = adapter.getKey?.(
+			program as any,
+			openOptions as OpenOptions<any>,
+		);
 		if (adapter.getKey && key === undefined) {
 			throw new Error(
 				`Canonical adapter '${adapter.name}' requires a cache key (adapter.getKey returned undefined)`,
@@ -328,14 +333,14 @@ export class PeerbitCanonicalClient {
 			}
 		}
 
-			const peer = this as any as ProgramClient;
-			const openPromise = (async () => {
-				const result = await adapter.open({
-					program: program as any,
-					options: openOptions as OpenOptions<any>,
-					peer,
-					client: this.canonical,
-				});
+		const peer = this as any as ProgramClient;
+		const openPromise = (async () => {
+			const result = await adapter.open({
+				program: program as any,
+				options: openOptions as OpenOptions<any>,
+				peer,
+				client: this.canonical,
+			});
 
 			let managed: any;
 			managed = createManagedProxy(result.proxy as any, {

packages/clients/test-utils/src/session.ts

@@ -2,8 +2,8 @@ import { yamux } from "@chainsafe/libp2p-yamux";
 import { DirectBlock } from "@peerbit/blocks";
 import { keychain } from "@peerbit/keychain";
 import {
-	listenFast,
 	TestSession as SSession,
+	listenFast,
 	transportsFast,
 } from "@peerbit/libp2p-test-utils";
 import { type ProgramClient } from "@peerbit/program";
@@ -119,7 +119,10 @@ export class TestSession {
 	 * Uses TCP-only transport (no WebRTC/WebSockets/circuit-relay) and disables
 	 * the libp2p relay service by default.
 	 */
-	static async connectedMock(n: number, options?: CreateOptions | CreateOptions[]) {
+	static async connectedMock(
+		n: number,
+		options?: CreateOptions | CreateOptions[],
+	) {
 		const session = await TestSession.disconnectedMock(n, options);
 		await session.connect();
 		// TODO types
@@ -135,7 +138,9 @@ export class TestSession {
 		n: number,
 		options?: CreateOptions | CreateOptions[],
 	) {
-		const applyMockDefaults = (o?: CreateOptions): CreateOptions | undefined => {
+		const applyMockDefaults = (
+			o?: CreateOptions,
+		): CreateOptions | undefined => {
 			if (!o) {
 				return {
 					libp2p: {

packages/programs/data/document/document/benchmark/document-put.ts

@@ -140,4 +140,3 @@ try {
 	await store.drop();
 	await session.stop();
 }
-

packages/programs/data/document/document/src/like.ts

@@ -11,6 +11,7 @@ import type * as indexerTypes from "@peerbit/indexer-interface";
 import type { Program } from "@peerbit/program";
 import type { SharedLogLike } from "@peerbit/shared-log";
 import type { PeerRefs } from "@peerbit/stream-interface";
+import type { CountEstimate } from "./program.js";
 import type {
 	GetOptions,
 	QueryOptions,
@@ -21,7 +22,6 @@ import type {
 	WithContext,
 	WithIndexedContext,
 } from "./search.js";
-import type { CountEstimate } from "./program.js";
 
 export type DocumentsLikeQuery =
 	| SearchRequest

packages/programs/data/document/document/src/search.ts

@@ -4255,26 +4255,26 @@ export class DocumentIndex<
 			}
 		};
 
-			return {
-				close,
-				next,
-				done: doneFn,
-				pending: async () => {
-					try {
-						await fetchPromise;
-						// In push-update mode, remotes will stream new results proactively.
-						// After the iterator has been primed (`first === true`), calling
-						// `fetchAtLeast(1)` from `pending()` can double-count by pulling from
-						// the remote iterator while we also have pushed results buffered locally.
-						//
-						// We still need to prime the iterator at least once so `pending()` is meaningful
-						// even before the first `next(...)` call.
-						if (!done && keepRemoteAlive && (!pushUpdates || !first)) {
-							await fetchAtLeast(1);
-						}
-					} catch (error) {
-						warn("Failed to refresh iterator pending state", error);
+		return {
+			close,
+			next,
+			done: doneFn,
+			pending: async () => {
+				try {
+					await fetchPromise;
+					// In push-update mode, remotes will stream new results proactively.
+					// After the iterator has been primed (`first === true`), calling
+					// `fetchAtLeast(1)` from `pending()` can double-count by pulling from
+					// the remote iterator while we also have pushed results buffered locally.
+					//
+					// We still need to prime the iterator at least once so `pending()` is meaningful
+					// even before the first `next(...)` call.
+					if (!done && keepRemoteAlive && (!pushUpdates || !first)) {
+						await fetchAtLeast(1);
 					}
+				} catch (error) {
+					warn("Failed to refresh iterator pending state", error);
+				}
 
 				let total = 0;
 				for (const buffer of peerBufferMap.values()) {

packages/programs/data/document/document/test/index.spec.ts

@@ -66,7 +66,11 @@ import {
 	PutOperation,
 	PutWithKeyOperation,
 } from "../src/operation.js";
-import { Documents, type CountEstimate, type SetupOptions } from "../src/program.js";
+import {
+	type CountEstimate,
+	Documents,
+	type SetupOptions,
+} from "../src/program.js";
 import {
 	type CanRead,
 	DocumentIndex,
@@ -7116,15 +7120,15 @@ describe("index", () => {
 
 					const expectedCount = Math.round(count / 2);
 
-						// The estimator is probabilistic; use the provided 95% margin, scaled
-						// up to ~99.9% to avoid CI flakes while still detecting regressions.
-						const assertWithinMargin = (result: CountEstimate) => {
-							expect(result.errorMargin).to.not.be.undefined;
-							const margin = Math.max(0.15, result.errorMargin! * (3.29 / 1.96));
-							expect(result.estimate).to.be.within(
-								expectedCount * (1 - margin),
-								expectedCount * (1 + margin),
-							);
+					// The estimator is probabilistic; use the provided 95% margin, scaled
+					// up to ~99.9% to avoid CI flakes while still detecting regressions.
+					const assertWithinMargin = (result: CountEstimate) => {
+						expect(result.errorMargin).to.not.be.undefined;
+						const margin = Math.max(0.15, result.errorMargin! * (3.29 / 1.96));
+						expect(result.estimate).to.be.within(
+							expectedCount * (1 - margin),
+							expectedCount * (1 + margin),
+						);
 					};
 					assertWithinMargin(approxCount1);
 					assertWithinMargin(approxCount2);

packages/programs/data/document/proxy/src/host.ts

@@ -15,11 +15,11 @@ import { Documents } from "@peerbit/document";
 import * as indexerTypes from "@peerbit/indexer-interface";
 import type { SharedLogService } from "@peerbit/shared-log-proxy";
 import { createSharedLogService } from "@peerbit/shared-log-proxy/host";
-	import {
-		DocumentsChange,
-		DocumentsCountRequest,
-		DocumentsGetRequest,
-		DocumentsIndexPutRequest,
+import {
+	DocumentsChange,
+	DocumentsCountRequest,
+	DocumentsGetRequest,
+	DocumentsIndexPutRequest,
 	DocumentsPutWithContextRequest,
 	DocumentsRemoteOptions,
 	DocumentsService,
@@ -389,20 +389,22 @@ export const documentModule: CanonicalModule = {
 					request.context,
 				);
 				await (acquired.program.index as any).index.put(wrapped);
-				},
-				count: async (request: DocumentsCountRequest) => {
-					const approximate = request?.approximate !== false;
-					if (approximate) {
-						const { estimate } = await acquired.program.count({ approximate: true });
-						return BigInt(estimate);
-					}
-					const count = await acquired.program.index.getSize();
-					return BigInt(count);
-				},
-				indexSize: async () => {
-					const size = await acquired.program.index.getSize();
-					return BigInt(size);
-				},
+			},
+			count: async (request: DocumentsCountRequest) => {
+				const approximate = request?.approximate !== false;
+				if (approximate) {
+					const { estimate } = await acquired.program.count({
+						approximate: true,
+					});
+					return BigInt(estimate);
+				}
+				const count = await acquired.program.index.getSize();
+				return BigInt(count);
+			},
+			indexSize: async () => {
+				const size = await acquired.program.index.getSize();
+				return BigInt(size);
+			},
 			waitFor: async (request: DocumentsWaitForRequest) => {
 				const requestId = request.requestId;
 				const controller = requestId ? new AbortController() : undefined;