Connect Clickhouse and Send WhatsApp messages using Vonage API in our serverless environment

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

    async fetch(publish, done) {
        // TODO: customize your sql query
        const sql = "SELECT * FROM your_table_name";

        const resultSet = await this.clickhouse.query({
            query: sql,
            format: "CSV",
        });
        const stream = resultSet.stream();
        stream.on("data", (rows) => {
            rows.forEach(publish);
        });
        stream.on("end", done);
    }

    async close() {
        await this.clickhouse.close();
    }
}

class HttpTargetVonageSendWhatsapp {
    async init() {
        // TODO: Create your http credential with Vonage information:
        // More info at https://yepcode.io/docs/integrations/http/#credential-configuration
        // baseUrl: https://messages-sandbox.nexmo.com/v1
        // username: <your-vonage-api-key>
        // password: <your-vonage-api-secret>
        this.httpClient = yepcode.integration.http(
            "your-http-vonage-credential-name"
        );
    }

    async consume(item) {
        const WHATSAPP_NUMBER = "14157386204"; // The WhatsApp number that has been allocated to you by Vonage

        // TODO: Customize your request checking the API documentation:
        // https://dashboard.nexmo.com/messages/sandbox
        await this.httpClient.post("/messages", {
            from: WHATSAPP_NUMBER,
            message_type: "text",
            channel: "whatsapp",
            to: item.to,
            text: item.text,
        });
    }

    async close() {}
}