@cinerino/domain/example/streamOwnershipInfos.js

const fs = require('fs');
const moment = require('moment');
const mongoose = require('mongoose');

const domain = require('../');

async function main() {
    await mongoose.connect(process.env.MONGOLAB_URI, {
        useUnifiedTopology: true
    });

    const ownershipInfoRepo = new domain.repository.OwnershipInfo(mongoose.connection);

    const now = moment('2020-05-30T15:00:00Z')
        .toDate();

    const readable = await domain.service.report.ownershipInfo.stream({
        conditions: {
            project: { id: { $eq: 'sskts-production' } },
            typeOfGood: {
                typeOf: 'ProgramMembership'
            },
            ownedFrom: now,
            ownedThrough: now,
            // ownedBy: { id: '94b3b1b6-51b2-46fa-bd5f-c56cdf00a963' }
        },
        format: domain.factory.encodingFormat.Text.csv
    })({
        ownershipInfo: ownershipInfoRepo
    });

    readable.on('data', function (data) {
        console.log(data);
    });
    readable.on('end', function (data) {
        console.log('all read!');
    });

    const stream = fs.createWriteStream('test.csv');
    readable.pipe(stream);
    // stream.write("Hello, ");
    // stream.write("Stream");
    // stream.end("\n");
}

main().then(() => {
    console.log('success!');
}).catch((error) => {
    console.error(error);
    process.exit(1);
});