feat: add Diavgeia decisions integration

Add support for linking meeting subjects to decisions from the Greek
Government Transparency portal (Diavgeia).

Schema changes:
- Add Decision model with ada, protocolNumber, title, pdfUrl, issueDate
- Add City.diavgeiaUid for organization identifier
- Add AdministrativeBody.diavgeiaUnitId for unit filtering

UI additions:
- Add DecisionsPanel for managing decision links in meeting admin
- Add diavgeiaUid field to CityForm
- Add diavgeiaUnitId field to AdministrativeBodiesList
- Add export functionality for manual matching

Task integration:
- Add pollDecisions task type and handler
- Register in task registry for automatic callback handling
- Support filtering by diavgeiaUnitId for more accurate matching

Also update CLAUDE.md with guidance on checking for existing types
before creating new ones.

Author: kouloumos

CLAUDE.md

@@ -23,6 +23,12 @@ This file provides guidance to Claude Code (claude.ai/code) when working with co
 - `npm run prisma:migrate:reset` - Reset database and re-run migrations
 - `npx prisma db seed` - Seed database with sample data
 
+**IMPORTANT**: When making schema changes, always use `--create-only` to generate the migration file without applying it:
+```
+npx prisma migrate dev --name <migration_name> --create-only
+```
+This allows testing the migration against a local database first before applying to production. Never run `npx prisma migrate dev` directly, as it both creates and applies the migration to whatever database `DATABASE_URL` points to.
+
 ### Utility Scripts
 - `npm run lint` - Run ESLint
 - `npm run email` - Test municipality email sending
@@ -78,6 +84,12 @@ src/
 - Re-export from `src/lib/db/types/index.ts`
 - Import from `@/lib/db/types` to prevent circular dependencies
 
+**CRITICAL - Before Creating New Types**:
+- **Always check if the type already exists** before defining a new one
+- When a function returns a type you need, follow the import chain to find its definition
+- If the type exists but isn't exported, export it rather than duplicating
+- Example: If `getCouncilMeeting()` returns `CouncilMeetingWithAdminBody`, check `src/lib/db/meetings.ts` for that type definition before creating your own
+
 ### Authentication Patterns
 
 **Always use methods from `src/lib/auth.ts`**:
@@ -181,6 +193,13 @@ Multi-channel delivery in `src/lib/notifications/`:
 3. Extract duplicates to shared utilities
 4. Ensure all imports are at the top of files
 
+**Build Verification**:
+- **Always run `npm run build` after completing changes** to verify TypeScript compiles and catch errors early
+- This closes the feedback loop quickly - don't wait for the user to discover build failures
+- For schema changes: run `npm run prisma:generate` before building
+- Quick TypeScript check without full build: `npx tsc --noEmit`
+- **Full stack verification**: Run `nix run .#dev` to verify the app starts with a fresh local DB (includes running migrations)
+
 ### TypeScript
 - Strict mode is enabled
 - Use interfaces/types for data structures

messages/el.json

@@ -87,6 +87,9 @@
         "supportsNotificationsDescription": "Ενεργοποίηση εγγραφής και διαχείρισης ειδοποιήσεων για τους πολίτες.",
         "consultationsEnabled": "Ενεργοποίηση Διαβουλεύσεων",
         "consultationsEnabledDescription": "Ενεργοποίηση της καρτέλας δημόσιων διαβουλεύσεων για αυτήν την πόλη",
+        "diavgeiaUid": "Diavgeia UID",
+        "diavgeiaUidPlaceholder": "π.χ. 6253",
+        "diavgeiaUidDescription": "Το UID του οργανισμού στη Διαύγεια (diavgeia.gov.gr). Απαιτείται για αυτόματη ανάκτηση αποφάσεων.",
         "administrativeBodies": "Διοικητικά Όργανα",
         "municipality": "Δήμος",
         "region": "Περιφέρεια",
