Script 'Get Nextcloud TaskProcessing Task' for nextcloud

Get Nextcloud TaskProcessing Task

Verified

Created by marcel klehr12 135 days ago Viewed 355 times

Submitted by nextcloud Bun

Verified 9 days ago

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,

  taskId: string,

  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 res = await client.GET("/ocs/v2.php/taskprocessing/task/{id}", {
    params: {
      header: {
        "OCS-APIRequest": true,
      },
      query: {
        format: "json",
      },
      path: {
        id: taskId,
      },

    },
  });
  return res.data;
}

Other submissions

Submitted by marcel klehr12 Deno

Created 135 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,
  taskId: string,
  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": "flow",
        "EX-APP-VERSION": "1.0.0",
        "AUTHORIZATION-APP-API": btoa(
          `${userId || ncResource.username}:${ncResource.password}`,
        ),
      },
    })),
  });
  const api = new nc.TaskProcessingApiApi(config);

  const res = await api.taskProcessingApiGetTaskRaw({
    id: taskId,
    oCSAPIRequest: true,
  });
  return await res.raw.json()
}



`1`	`import * as wmill from "windmill-client";`
`2`	`import createClient, { type Middleware } from "openapi-fetch";`
`3`
`4`	`type Nextcloud = {`
`5`	`baseUrl: string,`
`6`	`password: string,`
`7`	`username: string`
`8`	`};`
`9`
`10`	`export async function main(`
`11`	`ncResource: Nextcloud,`
`12`
`13`	`userId: string \| null = null,`
`14`
`15`	`taskId: string,`
`16`
`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 res = await client.GET("/ocs/v2.php/taskprocessing/task/{id}", {`
`40`	`params: {`
`41`	`header: {`
`42`	`"OCS-APIRequest": true,`
`43`	`},`
`44`	`query: {`
`45`	`format: "json",`
`46`	`},`
`47`	`path: {`
`48`	`id: taskId,`
`49`	`},`
`50`
`51`	`},`
`52`	`});`
`53`	`return res.data;`
`54`	`}`

`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`	`taskId: string,`
`11`	`useAppApiAuth: boolean = false,`
`12`	`) {`
`13`	`const ncResource = await wmill.getResource(`
`14`	`nextcloudResource,`
`15`	`);`
`16`	`const config = new nc.Configuration({`
`17`	`username: userId \|\| ncResource.username,`
`18`	`password: ncResource.password,`
`19`	`basePath: ncResource.baseUrl,`
`20`	`middleware: [{`
`21`	`async pre(context) {`
`22`	`if (!context.url.includes("?")) {`
`23`	`context.url += "?";`
`24`	`} else {`
`25`	`context.url += "&";`
`26`	`}`
`27`	`context.url += "format=json";`
`28`	`return context;`
`29`	`},`
`30`	`}],`
`31`	`...(useAppApiAuth && ({`
`32`	`headers: {`
`33`	`"AA-VERSION": "2.3.0",`
`34`	`"EX-APP-ID": "flow",`
`35`	`"EX-APP-VERSION": "1.0.0",`
`36`	`"AUTHORIZATION-APP-API": btoa(`
`37`	`${userId \|\| ncResource.username}:${ncResource.password}`,
`38`	`),`
`39`	`},`
`40`	`})),`
`41`	`});`
`42`	`const api = new nc.TaskProcessingApiApi(config);`
`43`
`44`	`const res = await api.taskProcessingApiGetTaskRaw({`
`45`	`id: taskId,`
`46`	`oCSAPIRequest: true,`
`47`	`});`
`48`	`return await res.raw.json()`
`49`	`}`
`50`
`51`