DUTCHIE_API_KEY=<your_api_key>

import { createDutchieConnector } from "@workspace/connector-dutchie";async function main() {  const dutchie = createDutchieConnector();  dutchie.initialize({    auth: { type: "basic", basic: { username: process.env.DUTCHIE_API_KEY! } },  });  for await (const page of conn.brand.getAll({ paging: { pageSize: 50 } })) {    console.log('page:', page);  }}main().catch((err) => {  console.error(err);  process.exit(1);});

import type { Brand } from '../connectors/dutchie';import {  IngestPipeline,  OlapTable,  DeadLetterModel,  ClickHouseEngines,} from "@514labs/moose-lib";// Create a new type that extends Brand with non-nullable brandId // (if you want to create a table with Moose, // if you are using other objects only, this step is not required)export interface BrandWithKey extends Omit<Brand, 'brandId'> {  brandId: number;}export const BrandPipeline = new IngestPipeline<BrandWithKey>("Brand",{    table: {      engine: ClickHouseEngines.ReplacingMergeTree,      orderByFields: ["brandId"]    },    stream: true,    ingest: true,    deadLetterQueue: false,})

import { Key, Task, Workflow } from "@514labs/moose-lib";import { createDutchieConnector } from '../connectors/dutchie'import { BrandWithKey, BrandPipeline } from '../ingest/models'export const dutchietask = new Task<null, void>("testdutchietask", {  run: async () => {    const apiKey = process.env.DUTCHIE_API_KEY;    if (!apiKey) throw new Error('DUTCHIE_API_KEY is required');    const conn = createDutchieConnector();    conn.initialize({      auth: { type: 'basic', basic: { username: apiKey } },    });    console.log('Getting brands from Dutchie');    for await (const page of conn.brand.getAll({ paging: { pageSize: 50 } })) {      const rows: BrandWithKey[] = page        .filter(b => b.brandId != null)        .map(b => ({ ...b, brandId: b.brandId as Key<number> }));      await BrandPipeline.table!.insert(rows);    }    console.log('Brands inserted into ClickHouse');  },  retries: 1,  timeout: "30s",});export const dutchieworkflow = new Workflow("testdutchie", {  startingTask: dutchietask,  retries: 1,  timeout: "30s",});

export * from "./ingest/models"; // may alreaxy existexport * from "./workflows/dutchie";