feat: add userEmailQueue procedure to retrieve queued emails for a user
This commit is contained in:
parent
7adb33f485
commit
ef31656639
1 changed files with 9 additions and 1 deletions
|
|
@ -7,7 +7,10 @@ import {
|
||||||
protectedProcedure,
|
protectedProcedure,
|
||||||
publicProcedure,
|
publicProcedure,
|
||||||
} from "~/server/api/trpc";
|
} 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 { UtenteInteressatoAdAnnuncioEmail } from "~/server/controllers/servizio.controller";
|
||||||
import { db } from "~/server/db";
|
import { db } from "~/server/db";
|
||||||
import {
|
import {
|
||||||
|
|
@ -212,4 +215,9 @@ export const comunicazioniRouter = createTRPCRouter({
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
}),
|
}),
|
||||||
|
getUserQueuedEmails: protectedProcedure
|
||||||
|
.input(z.object({ userId: zUserId }))
|
||||||
|
.query(async ({ input }) => {
|
||||||
|
return await userEmailQueue(input.userId);
|
||||||
|
}),
|
||||||
});
|
});
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue