Implement the rest of the jobs utility methods.

Signed-off-by: Alexander Trauzzi <[email protected]>

Author: atrauzzi

src/implementation/Client/HTTPClient/jobs.ts

@@ -11,20 +11,15 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
-import IClientJobs, { JobSchedule } from "../../../interfaces/Client/IClientJobs";
+import IClientJobs from "../../../interfaces/Client/IClientJobs";
 import HTTPClient from "./HTTPClient";
-import { Logger } from "../../../logger/Logger";
 import { THTTPExecuteParams } from "../../../types/http/THTTPExecuteParams.type";
+import { Job } from "../../../types/jobs/Job.type";
+import { JobSchedule } from "../../../types/jobs/JobSchedule.type";
 
 export default class HTTPClientJobs implements IClientJobs {
 
-    private readonly logger: Logger;
-    private readonly httpClient: HTTPClient;
-
-    constructor(httpClient: HTTPClient) {
-        this.logger = new Logger("HTTPClient", "Jobs", httpClient.options.logger);
-        this.httpClient = httpClient;
-    }
+    constructor(private readonly httpClient: HTTPClient) {}
 
     async schedule(
         jobName: string,
@@ -35,35 +30,47 @@ export default class HTTPClientJobs implements IClientJobs {
         ttl: string | null = null
     ): Promise<void> {
 
-        try {
-            await this.httpClient.executeWithApiVersion(
-                "v1.0-alpha1",
-                `/jobs/${jobName}`,
-                {
-                    method: "POST",
-                    body: {
-                        data,
-                        schedule,
-                        dueTime,
-                        repeats,
-                        ttl,
-                    },
-                    headers: {
-                        "content-type": "application/json",
-                    },
-                } as THTTPExecuteParams
-            );
-        }
-        catch (e: any) {
-            this.logger.error(e);
-        }
+        await this.httpClient.executeWithApiVersion(
+            "v1.0-alpha1",
+            `/jobs/${jobName}`,
+            {
+                method: "POST",
+                body: {
+                    data,
+                    schedule,
+                    dueTime,
+                    repeats,
+                    ttl,
+                },
+                headers: {
+                    "content-type": "application/json",
+                },
+            } as THTTPExecuteParams
+        );
     }
 
-    get(): Promise<unknown> {
-        throw new Error("Not yet!");
+    async get(jobName: string): Promise<Job>;
+    async get<DataType>(jobName: string): Promise<Job<DataType>> {
+
+        const result = await this.httpClient.executeWithApiVersion(
+            "v1.0-alpha1",
+            `/jobs/${jobName}`,
+            {
+                method: "GET",
+            }
+        );
+
+        return result as Job<DataType>;
     }
 
-    delete(): Promise<unknown> {
-        throw new Error("Not yet!");
+    async delete(jobName: string): Promise<void> {
+
+        await this.httpClient.executeWithApiVersion(
+            "v1.0-alpha1",
+            `/jobs/${jobName}`,
+            {
+                method: "DELETE"
+            }
+        );
     }
 }

src/interfaces/Client/IClientJobs.ts

@@ -11,22 +11,8 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
-export enum FixedPeriod {
-    Yearly = "@yearly",
-    Monthly = "@monthly",
-    Weekly = "@weekly",
-    Daily = "@daily",
-    Hourly = "@hourly"
-}
-
-// note: This can get pretty crazy, more than TS can really handle.
-type SystemDCronExpression = `${string} ${string} ${string} ${string} ${string} ${string}`;
-
-type EveryPeriod = `@every ${string}`;
-
-type Schedule = FixedPeriod | EveryPeriod | SystemDCronExpression;
-
-export type JobSchedule = Schedule;
+import { JobSchedule } from "../../types/jobs/JobSchedule.type";
+import { Job } from "../../types/jobs/Job.type";
 
 export default interface IClientJobs {
 
@@ -38,6 +24,6 @@ export default interface IClientJobs {
         repeats: number | null,
         ttl: string | null
     ): Promise<void>;
-    get(): Promise<unknown>;
-    delete(): Promise<unknown>;
+    get(jobName: string): Promise<Job>;
+    delete(jobName: string): Promise<void>;
 }

src/types/jobs/Job.type.ts

@@ -0,0 +1,22 @@
+/*
+Copyright 2025 The Dapr Authors
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+import { JobSchedule } from "./JobSchedule.type";
+
+export interface Job<DataType = object | string> {
+    name: string;
+    schedule: JobSchedule;
+    data: {
+        value: DataType,
+    };
+}

src/types/jobs/JobSchedule.type.ts

@@ -0,0 +1,29 @@
+/*
+Copyright 2025 The Dapr Authors
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+export enum FixedPeriod {
+    Yearly = "@yearly",
+    Monthly = "@monthly",
+    Weekly = "@weekly",
+    Daily = "@daily",
+    Hourly = "@hourly"
+}
+
+type EveryPeriod = `@every ${string}`;
+
+// note: This can get crazy, more than TS can really handle.
+type SystemDCronExpression = `${string} ${string} ${string} ${string} ${string} ${string}`;
+
+type Schedule = FixedPeriod | EveryPeriod | SystemDCronExpression;
+
+export type JobSchedule = Schedule;