From ef316566390c263a28650fefcf875c5c89f5fb9e Mon Sep 17 00:00:00 2001 From: Marco Pedone Date: Wed, 25 Mar 2026 17:30:45 +0100 Subject: [PATCH] feat: add userEmailQueue procedure to retrieve queued emails for a user --- .../src/server/api/routers/comunicazioni.ts | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/apps/infoalloggi/src/server/api/routers/comunicazioni.ts b/apps/infoalloggi/src/server/api/routers/comunicazioni.ts index 7f87a1f..872ca9d 100644 --- a/apps/infoalloggi/src/server/api/routers/comunicazioni.ts +++ b/apps/infoalloggi/src/server/api/routers/comunicazioni.ts @@ -7,7 +7,10 @@ import { protectedProcedure, publicProcedure, } from "~/server/api/trpc"; -import { addEventToQueue } from "~/server/controllers/event_queue.controller"; +import { + addEventToQueue, + userEmailQueue, +} from "~/server/controllers/event_queue.controller"; import { UtenteInteressatoAdAnnuncioEmail } from "~/server/controllers/servizio.controller"; import { db } from "~/server/db"; import { @@ -212,4 +215,9 @@ export const comunicazioniRouter = createTRPCRouter({ ); } }), + getUserQueuedEmails: protectedProcedure + .input(z.object({ userId: zUserId })) + .query(async ({ input }) => { + return await userEmailQueue(input.userId); + }), });