@@ -545,6 +548,9 @@
             "auto": "Αυτόματες",
             "approval": "Με Έγκριση"
         },
+        "diavgeiaUnitId": "ID Μονάδας Διαύγειας",
+        "diavgeiaUnitIdPlaceholder": "π.χ. 81689",
+        "diavgeiaUnitIdDescription": "Το ID της μονάδας στη Διαύγεια (για αυτόματη ανάκτηση αποφάσεων).",
         "submitting": "Αποθήκευση...",
         "update": "Ενημέρωση",
         "create": "Δημιουργία",

messages/el/admin.json

@@ -72,7 +72,8 @@
       "addTopic": "Προσθήκη Θέματος",
       "starting": "Ξεκινάει...",
       "syncing": "Συγχρονισμός...",
-      "process": "Επεξεργασία"
+      "process": "Επεξεργασία",
+      "manageDecisions": "Διαχείριση Αποφάσεων"
     },
     "forms": {
       "enterMediaUrl": "Εισάγετε URL Μέσου",
@@ -157,7 +158,56 @@
         "title": "Σφάλμα",
         "failedToInvalidateMeetingCache": "Αποτυχία ακύρωσης cache συνεδρίασης",
         "failedToInvalidateCityCache": "Αποτυχία ακύρωσης cache πόλης"
+      },
+      "pollDecisionsRequested": {
+        "title": "Αίτημα ανάκτησης αποφάσεων",
+        "description": "Η ανάκτηση αποφάσεων από τη Διαύγεια ξεκίνησε."
+      },
+      "errorPollingDecisions": {
+        "title": "Σφάλμα ανάκτησης αποφάσεων"
+      },
+      "decisionLinked": {
+        "title": "Η απόφαση συνδέθηκε"
+      },
+      "decisionUnlinked": {
+        "title": "Η απόφαση αποσυνδέθηκε"
+      },
+      "errorSavingDecision": {
+        "title": "Σφάλμα αποθήκευσης απόφασης"
+      },
+      "errorRemovingDecision": {
+        "title": "Σφάλμα αφαίρεσης απόφασης"
       }
+    },
+    "decisions": {
+      "title": "Διαχείριση Αποφάσεων (Διαύγεια)",
+      "description": "Σύνδεση αποφάσεων Διαύγειας με θέματα συνεδρίασης. Χρησιμοποιήστε αυτόματη ανάκτηση ή προσθέστε χειροκίνητα.",
+      "noSubjects": "Δεν βρέθηκαν θέματα για αυτή τη συνεδρίαση.",
+      "noDecision": "Χωρίς απόφαση",
+      "adaLabel": "ΑΔΑ",
+      "adaPlaceholder": "π.χ. 91ΥΔΩΡΦ-ΓΥ6",
+      "protocolNumberLabel": "Αριθμός Πρωτοκόλλου",
+      "protocolNumberPlaceholder": "π.χ. 261/2024",
+      "titleLabel": "Τίτλος Απόφασης",
+      "titlePlaceholder": "Τίτλος Απόφασης",
+      "pdfUrlLabel": "URL PDF",
+      "pdfUrlPlaceholder": "https://diavgeia.gov.gr/...",
+      "viewPdf": "Προβολή PDF",
+      "linked": "συνδεδεμένα",
+      "poll": "Ανάκτηση Διαύγεια",
+      "pollUnlinked": "Ανάκτηση μη συνδεδεμένων ({count})",
+      "pollAll": "Ανάκτηση όλων των θεμάτων",
+      "save": "Αποθήκευση",
+      "validation": {
+        "pdfUrlRequired": "Το URL PDF είναι υποχρεωτικό",
+        "pdfUrlInvalid": "Παρακαλώ εισάγετε ένα έγκυρο URL"
+      },
+      "sourceTask": "Προστέθηκε αυτόματα",
+      "addManually": "Χειροκίνητη προσθήκη",
+      "remove": "Αφαίρεση",
+      "tabAll": "Όλα",
+      "tabUnlinked": "Χωρίς σύνδεση",
+      "allLinked": "Όλα τα θέματα έχουν συνδεδεμένες αποφάσεις."
     }
   }
 }

