Implement registration.

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

Author: atrauzzi

src/implementation/Client/HTTPClient/jobs.ts

@@ -11,23 +11,58 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
-import IClientJobs from "../../../interfaces/Client/IClientJobs";
+import IClientJobs, { JobSchedule } from "../../../interfaces/Client/IClientJobs";
 import HTTPClient from "./HTTPClient";
+import { Logger } from "../../../logger/Logger";
+import { THTTPExecuteParams } from "../../../types/http/THTTPExecuteParams.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;
     }
 
-    schedule(): Promise<unknown> {
-        throw new Error("Not yet!");
+    async schedule(
+        jobName: string,
+        data: object | string,
+        schedule: JobSchedule | null = null,
+        dueTime: string | Date | null = null,
+        repeats: number | null = null,
+        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);
+        }
     }
+
     get(): Promise<unknown> {
         throw new Error("Not yet!");
     }
+
     delete(): Promise<unknown> {
         throw new Error("Not yet!");
     }

src/implementation/Server/HTTPServer/jobs.ts

@@ -14,6 +14,7 @@ limitations under the License.
 import IServerJobs from "../../../interfaces/Server/IServerJobs";
 import HTTPServer from "./HTTPServer";
 import { Logger } from "../../../logger/Logger";
+import { TypeDaprJobsCallback } from "../../../types/DaprJobsCallback.type";
 
 export default class HTTPServerJobs implements IServerJobs {
 
@@ -25,9 +26,7 @@ export default class HTTPServerJobs implements IServerJobs {
         this.httpServer = httpServer;
     }
 
-    listen(): Promise<unknown> {
-
-        // this.httpServer.server.post();
-
+    listen(jobName: string, callback: TypeDaprJobsCallback): void {
+        this.httpServer.getServer().post(`/job/${jobName}`, callback);
     }
 }

src/interfaces/Client/IClientJobs.ts

@@ -11,10 +11,33 @@ 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;
+
 export default interface IClientJobs {
 
-    schedule(): Promise<unknown>;
+    schedule(
+        jobName: string,
+        data: object | string,
+        schedule: JobSchedule | null,
+        dueTime: string | Date | null,
+        repeats: number | null,
+        ttl: string | null
+    ): Promise<void>;
     get(): Promise<unknown>;
     delete(): Promise<unknown>;
-
 }

src/interfaces/Server/IServerJobs.ts

@@ -11,8 +11,10 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
+import { TypeDaprJobsCallback } from "../../types/DaprJobsCallback.type";
+
 export default interface IServerJobs {
 
-    listen(): Promise<unknown>;
+    listen(jobName: string, callback: TypeDaprJobsCallback): void;
 
 }

src/types/DaprJobsCallback.type.ts

@@ -0,0 +1,14 @@
+/*
+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 type TypeDaprJobsCallback = (data: any, headers: object) => Promise<any | void>;