Script 'Schedule a TaskProcessing AI task in Nextcloud' for nextcloud

Schedule a TaskProcessing AI task in Nextcloud Approval

Verified

This must be added as an approval script

Created by marcel klehr12 140 days ago Viewed 731 times

Submitted by nextcloud Bun

Verified 13 days ago

All edits

Permalink

// This must be an approval script!

import * as wmill from "windmill-client";
import createClient, { type Middleware } from "openapi-fetch";

type Nextcloud = {
  baseUrl: string,
  password: string,
  username: string
};

export async function main(
  ncResource: Nextcloud,
  userId: string | null = null,
  taskType: string,
  input: object,
  useAppApiAuth: boolean = false,
) {

  const client = createClient<paths>({ baseUrl: ncResource.baseUrl });
  const authMiddleware: Middleware = {
    async onRequest({ request, options }) {
      // fetch token, if it doesn’t exist
      // add Authorization header to every request
      request.headers.set("Authorization", `Basic ${btoa((userId || ncResource.username) + ':' + ncResource.password)}`);
      if (useAppApiAuth) {
        request.headers.set("AA-VERSION", "2.3.0",);
        request.headers.set("EX-APP-ID", "flow",);
        request.headers.set("EX-APP-VERSION", "1.0.1",);
        request.headers.set("AUTHORIZATION-APP-API", btoa(
          `${userId || ncResource.username}:${ncResource.password}`,
        ));
      }
      return request;
    },
  };
  client.use(authMiddleware);

  const resumeUrls = await wmill.getResumeUrls()

  const res = await client.POST("/ocs/v2.php/taskprocessing/schedule", {
    params: {
      header: {
        "OCS-APIRequest": true,
      },
      query: {
        format: "json",
      },

    },
    body: {
      type: taskType,
      input: input,
      appId: 'windmill',
      webhookUri: resumeUrls.resume,
      webhookMethod: 'HTTP:POST',
    }
  });
  return {
    urls: resumeUrls,
    task: await res.data,
  }
}

Other submissions

Submitted by marcel klehr12 Deno

Created 140 days ago

All edits

Permalink

import * as wmill from "npm:windmill-client@1";
import * as nc from "https://raw.githubusercontent.com/marcelklehr/nextcloud-client-deno/c57692db56e9292b252c9b8aca7516753881409c/core/index.ts";

// fill the type, or use the +Resource type to get a type-safe reference to a resource
// type Postgresql = object

export async function main(
  nextcloudResource: string,
  userId: string | null = null,
  taskType: string,
  input: object,
  useAppApiAuth: boolean = false,
) {
  const ncResource = await wmill.getResource(
    nextcloudResource,
  );
  const config = new nc.Configuration({
    username: userId || ncResource.username,
    password: ncResource.password,
    basePath: ncResource.baseUrl,
    middleware: [{
      async pre(context) {
        if (!context.url.includes("?")) {
          context.url += "?";
        } else {
          context.url += "&";
        }
        context.url += "format=json";
        return context;
      },
    }],
    ...(useAppApiAuth && ({
      headers: {
        "AA-VERSION": "2.3.0",
        "EX-APP-ID": "windmill_app",
        "EX-APP-VERSION": "1.0.0",
        "AUTHORIZATION-APP-API": btoa(
          `${userId || ncResource.username}:${ncResource.password}`,
        ),
      },
    })),
  });
  const api = new nc.TaskProcessingApiApi(config);

  const resumeUrls = await wmill.getResumeUrls()

  const res = await api.taskProcessingApiScheduleRaw({
    taskProcessingApiScheduleRequest: {
      type: taskType,
      input,
      appId: 'windmill',
      webhookUri: resumeUrls.resume,
      webhookMethod: 'HTTP:POST',
    },
    oCSAPIRequest: true,
  });
  return {
    urls: resumeUrls,
    task: await res.raw.json()
  }
}



