BroccoliQ has been removed from dietcode-plugin. Work that was already in progress is finished, and remaining references are cleaned up.

Removed surface area
/broccoliq slash command and bq alias
queue_tools.py — broccolidb_queue_status, broccolidb_shard_status, broccolidb_hive_integrity
RPC methods — queue_status, shard_status, hive_integrity (RPC version bumped to 5)
hive_board_intel no longer includes queue metrics (hive metrics only)
Updated behavior
kanban_broccolidb_board_intel() returns "hive" instead of "broccoliq" in its JSON payload
Plugin metadata, prompts, toolset expectations, and public exports no longer mention BroccoliQ
Docs & branding
README, CHANGELOG, and docs under docs/ updated
BroccoliQ comments/strings updated across Python, TypeScript, and kernel files
Kernel memory telemetry sources renamed: broccolidb_memory, broccolidb_replay_cache
What remains
BroccoliDB — graph, audit, hive sync, kanban bridge tools
Internal queue tables/code under broccolidb/infrastructure/queue/ (database layer, not exposed as BroccoliQ)
The only remaining broccoliq mention is a historical note in kernel/MIGRATION.md for the old runtime/memory/broccoliq/ path.

Author: CardSorting

CHANGELOG.md

@@ -114,4 +114,4 @@ See [docs/releases/v1.9.0.md](docs/releases/v1.9.0.md) and [kernel/MIGRATION.md]
 
 ## v1.8.0 and earlier
 
-Prior releases: BroccoliDB, BroccoliQ, JoyZoning governance, and JSDP Hermes integration.
+Prior releases: BroccoliDB, JoyZoning governance, and JSDP Hermes integration.

README.md

@@ -74,8 +74,7 @@ progress telemetry (`/dietcode kernel cockpit`, watch, explain-gate).
 | Component | Role |
 | --- | --- |
 | **Roadmap** | Native `roadmap` toolset — checkpoint, validate, autofill, cockpit, gates |
-| **BroccoliDB** | Knowledge graph, audit, refactor, structural analysis |
-| **BroccoliQ** | Queue status, shard health, integrity |
+| **BroccoliDB** | Knowledge graph, audit, refactor, structural analysis, hive sync |
 | **JoyZoning** | Mutation lifecycle, convergence, runtime journal |
 | **JSDP** | Rolling-horizon autonomous delivery helpers |
 | **Kernel bridge** | Optional macOS `dietcode_kernel` patch/verify + raw-write policy |
