[feat 🖤] user modue | extension modules | categories module for all create 🐱‍🏍

Author: devlopersabbir

server/src/app.module.ts

@@ -3,6 +3,7 @@ import { DirzzleModule } from "./drizzle/drizzle.module";
 import { ConfigModule } from "@nestjs/config";
 import { UserModule } from "./modules/users/users.module";
 import { ExtensionModule } from "./modules/extensions/extensions.module";
+import { CategoriesModule } from "./modules/categories/categories.module";
 
 @Module({
   imports: [
@@ -12,6 +13,7 @@ import { ExtensionModule } from "./modules/extensions/extensions.module";
     DirzzleModule,
     UserModule,
     ExtensionModule,
+    CategoriesModule,
   ],
   controllers: [],
   providers: [],

server/src/modules/categories/categories.controller.ts

@@ -0,0 +1,27 @@
+import { Body, Controller, Get, Post, UsePipes } from "@nestjs/common";
+import { ZodValidationPipe } from "@/pipes";
+import {
+  CategoriesSchema,
+  categoriesSchema,
+} from "./data-transfer-object/categories.dto";
+import { CategoriesService } from "./categories.service";
+
+@Controller({ path: "categories", version: "v1" })
+export class CategoriesController {
+  constructor(private readonly service: CategoriesService) {}
+
+  @Post("/")
+  @UsePipes(new ZodValidationPipe(categoriesSchema))
+  async store(@Body() body: CategoriesSchema) {
+    try {
+      return await this.service.store(body);
+    } catch (err) {
+      return err;
+    }
+  }
+
+  @Get("/")
+  async index() {
+    return await this.service.index();
+  }
+}

server/src/modules/categories/categories.module.ts

@@ -0,0 +1,11 @@
+import { Module } from "@nestjs/common";
+import { CategoriesController } from "./categories.controller";
+import { CategoriesRepository } from "./categories.repository";
+import { CategoriesService } from "./categories.service";
+
+@Module({
+  controllers: [CategoriesController],
+  providers: [CategoriesRepository, CategoriesService],
+  exports: [CategoriesRepository],
+})
+export class CategoriesModule {}

server/src/modules/categories/categories.repository.ts

@@ -0,0 +1,26 @@
+import { Injectable } from "@nestjs/common";
+import { eq, SQL } from "drizzle-orm";
+import { db } from "@/drizzle";
+import { CategoriesSchema } from "./data-transfer-object/categories.dto";
+import categories from "./categories.schema";
+
+@Injectable()
+export class CategoriesRepository {
+  async create(input: CategoriesSchema) {
+    const [data] = await db
+      .insert(categories)
+      .values({ ...input, slug: String(input.slug) })
+      .returning();
+    return data;
+  }
+  async fetch() {
+    const filter: SQL[] = [];
+
+    return await db.query.categories.findMany();
+  }
+  async findBySlug(slug: string) {
+    return await db.query.categories.findFirst({
+      where: eq(categories.slug, slug),
+    });
+  }
+}

server/src/modules/categories/categories.schema.ts

@@ -14,9 +14,7 @@ const categories = pgTable(
     icon: text("icon"),
     sortOrder: integer("sort_order").default(0),
   },
-  (table) => ({
-    slugIdx: index("categories_slug_idx").on(table.slug),
-  }),
+  (table) => [index("categories_slug_idx").on(table.slug)],
 );
 
 export const categoriesRelations = relations(categories, ({ many }) => ({

server/src/modules/categories/categories.service.ts

@@ -0,0 +1,26 @@
+import { ConflictException, Injectable } from "@nestjs/common";
+import { slugify } from "@/lib/utils";
+import { CategoriesRepository } from "./categories.repository";
+import { CategoriesSchema } from "./data-transfer-object/categories.dto";
+
+@Injectable()
+export class CategoriesService {
+  constructor(private readonly repository: CategoriesRepository) {}
+
+  async store(input: CategoriesSchema) {
+    // generate slug from the category name
+    const slug = slugify(input.name, "-");
+    // search category into db using slug
+    const category = await this.repository.findBySlug(slug);
+    if (category)
+      throw new ConflictException(
+        "This name of category already has on this store",
+      );
+
+    // now create category
+    return await this.repository.create({ ...input, slug });
+  }
+  async index() {
+    return await this.repository.fetch();
+  }
+}

server/src/modules/categories/data-transfer-object/categories.dto.ts

@@ -0,0 +1,12 @@
+import { z } from "zod";
+
+export const categoriesSchema = z.object({
+  name: z.string().min(1),
+  slug: z.string().optional(),
+
+  description: z.string().min(1),
+  icon: z.url().optional(),
+  sortOrder: z.number().default(0),
+});
+
+export type CategoriesSchema = z.infer<typeof categoriesSchema>;

server/src/modules/downloads/downloads.schema.ts

@@ -17,11 +17,11 @@ const downloads = pgTable(
       .references(() => extensions.id, { onDelete: "cascade" }),
     ipAddress: text("ip_address"),
   },
-  (table) => ({
-    extensionIdIdx: index("downloads_extension_id_idx").on(table.extensionId),
-    userIdIdx: index("downloads_user_id_idx").on(table.userId),
-    createdAtIdx: index("downloads_created_at_idx").on(table.createdAt),
-  }),
+  (table) => [
+    index("downloads_extension_id_idx").on(table.extensionId),
+    index("downloads_user_id_idx").on(table.userId),
+    index("downloads_created_at_idx").on(table.createdAt),
+  ],
 );
 export const downloadsRelations = relations(downloads, ({ one }) => ({
   user: one(users, {

server/src/modules/earnings/earnings.schema.ts

@@ -33,11 +33,11 @@ const earnings = pgTable(
     status: typedTextEnum("status", earningStatus).default("pending"),
     paidAt: createdAt("paid_at"),
   },
-  (table) => ({
-    sellerIdIdx: index("earnings_seller_id_idx").on(table.sellerId),
-    purchaseIdIdx: uniqueIndex("earnings_purchase_id_idx").on(table.purchaseId),
-    statusIdx: index("earnings_status_idx").on(table.status),
-  }),
+  (table) => [
+    index("earnings_seller_id_idx").on(table.sellerId),
+    uniqueIndex("earnings_purchase_id_idx").on(table.purchaseId),
+    index("earnings_status_idx").on(table.status),
+  ],
 );
 
 export const earningsRelations = relations(earnings, ({ one }) => ({

server/src/modules/extension-files/extension-file.schema.ts

@@ -3,7 +3,6 @@ import { baseSchema } from "@/utils/db-utility";
 import extensions from "../extensions/extensions.schema";
 import { relations } from "drizzle-orm";
 
-// Extension files table (for version management)
 const extensionFiles = pgTable(
   "extension_files",
   {
@@ -18,15 +17,10 @@ const extensionFiles = pgTable(
     fileHash: text("file_hash").notNull(),
     fileSize: integer("file_size").notNull(),
   },
-  (table) => ({
-    extensionIdIdx: index("extension_files_extension_id_idx").on(
-      table.extensionId,
-    ),
-    versionIdx: index("extension_files_version_idx").on(
-      table.extensionId,
-      table.version,
-    ),
-  }),
+  (table) => [
+    index("extension_files_extension_id_idx").on(table.extensionId),
+    index("extension_files_version_idx").on(table.extensionId, table.version),
+  ],
 );
 
 export const extensionFilesRelations = relations(extensionFiles, ({ one }) => ({