Delete the entire recurring event or only the selected event

packages/api-client/lib/openapi/api.ts

@@ -321,6 +321,12 @@ export interface ApiServerModelsTortoiseModelsScheduledTaskScheduledTask {
    * @memberof ApiServerModelsTortoiseModelsScheduledTaskScheduledTask
    */
   last_ran?: string | null;
+  /**
+   *
+   * @type {any}
+   * @memberof ApiServerModelsTortoiseModelsScheduledTaskScheduledTask
+   */
+  except_dates?: any;
   /**
    *
    * @type {Array<ApiServerModelsTortoiseModelsScheduledTaskScheduledTaskScheduleLeaf>}
@@ -7340,6 +7346,60 @@ export class LiftsApi extends BaseAPI {
  */
 export const TasksApiAxiosParamCreator = function (configuration?: Configuration) {
   return {
+    /**
+     *
+     * @summary Del Scheduled Tasks Event
+     * @param {number} taskId
+     * @param {string} eventDate
+     * @param {*} [options] Override http request option.
+     * @throws {RequiredError}
+     */
+    delScheduledTasksEventScheduledTasksTaskIdClearPut: async (
+      taskId: number,
+      eventDate: string,
+      options: AxiosRequestConfig = {},
+    ): Promise<RequestArgs> => {
+      // verify required parameter 'taskId' is not null or undefined
+      assertParamExists('delScheduledTasksEventScheduledTasksTaskIdClearPut', 'taskId', taskId);
+      // verify required parameter 'eventDate' is not null or undefined
+      assertParamExists(
+        'delScheduledTasksEventScheduledTasksTaskIdClearPut',
+        'eventDate',
+        eventDate,
+      );
+      const localVarPath = `/scheduled_tasks/{task_id}/clear`.replace(
+        `{${'task_id'}}`,
+        encodeURIComponent(String(taskId)),
+      );
+      // use dummy base URL string because the URL constructor only accepts absolute URLs.
+      const localVarUrlObj = new URL(localVarPath, DUMMY_BASE_URL);
+      let baseOptions;
+      if (configuration) {
+        baseOptions = configuration.baseOptions;
+      }
+
+      const localVarRequestOptions = { method: 'PUT', ...baseOptions, ...options };
+      const localVarHeaderParameter = {} as any;
+      const localVarQueryParameter = {} as any;
+
+      if (eventDate !== undefined) {
+        localVarQueryParameter['event_date'] =
+          (eventDate as any) instanceof Date ? (eventDate as any).toISOString() : eventDate;
+      }
+
+      setSearchParams(localVarUrlObj, localVarQueryParameter);
+      let headersFromBaseOptions = baseOptions && baseOptions.headers ? baseOptions.headers : {};
+      localVarRequestOptions.headers = {
+        ...localVarHeaderParameter,
+        ...headersFromBaseOptions,
+        ...options.headers,
+      };
+
+      return {
+        url: toPathString(localVarUrlObj),
+        options: localVarRequestOptions,
+      };
+    },
     /**
      *
      * @summary Del Scheduled Tasks
@@ -8386,6 +8446,27 @@ export const TasksApiAxiosParamCreator = function (configuration?: Configuration
 export const TasksApiFp = function (configuration?: Configuration) {
   const localVarAxiosParamCreator = TasksApiAxiosParamCreator(configuration);
   return {
+    /**
+     *
+     * @summary Del Scheduled Tasks Event
+     * @param {number} taskId
+     * @param {string} eventDate
+     * @param {*} [options] Override http request option.
+     * @throws {RequiredError}
+     */
+    async delScheduledTasksEventScheduledTasksTaskIdClearPut(
+      taskId: number,
+      eventDate: string,
+      options?: AxiosRequestConfig,
+    ): Promise<(axios?: AxiosInstance, basePath?: string) => AxiosPromise<any>> {
+      const localVarAxiosArgs =
+        await localVarAxiosParamCreator.delScheduledTasksEventScheduledTasksTaskIdClearPut(
+          taskId,
+          eventDate,
+          options,
+        );
+      return createRequestFunction(localVarAxiosArgs, globalAxios, BASE_PATH, configuration);
+    },
     /**
      *
      * @summary Del Scheduled Tasks
@@ -8824,6 +8905,23 @@ export const TasksApiFactory = function (
 ) {
   const localVarFp = TasksApiFp(configuration);
   return {
+    /**
+     *
+     * @summary Del Scheduled Tasks Event
+     * @param {number} taskId
+     * @param {string} eventDate
+     * @param {*} [options] Override http request option.
+     * @throws {RequiredError}
+     */
+    delScheduledTasksEventScheduledTasksTaskIdClearPut(
+      taskId: number,
+      eventDate: string,
+      options?: any,
+    ): AxiosPromise<any> {
+      return localVarFp
+        .delScheduledTasksEventScheduledTasksTaskIdClearPut(taskId, eventDate, options)
+        .then((request) => request(axios, basePath));
+    },
     /**
      *
      * @summary Del Scheduled Tasks
@@ -9183,6 +9281,25 @@ export const TasksApiFactory = function (
  * @extends {BaseAPI}
  */
 export class TasksApi extends BaseAPI {
+  /**
+   *
+   * @summary Del Scheduled Tasks Event
+   * @param {number} taskId
+   * @param {string} eventDate
+   * @param {*} [options] Override http request option.
+   * @throws {RequiredError}
+   * @memberof TasksApi
+   */
+  public delScheduledTasksEventScheduledTasksTaskIdClearPut(
+    taskId: number,
+    eventDate: string,
+    options?: AxiosRequestConfig,
+  ) {
+    return TasksApiFp(this.configuration)
+      .delScheduledTasksEventScheduledTasksTaskIdClearPut(taskId, eventDate, options)
+      .then((request) => request(this.axios, this.basePath));
+  }
+
   /**
    *
    * @summary Del Scheduled Tasks

packages/api-client/lib/version.ts

@@ -3,6 +3,6 @@ import { version as rmfModelVer } from 'rmf-models';
 
 export const version = {
   rmfModels: rmfModelVer,
-  rmfServer: '0aa093dff56cb468ad8d8e51f28b930fe88492d9',
+  rmfServer: 'c8c43e395caae7ccc858008b7663d30914b2cc62',
   openapiGenerator: '6.2.1',
 };

packages/api-client/schema/index.ts

@@ -1250,6 +1250,39 @@ export default {
         },
       },
     },
+    '/scheduled_tasks/{task_id}/clear': {
+      put: {
+        tags: ['Tasks'],
+        summary: 'Del Scheduled Tasks Event',
+        operationId: 'del_scheduled_tasks_event_scheduled_tasks__task_id__clear_put',
+        parameters: [
+          {
+            required: true,
+            schema: { title: 'Task Id', type: 'integer' },
+            name: 'task_id',
+            in: 'path',
+          },
+          {
+            required: true,
+            schema: { title: 'Event Date', type: 'string', format: 'date-time' },
+            name: 'event_date',
+            in: 'query',
+          },
+        ],
+        responses: {
+          '200': {
+            description: 'Successful Response',
+            content: { 'application/json': { schema: {} } },
+          },
+          '422': {
+            description: 'Validation Error',
+            content: {
+              'application/json': { schema: { $ref: '#/components/schemas/HTTPValidationError' } },
+            },
+          },
+        },
+      },
+    },
     '/favorite_tasks': {
       get: {
         tags: ['Tasks'],
@@ -3669,6 +3702,7 @@ export default {
           task_request: { title: 'Task Request' },
           created_by: { title: 'Created By', maxLength: 255, type: 'string' },
           last_ran: { title: 'Last Ran', type: 'string', format: 'date-time', nullable: true },
+          except_dates: { title: 'Except Dates' },
           schedules: {
             title: 'Schedules',
             type: 'array',

packages/api-server/api_server/models/tortoise_models/scheduled_task.py

@@ -28,6 +28,7 @@ class ScheduledTask(Model):
     created_by = CharField(255)
     schedules: ReverseRelation["ScheduledTaskSchedule"]
     last_ran: Optional[datetime] = DatetimeField(null=True)
+    except_dates = JSONField(null=True, default=list)
 
 
 class ScheduledTaskSchedule(Model):

packages/api-server/api_server/routes/tasks/scheduled_tasks.py

@@ -25,6 +25,10 @@ class PostScheduledTaskRequest(BaseModel):
     schedules: list[ttm.ScheduledTaskSchedulePydantic]
 
 
+def datetime_to_date_format(date: datetime) -> str:
+    return date.date().strftime("%m/%d/%Y").lstrip("0")
+
+
 async def schedule_task(task: ttm.ScheduledTask, task_repo: TaskRepository):
     await task.fetch_related("schedules")
     jobs: list[tuple[ttm.ScheduledTaskSchedule, schedule.Job]] = []
@@ -49,6 +53,8 @@ async def run():
 
     def do():
         logger.info(f"starting task {task.pk}")
+        if datetime_to_date_format(datetime.now()) in task.except_dates:
+            return
         asyncio.get_event_loop().create_task(run())
 
     for _, j in jobs:
@@ -129,6 +135,25 @@ async def get_scheduled_task(task_id: int) -> ttm.ScheduledTask:
     return task
 
 
+@router.put("/{task_id}/clear")
+async def del_scheduled_tasks_event(
+    task_id: int,
+    event_date: datetime,
+    task_repo: TaskRepository = Depends(task_repo_dep),
+):
+    task = await get_scheduled_task(task_id)
+    if task is None:
+        raise HTTPException(404)
+
+    task.except_dates.append(datetime_to_date_format(event_date))
+    await task.save()
+
+    for sche in task.schedules:
+        schedule.clear(sche.get_id())
+
+    await schedule_task(task, task_repo)
+
+
 @router.delete("/{task_id}")
 async def del_scheduled_tasks(task_id: int):
     async with tortoise.transactions.in_transaction():