add

Author: khanh1902

server/src/constants/index.ts

@@ -54,7 +54,7 @@ export const ENDPOINTS = {
       GET_ONE: '/flow/get-one',
       PUBLISH: '/flow/publish-flow',
       ADD_CHANNELS: '/flow/add-channels',
-      SELECT_FLOWS_FOR_CHANNEL: '/flow/select'
+      SELECT_FLOWS_FOR_CHANNEL: '/flow/select',
    }
 };
 

server/src/controllers/flows.controller.ts

@@ -83,4 +83,11 @@ export class FlowController {
         );
         res.status(StatusCodes.OK).json({ data });
     });
+
+    public getFlowByContactId = catchAsync(async (req: RequestWithUser, res) => {
+        const data = await this.flowService.getFlowByContactId(
+            req.params.contactId,
+        );
+        res.status(StatusCodes.OK).json({ data });
+    });
 }

server/src/database/schema.ts

@@ -123,7 +123,6 @@ export const flows = pgTable('flows', {
    deleted: boolean('deleted').default(false),
    updatedAt: timestamp('updated_at'),
    createdAt: timestamp('created_at').defaultNow(),
-   diagrams: json('diagrams').default([]).$type<any[]>(),
    edges: json('edges').default([]).$type<any[]>(),
    nodes: json('nodes').default([]).$type<any[]>(),
    settings: json('settings').default([]).$type<any[]>(),

server/src/routes/flow.route.ts

@@ -66,5 +66,11 @@ export class FlowRoute implements Routes {
             authMiddleware,
             this.controller.selectFlowsForChannel
         );
+
+        this.router.get(
+            `${ENDPOINTS.FLOW.INDEX}/:contactId`,
+            authMiddleware,
+            this.controller.getFlowByContactId
+        );
     }
 }

server/src/services/flows.service.ts

@@ -7,7 +7,7 @@ import { HttpException } from '@/exceptions/http-exception';
 import { LocaleService } from '@/i18n/ctx';
 import { FlowExtend } from '@/interfaces/flows.interface';
 import { Paging } from '@/interfaces/paging.interface';
-import { and, asc, desc, eq, like, ne, notExists, sql } from 'drizzle-orm';
+import { and, asc, desc, eq, isNotNull, like, ne, notExists, sql } from 'drizzle-orm';
 import { StatusCodes } from 'http-status-codes';
 import { Inject, Service } from 'typedi';
 import { ChannelService } from './channels.service';
@@ -152,10 +152,6 @@ export class FlowService {
         return flowExisted;
     }
 
-    public async getFlowByContactId(contactId: string) {
-
-    }
-
     public async getAllFlows(paging: PagingDTO,
         userId: string
     ): Promise<Paging<FlowExtend>> {
@@ -201,7 +197,6 @@ export class FlowService {
         return orderBy;
     }
 
-
     public async addMultipleChannels(channelIDs: string[], flowId: string, userId: string) {
         const flowExisted = await db.query.flows.findFirst({
             where: and(
@@ -251,4 +246,32 @@ export class FlowService {
 
         return result;
     }
+
+    public async getFlowByContactId(contactId: string) {
+        const flow = db.query.flows.findFirst({
+            where: and(
+                eq(flows.deleted, false),
+                isNotNull(flows.publishAt),
+                isNotNull(
+                    db.select({
+                        id: channels.id
+                    })
+                        .from(channels)
+                        .where(
+                            and(
+                                eq(channels.contactId, contactId),
+                            )
+                        )
+                )
+            )
+        });
+
+        if (!flow) {
+            throw new HttpException(
+                StatusCodes.BAD_REQUEST,
+                this.localeService.i18n().FLOW.NOT_FOUND()
+            );
+        }
+        return flow;
+    }
 }