dogeared

  sanitizeFile: function(reportFile, columnAdditions, rowDeletions, callback, retryCount) {
    var rs = fs.createReadStream(reportFile, { encoding:'utf8' })
      , outputFile = path.dirname(reportFile) + "/" + path.basename(reportFile) + ".sanitized"
      , ws = fs.createWriteStream(outputFile);
      
     rs.on('data', function(data) {
        var flushed = ws.write(data);
        if (!flushed) { rs.pause(); }
     });
     

dogeared

app.post('/api/v1/sem/generate_report', function(req, res) {

  inspect("Java requested report for account: " + req.body.account_id);

  ReportService.generate(req, res, function(credentials, params) {
    ReportService.generateReportFor(credentials, params, res, function(engineId) {
      ReportService.downloadReportFor[credentials.engine](params, res, credentials, engineId, function(reportFile) {
        ReportService.uploadToS3(config.S3.reportBucket + config.S3.s3Suffix, params.s3_storage_path, res, reportFile, function(message) {
          res.send(message);
        });