Connect Azure Blob NDJSON file and LDAP entries in our serverless environment

class AzureBlobSourceReadRemoteNdjson {
    async init() {
        // More info at https://docs.microsoft.com/en-us/azure/storage/blobs/storage-quickstart-blobs-nodejs
        // TODO: Create team variables. More info at https://yepcode.io/docs/processes/team-variables
        this.azureBlob = BlobServiceClient.fromConnectionString(
            yepcode.env.AZURE_BLOB_CONNECTION_STRING
        );
    }

    async fetch(publish, done) {
        // TODO: customize the container name and blob name to download
        // // More info at https://docs.microsoft.com/en-us/javascript/api/@azure/storage-blob/blobserviceclient?view=azure-node-latest#@azure-storage-blob-blobserviceclient-getcontainerclient
        const containerClient = this.azureBlob.getContainerClient("container-name");
        const blobClient = containerClient.getBlobClient("blob-name");
        const result = await blobClient.download();

        // result.readableStreamBody is a stream of object content

        result.readableStreamBody
            .pipe(ndjson.parse())
            .on("data", async (line) => {
                await publish(line);
            })
            .on("end", done);
    }

    async close() {}
}

class LdapTargetAddEntry {
    async init() {
        // More info at https://www.npmjs.com/package/ldapjs
        // TODO: Create team variables. More info at https://yepcode.io/docs/processes/team-variables
        this.ldap = ldap.createClient({
            url: yepcode.env.LDAP_URL,
        });
    }

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