fixes

Author: Chetan11-dev

.gitignore

@@ -42,3 +42,4 @@ _todo_update/
 botasaurus/botasaurus_storage.json
 bota/src/bota/package_storage.json
 FUTURE.md
+.history/

docs/docs/botasaurus-desktop/botasaurus-desktop-api/adding-domain-and-ssl.md

@@ -53,12 +53,12 @@ The process involves two main steps:
 
    I use Porkbun because:
    - Unlike Cloudflare Domains, which is primarily a CDN provider, Porkbun specializes in domain registration. I want a specialist to manage my domains.
-   - It offers automatic renewals.
+   <!-- - It offers automatic renewals. -->
    - It sends multiple renewal reminders (45 days and 30 days before expiry), so I don't forget to renew my domains.
 
    ![Porkbun Renewal Emails](https://raw.githubusercontent.com/omkarcloud/botasaurus/master/images/domains/porkbun-renewal-emails.png)
 
-   Also, Porkbun's logo and branding are funny, nevertheless they provide a good experience and are [highly rated on Trustpilot.](https://www.trustpilot.com/review/porkbun.com)
+   <!-- Also, Porkbun's logo and branding are funny, nevertheless they provide a good experience and are [highly rated on Trustpilot.](https://www.trustpilot.com/review/porkbun.com) -->
 
 2. Next, log in to your domain registrar and create DNS **A records** pointing to your VM's IP address.
 

js/botasaurus-desktop-api/src/index.ts

@@ -291,14 +291,15 @@ const api = new Api({ apiUrl: 'https://example.com' })`);
         }
     }
 
-    async getTasks({ page = 1, perPage, withResults = false, parentTaskId }: { page?: number; perPage?: number; withResults?: boolean; parentTaskId?: number } = { page: 1, withResults: true }): Promise<PaginatedResponse<Task>> {
+    async getTasks({ page = 1, perPage, withResults = false, parentTaskId, status }: { page?: number; perPage?: number; withResults?: boolean; parentTaskId?: number; status?: string } = { page: 1, withResults: true }): Promise<PaginatedResponse<Task>> {
         /**
          * Fetches tasks from the server, with optional result inclusion, pagination, and filtering.
          *
          * @param page The page number for pagination.
          * @param perPage The number of tasks to return per page.
          * @param withResults Whether to include the task results in the response.
          * @param parentTaskId Filter tasks by parent task ID.
+         * @param status Filter tasks by status (pending, in_progress, completed, failed, aborted).
          * @return A dictionary containing the task results and pagination information.
          */
         const url = this._makeApiUrl("tasks");
@@ -308,6 +309,7 @@ const api = new Api({ apiUrl: 'https://example.com' })`);
         if (page !== undefined && page !== null) params.page = page;
         if (perPage !== undefined && perPage !== null) params.per_page = perPage;
         if (parentTaskId !== undefined && parentTaskId !== null) params.parent_task_id = parentTaskId;
+        if (status !== undefined && status !== null) params.status = status;
         try {
             const response = await axios.get(url, { params });
 
@@ -333,6 +335,10 @@ const api = new Api({ apiUrl: 'https://example.com' })`);
         }
     }
 
+    async getFailedTasks({ page = 1, perPage, withResults = false, parentTaskId }: { page?: number; perPage?: number; withResults?: boolean; parentTaskId?: number } = { page: 1, withResults: true }): Promise<PaginatedResponse<Task>> {
+        return this.getTasks({ page, perPage, withResults, parentTaskId, status: 'failed' });
+    }
+
     async getTask(taskId: number): Promise<Task> {
         /**
          * Retrieves a specific task by ID.
@@ -572,4 +578,26 @@ const api = new Api({ apiUrl: 'https://example.com' })`);
             throw error;
         }
     }
+
+    async retryTasks({ taskIds }: { taskIds: number[] }): Promise<OkResponse> {
+        /**
+         * Bulk retries failed tasks.
+         *
+         * @param taskIds A list of task IDs to be retried.
+         * @return A success message.
+         */
+        const url = this._makeApiUrl("tasks/bulk-retry");
+        const payload = { task_ids: taskIds };
+        try {
+            const response = await axios.post(url, payload);
+
+            this._writeJson("retry_tasks", response.data);
+            return response.data;
+        } catch (error) {
+            if (axios.isAxiosError(error)) {
+                raiseIfBadException(error.response as AxiosResponse);
+            }
+            throw error;
+        }
+    }
 }

js/botasaurus-server-js/src/api-config.ts

@@ -10,6 +10,7 @@ import {
     deleteSingleTask,
     bulkAbortTasks,
     bulkDeleteTasks,
+    bulkRetryTasks,
     getAppProps,
     isAnyTaskUpdated,
     isTaskUpdated,
@@ -605,6 +606,12 @@ export function buildApp(
         return result;
     });
 
+    app.post(`${apiBasePath}/tasks/bulk-retry`, async (request, _) => {
+        const jsonData = request.body;
+        const result = await bulkRetryTasks(jsonData);
+        return result;
+    });
+
     app.get(`${apiBasePath}/ui/app-props`, getAppProps);
 
     app.post(

js/botasaurus-server-js/src/routes-db-logic.ts

@@ -99,10 +99,13 @@ async function queryTasks(
   page?: any,
   per_page?: any,
   serializer: (task: any, withResults: boolean) => Promise<any> = serializeTask,
-  parent_task_id?: number | null
+  parent_task_id?: number | null,
+  status?: string | null
 ): Promise<any> {
   const projectionFields = createProjection(ets);
-  const queryFilter = isNotNullish(parent_task_id) ? { parent_task_id } : {};
+  const queryFilter: Record<string, any> = {};
+  if (isNotNullish(parent_task_id)) queryFilter.parent_task_id = parent_task_id;
+  if (status) queryFilter.status = status;
   const total_count = await wrapDbOperationInPromise((cb:any) => db.count(queryFilter, cb));
 
   if (isNullish(per_page)) {
@@ -689,7 +692,14 @@ async function executeGetTasks(queryParams: Record<string, any>): Promise<any> {
     }
   }
 
-  return queryTasks(getEts(), withResults, page, per_page, serializeTask, parent_task_id);
+  const status = queryParams.status;
+  if (isNotNullish(status) && ![TaskStatus.PENDING, TaskStatus.IN_PROGRESS, TaskStatus.COMPLETED, TaskStatus.FAILED, TaskStatus.ABORTED].includes(status)) {
+    throw new JsonHTTPResponseWithMessage(
+      `Invalid 'status' parameter value: "${status}". It must be one of: pending, in_progress, completed, failed, aborted.`
+    );
+  }
+
+  return queryTasks(getEts(), withResults, page, per_page, serializeTask, parent_task_id, status);
 }
 
   function isValidAllTasks(tasks: any[]): boolean {
@@ -1066,7 +1076,7 @@ function convertUnicodeDictToAsciiDictInPlace(inputList: any[]): any[] {
     // Only abort tasks that are in PENDING or IN_PROGRESS status
     const abortableStatuses: string[] = [TaskStatus.PENDING, TaskStatus.IN_PROGRESS];
     if (!abortableStatuses.includes(status)) {
-      // return;
+      return;
     }
 
     let fn: (() => Promise<void>) | null = null;