Implement article tag deletion logic in persistence layer and enhance SQL query building. Update GET request handler to remove specified tags for an article. Refactor related functions for improved clarity and functionality.

Author: kingRayhan

.github/persistence-context.md

@@ -0,0 +1,69 @@
+## Project Overview
+
+This project is a custom-built mini-ORM utility for managing database operations in a Node.js/TypeScript application. It includes features like query building, pagination, joins, and CRUD operations.
+
+### Key Directories and Files
+
+- **`src/backend/persistence/`**: Contains the core persistence logic.
+
+  - `persistence.repository.ts`: Implements the `PersistentRepository` class for database operations.
+  - `persistence-contracts.ts`: Defines interfaces and types for persistence operations.
+  - `persistence-utils.ts`: Utility functions for building SQL queries.
+  - `persistence-where-operator.ts`: Helper functions for building `WHERE` clauses.
+  - `database-drivers/pg.client.ts`: PostgreSQL database driver implementation.
+
+- **`src/backend/persistence-repositories.ts`**: Exports repository instances for specific database tables.
+
+### Key Features
+
+1. **Dynamic Query Building**:
+
+   - Supports `WHERE`, `ORDER BY`, `JOIN`, and pagination.
+   - Utility functions like `buildWhereClause`, `buildOrderByClause`, and `buildJoinClause`.
+
+2. **CRUD Operations**:
+
+   - `findRows`, `findRowCount`, `createOne`, `createMany`, `updateOne`, `deleteRows`.
+
+3. **Error Handling**:
+
+   - Custom error classes like `PersistenceDriverError`.
+
+4. **Database Driver**:
+   - Uses PostgreSQL (`pg` package) for database interactions.
+
+### Testing
+
+- Tests are written using Jest.
+- Mocking is used for the database driver (`IPersistentDriver`).
+- Test cases cover all repository methods and utility functions.
+
+### Common Queries
+
+1. **How to test a specific method?**
+
+   - Provide the method name and its file path. Example: `findRows` in `persistence.repository.ts`.
+
+2. **How to add a new feature?**
+
+   - Specify the feature and its purpose. Example: Add support for `GROUP BY` in queries.
+
+3. **How to debug an issue?**
+
+   - Provide the error message and the relevant file or method.
+
+4. **How to write migrations?**
+   - Specify the table and column changes. Example: Add a new column to the `users` table.
+
+### Example Prompts
+
+- "Can you check the `findRows` method in `persistence.repository.ts`?"
+- "Can you write test cases for the `updateOne` method?"
+- "How can I add a `GROUP BY` clause to the query builder?"
+- "Can you help me debug this error: `Failed to initialize database connection`?"
+
+### Notes
+
+- Always use parameterized queries to prevent SQL injection.
+- Follow TypeScript best practices for type safety.
+- Use environment variables for database configuration.

.idea/.gitignore

@@ -1,10 +1,35 @@
-import * as articleActions from "@/backend/services/article.actions";
-import { NextResponse } from "next/server";
+import {persistenceRepository} from "@/backend/persistence-repositories";
+import {NextResponse} from "next/server";
 
 export async function GET(request: Request) {
-  // return NextResponse.json({
-  //   handle: await articleActions.updateArticle({
-  //     article_id: "5f0a1c0c-a8c8-4f5b-b8d8-c4d4d4d4d4d4",
-  //   }),
-  // });
+  // [
+  //   {
+  //     "key": "article_id",
+  //     "operator": "=",
+  //     "value": "317eb5cf-9ef5-4ef1-9da7-78007dd83149"
+  //   },
+  //   {
+  //     "key": "tag_id",
+  //     "operator": "not in",
+  //     "value": []
+  //   }
+  // ]
+  return NextResponse.json({
+    handle: await persistenceRepository.articleTag.deleteRows({
+      where: {
+        AND: [
+          {
+            "key": "article_id",
+            "operator": "=",
+            "value": "317eb5cf-9ef5-4ef1-9da7-78007dd83149"
+          },
+          {
+            "key": "tag_id",
+            "operator": "not in",
+            "value": ["060f882f-e40e-415b-bc06-ed618f77d9bc", "2e27c4b0-226d-41ed-ae3f-3f9ac493b6a7"]
+          }
+        ]
+      }
+    }),
+  });
 }

.idea/inspectionProfiles/Project_Default.xml

@@ -11,6 +11,7 @@ export const sql = String.raw;
 /**
  * Builds a WHERE clause for SQL queries
  * @param where Where condition or undefined
+ * @param tableName
  * @returns Object containing the WHERE clause and values array
  */
 export const buildWhereClause = <T>(
@@ -27,8 +28,6 @@ export const buildWhereClause = <T>(
   // Process the where condition
   const whereClause = processWhereCondition(where, values, tableName);
 
-  console.log({ whereClause, tableName });
-
   return {
     whereClause,
     values,
@@ -94,15 +93,7 @@ const processSimpleCondition = <T>(
       return operator === "in" ? "FALSE" : "TRUE";
     }
 
-    const placeholders = value
-      .map(() => `$${values.length + 1}`)
-      .map((placeholder, index) => {
-        values.push(value[index]);
-        return placeholder;
-      })
-      .join(", ");
-
-    return `"${tableName}"."${key.toString()}" ${operator} (${placeholders})`;
+    return `"${tableName}"."${key.toString()}" ${operator} (${value.map(v => `'${v}'`).join(',')})`;
   }
 
   // Handle NULL values

.idea/modules.xml

@@ -15,6 +15,7 @@ import {
   neq,
   notInArray,
   or,
+  inArray,
 } from "../persistence/persistence-where-operator";
 import { PersistentRepository } from "../persistence/persistence.repository";
 import {
@@ -233,12 +234,13 @@ export async function updateMyArticle(
     });
 
     if (input.tag_ids) {
-      await persistenceRepository.articleTag.deleteRows({
+     const deleted =  await persistenceRepository.articleTag.deleteRows({
         where: and(
-          eq("article_id", article.id),
+          // eq("article_id", article.id),
           notInArray("tag_id", input.tag_ids)
         ),
       });
+      console.log(deleted)
 
       input.tag_ids.forEach(async (tag_id) => {
         await persistenceRepository.articleTag.createOne({

.idea/techdiary.dev.iml

@@ -2,9 +2,9 @@
 
 import { z } from "zod";
 import { persistenceRepository } from "../persistence-repositories";
+import { like } from "../persistence/persistence-where-operator";
 import { TagRepositoryInput } from "./inputs/tag.input";
 import { handleRepositoryException } from "./RepositoryException";
-import { like } from "../persistence/persistence-where-operator";
 
 export const getTags = async (
   _input: z.infer<typeof TagRepositoryInput.findAllInput>