Ignored modules directory

Author: Stephen Parente

.gitignore

@@ -0,0 +1 @@
+node_modules

exporter.js

@@ -2,6 +2,7 @@ var util = require('util');
 var events = require('events');
 var csv = require('csv');
 var fs = require('fs');
+var stream = require('stream');
 
 function Exporter(path) {
 this.path = path;
@@ -10,6 +11,29 @@ function Exporter(path) {
 
 util.inherits(Exporter, events.EventEmitter);
 
+Exporter.prototype.toStream = function(data) {
+var s = new stream.Readable();
+
+s._data = data.toString();
+
+s._read = function(n) {
+var chunk;
+n = (n == null || n === -1) ? undefined : n;
+chunk = this._data.slice(0, n);
+
+this._data = this._data.slice(n);
+if (chunk == "") {
+return this.emit('end');
+} else {
+this.push(chunk);
+this.emit('data', chunk);
+return chunk;
+}
+};
+
+return s;
+}
+
 Exporter.prototype.doWrite = function(data) {
 var $self = this;
 fs.writeFile(this.path, data, function(err) {

index.js

@@ -4,9 +4,9 @@ var colors = require('colors');
 var _ = require('./tools');
 var Exporter = require('./exporter');
 
-function fetch(url, path, cb) {
+function fetch(url, cb, path) {
 if (!cb) cb = function() {};
-path = path || './export.csv';
+path = path || false;
 
 var firebase = new Firebase(firebaseUrl);
 
@@ -16,6 +16,10 @@ function fetch(url, path, cb) {
 var data = _.prepareCSV(array);
 
 var e = new Exporter(path);
+if (path === false) {
+return cb(e.toStream(data));
+}
+
 e.writeToFile(data);
 
 e.on('finished', cb);
@@ -50,10 +54,17 @@ if (require.main === module) {
 }
 });
 
-fetch(firebaseUrl, false, function() {
-process.exit();
+fetch(firebaseUrl, function(stream) {
+stream
+.pipe(process.stdout);
+
+stream.on('end', process.exit);
 });
 
+/*fetch(firebaseUrl, function() {
+process.exit();
+}, './export.csv');*/
+
 }
 
 module.exports = fetch;