update

Author: khanh1902

server/src/constants/index.ts

@@ -25,4 +25,5 @@ export const ENDPOINTS = {
       SINGLE: '/upload/single',
       MULTIPLE: '/upload/multiple',
    },
+   CHANNEL: '/channel',
 };

server/src/controllers/channels.controller.ts

@@ -0,0 +1,17 @@
+import { ChannelService } from "@/services/channels.service";
+import { catchAsync } from "@/utils/catch-async";
+import { StatusCodes } from "http-status-codes";
+import Container from "typedi";
+
+export class ChannelController {
+    public channelService = Container.get(ChannelService);
+
+    public createChannel = catchAsync(async (req, res) => {
+        const data = await this.channelService.create(req.body);
+        res.status(StatusCodes.OK).json({
+            message: 'Tạo channel thành công',
+            data,
+        });
+    });
+
+}

server/src/database/schema.ts

@@ -59,8 +59,8 @@ export const channels = pgTable(
          .primaryKey(),
       contactId: text('contact_id').unique().notNull(),
       contactName: text('contact_name').notNull(),
-      credentials: json('credentials'),
-      active: boolean('active').default(true),
+      credentials: text('credentials'),
+      active: boolean('active'),
       channelTypeId: integer('channel_type_id').notNull(),
       createdAt: timestamp('created_at').defaultNow(),
       updatedAt: timestamp('update_at').defaultNow(),

server/src/database/types.ts

@@ -40,3 +40,7 @@ export const ROLES = z.enum(schema.roles.enumValues);
 export type TNewUser = typeof schema.users.$inferInsert;
 
 export type TUpdateUser = Partial<TNewUser>;
+
+export type TNewChannel = typeof schema.channels.$inferInsert;
+
+export type TUpdateChannel = Partial<TNewChannel>;

server/src/dtos/channels.dto.ts

@@ -0,0 +1,27 @@
+import { IsBoolean, IsNotEmpty, IsNumber, IsString } from "class-validator";
+
+export class channelDTO {
+    @IsString()
+    @IsNotEmpty({
+        message: 'ContactID không được bỏ trống',
+    })
+    contactId: string;
+
+    @IsString()
+    @IsNotEmpty({
+        message: 'Contact name không được bỏ trống',
+    })
+    contactName: string;
+
+    @IsNumber()
+    @IsNotEmpty({
+        message: 'Channel type không được bỏ trống',
+    })
+    channelTypeId: number;
+
+    @IsString()
+    credentials: string;
+
+    @IsBoolean()
+    active: boolean | false;
+}

server/src/interfaces/channels.interface.ts

@@ -0,0 +1,21 @@
+import { ENDPOINTS } from '@/constants';
+import { ChannelController } from '@/controllers/channels.controller';
+import { channelDTO } from '@/dtos/channels.dto';
+import { validate } from '@/middlewares/validation.middleware';
+import type { Routes } from '@interfaces/routes.interface';
+import { Router } from 'express';
+export class ChannelRoute implements Routes {
+    public router: Router = Router();
+    public controller = new ChannelController();
+
+    constructor() {
+        this.initializeRoutes();
+    }
+    initializeRoutes() {
+        this.router.post(
+            ENDPOINTS.CHANNEL,
+            validate(channelDTO, 'body'),
+            this.controller.createChannel
+        );
+    }
+}

server/src/routes/channels.route.ts

@@ -2,9 +2,14 @@ import { App } from '@/app';
 import { AuthRoute } from '@routes/auth.route';
 import { ValidateEnv } from '@/utils/validate-env';
 import { UploadRoute } from './routes/upload.route';
+import { ChannelRoute } from './routes/channels.route';
 
 ValidateEnv();
 
-const app = new App([new AuthRoute(), new UploadRoute()]);
+const app = new App([
+    new AuthRoute(),
+    new UploadRoute(),
+    new ChannelRoute(),
+]);
 
 app.listen();

server/src/server.ts

@@ -0,0 +1,42 @@
+import { db } from "@/database/db";
+import { channels } from "@/database/schema";
+import { TNewChannel, TUpdateChannel } from "@/database/types";
+import { tryCatch } from "bullmq";
+import { eq } from "drizzle-orm";
+import { Service } from "typedi";
+
+@Service()
+export class ChannelService {
+    public async create(fields: TNewChannel) {
+        try {
+            console.log("start create channel")
+            console.log(fields);
+            fields.contactId = fields.contactId && fields.contactId.trim() || null;
+            const channel = await db.insert(channels).values(fields).returning;
+            console.log(channel[0]);
+
+            return channel[0];
+        }
+        catch (error) {
+            console.log(error);
+        }
+    }
+
+    public async findOneById(id: number) {
+        const channel = await db.query.channels.findFirst({
+            where: eq(channels.id, id),
+        });
+
+        return channel;
+    }
+
+    public async updateById(id: number, fields: TUpdateChannel) {
+        const channel = await db
+            .update(channels)
+            .set(fields)
+            .where(eq(channels.id, id))
+            .returning();
+
+        return channel[0];
+    }
+}