@@ -96,7 +101,49 @@ export function NotificationView({ contactId }: NotificationViewProps) {
);
}
+NotificationView.Skeleton = function NotificationViewSkeleton() {
+
+ return (
+
+
+
+
Criar notificação
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ );
+}
export interface NotificationViewProps {
contactId: string;
+ triggerId?: string;
}
diff --git a/src/domains/notification-triggers/client-api.ts b/src/domains/notification-triggers/client-api.ts
index 83ac955..bf985be 100644
--- a/src/domains/notification-triggers/client-api.ts
+++ b/src/domains/notification-triggers/client-api.ts
@@ -3,6 +3,7 @@ import { HttpClient } from "@/common/http/client";
import { PagedInput, PagedResult } from "@/common/http/pagination";
import { UrlFormatter } from "@/common/http/url/url-formatter";
import { RegisterNotificationTriggerInput } from "./use-cases/register-notification-trigger-types";
+import { UpdateNotificationTriggerInput } from "./use-cases/update-notification-trigger-types";
import { Trigger1, TriggerProps } from "./entities";
export class NotificationTriggersApi {
@@ -24,6 +25,28 @@ export class NotificationTriggersApi {
return result;
}
+ public async update(args: UpdateNotificationTriggerInput): Promise
{
+
+ const url = UrlFormatter.format('{id}', { id: args.triggerId });
+ const result = await this._client.put(url, args);
+
+ if (!result)
+ throw new Error('Server did not return results');
+
+ return result;
+ }
+
+ public async getById(args: GetByIdArgs): Promise {
+
+ const url = UrlFormatter.format('{id}', args);
+ const result = await this._client.get(url);
+
+ if (!result)
+ throw new Error('Server did not return results');
+
+ return result;
+ }
+
public async getAll(args: GetAllArgs): Promise> {
const url = UrlFormatter.format('', args);
@@ -42,6 +65,10 @@ export class NotificationTriggersApi {
}
}
+export interface GetByIdArgs {
+ id: string;
+}
+
export interface GetAllArgs extends PagedInput {
contactId?: string;
}
\ No newline at end of file
diff --git a/src/domains/notification-triggers/use-cases/get-notification-trigger.ts b/src/domains/notification-triggers/use-cases/get-notification-trigger.ts
new file mode 100644
index 0000000..2a16695
--- /dev/null
+++ b/src/domains/notification-triggers/use-cases/get-notification-trigger.ts
@@ -0,0 +1,48 @@
+import { PrismaClient } from "@prisma/client";
+import { UseCase } from "@/common/use-cases";
+import { UserLogged } from "@/common/auth/user";
+import { Trigger1 } from "../entities";
+import { TriggerMapper } from "../mapper";
+
+
+export class GetNotificationTrigger implements UseCase {
+
+ private _user: UserLogged;
+ private _db: PrismaClient;
+
+ constructor({ userLogged, prismaClient }: { userLogged: UserLogged, prismaClient: PrismaClient }) {
+
+ this._user = userLogged;
+ this._db = prismaClient;
+ }
+
+ public async execute(input: GetNotificationTriggerInput): Promise {
+
+ const trigger = await this._db.notificationTrigger.findFirst({
+ where: {
+ id: input.triggerId,
+ contact: {
+ accountId: this._user.accountId
+ }
+ },
+ include: {
+ templateMessage: {
+ select: {
+ id: true,
+ name: true,
+ notifyDaysBefore: true
+ }
+ }
+ }
+ });
+
+ const mapper = new TriggerMapper();
+ const result = trigger ? mapper.mapToView1(trigger) : null;
+ return result;
+ }
+
+}
+
+export interface GetNotificationTriggerInput {
+ triggerId: string;
+}
diff --git a/src/domains/notification-triggers/use-cases/update-notification-trigger-types.ts b/src/domains/notification-triggers/use-cases/update-notification-trigger-types.ts
new file mode 100644
index 0000000..a46ce3d
--- /dev/null
+++ b/src/domains/notification-triggers/use-cases/update-notification-trigger-types.ts
@@ -0,0 +1,11 @@
+import { TriggerParamValue, TriggerType } from "../entities";
+
+export interface UpdateNotificationTriggerInput {
+ triggerId: string;
+ templateMessageId: string;
+ contactId: string;
+ type: TriggerType;
+ day: number | null;
+ month: number | null;
+ paramsValue: TriggerParamValue[];
+}
\ No newline at end of file
diff --git a/src/domains/notification-triggers/use-cases/update-notification-trigger.ts b/src/domains/notification-triggers/use-cases/update-notification-trigger.ts
new file mode 100644
index 0000000..b55eeb6
--- /dev/null
+++ b/src/domains/notification-triggers/use-cases/update-notification-trigger.ts
@@ -0,0 +1,123 @@
+import z from "zod";
+import { AppError } from "@/common/error";
+import { UseCase } from "@/common/use-cases";
+import { messages } from "@/common/validation/messages";
+import { UserLogged } from "@/common/auth/user";
+import { PrismaClient } from "@prisma/client";
+import { Trigger, TriggerType } from "../entities";
+import { TriggerMapper } from "../mapper";
+import { UpdateNotificationTriggerInput } from "./update-notification-trigger-types";
+
+export class UpdateNotificationTrigger implements UseCase {
+
+ private _user: UserLogged;
+ private _db: PrismaClient;
+
+ constructor({ userLogged, prismaClient }: { userLogged: UserLogged, prismaClient: PrismaClient }) {
+
+ this._user = userLogged;
+ this._db = prismaClient;
+ }
+
+ public async execute(input: UpdateNotificationTriggerInput): Promise {
+
+ this.validate(input);
+
+ const triggerMapper = new TriggerMapper();
+
+ const triggerExists = await this._db.notificationTrigger.findFirst({
+ where: {
+ contactId: input.contactId,
+ templateMessageId: input.templateMessageId,
+ type: triggerMapper.mapTriggerType2(input.type),
+ day: input.day,
+ month: input.month,
+ id: {
+ not: input.triggerId
+ }
+ },
+ select: {
+ id: true
+ }
+ });
+
+ if (triggerExists) {
+ throw new AppError('Existe outra notificação para o dia informado');
+ }
+
+ await this._db.$transaction(async transaction => {
+
+ await this._db.notificationTrigger.update({
+ where: { id: input.triggerId },
+ data: {
+ templateMessageId: input.templateMessageId,
+ contactId: input.contactId,
+ type: triggerMapper.mapTriggerType2(input.type),
+ day: input.day,
+ month: input.month,
+ paramsValue: JSON.stringify(input.paramsValue ?? [])
+ }
+ });
+
+ await transaction.notification.deleteMany({
+ where: {
+ accountId: this._user.accountId,
+ triggerId: input.triggerId,
+ sendedAt: null,
+ }
+ });
+
+ });
+
+ const triggerDb = await this._db.notificationTrigger.findFirst({
+ where: {
+ id: input.triggerId
+ },
+ include: {
+ templateMessage: true
+ }
+ });
+
+ return triggerMapper.map(triggerDb!);
+ }
+
+ private validate(input: UpdateNotificationTriggerInput) {
+
+ const baseValidationSchema = z.object({
+ triggerId: z.string().min(1, { message: messages.required }),
+ templateMessageId: z.string().min(1, { message: messages.required }),
+ contactId: z.string().min(1, { message: messages.required }),
+ type: z.nativeEnum(TriggerType),
+ paramsValue: z.array(z.object({
+ name: z.string().min(1, { message: messages.required }),
+ value: z.string().min(1, { message: messages.required })
+ })),
+ day: z.coerce.number().optional(),
+ month: z.coerce.number().optional(),
+ });
+
+ const dailyValidationSchema = z.object({
+ type: z.literal(TriggerType.Daily)
+ });
+
+ const monthlyValidationSchema = z.object({
+ type: z.literal(TriggerType.Monthy),
+ day: z.coerce.number().min(1).max(31)
+ });
+
+ const yearlyValidationSchema = z.object({
+ type: z.literal(TriggerType.Yearly),
+ day: z.coerce.number().min(1).max(31),
+ month: z.coerce.number().min(1).max(12),
+ });
+
+ const validationSchema = z.intersection(baseValidationSchema, z.discriminatedUnion('type', [ dailyValidationSchema, monthlyValidationSchema, yearlyValidationSchema ]));
+
+ const result = validationSchema.safeParse(input);
+
+ if (result.success)
+ return;
+
+ throw AppError.fromZodError(result.error);
+ }
+}
\ No newline at end of file