Connect SAP HANA Cloud and LDAP entries in our serverless environment

class SapHanaSourceSelect {
    async init() {
        // TODO: Create your SAP HANA credential:
        // More info at https://yepcode.io/docs/integrations/sap-hana#credential-configuration
        this.connection = yepcode.integration.sapHana(
            "your-sap-hana-credential-name"
        );
    }

    async fetch(publish, done) {
        // TODO: Customize your sql query
        // https://help.sap.com/docs/SAP_HANA_CLIENT/f1b440ded6144a54ada97ff95dac7adf/a5c332936d9f47d8b820a4ecc427352c.html?locale=en-US
        const sql = "SELECT * FROM your_table";
        const rows = this.connection.exec(sql);
        for (const row of rows) {
            await publish(row);
        }
        done();
    }

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

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

    async consume(item) {
        const entry = {
            // TODO: Customize entry attributes
            name: item.name,
            email: item.email,
        };

        // TODO: Customize the distinguished name
        this.ldap.add("dn", entry, (err) => {
            if (err) {
                throw err;
            }
            // Completed
        });
    }

    async close() {}
}