messages/en.json

@@ -85,6 +85,9 @@
         "supportsNotificationsDescription": "Enable email and SMS notifications for meetings in this city",
         "consultationsEnabled": "Enable Consultations",
         "consultationsEnabledDescription": "Enable the public consultations tab for this city",
+        "diavgeiaUid": "Diavgeia UID",
+        "diavgeiaUidPlaceholder": "e.g. 6253",
+        "diavgeiaUidDescription": "The organization UID on Diavgeia (diavgeia.gov.gr). Required for automatic decision polling.",
         "administrativeBodies": "Administrative Bodies",
         "CityMessageForm": {
             "sectionTitle": "City Message",
@@ -367,6 +370,43 @@
         "humanReview": "Human reviewed",
         "summarize": "Summarized"
     },
+    "AdministrativeBodiesList": {
+        "addNew": "Add New",
+        "editBody": "Edit Body",
+        "addBody": "Add Body",
+        "namePlaceholder": "Body Name",
+        "nameDescription": "Enter the name of the administrative body.",
+        "nameEnPlaceholder": "Body Name (English)",
+        "nameEnDescription": "Enter the name of the administrative body in English.",
+        "type": "Type",
+        "selectType": "Select type",
+        "typeDescription": "Select the type of administrative body.",
+        "types": {
+            "council": "City Council",
+            "committee": "Municipal Committee",
+            "community": "Municipal Community"
+        },
+        "youtubeChannelUrl": "YouTube Channel URL",
+        "youtubeChannelUrlPlaceholder": "https://youtube.com/@channel",
+        "youtubeChannelUrlDescription": "Enter the YouTube channel URL for this administrative body.",
+        "notificationBehavior": "Notification Behavior",
+        "notificationBehaviorDescription": "Choose the notification behavior for meetings of this body.",
+        "notificationBehaviorOptions": {
+            "disabled": "Disabled",
+            "auto": "Automatic",
+            "approval": "With Approval"
+        },
+        "diavgeiaUnitId": "Diavgeia Unit ID",
+        "diavgeiaUnitIdPlaceholder": "e.g. 81689",
+        "diavgeiaUnitIdDescription": "The unit ID on Diavgeia (for automatic decision retrieval).",
+        "submitting": "Submitting...",
+        "update": "Update",
+        "create": "Create",
+        "failedToSave": "Failed to save",
+        "unexpectedError": "An unexpected error occurred",
+        "confirmDelete": "Are you sure you want to delete this administrative body?",
+        "failedToDelete": "Failed to delete"
+    },
     "PartyMemberRankingSheet": {
         "title": "Change Member Ordering",
         "description": "Drag and drop members to reorder them. The order will be saved as rankings.",

messages/en/admin.json

@@ -72,7 +72,8 @@
       "addTopic": "Add Topic",
       "starting": "Starting...",
       "syncing": "Syncing...",
-      "process": "Process"
+      "process": "Process",
+      "manageDecisions": "Manage Decisions"
     },
     "forms": {
       "enterMediaUrl": "Enter Media URL",
@@ -157,7 +158,56 @@
         "title": "Error",
         "failedToInvalidateMeetingCache": "Failed to invalidate meeting cache",
         "failedToInvalidateCityCache": "Failed to invalidate city cache"
+      },
+      "pollDecisionsRequested": {
+        "title": "Poll decisions requested",
+        "description": "Diavgeia decision polling has been started."
+      },
+      "errorPollingDecisions": {
+        "title": "Error polling decisions"
+      },
+      "decisionLinked": {
+        "title": "Decision linked"
+      },
+      "decisionUnlinked": {
+        "title": "Decision unlinked"
+      },
+      "errorSavingDecision": {
+        "title": "Error saving decision"
+      },
+      "errorRemovingDecision": {
+        "title": "Error removing decision"
       }