@@ -168,7 +167,6 @@ Decision tree when stuck: [docs/roadmap.md#decision-tree](docs/roadmap.md#decisi
 /dietcode tools
 /dietcode broccolidb
 /broccolidb status
-/broccoliq queue
 /joyzoning status
 ```
 

__init__.py

@@ -1,5 +1,5 @@
 # -*- coding: utf-8 -*-
-"""DietCode unified plugin — BroccoliDB, BroccoliQ, JoyZoning, and JSDP for upstream Hermes."""
+"""DietCode unified plugin — BroccoliDB, JoyZoning, and JSDP for upstream Hermes."""
 from __future__ import annotations
 
 import importlib.util
@@ -41,15 +41,14 @@ def _mark_registered(ctx) -> None:
 def _register_commands(ctx) -> None:
     from plugins.dietcode.slash_commands import (
         _handle_broccolidb,
-        _handle_broccoliq,
         _handle_joyzoning,
         _handle_roadmap,
     )
 
     ctx.register_command(
         "dietcode",
         handler=handle_dietcode_command,
-        description="DietCode integration health — BroccoliDB, BroccoliQ, JoyZoning, JSDP.",
+        description="DietCode integration health — BroccoliDB, JoyZoning, JSDP.",
         args_hint="[status|doctor|tools|broccolidb]",
     )
     ctx.register_command(
@@ -63,8 +62,6 @@ def _register_commands(ctx) -> None:
         ("jz", _handle_joyzoning, "JoyZoning layering audit (alias).", "[status|check <file>|…]"),
         ("broccolidb", _handle_broccolidb, "BroccoliDB epistemic database console.", "[status|query|audit|heal]"),
         ("bdb", _handle_broccolidb, "BroccoliDB console (alias).", "[status|query|audit|heal]"),
-        ("broccoliq", _handle_broccoliq, "BroccoliQ sharded queue and hive infrastructure.", "[queue|shards|integrity]"),
-        ("bq", _handle_broccoliq, "BroccoliQ console (alias).", "[queue|shards|integrity]"),
         ("roadmap", _handle_roadmap, "Native roadmap checkpoint console.", "[cockpit|doctor|checkpoint|validate|guide]"),
         ("rm", _handle_roadmap, "Roadmap checkpoint console (alias).", "[cockpit|doctor|checkpoint|validate|guide]"),
     ):

broccolidb/infrastructure/db/BufferedDbPool.ts

@@ -112,7 +112,7 @@ export type WriteOp = {
   where?: WhereCondition | WhereCondition[];
   conflictTarget?: string | string[]; // For upserts
   agentId?: string;
-  shardId?: string; // Level 8: BroccoliQ shard partitioning
+  shardId?: string; // Level 8: shard partitioning
   layer?: DbLayer;
   // Level 6: Pre-calculated Metadata
   hasIncrements?: boolean;
@@ -976,12 +976,12 @@ export class BufferedDbPool {
     return results.length > 0 ? (results[results.length - 1] as Schema[T]) : null;
   }
 
-  /** BroccoliQ Level 8: resolve a sharded database handle. */
+  /** Level 8: resolve a sharded database handle. */
   public async getDb(shardId: string = 'main'): Promise<Kysely<Schema>> {
     return getDb(shardId);
   }
 
-  /** BroccoliQ Level 5: distributed lock via claims table. */
+  /** Level 5: distributed lock via claims table. */
   public async acquireLock(
     resource: string,
     author: string,

broccolidb/infrastructure/db/DatabaseSchema.ts

@@ -4,11 +4,11 @@
  * Principle: Unified TypeScript type definitions for Kysely database schema
  * Hardening: Master Sovereign Hive Architecture (v2.0)
  * 
- * Provides bit-for-bit parity across DietCode and BroccoliQ/broccolidb.
+ * Provides bit-for-bit parity across DietCode and broccolidb.
  */
 
 export interface Schema {
-	// --- CORE BROCCOLIQ TABLES ---
+	// --- CORE HIVE / QUEUE TABLES ---
 	users: {
 		id: string;
 		createdAt: number;

broccolidb/infrastructure/db/pool/index.ts

@@ -1,6 +1,6 @@
 /**
- * BroccoliQ pool module — re-exports the canonical BufferedDbPool singleton
- * used throughout broccolidb. Keeps @noorm/broccoliq import paths stable.
+ * Broccolidb pool module — re-exports the canonical BufferedDbPool singleton
+ * used throughout broccolidb.
  */
 export {
   BufferedDbPool,

broccolidb/infrastructure/hermes/README.md

@@ -1,6 +1,6 @@
 # Hermes native RPC (`infrastructure/hermes/`)
 
-Persistent BroccoliDB/BroccoliQ worker used by DietCode / Hermes Python tools.
+Persistent BroccoliDB worker used by DietCode / Hermes Python tools.
 
 ## Documentation
 
@@ -17,7 +17,7 @@ Persistent BroccoliDB/BroccoliQ worker used by DietCode / Hermes Python tools.
 |------|------|
 | `hermes_rpc.ts` | Persistent stdin/stdout worker (`ready` first, lazy DB warm) |
 | `hermes_oneshot.ts` | Cold fallback: one JSON line on stdout, then `process.exit(0)` |
-| `rpc_handlers.ts` | Canonical handlers (`dispatchRpc`, `RPC_VERSION = 4`) |
+| `rpc_handlers.ts` | Canonical handlers (`dispatchRpc`, `RPC_VERSION = 5`) |
 | `agent_session.ts` | Warm `AgentContext` singleton |
 | `agent_invoke.ts` | Graph / kanban cognitive ops |
 | `queue_metrics.ts` | SQL `GROUP BY` queue status (no full-table scan) |
@@ -44,7 +44,7 @@ Expect: one `{"ready":true,…}` line, then one `{"id":1,"ok":true,…}` line. L
 from plugins.dietcode.lib.tools.broccolidb_tools.exec import run_db_rpc, run_agent_rpc, warm_db_rpc
 
 warm_db_rpc(block=True)
-raw = run_db_rpc("queue_status")
+raw = run_db_rpc("hive_board_intel", {"shard_id": "kanban"})
 ```
 
 ## Node native modules

broccolidb/infrastructure/hermes/hermes_rpc.ts

@@ -1,5 +1,5 @@
 /**
- * Hermes ↔ BroccoliDB/BroccoliQ native RPC — persistent stdin/stdout worker.
+ * Hermes ↔ BroccoliDB native RPC — persistent stdin/stdout worker.
  *
  * Emits {"ready":true} immediately so Python never blocks on schema migration.
  * DB / AgentContext warmup runs lazily on the first request.

broccolidb/infrastructure/hermes/rpc_handlers.ts

@@ -1,25 +1,20 @@
 /**
- * Canonical BroccoliDB/BroccoliQ RPC handlers — single implementation for
+ * Canonical BroccoliDB RPC handlers — single implementation for
  * hermes_rpc.ts (persistent worker) and thin CLI wrappers (hive_*.ts).
  */
 import * as crypto from "node:crypto";
 import { sql } from "kysely";
 import { buildDashboardSnapshot } from "../dashboard/snapshot_core.js";
 import { getActiveShards, getDb } from "../db/Config.js";
-import { IntegrityWorker } from "../db/IntegrityWorker.js";
 import { runAgentInvoke } from "./agent_invoke.js";
 import { flushDbPool } from "./agent_session.js";
-import { aggregateQueueByStatus } from "./queue_metrics.js";
 
-export const RPC_VERSION = 4;
+export const RPC_VERSION = 5;
 
 export const RPC_METHODS = [
 	"ping",
 	"rpc_health",
 	"dashboard_snapshot",
-	"queue_status",
-	"shard_status",
-	"hive_integrity",
 	"proposal_action",
 	"hive_sync",
 	"hive_drift",
@@ -82,7 +77,6 @@ export interface HiveDriftPayload {
 
 export interface HiveBoardIntelPayload {
 	shard_id?: string;
-	queue_limit?: number;
 	hive_limit?: number;
 }
 
@@ -117,56 +111,6 @@ export async function runRpcHealth(): Promise<Record<string, unknown>> {
 	};
 }
 
-export async function runQueueStatus(): Promise<Record<string, unknown>> {
-	const shards = getActiveShards().length ? getActiveShards() : ["main"];
-	const byStatus: Record<string, number> = {};
-	let total = 0;
-	for (const shardId of shards) {
-		const db = await getDb(shardId);
-		const agg = await aggregateQueueByStatus(db);
-		for (const [status, count] of Object.entries(agg.byStatus)) {
-			byStatus[status] = (byStatus[status] ?? 0) + count;
-		}
-		total += agg.total;
-	}
-	return { success: true, total, byStatus, shards };
-}
-
-export async function runShardStatus(): Promise<Record<string, unknown>> {
-	const shards = getActiveShards();
-	const listed = shards.length ? shards : ["main"];
-	const detail: Array<Record<string, unknown>> = [];
-	for (const shardId of listed) {
-		try {
-			const db = await getDb(shardId);
-			const probe = await db
-				.selectFrom("queue_settings" as never)
-				.selectAll()
-				.limit(1)
-				.execute();
-			detail.push({ shardId, healthy: true, probeRows: probe.length });
-		} catch (e) {
-			detail.push({
-				shardId,
-				healthy: false,
-				error: e instanceof Error ? e.message : String(e),
-			});
-		}
-	}
-	return { success: true, shardCount: detail.length, shards: detail };
-}
-
-export async function runHiveIntegrity(): Promise<Record<string, unknown>> {
-	const worker = new IntegrityWorker(600_000);
-	await worker.runAudit();
-	const shards = getActiveShards();
-	return {
-		success: true,
-		message: "Integrity audit complete",
-		shards: shards.length ? shards : ["main"],
-	};
-}
-
 export async function runProposalAction(
 	params: Record<string, unknown>,
 ): Promise<Record<string, unknown>> {
@@ -376,8 +320,6 @@ export async function runHiveBoardIntel(
 
 	const db = await getDb(shardId);
 
-	const queueAgg = await aggregateQueueByStatus(db);
-
 	const hiveRows = await db
 		.selectFrom("hive_tasks")
 		.select(["status", sql<number>`count(*)`.as("count")])
@@ -395,10 +337,6 @@ export async function runHiveBoardIntel(
 	return {
 		success: true,
 		shard_id: shardId,
-		queue: {
-			total: queueAgg.total,
-			byStatus: queueAgg.byStatus,
-		},
 		hive: {
 			total: hiveTotal,
 			byStatus: hiveByStatus,
@@ -418,9 +356,6 @@ export const rpcHandlers: Record<string, HandlerFn> = {
 	ping: async () => runPing(),
 	rpc_health: async () => runRpcHealth(),
 	dashboard_snapshot: async () => buildDashboardSnapshot(),
-	queue_status: async () => runQueueStatus(),
-	shard_status: async () => runShardStatus(),
-	hive_integrity: async () => runHiveIntegrity(),
 	proposal_action: async (p) => runProposalAction(p),
 	hive_sync: async (p) => runHiveSync(p as unknown as KanbanHiveSyncPayload),
 	hive_drift: async (p) => runHiveDrift(p as unknown as HiveDriftPayload),

broccolidb/infrastructure/index.ts

@@ -1,8 +1,7 @@
 /**
- * BroccoliQ - Queue and Database Processing Infrastructure
+ * BroccoliDB infrastructure — queue and database processing.
  *
- * Re-exports the main public API for easy import from '@broccoliq/queue'.
- * Use direct imports from 'broccoliq' for the primary entry points.
+ * Re-exports the main public API for broccolidb consumers.
  */
 
 // Core database and pool functionality