style: post-merge lint normalization

Co-authored-by: Alfonso <alfonso@cortexkit.io>

Author: ualtinok

packages/pi-plugin/src/context-handler.test.ts

@@ -1,4 +1,3 @@
-import { setBootQuietPeriodForTests } from '@magic-context/core/plugin/boot-quiet';
 import { afterEach, describe, expect, it, mock, spyOn } from "bun:test";
 import { mkdtempSync, readFileSync, rmSync } from "node:fs";
 import { tmpdir } from "node:os";

packages/plugin/src/features/magic-context/memory/embedding-identity.ts

@@ -1,7 +1,7 @@
 import type { EmbeddingConfig } from "../../../config/schema/magic-context";
 import { DEFAULT_LOCAL_EMBEDDING_MODEL } from "../../../config/schema/magic-context";
-import { computeNormalizedHash } from "./normalize-hash";
 import { getSynapseLaneIdentity } from "./embedding-synapse";
+import { computeNormalizedHash } from "./normalize-hash";
 
 function normalizeEndpoint(endpoint?: string): string {
     return endpoint?.trim().replace(/\/+$/, "") ?? "";

packages/plugin/src/features/magic-context/memory/embedding-synapse.test.ts

@@ -1,18 +1,22 @@
 import { afterEach, describe, expect, it } from "bun:test";
 import {
-    SYNAPSE_MAX_INPUT_TOKENS,
-    SynapseEmbeddingProvider,
     _resetSynapseClientForTests,
     getSynapseLaneIdentity,
+    SYNAPSE_MAX_INPUT_TOKENS,
     type SynapseClientLike,
+    SynapseEmbeddingProvider,
 } from "./embedding-synapse";
 
 class MockSynapseClient implements SynapseClientLike {
     readonly requests: Array<{ method: string; params: unknown }> = [];
     private batchAttempts = 0;
     constructor(private readonly batchSize = 2) {}
 
-    async call<Response = unknown>(_module: string, method: string, params?: unknown): Promise<Response> {
+    async call<Response = unknown>(
+        _module: string,
+        method: string,
+        params?: unknown,
+    ): Promise<Response> {
         this.requests.push({ method, params });
         if (method === "models.list") {
             return {
@@ -117,11 +121,22 @@ describe("SynapseEmbeddingProvider", () => {
 
     it("rejects served fingerprint substitution without adapting", async () => {
         const client = new MockSynapseClient();
-        client.call = async <Response = unknown>(_module: string, method: string, params?: unknown) => {
+        client.call = async <Response = unknown>(
+            _module: string,
+            method: string,
+            params?: unknown,
+        ) => {
             client.requests.push({ method, params });
             if (method === "models.list") {
                 return {
-                    models: [{ model: "gte-modernbert-base-f16", fingerprint: "fp-live", table_epoch: 0, dims: 3 }],
+                    models: [
+                        {
+                            model: "gte-modernbert-base-f16",
+                            fingerprint: "fp-live",
+                            table_epoch: 0,
+                            dims: 3,
+                        },
+                    ],
                 } as Response;
             }
             return { vector: [1, 2, 3], fingerprint: "fp-other", table_epoch: 0 } as Response;

packages/plugin/src/features/magic-context/memory/embedding-synapse.ts

@@ -224,8 +224,7 @@ function extractCatalogEntries(value: unknown): SynapseCatalogEntry[] {
         const fingerprint =
             typeof record.fingerprint === "string" && record.fingerprint.length > 0
                 ? record.fingerprint
-                : Array.isArray(record.fingerprints) &&
-                    typeof record.fingerprints[0] === "string"
+                : Array.isArray(record.fingerprints) && typeof record.fingerprints[0] === "string"
                   ? record.fingerprints[0]
                   : "";
         const entryEpoch = record.table_epoch ?? record.tableEpoch;
@@ -249,9 +248,7 @@ function extractCatalogEntries(value: unknown): SynapseCatalogEntry[] {
                 model,
                 fingerprint,
                 table_epoch: tableEpoch,
-                ...(typeof dims === "number" && Number.isInteger(dims) && dims > 0
-                    ? { dims }
-                    : {}),
+                ...(typeof dims === "number" && Number.isInteger(dims) && dims > 0 ? { dims } : {}),
                 ...(typeof recommendedBatch === "number" && recommendedBatch > 0
                     ? { recommended_batch: Math.floor(recommendedBatch) }
                     : {}),
@@ -274,9 +271,7 @@ function extractVector(
     // The live envelope carries vectors: [{id, vector, content_sha256}] for
     // every embed op, including single-text queries; older sketches used a
     // top-level vector/embedding field, kept as a fallback.
-    const fromVectors = Array.isArray(body.vectors)
-        ? asRecord(body.vectors[0])?.vector
-        : undefined;
+    const fromVectors = Array.isArray(body.vectors) ? asRecord(body.vectors[0])?.vector : undefined;
     const raw = fromVectors ?? body.vector ?? body.embedding;
     if (
         !Array.isArray(raw) ||

packages/plugin/src/features/magic-context/migrations-v53.test.ts

@@ -3,9 +3,9 @@
 import { describe, expect, test } from "bun:test";
 import { Database } from "../../shared/sqlite";
 import { closeQuietly } from "../../shared/sqlite-helpers";
-import { clearSession } from "./storage-meta-session";
 import { LATEST_MIGRATION_VERSION, runMigrations } from "./migrations";
 import { initializeDatabase, LATEST_SUPPORTED_VERSION } from "./storage-db";
+import { clearSession } from "./storage-meta-session";
 
 function tableExists(db: Database, table: string): boolean {
     return Boolean(
@@ -51,13 +51,17 @@ describe("migration v53: Synapse embedding storage", () => {
             clearSession(db, "ses-v53");
 
             expect(
-                db.prepare("SELECT COUNT(*) AS count FROM synapse_batch_ledger WHERE session_id = ?").get(
-                    "ses-v53",
-                ),
+                db
+                    .prepare(
+                        "SELECT COUNT(*) AS count FROM synapse_batch_ledger WHERE session_id = ?",
+                    )
+                    .get("ses-v53"),
             ).toEqual({ count: 0 });
             expect(
                 db
-                    .prepare("SELECT COUNT(*) AS count FROM embedding_measurement_corpus WHERE session_id = ?")
+                    .prepare(
+                        "SELECT COUNT(*) AS count FROM embedding_measurement_corpus WHERE session_id = ?",
+                    )
                     .get("ses-v53"),
             ).toEqual({ count: 0 });
         } finally {

packages/plugin/src/features/magic-context/project-embedding-registry.test.ts

@@ -247,16 +247,33 @@ describe("project embedding registry", () => {
             features,
             "/repo",
         );
-        const off = registerProjectEmbedding(db, "golden-off", { provider: "off" }, features, "/repo");
-        expect({ providerIdentity: local.providerIdentity, runtimeFingerprint: local.runtimeFingerprint }).toEqual({
+        const off = registerProjectEmbedding(
+            db,
+            "golden-off",
+            { provider: "off" },
+            features,
+            "/repo",
+        );
+        expect({
+            providerIdentity: local.providerIdentity,
+            runtimeFingerprint: local.runtimeFingerprint,
+        }).toEqual({
             providerIdentity: "embedding-provider:c447205ebd551e83d18c4fd5fd8fc357",
-            runtimeFingerprint: "embedding-provider:c447205ebd551e83d18c4fd5fd8fc357:f0bab7fe74e0f0a0",
+            runtimeFingerprint:
+                "embedding-provider:c447205ebd551e83d18c4fd5fd8fc357:f0bab7fe74e0f0a0",
         });
-        expect({ providerIdentity: openai.providerIdentity, runtimeFingerprint: openai.runtimeFingerprint }).toEqual({
+        expect({
+            providerIdentity: openai.providerIdentity,
+            runtimeFingerprint: openai.runtimeFingerprint,
+        }).toEqual({
             providerIdentity: "embedding-provider:efd9edf1dbe1d83cef0860fb93475cb4",
-            runtimeFingerprint: "embedding-provider:efd9edf1dbe1d83cef0860fb93475cb4:9b840cd5c05319d9",
+            runtimeFingerprint:
+                "embedding-provider:efd9edf1dbe1d83cef0860fb93475cb4:9b840cd5c05319d9",
         });
-        expect({ providerIdentity: off.providerIdentity, runtimeFingerprint: off.runtimeFingerprint }).toEqual({
+        expect({
+            providerIdentity: off.providerIdentity,
+            runtimeFingerprint: off.runtimeFingerprint,
+        }).toEqual({
             providerIdentity: "embedding-provider:off",
             runtimeFingerprint: "embedding-provider:off",
         });

packages/plugin/src/features/magic-context/storage.ts

@@ -55,6 +55,16 @@ export {
     schemaVersionIsSupported,
     setSqlitePragmaConfig,
 } from "./storage-db";
+export {
+    beginSynapseBatchLedger,
+    type EmbeddingMeasurementInput,
+    type EmbeddingMeasurementRow,
+    finishSynapseBatchLedger,
+    listEmbeddingMeasurements,
+    normalizedQueryHash,
+    recordEmbeddingMeasurement,
+    type SynapseBatchLedgerInput,
+} from "./storage-embedding-measurements";
 export {
     deleteIdentityRekeyMap,
     getIdentityRekeyMap,
@@ -191,16 +201,6 @@ export {
     type WrapupInProgressState,
 } from "./storage-meta";
 export { bumpSessionFactsVersion } from "./storage-meta-shared";
-export {
-    listEmbeddingMeasurements,
-    normalizedQueryHash,
-    recordEmbeddingMeasurement,
-    type EmbeddingMeasurementInput,
-    type EmbeddingMeasurementRow,
-    beginSynapseBatchLedger,
-    finishSynapseBatchLedger,
-    type SynapseBatchLedgerInput,
-} from "./storage-embedding-measurements";
 export {
     addNote,
     deleteNote,

packages/plugin/src/hooks/magic-context/shadow-sender.test.ts

@@ -715,7 +715,10 @@ describe("shadow sender", () => {
             expect(first).toEqual(expect.objectContaining({ ok: true }));
             if (!first.ok) throw new Error("provisional ordinal setup failed");
 
-            rows = [...rows, { id: "m3", timeCreated: 3, contributesOrdinal: true, hasValidInfo: true }];
+            rows = [
+                ...rows,
+                { id: "m3", timeCreated: 3, contributesOrdinal: true, hasValidInfo: true },
+            ];
             const healed = await __shadowSenderTest.resolveOrdinalsForShadow({
                 sessionId,
                 messages: provisional,
@@ -744,7 +747,14 @@ describe("shadow sender", () => {
                 { id: "m1", timeCreated: 1, contributesOrdinal: true, hasValidInfo: true },
                 { id: "m2", timeCreated: 2, contributesOrdinal: true, hasValidInfo: true },
             ];
-            sender.enqueue(basePass({ db, sessionId, inputMessages: provisional, outputMessages: provisional }));
+            sender.enqueue(
+                basePass({
+                    db,
+                    sessionId,
+                    inputMessages: provisional,
+                    outputMessages: provisional,
+                }),
+            );
             await waitFor(() => sender.getStats(sessionId).transforms_sent === 1);
             rows = [
                 ...rows,
@@ -761,9 +771,9 @@ describe("shadow sender", () => {
                 }),
             );
             await waitFor(() => sender.getStats(sessionId).transforms_sent === 2);
-            expect(resetTransport.calls.filter((call) => call.method === "shadow_reset")).toHaveLength(
-                2,
-            );
+            expect(
+                resetTransport.calls.filter((call) => call.method === "shadow_reset"),
+            ).toHaveLength(2);
             expect(sender.getStats(sessionId).ordinal_mismatch).toBe(1);
         } finally {
             unregister();
@@ -1317,7 +1327,14 @@ describe("shadow sender", () => {
             ),
         ).toBe(true);
         const assembled = { ...pages.at(-1) } as Record<string, unknown>;
-        for (const field of ["transform_page_id", "transform_generation", "transform_page_index", "transform_page_total", "transform_page_complete", "transform_page_digest"]) {
+        for (const field of [
+            "transform_page_id",
+            "transform_generation",
+            "transform_page_index",
+            "transform_page_total",
+            "transform_page_complete",
+            "transform_page_digest",
+        ]) {
             delete assembled[field];
         }
         for (const field of ["input", "ts_output", "normalizations"]) {
@@ -1378,14 +1395,20 @@ describe("shadow sender", () => {
                 message(sessionId, "m2", "b".repeat(220 * 1024)),
                 message(sessionId, "m3", "c".repeat(220 * 1024)),
             ];
-            sender.enqueue(basePass({ db, sessionId, inputMessages: large, outputMessages: structuredClone(large) }));
-            await waitFor(
-                () =>
-                    transport.calls.some(
-                        (call) =>
-                            call.method === "shadow_transform" &&
-                            (call.body as { transform_page_index?: number }).transform_page_index === 0,
-                    ),
+            sender.enqueue(
+                basePass({
+                    db,
+                    sessionId,
+                    inputMessages: large,
+                    outputMessages: structuredClone(large),
+                }),
+            );
+            await waitFor(() =>
+                transport.calls.some(
+                    (call) =>
+                        call.method === "shadow_transform" &&
+                        (call.body as { transform_page_index?: number }).transform_page_index === 0,
+                ),
             );
             sender.enqueue(
                 basePass({
@@ -1400,7 +1423,9 @@ describe("shadow sender", () => {
             transport.releaseTransform?.();
             await waitFor(() => sender.getStats(sessionId).transforms_sent === 2);
             const pageCalls = transport.calls.filter((call) => call.method === "shadow_transform");
-            const pageIds = pageCalls.map((call) => (call.body as { transform_page_id?: string }).transform_page_id);
+            const pageIds = pageCalls.map(
+                (call) => (call.body as { transform_page_id?: string }).transform_page_id,
+            );
             const firstId = pageIds[0];
             const firstEnd = pageIds.lastIndexOf(firstId);
             expect(firstId).toBeDefined();

packages/plugin/src/plugin/tool-registry.ts

@@ -8,8 +8,8 @@ import {
     isDatabasePersisted,
     openDatabase,
 } from "../features/magic-context/storage";
-import { getErrorMessage } from '../shared/error-message';
-import { log } from '../shared/logger';
+import { getErrorMessage } from "../shared/error-message";
+import { log } from "../shared/logger";
 import type { Database } from "../shared/sqlite";
 import { createCtxExpandTools } from "../tools/ctx-expand";
 import { CTX_MEMORY_ACTIONS, createCtxMemoryTools } from "../tools/ctx-memory";