+    },
+    "decisions": {
+      "title": "Manage Decisions (Diavgeia)",
+      "description": "Link Diavgeia decisions to meeting subjects. Use automatic polling or add manually.",
+      "noSubjects": "No subjects found for this meeting.",
+      "noDecision": "No decision",
+      "adaLabel": "ADA",
+      "adaPlaceholder": "e.g. 91ΥΔΩΡΦ-ΓΥ6",
+      "protocolNumberLabel": "Protocol Number",
+      "protocolNumberPlaceholder": "e.g. 261/2024",
+      "titleLabel": "Decision Title",
+      "titlePlaceholder": "Decision Title",
+      "pdfUrlLabel": "PDF URL",
+      "pdfUrlPlaceholder": "https://diavgeia.gov.gr/...",
+      "viewPdf": "View PDF",
+      "linked": "linked",
+      "poll": "Poll Diavgeia",
+      "pollUnlinked": "Poll unlinked ({count})",
+      "pollAll": "Poll all subjects",
+      "save": "Save",
+      "validation": {
+        "pdfUrlRequired": "PDF URL is required",
+        "pdfUrlInvalid": "Please enter a valid URL"
+      },
+      "sourceTask": "Added automatically",
+      "addManually": "Add manually",
+      "remove": "Remove",
+      "tabAll": "All",
+      "tabUnlinked": "Unlinked",
+      "allLinked": "All subjects have linked decisions."
     }
   }
 }

prisma/migrations/20260202164839_add_diavgeia_decisions/migration.sql

