feat: Add project filter to listInitiatives

Add findByProjectId to InitiativeRepository using a subquery on the
initiative_projects junction table. Extend the listInitiatives tRPC
procedure to accept an optional projectId filter that composes with
the existing status filter. Add a project dropdown to the initiatives
page alongside the status filter.

apps/server/db/repositories/drizzle/initiative.ts

@@ -4,10 +4,10 @@
  * Implements InitiativeRepository interface using Drizzle ORM.
  */
 
-import { eq } from 'drizzle-orm';
+import { eq, inArray } from 'drizzle-orm';
 import { nanoid } from 'nanoid';
 import type { DrizzleDatabase } from '../../index.js';
-import { agents, initiatives, type Initiative } from '../../schema.js';
+import { agents, initiatives, initiativeProjects, type Initiative } from '../../schema.js';
 import type {
   InitiativeRepository,
   CreateInitiativeData,
@@ -59,6 +59,18 @@ export class DrizzleInitiativeRepository implements InitiativeRepository {
       .where(eq(initiatives.status, status));
   }
 
+  async findByProjectId(projectId: string): Promise<Initiative[]> {
+    const linkedIds = this.db
+      .select({ id: initiativeProjects.initiativeId })
+      .from(initiativeProjects)
+      .where(eq(initiativeProjects.projectId, projectId));
+
+    return this.db
+      .select()
+      .from(initiatives)
+      .where(inArray(initiatives.id, linkedIds));
+  }
+
   async update(id: string, data: UpdateInitiativeData): Promise<Initiative> {
     const [updated] = await this.db
       .update(initiatives)

apps/server/db/repositories/initiative-repository.ts

@@ -57,6 +57,12 @@ export interface InitiativeRepository {
    */
   update(id: string, data: UpdateInitiativeData): Promise<Initiative>;
 
+  /**
+   * Find all initiatives linked to a specific project.
+   * Returns empty array if none exist.
+   */
+  findByProjectId(projectId: string): Promise<Initiative[]>;
+
   /**
    * Delete an initiative.
    * Throws if initiative not found.

apps/server/trpc/routers/initiative.ts

@@ -111,12 +111,22 @@ export function initiativeProcedures(publicProcedure: ProcedureBuilder) {
     listInitiatives: publicProcedure
       .input(z.object({
         status: z.enum(['active', 'completed', 'archived']).optional(),
+        projectId: z.string().min(1).optional(),
       }).optional())
       .query(async ({ ctx, input }) => {
         const repo = requireInitiativeRepository(ctx);
-        const initiatives = input?.status
+
-          ? await repo.findByStatus(input.status)
+        let initiatives;
-          : await repo.findAll();
+        if (input?.projectId) {
+          const all = await repo.findByProjectId(input.projectId);
+          initiatives = input.status
+            ? all.filter(i => i.status === input.status)
+            : all;
+        } else {
+          initiatives = input?.status
+            ? await repo.findByStatus(input.status)
+            : await repo.findAll();
+        }
 
         // Fetch active architect agents once for all initiatives
         const ARCHITECT_MODES = ['discuss', 'plan', 'detail', 'refine'];

apps/web/src/components/InitiativeList.tsx

@@ -8,18 +8,27 @@ import { trpc } from "@/lib/trpc";
 
 interface InitiativeListProps {
   statusFilter?: "all" | "active" | "completed" | "archived";
+  projectFilter?: string;
   onCreateNew: () => void;
   onViewInitiative: (id: string) => void;
 }
 
 export function InitiativeList({
   statusFilter = "all",
+  projectFilter,
   onCreateNew,
   onViewInitiative,
 }: InitiativeListProps) {
-  const initiativesQuery = trpc.listInitiatives.useQuery(
+  const queryInput = (() => {
-    statusFilter === "all" ? undefined : { status: statusFilter },
+    const hasStatus = statusFilter !== "all";
-  );
+    if (!hasStatus && !projectFilter) return undefined;
+    return {
+      ...(hasStatus && { status: statusFilter as "active" | "completed" | "archived" }),
+      ...(projectFilter && { projectId: projectFilter }),
+    };
+  })();
+
+  const initiativesQuery = trpc.listInitiatives.useQuery(queryInput);
 
   // Loading state
   if (initiativesQuery.isLoading) {

apps/web/src/routes/initiatives/index.tsx

@@ -6,6 +6,7 @@ import { Button } from "@/components/ui/button";
 import { InitiativeList } from "@/components/InitiativeList";
 import { CreateInitiativeDialog } from "@/components/CreateInitiativeDialog";
 import { useLiveUpdates } from "@/hooks";
+import { trpc } from "@/lib/trpc";
 
 export const Route = createFileRoute("/initiatives/")({
   component: DashboardPage,
@@ -23,7 +24,9 @@ const filterOptions: { value: StatusFilter; label: string }[] = [
 function DashboardPage() {
   const navigate = useNavigate();
   const [statusFilter, setStatusFilter] = useState<StatusFilter>("all");
+  const [projectFilter, setProjectFilter] = useState<string>("all");
   const [createDialogOpen, setCreateDialogOpen] = useState(false);
+  const projectsQuery = trpc.listProjects.useQuery();
 
   // Single SSE stream for live updates
   useLiveUpdates([
@@ -42,6 +45,18 @@ function DashboardPage() {
       <div className="flex items-center justify-between">
         <h1 className="font-display text-2xl font-semibold">Initiatives</h1>
         <div className="flex items-center gap-3">
+          <select
+            value={projectFilter}
+            onChange={(e) => setProjectFilter(e.target.value)}
+            className="rounded-md border border-input bg-background px-3 py-1.5 text-sm ring-offset-background focus:outline-none focus:ring-2 focus:ring-ring focus:ring-offset-2"
+          >
+            <option value="all">All projects</option>
+            {(projectsQuery.data ?? []).map((p) => (
+              <option key={p.id} value={p.id}>
+                {p.name}
+              </option>
+            ))}
+          </select>
           <select
             value={statusFilter}
             onChange={(e) =>
@@ -70,6 +85,7 @@ function DashboardPage() {
       >
         <InitiativeList
           statusFilter={statusFilter}
+          projectFilter={projectFilter === "all" ? undefined : projectFilter}
           onCreateNew={() => setCreateDialogOpen(true)}
           onViewInitiative={(id) =>
             navigate({ to: "/initiatives/$id", params: { id } })

docs/server-api.md

@@ -88,7 +88,7 @@ Each procedure uses `require*Repository(ctx)` helpers that throw `TRPCError(INTE
 | Procedure | Type | Description |
 |-----------|------|-------------|
 | createInitiative | mutation | Create with optional branch/projectIds/description, auto-creates root page (seeded with description); if description provided, auto-spawns refine agent |
-| listInitiatives | query | Filter by status; returns `activity` (state, activePhase, phase counts) computed from phases |
+| listInitiatives | query | Filter by status and/or projectId; returns `activity` (state, activePhase, phase counts) computed from phases |
 | getInitiative | query | With projects array |
 | updateInitiative | mutation | Name, status |
 | deleteInitiative | mutation | Cascade delete initiative and all children |