Connect PostgreSQL and LDAP entries in our serverless environment

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

    async fetch(publish, done) {
        // TODO: Customize your sql query
        const {
            rows
        } = await this.postgresPool.query(
            "SELECT * FROM your_schema.your_table LIMIT 10"
        );
        for (const row of rows) {
            await publish(row);
        }
        done();
    }

    async close() {
        await this.postgresPool.end();
    }
}

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() {}
}