Implement tag management functionality by adding Tag model and repository. Update persistence layer to use DatabaseTableName constants for consistency. Refactor Page component to fetch and display tags asynchronously.

Author: kingRayhan

src/app/test/page.tsx

@@ -1,10 +1,9 @@
-"use client";
-
+import { getTags } from "@/backend/services/tag.action";
 import React from "react";
 
-const Page = () => {
-  const [tags, setTags] = React.useState<string[]>([]);
-  return <div className="p-10"></div>;
+const Page = async () => {
+  const tags = await getTags({ page: 1, limit: -1 });
+  return <pre className="p-10">{JSON.stringify(tags, null, 2)}</pre>;
 };
 
 export default Page;

src/backend/models/domain-models.ts

@@ -90,3 +90,13 @@ export interface SeriesItem {
   created_at: Date;
   updated_at: Date;
 }
+
+export interface Tag {
+  id: string;
+  name: string;
+  icon?: IServerFile | null;
+  color?: string | null;
+  description?: string | null;
+  created_at: Date;
+  updated_at: Date;
+}

src/backend/persistence-repositories.ts

@@ -2,32 +2,43 @@ import {
   Article,
   Series,
   SeriesItem,
+  Tag,
   User,
   UserSession,
   UserSocial,
 } from "./models/domain-models";
 import { pgClient } from "./persistence/database-drivers/pg.client";
+import { DatabaseTableName } from "./persistence/persistence-contracts";
 import { PersistentRepository } from "./persistence/persistence.repository";
 
-export const userRepository = new PersistentRepository<User>("users", pgClient);
+export const userRepository = new PersistentRepository<User>(
+  DatabaseTableName.users,
+  pgClient
+);
 export const articleRepository = new PersistentRepository<Article>(
-  "articles",
+  DatabaseTableName.articles,
+  pgClient
+);
+export const tagRepository = new PersistentRepository<Tag>(
+  DatabaseTableName.tags,
   pgClient
 );
-
 export const userSocialRepository = new PersistentRepository<UserSocial>(
-  "user_socials",
+  DatabaseTableName.user_socials,
   pgClient
 );
 export const userSessionRepository = new PersistentRepository<UserSession>(
-  "user_sessions",
+  DatabaseTableName.user_sessions,
   pgClient
 );
 
-const seriesRepository = new PersistentRepository<Series>("series", pgClient);
+const seriesRepository = new PersistentRepository<Series>(
+  DatabaseTableName.series,
+  pgClient
+);
 
 const seriesItemsRepository = new PersistentRepository<SeriesItem>(
-  "series_items",
+  DatabaseTableName.series_items,
   pgClient
 );
 
@@ -36,6 +47,7 @@ export const persistenceRepository = {
   userSocial: userSocialRepository,
   userSession: userSessionRepository,
   article: articleRepository,
+  tags: tagRepository,
   series: seriesRepository,
   seriesItems: seriesItemsRepository,
 };

src/backend/persistence/persistence-contracts.ts

@@ -109,4 +109,10 @@ export enum DatabaseTableName {
   clients = "clients",
   users = "users",
   roles = "roles",
+  articles = "articles",
+  user_socials = "user_socials",
+  user_sessions = "user_sessions",
+  series = "series",
+  series_items = "series_items",
+  tags = "tags",
 }

src/backend/persistence/persistence.repository.ts

@@ -1,6 +1,7 @@
 import { log } from "console";
 import {
   AppPaginationResponseDto,
+  DatabaseTableName,
   IPagination,
   IPersistentDriver,
   IPersistentPaginationPayload,
@@ -18,7 +19,7 @@ import { removeNullOrUndefinedFromObject } from "@/lib/utils";
 
 export class PersistentRepository<DOMAIN_MODEL_TYPE> {
   constructor(
-    public readonly tableName: string,
+    public readonly tableName: DatabaseTableName,
     public readonly persistentDriver: IPersistentDriver
   ) {}
 
@@ -51,7 +52,7 @@ export class PersistentRepository<DOMAIN_MODEL_TYPE> {
         totalCount: +totalCountResult,
         currentPage: +_page,
         hasNextPage: _page * _limit < totalCountResult,
-        totalPages: +Math.ceil(totalCountResult / _limit),
+        totalPages: _limit == -1 ? 1 : +Math.ceil(totalCountResult / _limit),
       },
     };
   }

src/backend/services/article.actions.ts

@@ -21,9 +21,10 @@ import {
 } from "./RepositoryException";
 import { ArticleRepositoryInput } from "./inputs/article.input";
 import { getSessionUserId } from "./session.actions";
+import { DatabaseTableName } from "../persistence/persistence-contracts";
 
 const articleRepository = new PersistentRepository<Article>(
-  "articles",
+  DatabaseTableName.articles,
   pgClient
 );
 

src/backend/services/tag.action.ts

@@ -1 +1,20 @@
+"use server";
 
+import { z } from "zod";
+import { persistenceRepository } from "../persistence-repositories";
+import { TagRepositoryInput } from "./inputs/tag.input";
+import { handleRepositoryException } from "./RepositoryException";
+
+export const getTags = async (
+  _input: z.infer<typeof TagRepositoryInput.findAllInput>
+) => {
+  try {
+    const input = await TagRepositoryInput.findAllInput.parseAsync(_input);
+    return persistenceRepository.tags.findAllWithPagination({
+      page: input.page,
+      limit: input.limit,
+    });
+  } catch (error) {
+    handleRepositoryException(error);
+  }
+};