Connect Tinybird and Oracle in our serverless environment

class HttpSourceTinybirdGetEndpoint {
    async init() {
        // TODO: Create team variables. More info at https://yepcode.io/docs/processes/team-variables
        // TODO: Add your http credential with tynibird information:
        // More info at https://www.npmjs.com/package/axios
        // baseUrl: https://api.tinybird.co/v0
        // HTTP Headers: { "Authorization": "Bearer <your-read-token>" }
        this.httpClient = axios.create({
            baseURL: "https://api.tinybird.co/v0",
            headers: {
                Authorization: `Bearer ${yepcode.env.TINYBIRD_READ_TOKEN}`,
            },
        });
    }

    async fetch(publish, done) {
        // TODO: Customize your request checking the API documentation:
        // https://www.tinybird.co/docs/api-reference/query-api.html
        this.httpClient
            .get("/pipes/your_end_point_name.csv", {
                responseType: "stream",
            })
            .then(({
                data
            }) => {
                data
                    .pipe(
                        csv.parse({
                            trim: true,
                            columns: true,
                            delimiter: ",",
                            skip_empty_lines: true,
                        })
                    )
                    .on("data", publish)
                    .on("end", done);
            });
    }

    async close() {}
}

class OracleTargetInsert {
    async init() {
        // More info at https://www.npmjs.com/package/oracledb
        // TODO: Create team variables. More info at https://yepcode.io/docs/processes/team-variables
        const oraclePool = await oracledb.createPool({
            user: yepcode.env.ORACLE_USER,
            password: yepcode.env.ORACLE_PASSWORD,
            connectString: yepcode.env.ORACLE_CONNECT_STRING,
        });
        this.connection = await oraclePool.getConnection();
    }

    async consume(item) {
        // TODO: Customize INSERT statement and map your item to row
        this.connection
            .execute(`INSERT INTO your_table values (:id, :name)`, {
                id: item.id,
                name: item.name,
            })
            .then((result) => {
                return this.connection.commit();
            });
    }

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