Function main

packages/plugin/scripts/test-proactive-search.ts:232–322

()

// ─── Main ────────────────────────────────────────────────

async function main() {
	const openDb = new Database(OPENCODE_DB, { readonly: true });
	const ctxDb = new Database(CONTEXT_DB, { readonly: true });

	// Resolve session ID
	if (!sessionId) {
		const latest = openDb.prepare(`
			SELECT id FROM session ORDER BY time_created DESC LIMIT 1
		`).get() as { id: string } | null;
		if (!latest) { console.error("No sessions found"); process.exit(1); }
		sessionId = latest.id;
	}

	// Resolve project identity
	const proc = Bun.spawnSync(["git", "rev-list", "--max-parents=0", "HEAD"], { stdout: "pipe" });
	const rootHash = new TextDecoder().decode(proc.stdout).trim().split("\n")[0] ?? "";
	const projectPath = rootHash ? `git:${rootHash}` : "";

	console.log(`Session: ${sessionId}`);
	console.log(`Project: ${projectPath}`);
	console.log(`Threshold: ${scoreThreshold}`);
	console.log(`Limit: ${messageLimit} user messages (newest first)\n`);

	const messages = readUserMessages(openDb, sessionId, messageLimit);
	console.log(`Found ${messages.length} user messages\n`);
	console.log("═".repeat(80));

	let wouldNudge = 0;
	let totalMessages = 0;
	let skippedShort = 0;

	for (const msg of messages) {
		totalMessages++;
		const preview = msg.text.length > 120 ? `${msg.text.slice(0, 120)}…` : msg.text;

		// Extract terms
		const terms = extractSearchTerms(msg.text);

		if (terms.length < 2) {
			skippedShort++;
			console.log(`\n[${totalMessages}] ${preview}`);
			console.log(`  Terms: ${terms.length === 0 ? "(none)" : terms.join(", ")}`);
			console.log("  → SKIP (too few terms)");
			continue;
		}

		// Build search query from top terms (max 6 to avoid noise)
		const searchQuery = terms.slice(0, 6).join(" ");

		// Search
		const memHits = searchMemoriesFTS(ctxDb, projectPath, searchQuery, 5);
		const factHits = searchFactsFTS(ctxDb, sessionId, searchQuery);

		const allHits = [...memHits, ...factHits].sort((a, b) => b.score - a.score);
		const topHit = allHits[0];
		const triggered = topHit && topHit.score >= scoreThreshold;

		console.log(`\n[${totalMessages}] ${preview}`);