first commit

Author: cowboy

.gitignore

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

.jshintrc

@@ -0,0 +1,14 @@
+{
+  "curly": true,
+  "eqeqeq": true,
+  "immed": true,
+  "latedef": "nofunc",
+  "newcap": true,
+  "noarg": true,
+  "sub": true,
+  "undef": true,
+  "unused": true,
+  "boss": true,
+  "eqnull": true,
+  "node": true
+}

.travis.yml

@@ -0,0 +1,6 @@
+language: node_js
+node_js:
+  - 0.8
+  - '0.10'
+before_script:
+  - npm install -g grunt-cli

Gruntfile.js

@@ -0,0 +1,48 @@
+'use strict';
+
+module.exports = function(grunt) {
+
+  // Project configuration.
+  grunt.initConfig({
+    nodeunit: {
+      files: ['test/**/*_test.js'],
+    },
+    jshint: {
+      options: {
+        jshintrc: '.jshintrc'
+      },
+      gruntfile: {
+        src: 'Gruntfile.js'
+      },
+      lib: {
+        src: ['lib/**/*.js']
+      },
+      test: {
+        src: ['test/**/*.js']
+      },
+    },
+    watch: {
+      gruntfile: {
+        files: '<%= jshint.gruntfile.src %>',
+        tasks: ['jshint:gruntfile']
+      },
+      lib: {
+        files: '<%= jshint.lib.src %>',
+        tasks: ['jshint:lib', 'nodeunit']
+      },
+      test: {
+        files: '<%= jshint.test.src %>',
+        tasks: ['jshint:test', 'nodeunit']
+      },
+    },
+  });
+
+  // These plugins provide necessary tasks.
+  grunt.loadNpmTasks('grunt-contrib-nodeunit');
+  grunt.loadNpmTasks('grunt-contrib-jshint');
+  grunt.loadNpmTasks('grunt-contrib-watch');
+
+  // Default task.
+  grunt.registerTask('default', ['jshint', 'nodeunit']);
+
+};

LICENSE-MIT

@@ -0,0 +1,22 @@
+Copyright (c) 2013 "Cowboy" Ben Alman
+
+Permission is hereby granted, free of charge, to any person
+obtaining a copy of this software and associated documentation
+files (the "Software"), to deal in the Software without
+restriction, including without limitation the rights to use,
+copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the
+Software is furnished to do so, subject to the following
+conditions:
+
+The above copyright notice and this permission notice shall be
+included in all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
+OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
+HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
+WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
+OTHER DEALINGS IN THE SOFTWARE.

README.md

