Connect Devengo transactions and Notion pages in our serverless environment

class HttpSourceDevengoListTransactions {
    async init() {
        // TODO: Create your http credential with devengo information:
        // More info at https://yepcode.io/docs/integrations/http/#credential-configuration
        // baseUrl: https://api.sandbox.devengo.com/v1
        this.httpClient = yepcode.integration.http(
            "your-http-devengo-credential-name"
        );

        // TODO: You need to define two env vars (https://yepcode.io/docs/processes/team-variables)
        this.jwtToken = await this.httpClient
            .post("/auth/tokens", {
                email: yepcode.env.DEVENGO_USERNAME,
                password: yepcode.env.DEVENGO_PASSWORD,
            })
            .then((response) => response.data.token);
    }

    async fetch(publish, done) {
        // TODO: Customize your request checking the API documentation:
        // https://docs.devengo.com/reference/list-transactions-1
        const accountId = "<your-acccount-id>";
        const page = 1;

        const {
            data: {
                transactions
            },
        } = await this.httpClient.get(
            `/accounts/${accountId}/transactions?page=${page}`, {
                headers: {
                    Authorization: `Bearer ${this.jwtToken}`,
                },
            }
        );

        for (const transaction of transactions) {
            await publish(transaction);
        }
        done();
    }

    async close() {}
}

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

    async consume(item) {
        // TODO: Customize your page content
        // You may want to check the official docs:
        // https://developers.notion.com/reference/post-page

        // TODO: Customize your database id
        const databaseId = "your-notion-database-id";
        await this.notion.pages.create({
            parent: {
                database_id: databaseId
            },
            icon: {
                type: "emoji",
                emoji: "🥬",
            },
            cover: {
                type: "external",
                external: {
                    url: item.url
                },
            },
            properties: {
                Name: {
                    title: [{
                        text: {
                            content: item.name,
                        },
                    }, ],
                },
                Description: {
                    rich_text: [{
                        text: {
                            content: item.description,
                        },
                    }, ],
                },
                Price: {
                    number: item.price,
                },
            },
            children: [{
                object: "block",
                type: "paragraph",
                paragraph: {
                    rich_text: [{
                        type: "text",
                        text: {
                            content: item.longDescription,
                            link: {
                                url: item.url
                            },
                        },
                    }, ],
                },
            }, ],
        });
    }

    async close() {}
}