@@ -0,0 +1,40 @@
+-- AlterTable
+ALTER TABLE "City" ADD COLUMN "diavgeiaUid" TEXT;
+
+-- AlterTable
+ALTER TABLE "AdministrativeBody" ADD COLUMN "diavgeiaUnitId" TEXT;
+
+-- CreateTable
+CREATE TABLE "Decision" (
+    "id" TEXT NOT NULL,
+    "subjectId" TEXT NOT NULL,
+    "ada" TEXT,
+    "protocolNumber" TEXT,
+    "title" TEXT,
+    "pdfUrl" TEXT NOT NULL,
+    "issueDate" TIMESTAMP(3),
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updatedAt" TIMESTAMP(3) NOT NULL,
+    "taskId" TEXT,
+    "createdById" TEXT,
+
+    CONSTRAINT "Decision_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "Decision_subjectId_key" ON "Decision"("subjectId");
+
+-- CreateIndex
+CREATE UNIQUE INDEX "Decision_ada_key" ON "Decision"("ada");
+
+-- CreateIndex
+CREATE UNIQUE INDEX "AdministrativeBody_diavgeiaUnitId_key" ON "AdministrativeBody"("diavgeiaUnitId");
+
+-- AddForeignKey
+ALTER TABLE "Decision" ADD CONSTRAINT "Decision_subjectId_fkey" FOREIGN KEY ("subjectId") REFERENCES "Subject"("id") ON DELETE CASCADE ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "Decision" ADD CONSTRAINT "Decision_taskId_fkey" FOREIGN KEY ("taskId") REFERENCES "TaskStatus"("id") ON DELETE SET NULL ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "Decision" ADD CONSTRAINT "Decision_createdById_fkey" FOREIGN KEY ("createdById") REFERENCES "User"("id") ON DELETE SET NULL ON UPDATE CASCADE;

prisma/schema.prisma

@@ -32,6 +32,7 @@ model City {
   consultationsEnabled Boolean @default(false)
   peopleOrdering PeopleOrdering @default(default)
   highlightCreationPermission HighlightCreationPermission @default(ADMINS_ONLY)
+  diavgeiaUid String?
 
   parties        Party[]
   persons        Person[]
@@ -95,6 +96,7 @@ model AdministrativeBody {
   type      AdministrativeBodyType
   notificationBehavior NotificationBehavior @default(NOTIFICATIONS_APPROVAL)
   youtubeChannelUrl String?
+  diavgeiaUnitId String? @unique  // Diavgeia unit ID (e.g., "81689")
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
 
@@ -210,7 +212,9 @@ model TaskStatus {
 
   councilMeeting   CouncilMeeting @relation(fields: [councilMeetingId, cityId], references: [id, cityId], onDelete: Cascade)
   councilMeetingId String
-  cityId            String
+  cityId           String
+
+  decisions Decision[]
 
   @@index([councilMeetingId, cityId])
 }
@@ -431,10 +435,32 @@ model Subject {
   discussedIn Subject? @relation("GroupedSubjects", fields: [discussedInId], references: [id], onDelete: SetNull)
   groupedSubjects Subject[] @relation("GroupedSubjects")
 
+  decision Decision?
+
   @@index([cityId, councilMeetingId])
   @@index([discussedInId])
 }
 
+model Decision {
+  id             String    @id @default(cuid())
+  subjectId      String    @unique
+  ada            String?   @unique  // Diavgeia unique identifier (e.g., "91ΥΔΩΡΦ-ΓΥ6")
+  protocolNumber String?             // Protocol number (e.g., "261/2024")
+  title          String?             // Decision title from Diavgeia
+  pdfUrl         String
+  issueDate      DateTime?           // Date published on Diavgeia
+  createdAt      DateTime  @default(now())
+  updatedAt      DateTime  @updatedAt
+
+  subject   Subject   @relation(fields: [subjectId], references: [id], onDelete: Cascade)
+
+  // Track whether decision was added by task or manually by user
+  task      TaskStatus? @relation(fields: [taskId], references: [id], onDelete: SetNull)
+  taskId    String?
+  createdBy User?       @relation(fields: [createdById], references: [id], onDelete: SetNull)
+  createdById String?
+}
+
 enum NonAgendaReason {
   beforeAgenda
   outOfAgenda
@@ -636,6 +662,7 @@ model User {
   updatedAt DateTime @updatedAt
   utteranceEdits UtteranceEdit[]
   highlights Highlight[]
+  decisions Decision[]
 }
 
 model Account {

src/app/api/cities/[cityId]/administrative-bodies/[bodyId]/route.ts

@@ -18,7 +18,8 @@ const bodySchema = z.object({
         }),
         z.literal('')
     ]).optional().transform(val => val === '' ? undefined : val),
-    notificationBehavior: z.enum(['NOTIFICATIONS_DISABLED', 'NOTIFICATIONS_AUTO', 'NOTIFICATIONS_APPROVAL']).optional()
+    notificationBehavior: z.enum(['NOTIFICATIONS_DISABLED', 'NOTIFICATIONS_AUTO', 'NOTIFICATIONS_APPROVAL']).optional(),
+    diavgeiaUnitId: z.string().optional().transform(val => val === '' ? undefined : val),
 });
 
 export async function PUT(
@@ -29,14 +30,15 @@ export async function PUT(
         await withUserAuthorizedToEdit({ cityId: params.cityId });
         const body = await request.json();
         const parsed = bodySchema.parse(body);
-        const { name, name_en, type, youtubeChannelUrl, notificationBehavior } = parsed;
+        const { name, name_en, type, youtubeChannelUrl, notificationBehavior, diavgeiaUnitId } = parsed;
 
         const updatedBody = await editAdministrativeBody(params.bodyId, {
             name,
             name_en,
             type,
             youtubeChannelUrl: youtubeChannelUrl && youtubeChannelUrl.trim() !== '' ? youtubeChannelUrl : null,
             notificationBehavior: notificationBehavior,
+            diavgeiaUnitId: diavgeiaUnitId || null,
         });
 
         revalidateTag(`city:${params.cityId}:administrativeBodies`);