Verbinden Sie jedes System, das Sie nutzen.
Das fehlende bauen wir in Stunden.

import { auth, defineIntegration, z } from "@beetlio/connect"; const Order = z.object({  id: z.string(),  customer: z.string(),  total: z.number(),  status: z.enum(["open", "shipped", "invoiced"]),  updated_at: z.iso.datetime(),});const Page = z.object({ orders: z.array(Order), next: z.string().nullable() }); export default defineIntegration({  key: "erp-orders",  displayName: "ERP orders",  connection: {    origin: { type: "input", input: "origin" },    inputs: z.object({      origin: z.url().meta({ title: "ERP address" }),      company: z.string().meta({ title: "Company code" }),    }),    auth: auth.bearer(),    retry: { maxAttempts: 5, statuses: [429, 500, 502, 503] },    async verify(ctx) {      await ctx.json(`/api/${ctx.config.company}/orders?limit=1`, Page);    },  },  syncs: (sync) => ({    orders: sync({      displayName: "Orders",      mode: "merge",      primaryKey: ["id"],      records: Order,      checkpoint: z.object({ since: z.string() }),      async *run(ctx) {        const { company } = ctx.config.connection;        let since = ctx.checkpoint?.since ?? "";        for await (const page of ctx.paginate({          request: { path: `/api/${company}/orders`, query: { since } },          schema: Page,          next: ({ data }) => (data.next ? { path: data.next } : undefined),        })) {          since = page.data.orders.at(-1)?.updated_at ?? since;          yield { records: page.data.orders, checkpoint: { since } };        }      },    }),  }),});