fix(ci): resolve typecheck and test failures

- Add missing @engram/{common,graph,logger} dependencies to @engram/temporal
- Fix expectToReject type signature in @engram/testing to accept built-in Error constructors
- Update rehydrator tests to use object format for query results (blobRef/snapshotAt)
- Fix QueryBuilder test expectation for queries without match clause
- Update observatory tests for parameterized LIMIT clause (limit_0)

Author: ccheney

apps/memory/src/turn-aggregator.test.ts

@@ -1,8 +1,8 @@
 import type { Mock } from "bun:test";
 import { beforeEach, describe, expect, it, mock } from "bun:test";
-import { createTestGraphClient, createTestLogger } from "@engram/testing";
 import type { ParsedStreamEvent } from "@engram/events";
 import type { GraphClient } from "@engram/storage";
+import { createTestGraphClient, createTestLogger } from "@engram/testing";
 import type { EventHandler, EventHandlerRegistry, HandlerContext, HandlerResult } from "./handlers";
 import {
 	type NodeCreatedCallback,

apps/observatory/lib/graph-queries.spec.ts

@@ -1831,8 +1831,8 @@ describeOrSkip("graph-queries", () => {
 			// Act
 			await getSessionsForWebSocket();
 
-			// Assert
-			expect(mockQuery).toHaveBeenCalledWith(expect.stringContaining("LIMIT"), { limit: 50 });
+			// Assert - QueryBuilder uses parameterized limits with suffix
+			expect(mockQuery).toHaveBeenCalledWith(expect.stringContaining("LIMIT"), { limit_0: 50 });
 		});
 
 		it("should respect custom limit", async () => {
@@ -1842,8 +1842,8 @@ describeOrSkip("graph-queries", () => {
 			// Act
 			await getSessionsForWebSocket(25);
 
-			// Assert
-			expect(mockQuery).toHaveBeenCalledWith(expect.stringContaining("LIMIT"), { limit: 25 });
+			// Assert - QueryBuilder uses parameterized limits with suffix
+			expect(mockQuery).toHaveBeenCalledWith(expect.stringContaining("LIMIT"), { limit_0: 25 });
 		});
 
 		it("should use lastEventAt from row when session has no last_event_at", async () => {

bun.lock

@@ -132,6 +132,7 @@ describe("QueryBuilder", () => {
 		const qb = new QueryBuilder();
 		const { cypher } = qb.return("1").build();
 
-		expect(cypher).toBe("MATCH  RETURN 1");
+		// QueryBuilder now omits empty MATCH clauses
+		expect(cypher).toBe("RETURN 1");
 	});
 });

packages/graph/src/queries/builder.test.ts

@@ -7,10 +7,10 @@
  * Run with: RUN_INTEGRATION_TESTS=1 bun test packages/storage/tests/integration/blob.integration.spec.ts
  */
 
+import { afterAll, beforeAll, describe, expect, it } from "bun:test";
 import * as fs from "node:fs/promises";
 import * as path from "node:path";
-import { afterAll, beforeAll, describe, expect, it } from "bun:test";
-import { FileSystemBlobStore, GCSBlobStore, createBlobStore } from "../../src/blob";
+import { createBlobStore, FileSystemBlobStore, GCSBlobStore } from "../../src/blob";
 import { shouldRunIntegrationTests } from "./fixtures";
 
 // Skip all tests if integration tests are not enabled

packages/storage/tests/integration/blob.integration.spec.ts

@@ -5,11 +5,11 @@
  * Supports both testcontainers (CI) and existing dev containers (local dev).
  */
 
-import { FalkorDB, type Graph } from "falkordb";
-import { connect, type NatsConnection } from "@nats-io/transport-node";
 import { jetstream, jetstreamManager } from "@nats-io/jetstream";
-import { GenericContainer, type StartedTestContainer, Wait } from "testcontainers";
+import { connect, type NatsConnection } from "@nats-io/transport-node";
+import { FalkorDB, type Graph } from "falkordb";
 import pg from "pg";
+import { GenericContainer, type StartedTestContainer, Wait } from "testcontainers";
 
 // Container instances (session-scoped)
 let falkordbContainer: StartedTestContainer | null = null;

packages/storage/tests/integration/fixtures.ts

@@ -7,9 +7,9 @@
 
 import { afterAll, afterEach, beforeAll, describe, expect, it } from "bun:test";
 import {
-	NatsClient,
 	createNatsPubSubPublisher,
 	createNatsPubSubSubscriber,
+	NatsClient,
 	type SessionUpdate,
 } from "../../src/nats";
 import {

packages/storage/tests/integration/nats.integration.spec.ts

@@ -11,6 +11,9 @@
 	},
 	"dependencies": {
 		"zod": "4.2.1",
+		"@engram/common": "*",
+		"@engram/graph": "*",
+		"@engram/logger": "*",
 		"@engram/storage": "*",
 		"@engram/vfs": "*"
 	},

packages/temporal/package.json

@@ -53,7 +53,7 @@ describe("Rehydrator", () => {
 	});
 
 	it("should attempt to load snapshot if found", async () => {
-		const mockSnapshot = ["blob-ref-123", 1000];
+		const mockSnapshot = { blobRef: "blob-ref-123", snapshotAt: 1000 };
 		// First call: snapshot found, second call: no diffs
 		mockFalkorQuery.mockResolvedValueOnce([mockSnapshot]).mockResolvedValueOnce([]);
 		mockBlobStore.load.mockResolvedValueOnce(
@@ -92,7 +92,7 @@ describe("Rehydrator", () => {
 	});
 
 	it("should pass lastSnapshotTime to diff query", async () => {
-		const mockSnapshot = ["blob-ref-123", 5000];
+		const mockSnapshot = { blobRef: "blob-ref-123", snapshotAt: 5000 };
 		mockFalkorQuery.mockResolvedValueOnce([mockSnapshot]).mockResolvedValueOnce([]);
 		mockBlobStore.load.mockResolvedValueOnce(
 			JSON.stringify({ root: { name: "", type: "directory", children: {} } }),
@@ -108,7 +108,7 @@ describe("Rehydrator", () => {
 	});
 
 	it("should handle snapshot loading with JSON fallback when gzip fails", async () => {
-		const mockSnapshot = ["blob-ref-json", 1000];
+		const mockSnapshot = { blobRef: "blob-ref-json", snapshotAt: 1000 };
 		mockFalkorQuery.mockResolvedValueOnce([mockSnapshot]).mockResolvedValueOnce([]);
 
 		const jsonContent = JSON.stringify({
@@ -121,7 +121,7 @@ describe("Rehydrator", () => {
 	});
 
 	it("should throw RehydrationError when both gzip and JSON parsing fail", async () => {
-		const mockSnapshot = ["blob-ref-invalid", 1000];
+		const mockSnapshot = { blobRef: "blob-ref-invalid", snapshotAt: 1000 };
 		mockFalkorQuery.mockResolvedValueOnce([mockSnapshot]).mockResolvedValueOnce([]);
 
 		mockBlobStore.load.mockResolvedValueOnce("invalid data that is neither gzip nor JSON");
@@ -265,7 +265,7 @@ describe("Rehydrator", () => {
 	});
 
 	it("should handle non-Error exception when JSON parsing fails", async () => {
-		const mockSnapshot = ["blob-ref-invalid", 1000];
+		const mockSnapshot = { blobRef: "blob-ref-invalid", snapshotAt: 1000 };
 		mockFalkorQuery.mockResolvedValueOnce([mockSnapshot]).mockResolvedValueOnce([]);
 
 		// Mock JSON.parse to throw a non-Error value

packages/temporal/src/rehydrator.test.ts

@@ -37,6 +37,7 @@ import { mock } from "bun:test";
 
 // Simplified Mock type alias for common use cases
 type Mock = BunMock<(...args: unknown[]) => unknown>;
+
 import type {
 	FileTouchNode,
 	ObservationNode,
@@ -512,7 +513,8 @@ class PromiseResolvedError extends Error {
  */
 export async function expectToReject<E extends Error>(
 	promise: Promise<unknown>,
-	errorType: new (...args: unknown[]) => E,
+	// biome-ignore lint/suspicious/noExplicitAny: Constructor types need any[] for variance compatibility with built-in error constructors
+	errorType: new (...args: any[]) => E,
 	messageMatch?: string | RegExp,
 ): Promise<E> {
 	try {