@@ -0,0 +1,31 @@
+# exit [![Build Status](https://secure.travis-ci.org/cowboy/node-exit.png?branch=master)](http://travis-ci.org/cowboy/node-exit)
+
+A replacement for process.exit that ensures stdio are fully drained before exiting.
+
+## Getting Started
+Install the module with: `npm install exit`
+
+```javascript
+var exit = require('exit');
+
+// These lines should appear in the output.
+console.log("foo");
+console.error("bar");
+
+// process.exit(5);
+exit(5);
+
+// These lines shouldn't appear in the output.
+console.log("foo");
+console.error("bar");
+```
+
+## Contributing
+In lieu of a formal styleguide, take care to maintain the existing coding style. Add unit tests for any new or changed functionality. Lint and test your code using [Grunt](http://gruntjs.com/).
+
+## Release History
+_(Nothing yet)_
+
+## License
+Copyright (c) 2013 "Cowboy" Ben Alman  
+Licensed under the MIT license.

lib/exit.js

@@ -0,0 +1,35 @@
+/*
+ * exit
+ * https://github.com/cowboy/node-exit
+ *
+ * Copyright (c) 2013 "Cowboy" Ben Alman
+ * Licensed under the MIT license.
+ */
+
+'use strict';
+
+module.exports = function exit(exitCode, streams) {
+  if (!streams) { streams = [process.stdout, process.stderr]; }
+  var drainCount = 0;
+  // Actually exit if all streams are drained.
+  function tryToExit() {
+    if (drainCount === streams.length) {
+      process.exit(exitCode);
+    }
+  }
+  streams.forEach(function(stream) {
+    // Prevent further writing.
+    stream.write = function() {};
+    // Count drained streams now, but monitor non-drained streams.
+    if (stream.bufferSize === 0) {
+      drainCount++;
+    } else {
+      stream.once('drain', function() {
+        drainCount++;
+        tryToExit();
+      });
+    }
+  });
+  // If all streams were already drained, exit now.
+  tryToExit();
+};

package.json

@@ -0,0 +1,48 @@
+{
+  "name": "exit",
+  "description": "A replacement for process.exit that ensures stdio are fully drained before exiting.",
+  "version": "0.1.0",
+  "homepage": "https://github.com/cowboy/node-exit",
+  "author": {
+    "name": "\"Cowboy\" Ben Alman",
+    "url": "http://benalman.com/"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git://github.com/cowboy/node-exit.git"
+  },
+  "bugs": {
+    "url": "https://github.com/cowboy/node-exit/issues"
+  },
+  "licenses": [
+    {
+      "type": "MIT",
+      "url": "https://github.com/cowboy/node-exit/blob/master/LICENSE-MIT"
+    }
+  ],
+  "main": "lib/exit",
+  "engines": {
+    "node": ">= 0.8.0"
+  },
+  "scripts": {
+    "test": "grunt nodeunit"
+  },
+  "devDependencies": {
+    "grunt-contrib-jshint": "~0.6.4",
+    "grunt-contrib-nodeunit": "~0.2.0",
+    "grunt-contrib-watch": "~0.5.3",
+    "grunt": "~0.4.1",
+    "async": "~0.2.9",
+    "diff": "~1.0.7"
+  },
+  "keywords": [
+    "exit",
+    "process",
+    "stdio",
+    "stdout",
+    "stderr",
+    "drain",
+    "flush",
+    "3584"
+  ]
+}

test/exit_test.js

@@ -0,0 +1,119 @@
+'use strict';
+
+/*
+  ======== A Handy Little Nodeunit Reference ========
+  https://github.com/caolan/nodeunit
+
+  Test methods:
+    test.expect(numAssertions)
+    test.done()
+  Test assertions:
+    test.ok(value, [message])
+    test.equal(actual, expected, [message])
+    test.notEqual(actual, expected, [message])
+    test.deepEqual(actual, expected, [message])
+    test.notDeepEqual(actual, expected, [message])
+    test.strictEqual(actual, expected, [message])
+    test.notStrictEqual(actual, expected, [message])
+    test.throws(block, [error], [message])
+    test.doesNotThrow(block, [error], [message])
+    test.ifError(value)
+*/
+
+var fs = require('fs');
+var exec = require('child_process').exec;
+var async = require('async');
+var jsdiff = require('diff');
+
+function run(command, options, callback) {
+  if (typeof options === 'function') {
+    callback = options;
+    options = {};
+  }
+  command += ' 2>&1';
+  if (options.pipe) {
+    command += ' | ' + (process.platform === 'win32' ? 'find' : 'grep') + ' "std"';
+  }
+  exec(command, function(error, stdout) {
+    callback(error ? error.code : 0, stdout);
+  });
+}
+
+function showDiff(actual, expected) {
+  if (actual === expected) {
+    return true;
+  } else {
+    return jsdiff.diffLines(expected, actual).map(function(d) {
+      if (d.removed) {
+        return 'MISSING: ' + d.value;
+      } else if (d.added) {
+        return 'EXTRA: ' + d.value;
+      }
+    }).filter(Boolean).join('');
+  }
+}
+
+function fixture(filename) {
+  return String(fs.readFileSync(filename));
+}
+
+exports['awesome'] = {
+  setUp: function(done) {
+    this.origCwd = process.cwd();
+    process.chdir('test/fixtures');
+    done();
+  },
+  tearDown: function(done) {
+    process.chdir(this.origCwd);
+    done();
+  },
+  'stdout stderr': function(test) {
+    var counts = [10, 100, 1000];
+    test.expect(counts.length);
+    async.eachSeries(counts, function(n, next) {
+      var command = 'node log.js 0 ' + n + ' stdout stderr';
+      run(command, {pipe: true}, function(code, actual) {
+        var expected = fixture(n + '-stdout-stderr.txt');
+        test.equal(true, showDiff(actual, expected), command);
+        next();
+      });
+    }, test.done);
+  },
+  'stdout': function(test) {
+    var counts = [10, 100, 1000];
+    test.expect(counts.length);
+    async.eachSeries(counts, function(n, next) {
+      var command = 'node log.js 0 ' + n + ' stdout';
+      run(command, {pipe: true}, function(code, actual) {
+        var expected = fixture(n + '-stdout.txt');
+        test.equal(true, showDiff(actual, expected), command);
+        next();
+      });
+    }, test.done);
+  },
+  'stderr': function(test) {
+    var counts = [10, 100, 1000];
+    test.expect(counts.length);
+    async.eachSeries(counts, function(n, next) {
+      var command = 'node log.js 0 ' + n + ' stderr';
+      run(command, {pipe: true}, function(code, actual) {
+        var expected = fixture(n + '-stderr.txt');
+        test.equal(true, showDiff(actual, expected), command);
+        next();
+      });
+    }, test.done);
+  },
+  'exit codes': function(test) {
+    var codes = [0, 1, 123];
+    test.expect(codes.length * 2);
+    async.eachSeries(codes, function(n, next) {
+      var command = 'node log.js ' + n + ' 10 stdout stderr';
+      run(command, {pipe: false}, function(code, actual) {
+        test.equal(code, n, 'should have exited with ' + n + ' error code.');
+        var expected = fixture('10-stdout-stderr.txt');
+        test.equal(true, showDiff(actual, expected), command);
+        next();
+      });
+    }, test.done);
+  },
+};

test/fixtures/10-stderr.txt

@@ -0,0 +1,10 @@
+[stderr] testing 0
+[stderr] testing 1
+[stderr] testing 2
+[stderr] testing 3
+[stderr] testing 4
+[stderr] testing 5
+[stderr] testing 6
+[stderr] testing 7
+[stderr] testing 8
+[stderr] testing 9