return also number of updated establishments

back/src/domains/establishment/adapters/PgEstablishmentAggregateRepository.sql.integration.test.ts

@@ -219,7 +219,11 @@ describe("SQL queries, independent from PgEstablishmentAggregateRepository", ()
       );
 
       // Run the deactivation query
-      await deactivateUnresponsiveEstablishmentsQuery(db);
+      const updatedEstablishments =
+        await deactivateUnresponsiveEstablishmentsQuery(db);
+
+      // Verify the count of updated establishments
+      expectToEqual(updatedEstablishments.length, 1);
 
       // Verify the establishment was deactivated using direct DB query
       const result = await db
@@ -290,7 +294,11 @@ describe("SQL queries, independent from PgEstablishmentAggregateRepository", ()
       );
 
       // Run the deactivation query
-      await deactivateUnresponsiveEstablishmentsQuery(db);
+      const updatedEstablishments =
+        await deactivateUnresponsiveEstablishmentsQuery(db);
+
+      // Verify no establishments were updated
+      expectToEqual(updatedEstablishments.length, 0);
 
       // Verify the establishment was not deactivated using direct DB query
       const result = await db

back/src/domains/establishment/adapters/PgEstablishmentAggregateRepository.sql.ts

@@ -238,4 +238,5 @@ export const deactivateUnresponsiveEstablishmentsQuery = (db: KyselyDb) =>
         ),
       ),
     )
+    .returningAll()
     .execute();

back/src/scripts/triggerDeactivateUnresponsiveEstablishments.ts

@@ -8,14 +8,21 @@ import { handleCRONScript } from "./handleCRONScript";
 const logger = createLogger(__filename);
 const config = AppConfig.createFromEnv();
 
-type Report = { status: "success" } | { status: "error"; message: string };
+type Report =
+  | { status: "success"; updatedCount: number }
+  | { status: "error"; message: string };
 
 const deactivateUnresponsiveEstablishments = async (): Promise<Report> => {
   const pool = new Pool({ connectionString: config.pgImmersionDbUrl });
   const db = makeKyselyDb(pool);
 
   return deactivateUnresponsiveEstablishmentsQuery(db)
-    .then((): Report => ({ status: "success" }))
+    .then(
+      (updatedEstablishments): Report => ({
+        status: "success",
+        updatedCount: updatedEstablishments.length,
+      }),
+    )
     .catch(
       (e): Report => ({
         status: "error",
@@ -31,7 +38,7 @@ handleCRONScript(
   deactivateUnresponsiveEstablishments,
   (report) =>
     report.status === "success"
-      ? "Unresponsive establishments deactivated successfully"
+      ? `${report.updatedCount} unresponsive establishments deactivated successfully`
       : `Error deactivating unresponsive establishments: ${report.message}`,
   logger,
 );