`1`	`// This must be an approval script!`
`2`
`3`	`import * as wmill from "windmill-client";`
`4`	`import createClient, { type Middleware } from "openapi-fetch";`
`5`
`6`	`type Nextcloud = {`
`7`	`baseUrl: string,`
`8`	`password: string,`
`9`	`username: string`
`10`	`};`
`11`
`12`	`export async function main(`
`13`	`ncResource: Nextcloud,`
`14`	`userId: string \| null = null,`
`15`	`taskType: string,`
`16`	`input: object,`
`17`	`useAppApiAuth: boolean = false,`
`18`	`) {`
`19`
`20`	`const client = createClient<paths>({ baseUrl: ncResource.baseUrl });`
`21`	`const authMiddleware: Middleware = {`
`22`	`async onRequest({ request, options }) {`
`23`	`// fetch token, if it doesn’t exist`
`24`	`// add Authorization header to every request`
`25`	request.headers.set("Authorization", `Basic ${btoa((userId \|\| ncResource.username) + ':' + ncResource.password)}`);
`26`	`if (useAppApiAuth) {`
`27`	`request.headers.set("AA-VERSION", "2.3.0",);`
`28`	`request.headers.set("EX-APP-ID", "flow",);`
`29`	`request.headers.set("EX-APP-VERSION", "1.0.1",);`
`30`	`request.headers.set("AUTHORIZATION-APP-API", btoa(`
`31`	`${userId \|\| ncResource.username}:${ncResource.password}`,
`32`	`));`
`33`	`}`
`34`	`return request;`
`35`	`},`
`36`	`};`
`37`	`client.use(authMiddleware);`
`38`
`39`	`const resumeUrls = await wmill.getResumeUrls()`
`40`
`41`	`const res = await client.POST("/ocs/v2.php/taskprocessing/schedule", {`
`42`	`params: {`
`43`	`header: {`
`44`	`"OCS-APIRequest": true,`
`45`	`},`
`46`	`query: {`
`47`	`format: "json",`
`48`	`},`
`49`
`50`	`},`
`51`	`body: {`
`52`	`type: taskType,`
`53`	`input: input,`
`54`	`appId: 'windmill',`
`55`	`webhookUri: resumeUrls.resume,`
`56`	`webhookMethod: 'HTTP:POST',`
`57`	`}`
`58`	`});`
`59`	`return {`
`60`	`urls: resumeUrls,`
`61`	`task: await res.data,`
`62`	`}`
`63`	`}`

`1`	`import * as wmill from "npm:windmill-client@1";`
`2`	`import * as nc from "https://raw.githubusercontent.com/marcelklehr/nextcloud-client-deno/c57692db56e9292b252c9b8aca7516753881409c/core/index.ts";`
`3`
`4`	`// fill the type, or use the +Resource type to get a type-safe reference to a resource`
`5`	`// type Postgresql = object`
`6`
`7`	`export async function main(`
`8`	`nextcloudResource: string,`
`9`	`userId: string \| null = null,`
`10`	`taskType: string,`
`11`	`input: object,`
`12`	`useAppApiAuth: boolean = false,`
`13`	`) {`
`14`	`const ncResource = await wmill.getResource(`
`15`	`nextcloudResource,`
`16`	`);`
`17`	`const config = new nc.Configuration({`
`18`	`username: userId \|\| ncResource.username,`
`19`	`password: ncResource.password,`
`20`	`basePath: ncResource.baseUrl,`
`21`	`middleware: [{`
`22`	`async pre(context) {`
`23`	`if (!context.url.includes("?")) {`
`24`	`context.url += "?";`
`25`	`} else {`
`26`	`context.url += "&";`
`27`	`}`
`28`	`context.url += "format=json";`
`29`	`return context;`
`30`	`},`
`31`	`}],`
`32`	`...(useAppApiAuth && ({`
`33`	`headers: {`
`34`	`"AA-VERSION": "2.3.0",`
`35`	`"EX-APP-ID": "windmill_app",`
`36`	`"EX-APP-VERSION": "1.0.0",`
`37`	`"AUTHORIZATION-APP-API": btoa(`
`38`	`${userId \|\| ncResource.username}:${ncResource.password}`,
`39`	`),`
`40`	`},`
`41`	`})),`
`42`	`});`
`43`	`const api = new nc.TaskProcessingApiApi(config);`
`44`
`45`	`const resumeUrls = await wmill.getResumeUrls()`
`46`
`47`	`const res = await api.taskProcessingApiScheduleRaw({`
`48`	`taskProcessingApiScheduleRequest: {`
`49`	`type: taskType,`
`50`	`input,`
`51`	`appId: 'windmill',`
`52`	`webhookUri: resumeUrls.resume,`
`53`	`webhookMethod: 'HTTP:POST',`
`54`	`},`
`55`	`oCSAPIRequest: true,`
`56`	`});`
`57`	`return {`
`58`	`urls: resumeUrls,`
`59`	`task: await res.raw.json()`
`60`	`}`
`61`	`}`
`62`
`63`