Edits history of script submission #22268 for ' Translate Text (nextcloud)'

• bun

  Ap­pro­ved version

  Edit in Windmill

  Embed

  import createClient, { type Middleware } from "openapi-fetch";
  
  type Nextcloud = {
    baseUrl: string,
    userId: string,
    token: string
  };
  
  const TASK_TYPE_TRANSLATE = "core:text2text:translate";
  const POLL_INTERVAL_MS = 1000;
  const DEFAULT_POLL_TIMEOUT_MS = 600_000; // 10 minutes (ensure one cron job finished)
  
  /**
   * Creates a translation task via the Nextcloud OCS Task Processing API,
   * polls until the task completes, and returns the translated text.
   */
  export async function main(
    ncResource: Nextcloud,
    text: string,
    targetLanguage: string,
    originLanguage: string | null = null,
    model: string | null = null,
    timeout_ms: number = DEFAULT_POLL_TIMEOUT_MS,
    interval_ms: number = POLL_INTERVAL_MS,
  ) {
    const client = createClient({ baseUrl: ncResource.baseUrl }) as any;
    const authMiddleware: Middleware = {
      async onRequest({ request, options }) {
        request.headers.set("Authorization", `Basic ${btoa(ncResource.userId + ':' + ncResource.token)}`);
        return request;
      },
    };
    client.use(authMiddleware);
  
    const input: Record<string, string> = {
      input: text,
      target_language: targetLanguage,
    };
    if (originLanguage !== null && originLanguage !== "") {
      input.origin_language = originLanguage;
    }
    if (model !== null && model !== "") {
      input.model = model
    }
  
    // Schedule the translation task
    const { data: scheduleData, error: scheduleError } = await client.POST(
      "/ocs/v2.php/taskprocessing/schedule",
      {
        params: {
          header: {
            "OCS-APIRequest": true,
          },
          query: {
            format: "json",
          },
        },
        body: {
          type: TASK_TYPE_TRANSLATE,
          input,
          appId: "windmill",
        },
      },
    );
  
    if (scheduleError) {
      throw new Error(`Failed to schedule translation task: ${JSON.stringify(scheduleError)}`);
    }
    const taskId = scheduleData?.ocs?.data?.task?.id;
  
    // Polls every interval until timeout or a result happens
    const deadline = Date.now() + timeout_ms;
    while (Date.now() < deadline) {
      console.log("Polling task output")
      const { data: taskData, error: taskError } = await client.GET(
        "/ocs/v2.php/taskprocessing/task/{id}",
        {
          params: {
            header: {
              "OCS-APIRequest": true,
            },
            query: {
              format: "json",
            },
            path: {
              id: taskId,
            },
          },
        },
      );
  
      if (taskError) {
        throw new Error(`Failed to get task ${taskId}: ${JSON.stringify(taskError)}`);
      }
      const task = taskData.ocs?.data?.task;
      const status = task.status;
  
      if (status === "STATUS_SUCCESSFUL") {
        const output = task.output;
        if (output && typeof output.output === "string") {
          return { translatedText: output.output, taskId };
        }
        return { translatedText: output, taskId };
      }
  
      if (status === "STATUS_FAILED" || status === "STATUS_CANCELLED") {
        const msg = JSON.stringify(task);
        throw new Error(`Translation task failed: ${msg}`);
      }
      if (!["STATUS_SCHEDULED", "STATUS_RUNNING"].includes(status)) {
        const msg = JSON.stringify(task);
        throw new Error(`Translation task failed with unknown status: ${msg}`)
      }
      await new Promise((r) => setTimeout(r, interval_ms));
    }
  
    throw new Error(
      `Translation task did not complete within ${timeout_ms}ms (taskId: ${taskId})`,
    );
  }
  

  Submitted by nextcloud 17 days ago