Rough-in the contracts.

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

Author: atrauzzi

src/implementation/Client/DaprClient.ts

@@ -26,6 +26,7 @@ import IClientSecret from "../../interfaces/Client/IClientSecret";
 import IClientSidecar from "../../interfaces/Client/IClientSidecar";
 import IClientState from "../../interfaces/Client/IClientState";
 import IClientWorkflow from "../../interfaces/Client/IClientWorkflow";
+import IClientJobs from "../../interfaces/Client/IClientJobs";
 
 import GRPCClient from "./GRPCClient/GRPCClient";
 import GRPCClientActor from "./GRPCClient/actor";
@@ -41,6 +42,7 @@ import GRPCClientSecret from "./GRPCClient/secret";
 import GRPCClientSidecar from "./GRPCClient/sidecar";
 import GRPCClientState from "./GRPCClient/state";
 import GRPCClientWorkflow from "./GRPCClient/workflow";
+import GRPCClientJobs from "./GRPCClient/jobs";
 
 import HTTPClient from "./HTTPClient/HTTPClient";
 import HTTPClientActor from "./HTTPClient/actor";
@@ -57,6 +59,7 @@ import HTTPClientSecret from "./HTTPClient/secret";
 import HTTPClientSidecar from "./HTTPClient/sidecar";
 import HTTPClientState from "./HTTPClient/state";
 import HTTPClientWorkflow from "./HTTPClient/workflow";
+import HTTPClientJobs from "./HTTPClient/jobs";
 
 import CommunicationProtocolEnum from "../../enum/CommunicationProtocol.enum";
 import { DaprClientOptions } from "../../types/DaprClientOptions";
@@ -83,6 +86,7 @@ export default class DaprClient {
   readonly sidecar: IClientSidecar;
   readonly state: IClientState;
   readonly workflow: IClientWorkflow;
+  readonly jobs: IClientJobs;
 
   private readonly logger: Logger;
 
@@ -119,6 +123,7 @@ export default class DaprClient {
         this.crypto = new GRPCClientCrypto(client);
         this.actor = new GRPCClientActor(client); // we use an abstractor here since we interface through a builder with the Actor Runtime
         this.workflow = new GRPCClientWorkflow(client);
+        this.jobs = new GRPCClientJobs(client);
         break;
       }
       case CommunicationProtocolEnum.HTTP:
@@ -140,6 +145,7 @@ export default class DaprClient {
         this.sidecar = new HTTPClientSidecar(client);
         this.state = new HTTPClientState(client);
         this.workflow = new HTTPClientWorkflow(client);
+        this.jobs = new HTTPClientJobs(client);
         break;
       }
     }

src/implementation/Client/GRPCClient/jobs.ts

