add job.remote()

Author: wangzuo

README.md

@@ -81,7 +81,7 @@ const job = load({
 To serialize a job to a JSON object, use the `dump` method:
 
 ```ts
-const obj = await job.dump();
+const payload = job.dump();
 ```
 
 This allows you to save the job's state for later use, such as storing it in a queue or database.
@@ -90,7 +90,7 @@ To recreate and execute a job from the JSON object, use the `load` function:
 ```ts
 import { load } from "fluent-ai";
 
-const job = load(obj);
+const job = load(payload);
 await job.run();
 ```
 

examples/openai-chat-remote.ts

@@ -0,0 +1,8 @@
+import { openai, userPrompt } from "../src";
+
+const job = openai()
+  .chat("gpt-4o-mini")
+  .messages([{ role: "user", content: "generate a 50 words text" }])
+  .stream();
+
+const stream = await job.remote();

src/jobs/job.ts

@@ -1,6 +1,7 @@
 import { z } from "zod";
 import zodToJsonSchema from "zod-to-json-schema";
 import { version } from "../../package.json";
+import { runRemoteJob, type JobRemoteOptions } from "./remote";
 
 export const providerSchema = z.enum([
   "anthropic",
@@ -282,6 +283,11 @@ export class Job {
     return await this.handleResponse!(response);
   }
 
+  async remote(options?: JobRemoteOptions) {
+    const payload = this.dump() as AIJob;
+    return runRemoteJob(payload, options);
+  }
+
   dump() {
     return {
       version: version,

src/jobs/remote.ts

@@ -0,0 +1,28 @@
+import type { AIJob } from "./job";
+import { version } from "../../package.json";
+
+export interface JobRemoteOptions {
+  apiKey?: string;
+  baseURL?: string;
+}
+
+export async function runRemoteJob(payload: AIJob, options?: JobRemoteOptions) {
+  options = options || {};
+  options.apiKey = options.apiKey || process.env.FLUENT_API_KEY;
+  const baseURL = options.baseURL || "http://localhost:5173/api";
+
+  // TODO: add more api types
+  const job: { id: string; stream: boolean } = await fetch(`${baseURL}/jobs`, {
+    method: "POST",
+    headers: {
+      "Content-Type": "application/json",
+      "User-Agent": `fluent-ai/${version}`,
+      Authorization: `Bearer ${options?.apiKey}`,
+    },
+    body: JSON.stringify(payload),
+  }).then((r) => r.json());
+
+  console.log("created", job);
+
+  const stream = await fetch(`${baseURL}/jobs/${job.id}/stream`);
+}