VIBE-300 Add subscription by case name and case number

apps/postgres/prisma/migrations/20260119150000_add_list_search_config/migration.sql

@@ -0,0 +1,14 @@
+-- CreateTable
+CREATE TABLE "list_search_config" (
+    "id" TEXT NOT NULL,
+    "list_type_id" INTEGER NOT NULL,
+    "case_number_field_name" VARCHAR(100) NOT NULL,
+    "case_name_field_name" VARCHAR(100) NOT NULL,
+    "created_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updated_at" TIMESTAMP(3) NOT NULL,
+
+    CONSTRAINT "list_search_config_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "list_search_config_list_type_id_key" ON "list_search_config"("list_type_id");

apps/postgres/prisma/migrations/20260119151000_refactor_subscription_and_add_artefact_search/migration.sql

@@ -0,0 +1,37 @@
+-- DropForeignKey
+ALTER TABLE "subscription" DROP CONSTRAINT IF EXISTS "subscription_location_id_fkey";
+
+-- DropIndex
+DROP INDEX IF EXISTS "idx_subscription_location";
+
+-- DropIndex
+DROP INDEX IF EXISTS "unique_user_location";
+
+-- AlterTable
+ALTER TABLE "subscription"
+ADD COLUMN "search_type" VARCHAR(50) NOT NULL,
+ADD COLUMN "search_value" TEXT NOT NULL,
+DROP COLUMN IF EXISTS "location_id";
+
+-- CreateTable
+CREATE TABLE "artefact_search" (
+    "id" TEXT NOT NULL,
+    "artefact_id" UUID NOT NULL,
+    "case_number" TEXT,
+    "case_name" TEXT,
+    "created_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+
+    CONSTRAINT "artefact_search_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE INDEX "artefact_search_artefact_id_idx" ON "artefact_search"("artefact_id");
+
+-- CreateIndex
+CREATE INDEX "idx_subscription_search" ON "subscription"("search_type", "search_value");
+
+-- CreateIndex
+CREATE UNIQUE INDEX "subscription_user_id_search_type_search_value_key" ON "subscription"("user_id", "search_type", "search_value");
+
+-- AddForeignKey
+ALTER TABLE "artefact_search" ADD CONSTRAINT "artefact_search_artefact_id_fkey" FOREIGN KEY ("artefact_id") REFERENCES "artefact"("artefact_id") ON DELETE CASCADE ON UPDATE CASCADE;

apps/postgres/prisma/migrations/20260122150011_add_case_name_and_case_number_to_subscription/migration.sql

@@ -0,0 +1,6 @@
+-- AlterTable
+ALTER TABLE "subscription" ADD COLUMN     "case_name" TEXT,
+ADD COLUMN     "case_number" TEXT;
+
+-- CreateIndex
+CREATE INDEX "idx_subscription_case_number" ON "subscription"("case_number");

apps/postgres/prisma/migrations/20260123151728_add_cascade_delete_to_notification_audit_log/migration.sql

@@ -0,0 +1,5 @@
+-- DropForeignKey
+ALTER TABLE "notification_audit_log" DROP CONSTRAINT "notification_audit_log_subscription_id_fkey";
+
+-- AddForeignKey
+ALTER TABLE "notification_audit_log" ADD CONSTRAINT "notification_audit_log_subscription_id_fkey" FOREIGN KEY ("subscription_id") REFERENCES "subscription"("subscription_id") ON DELETE CASCADE ON UPDATE CASCADE;

apps/postgres/prisma/schema.prisma

@@ -9,24 +9,38 @@ datasource db {
 }
 
 model Artefact {
-  artefactId        String          @id @default(uuid()) @map("artefact_id") @db.Uuid
-  locationId        String          @map("location_id")
-  listTypeId        Int             @map("list_type_id")
-  contentDate       DateTime        @map("content_date") @db.Date
+  artefactId        String            @id @default(uuid()) @map("artefact_id") @db.Uuid
+  locationId        String            @map("location_id")
+  listTypeId        Int               @map("list_type_id")
+  contentDate       DateTime          @map("content_date") @db.Date
   sensitivity       String
   language          String
-  displayFrom       DateTime        @map("display_from")
-  displayTo         DateTime        @map("display_to")
-  lastReceivedDate  DateTime        @default(now()) @map("last_received_date")
-  isFlatFile        Boolean         @map("is_flat_file")
+  displayFrom       DateTime          @map("display_from")
+  displayTo         DateTime          @map("display_to")
+  lastReceivedDate  DateTime          @default(now()) @map("last_received_date")
+  isFlatFile        Boolean           @map("is_flat_file")
   provenance        String
-  supersededCount   Int             @default(0) @map("superseded_count")
-  noMatch           Boolean         @default(false) @map("no_match")
+  supersededCount   Int               @default(0) @map("superseded_count")
+  noMatch           Boolean           @default(false) @map("no_match")
   ingestionLogs     IngestionLog[]
+  artefactSearches  ArtefactSearch[]
 
   @@map("artefact")
 }
 
+model ArtefactSearch {
+  id         String    @id @default(cuid())
+  artefactId String    @map("artefact_id") @db.Uuid
+  caseNumber String?   @map("case_number")
+  caseName   String?   @map("case_name")
+  createdAt  DateTime  @default(now()) @map("created_at")
+
+  artefact Artefact @relation(fields: [artefactId], references: [artefactId], onDelete: Cascade)
+
+  @@index([artefactId])
+  @@map("artefact_search")
+}
+
 model User {
   userId             String         @id @default(uuid()) @map("user_id") @db.Uuid
   email              String         @db.VarChar(255)

apps/postgres/scripts/migrate-subscriptions.ts

@@ -0,0 +1,57 @@
+import { prisma } from "@hmcts/postgres";
+
+async function migrateSubscriptions() {
+  console.log("Starting subscription data migration...");
+
+  const subscriptions = await prisma.subscription.findMany({
+    where: {
+      searchType: null
+    }
+  });
+
+  console.log(`Found ${subscriptions.length} subscriptions to migrate`);
+
+  let migratedCount = 0;
+  let errorCount = 0;
+
+  for (const subscription of subscriptions) {
+    try {
+      if (subscription.locationId) {
+        await prisma.subscription.update({
+          where: {
+            subscriptionId: subscription.subscriptionId
+          },
+          data: {
+            searchType: "LOCATION_ID",
+            searchValue: subscription.locationId.toString()
+          }
+        });
+        migratedCount++;
+      }
+    } catch (error) {
+      console.error(`Failed to migrate subscription ${subscription.subscriptionId}:`, error);
+      errorCount++;
+    }
+  }
+
+  console.log(`Migration completed:`);
+  console.log(`  - Successfully migrated: ${migratedCount}`);
+  console.log(`  - Errors: ${errorCount}`);
+
+  const verifyCount = await prisma.subscription.count({
+    where: {
+      searchType: "LOCATION_ID"
+    }
+  });
+
+  console.log(`Verification: ${verifyCount} subscriptions now have searchType='LOCATION_ID'`);
+}
+
+migrateSubscriptions()
+  .catch((error) => {
+    console.error("Migration failed:", error);
+    process.exit(1);
+  })
+  .finally(async () => {
+    await prisma.$disconnect();
+  });

apps/postgres/src/schema-discovery.test.ts

@@ -12,12 +12,13 @@
       expect(Array.isArray(result)).toBe(true);
     });
 
-    it("should return array with subscriptions, location, and notifications schemas", () => {
+    it("should return array with subscriptions, location, notifications, and list-search-config schemas", () => {
       const result = getPrismaSchemas();
-      expect(result.length).toBe(3);
+      expect(result.length).toBe(4);
       expect(result.some((path) => path.includes("subscriptions"))).toBe(true);
       expect(result.some((path) => path.includes("location"))).toBe(true);
       expect(result.some((path) => path.includes("notifications"))).toBe(true);
+      expect(result.some((path) => path.includes("list-search-config"))).toBe(true);
     });
 
     it("should return a new array on each call", () => {

apps/postgres/src/schema-discovery.ts

@@ -1,8 +1,9 @@
 // Schema discovery functionality for module integration
+import { prismaSchemas as listSearchConfigSchemas } from "@hmcts/list-search-config/config";
 import { prismaSchemas as locationSchemas } from "@hmcts/location/config";
 import { prismaSchemas as notificationsSchemas } from "@hmcts/notifications/config";
-import { prismaSchemas as subscriptionsSchemas } from "@hmcts/subscriptions/config";
+import { prismaSchemas as subscriptionSchemas } from "@hmcts/subscription/config";
 
 export function getPrismaSchemas(): string[] {
-  return [subscriptionsSchemas, locationSchemas, notificationsSchemas];
+  return [subscriptionSchemas, locationSchemas, notificationsSchemas, listSearchConfigSchemas];
 }