const queryLogentriesFactory = require('query-logentries');
 
// Required. Replace with your API KEY
const apiKey = '6971aef7-998f-4cb2-9613-ddb42b9697b8';
 
// Optional. Defaults to https://rest.logentries.com/query/logs
const queryUrl = 'https://rest.logentries.com/query/logs';
 
const queryLogentries = queryLogentriesFactory(apiKey, queryUrl);
const opts = {
    // Required. Set it to the id of the log in logEntries you wish
    // to query
    logId: '7d9ff278-3a6d-4c7a-8e65-df89fd3f5a96',
 
    // Required. Set it to any valid value or stringDate that can
    //be passed to a javascript Date object
    from: '2017-01-01T00:00:00.000',
 
    // Optional. If empty will default to now. Set it to any valid
    // value or stringDate that can be passed to a javascript Date
    // object
    to: '2017-01-02T23:59:59.999',
 
    // Optional. Default to 'where()'. The leql query you wish to
    // query with. Please ensure it is a valid leql query or you
    // get statusCode 400 errors from logEntries.
    query: 'where(method=GET)',
 
    // Optional. Defaults to 50. How many messages should be
    // retrieved per paging request made to logEntries
    perPage: 50,
 
    // Optional. Defaults to 30000 (30 seconds). How long should
    //the request wait before it times out
    timeout: 30000,
 
    // Optional. Defaults to 3000 (3 seconds). How long should
    // this module wait when checking if a query response is
    // finished on logEntries
    pollInterval: 3000
};

queryLogentries(opts, (err, messages) => {
    if (err) {
        return; //TODO handle err
    }
    console.log('messages', messages);
});

const pump = require('pump');
const through2 = require('through2');
const fs = require('fs');
 
const logEntriesStream = queryLogentries(opts);
const toStringStream = through2.obj(function(message, enc, callback) {
    this.push(JSON.stringify(message) + '\n');
    callback();
});
const toFileStream = fs.createWriteStream('./result.txt');
 
pump(logEntriesStream, toStringStream, toFileStream, err => {
    if (err) {
        //TODO handle err
    }
});