Connect Couchbase and Toggl in our serverless environment

class CouchbaseSourceQuery {
    async init() {
        // TODO: Create your couchbase credential
        // More info at https://yepcode.io/docs/integrations/couchbase/#credential-configuration
        this.couchbaseCluster = yepcode.integration.couchbase(
            "your-couchbase-credential-name"
        );
    }

    async fetch(publish, done) {
        // TODO: Customize your collection name, query and parameters.
        const query = `SELECT name FROM your-collection-name WHERE type=$1`;
        const options = {
            parameters: ["some_type"],
        };

        // TODO: Customize your bucket and scope names
        const queryStream = this.couchbaseCluster
            .bucket("your-bucket-name")
            .scope("your-scope-name")
            .query(query, options);
        queryStream.on("row", publish);
        queryStream.on("end", done);
    }

    async close() {}
}

class HttpTargetTogglCreateTimeEntry {
    async init() {
        // TODO: Create your http credential with toggl information:
        // More info at https://yepcode.io/docs/integrations/http/#credential-configuration
        // Official docs: https://developers.track.toggl.com/docs/index.html
        this.toggl = await yepcode.integration.http("your-toggl-credential-name");
    }
    async consume(item) {
        // Official docs: https://developers.track.toggl.com/docs/api/time_entries
        const workspaceId = "<your-workspace-id>";
        const response = await this.toggl.post(
            `workspaces/${workspaceId}/time_entries`, {
                description: item.description,
                tags: [...item.tags],
                workspace_id: workspaceId,
                duration: item.duration,
                start: new Date(item.date).toISOString(),
                created_with: "yepcode",
            }
        );
    }

    async close() {}
}