@@ -0,0 +1,35 @@
+/*
+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 IClientJobs from "../../../interfaces/Client/IClientJobs";
+import GRPCClient from "./GRPCClient";
+
+
+export default class GRPCClientJobs implements IClientJobs {
+
+    private readonly grpcClient: GRPCClient;
+
+    constructor(grpcClient: GRPCClient) {
+        this.grpcClient = grpcClient;
+    }
+
+    schedule(): Promise<unknown> {
+        throw new Error("Not yet!");
+    }
+    get(): Promise<unknown> {
+        throw new Error("Not yet!");
+    }
+    delete(): Promise<unknown> {
+        throw new Error("Not yet!");
+    }
+}

src/implementation/Client/HTTPClient/jobs.ts

@@ -0,0 +1,34 @@
+/*
+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 IClientJobs from "../../../interfaces/Client/IClientJobs";
+import HTTPClient from "./HTTPClient";
+
+export default class HTTPClientJobs implements IClientJobs {
+
+    private readonly httpClient: HTTPClient;
+
+    constructor(httpClient: HTTPClient) {
+        this.httpClient = httpClient;
+    }
+
+    schedule(): Promise<unknown> {
+        throw new Error("Not yet!");
+    }
+    get(): Promise<unknown> {
+        throw new Error("Not yet!");
+    }
+    delete(): Promise<unknown> {
+        throw new Error("Not yet!");
+    }
+}

src/implementation/Server/DaprServer.ts

@@ -16,24 +16,30 @@ import IServerPubSub from "../../interfaces/Server/IServerPubSub";
 import IServerBinding from "../../interfaces/Server/IServerBinding";
 import IServerInvoker from "../../interfaces/Server/IServerInvoker";
 import IServerActor from "../../interfaces/Server/IServerActor";
+import IServerJobs from "../../interfaces/Server/IServerJobs";
 
 import CommunicationProtocolEnum from "../../enum/CommunicationProtocol.enum";
 import GRPCServer from "./GRPCServer/GRPCServer";
 import GRPCServerPubSub from "./GRPCServer/pubsub";
 import GRPCServerBinding from "./GRPCServer/binding";
 import GRPCServerInvoker from "./GRPCServer/invoker";
 import GRPCServerActor from "./GRPCServer/actor";
+import GRPCServerJobs from "./GRPCServer/jobs";
 
 import HTTPServer from "./HTTPServer/HTTPServer";
 import HTTPServerPubSub from "./HTTPServer/pubsub";
 import HTTPServerBinding from "./HTTPServer/binding";
 import HTTPServerInvoker from "./HTTPServer/invoker";
 import HTTPServerActor from "./HTTPServer/actor";
+import HTTPServerJobs from "./HTTPServer/jobs";
+
 import { Settings } from "../../utils/Settings.util";
 import { DaprServerOptions } from "../../types/DaprServerOptions";
 import DaprClient from "../Client/DaprClient";
 import { getClientOptions } from "../../utils/Client.util";
 
+
+
 export default class DaprServer {
   // App details
   private readonly serverOptions: DaprServerOptions;
@@ -43,6 +49,7 @@ export default class DaprServer {
   readonly binding: IServerBinding;
   readonly invoker: IServerInvoker;
   readonly actor: IServerActor;
+  readonly jobs: IServerJobs;
   readonly client: DaprClient;
 
   constructor(serverOptions: Partial<DaprServerOptions> = {}) {
@@ -90,6 +97,7 @@ export default class DaprServer {
         this.binding = new GRPCServerBinding(server);
         this.invoker = new GRPCServerInvoker(server);
         this.actor = new GRPCServerActor(server);
+        this.jobs = new GRPCServerJobs(server);
         break;
       }
       case CommunicationProtocolEnum.HTTP:
@@ -101,6 +109,7 @@ export default class DaprServer {
         this.binding = new HTTPServerBinding(server);
         this.invoker = new HTTPServerInvoker(server);
         this.actor = new HTTPServerActor(server, this.client);
+        this.jobs = new HTTPServerJobs(server);
         break;
       }
     }

src/implementation/Server/GRPCServer/jobs.ts

@@ -0,0 +1,28 @@
+/*
+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 IServerJobs from "../../../interfaces/Server/IServerJobs";
+import GRPCServer from "./GRPCServer";
+
+export default class GRPCServerJobs implements IServerJobs {
+
+    private readonly server: GRPCServer;
+
+    constructor(server: GRPCServer) {
+        this.server = server;
+    }
+
+    listen(): Promise<unknown> {
+        throw new Error("Not yet!");
+    }
+}

src/implementation/Server/HTTPServer/jobs.ts

@@ -0,0 +1,33 @@
+/*
+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 IServerJobs from "../../../interfaces/Server/IServerJobs";
+import HTTPServer from "./HTTPServer";
+import { Logger } from "../../../logger/Logger";
+
+export default class HTTPServerJobs implements IServerJobs {
+
+    private readonly httpServer: HTTPServer;
+    private readonly logger: Logger;
+
+    constructor(httpServer: HTTPServer) {
+        this.logger = new Logger("HTTPServer", "Jobs", httpServer.client.options.logger);
+        this.httpServer = httpServer;
+    }
+
+    listen(): Promise<unknown> {
+
+        // this.httpServer.server.post();
+
+    }
+}

src/interfaces/Client/IClientJobs.ts

@@ -0,0 +1,20 @@
+/*
+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 default interface IClientJobs {
+
+    schedule(): Promise<unknown>;
+    get(): Promise<unknown>;
+    delete(): Promise<unknown>;
+
+}

src/interfaces/Server/IServerJobs.ts

@@ -0,0 +1,18 @@
+/*
+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 default interface IServerJobs {
+
+    listen(): Promise<unknown>;
+
+}