refactor: update article deletion logic to use lte for date comparison

- Modified the article cleanup service to use lte (less than or equal) instead of lt (less than) for the delete_scheduled_at comparison, ensuring articles are deleted correctly when the scheduled time is reached.
- Added a comma for consistency in error messages in the search service.

These changes improve the accuracy of article deletion and enhance code consistency.

Author: kingRayhan

src/backend/services/article-cleanup-service.ts

@@ -1,5 +1,5 @@
 "use server";
-import { and, lt, neq } from "sqlkit";
+import { and, lt, lte, neq } from "sqlkit";
 import { persistenceRepository } from "../persistence/persistence-repositories";
 import { handleActionException } from "./RepositoryException";
 import { deleteArticleById } from "./search.service";
@@ -14,7 +14,7 @@ export async function deleteExpiredArticles() {
     const articlesToDelete = await persistenceRepository.article.find({
       where: and(
         neq("delete_scheduled_at", null),
-        lt("delete_scheduled_at", currentTime)
+        lte("delete_scheduled_at", currentTime),
       ),
     });
 
@@ -25,12 +25,12 @@ export async function deleteExpiredArticles() {
     const deleteResult = await persistenceRepository.article.delete({
       where: and(
         neq("delete_scheduled_at", null),
-        lt("delete_scheduled_at", currentTime)
+        lte("delete_scheduled_at", currentTime),
       ),
     });
 
     console.log(
-      `Successfully deleted ${deleteResult?.rowCount} expired articles`
+      `Successfully deleted ${deleteResult?.rowCount} expired articles`,
     );
 
     return {

src/backend/services/search.service.ts

@@ -71,7 +71,7 @@ export const syncArticleById = async (articleId: string) => {
 
     if (!article) {
       throw new Error(
-        `Article with ID ${articleId} not found or not published.`
+        `Article with ID ${articleId} not found or not published.`,
       );
     }
 
@@ -91,6 +91,7 @@ export const syncArticleById = async (articleId: string) => {
     console.error(`Error syncing article ${articleId}:`, error);
   }
 };
+
 export const deleteArticleById = async (articleId: string) => {
   try {
     const response = await index.deleteDocument(articleId);