release V2 as stable

.gitignore

@@ -1,4 +1,5 @@
-node_modules
 .idea
+.tmp
 .coverage_data
 cover_html
+node_modules

.jshintignore

@@ -0,0 +1,4 @@
+node_modules/
+test/
+cover_html/
+.coverage_data/

.jshintrc

@@ -0,0 +1,126 @@
+{
+    // --------------------------------------------------------------------
+    // JSHint Configuration, Strict Edition
+    // --------------------------------------------------------------------
+    //
+    // This is a options template for [JSHint][1], using [JSHint example][2]
+    // and [Ory Band's example][3] as basis and setting config values to
+    // be most strict:
+    //
+    // * set all enforcing options to true
+    // * set all relaxing options to false
+    // * set all environment options to false, except the browser value
+    // * set all JSLint legacy options to false
+    //
+    // [1]: http://www.jshint.com/
+    // [2]: https://github.com/jshint/node-jshint/blob/master/example/config.json
+    // [3]: https://github.com/oryband/dotfiles/blob/master/jshintrc
+    //
+    // @author http://michael.haschke.biz/
+    // @license http://unlicense.org/
+
+    // == Enforcing Options ===============================================
+    //
+    // These options tell JSHint to be more strict towards your code. Use
+    // them if you want to allow only a safe subset of JavaScript, very
+    // useful when your codebase is shared with a big number of developers
+    // with different skill levels.
+    "unused"        : false,
+    "bitwise"       : false,     // Prohibit bitwise operators (&, |, ^, etc.).
+    "curly"         : false,     // Require {} for every new block or scope.
+    "eqeqeq"        : false,     // Require triple equals i.e. `===`.
+    "forin"         : false,     // Tolerate `for in` loops without `hasOwnPrototype`.
+    "immed"         : true,     // Require immediate invocations to be wrapped in parens e.g. `( function(){}() );`
+    "latedef"       : false,     // Prohibit variable use before definition.
+    "newcap"        : false,     // Require capitalization of all constructor functions e.g. `new F()`.
+    "noarg"         : true,     // Prohibit use of `arguments.caller` and `arguments.callee`.
+    "noempty"       : false,     // Prohibit use of empty blocks.
+    "nonew"         : true,     // Prohibit use of constructors for side-effects.
+    "plusplus"      : false,     // Prohibit use of `++` & `--`.
+    "regexp"        : true,     // Prohibit `.` and `[^...]` in regular expressions.
+    "undef"         : true,     // Require all non-global variables be declared before they are used.
+    "strict"        : false,     // Require `use strict` pragma in every file.
+    "trailing"      : true,     // Prohibit trailing whitespaces.
+
+    // == Relaxing Options ================================================
+    //
+    // These options allow you to suppress certain types of warnings. Use
+    // them only if you are absolutely positive that you know what you are
+    // doing.
+
+    "asi"           : true,    // Tolerate Automatic Semicolon Insertion (no semicolons).
+    "boss"          : false,    // Tolerate assignments inside if, for & while. Usually conditions & loops are for comparison, not assignments.
+    "debug"         : false,    // Allow debugger statements e.g. browser breakpoints.
+    "eqnull"        : false,    // Tolerate use of `== null`.
+    "es5"           : false,    // Allow EcmaScript 5 syntax.
+    "esnext"        : false,    // Allow ES.next specific features such as `const` and `let`.
+    "evil"          : false,    // Tolerate use of `eval`.
+    "expr"          : false,    // Tolerate `ExpressionStatement` as Programs.
+    "funcscope"     : false,    // Tolerate declarations of variables inside of control structures while accessing them later from the outside.
+    "globalstrict"  : true,    // Allow global "use strict" (also enables 'strict').
+    "iterator"      : false,    // Allow usage of __iterator__ property.
+    "lastsemic"     : false,    // Tolerat missing semicolons when the it is omitted for the last statement in a one-line block.
+    "laxbreak"      : false,    // Tolerate unsafe line breaks e.g. `return [\n] x` without semicolons.
+    "laxcomma"      : false,    // Suppress warnings about comma-first coding style.
+    "loopfunc"      : false,    // Allow functions to be defined within loops.
+    "multistr"      : true,    // Tolerate multi-line strings.
+    "onecase"       : false,    // Tolerate switches with just one case.
+    "proto"         : true,    // Tolerate __proto__ property. This property is deprecated.
+    "regexdash"     : false,    // Tolerate unescaped last dash i.e. `[-...]`.
+    "scripturl"     : false,    // Tolerate script-targeted URLs.
+    "smarttabs"     : false,    // Tolerate mixed tabs and spaces when the latter are used for alignmnent only.
+    "shadow"        : false,    // Allows re-define variables later in code e.g. `var x=1; x=2;`.
+    "sub"           : true,    // Tolerate all forms of subscript notation besides dot notation e.g. `dict['key']` instead of `dict.key`.
+    "supernew"      : true,    // Tolerate `new function () { ... };` and `new Object;`.
+    "validthis"     : false,    // Tolerate strict violations when the code is running in strict mode and you use this in a non-constructor function.
+
+    // == Environments ====================================================
+    //
+    // These options pre-define global variables that are exposed by
+    // popular JavaScript libraries and runtime environments—such as
+    // browser or node.js.
+
+    "browser"       : true,     // Standard browser globals e.g. `window`, `document`.
+    "couch"         : false,    // Enable globals exposed by CouchDB.
+    "devel"         : true,    // Allow development statements e.g. `console.log();`.
+    "dojo"          : false,    // Enable globals exposed by Dojo Toolkit.
+    "jquery"        : false,    // Enable globals exposed by jQuery JavaScript library.
+    "mootools"      : false,    // Enable globals exposed by MooTools JavaScript framework.
+    "node"          : false,    // Enable globals available when code is running inside of the NodeJS runtime environment.
+    "nonstandard"   : false,    // Define non-standard but widely adopted globals such as escape and unescape.
+    "prototypejs"   : false,    // Enable globals exposed by Prototype JavaScript framework.
+    "rhino"         : false,    // Enable globals available when your code is running inside of the Rhino runtime environment.
+    "wsh"           : false,    // Enable globals available when your code is running as a script for the Windows Script Host.
+
+    // == JSLint Legacy ===================================================
+    //
+    // These options are legacy from JSLint. Aside from bug fixes they will
+    // not be improved in any way and might be removed at any point.
+
+    "nomen"         : false,    // Prohibit use of initial or trailing underbars in names.
+    "onevar"        : false,    // Allow only one `var` statement per function.
+    "passfail"      : false,    // Stop on first error.
+    "white"         : false,    // Check against strict whitespace and indentation rules.
+
+    // == Undocumented Options ============================================
+    //
+    // While I've found these options in [example1][2] and [example2][3]
+    // they are not described in the [JSHint Options documentation][4].
+    //
+    // [4]: http://www.jshint.com/options/
+
+    "maxerr"        : 100,      // Maximum errors before stopping.
+    "predef"        : [         // Extra globals.
+        //"exampleVar",
+        //"anotherCoolGlobal",
+        //"iLoveDouglas"
+    ],
+    "indent"        : 4,         // Specify indentation spacing
+    "globals": {
+      "URL": true,
+      "Buffer": false,
+      "require": false,
+      "exports": false,
+      "module": false
+    }
+}

.npmignore

@@ -1 +1,4 @@
+.idea
 .tmp
+.coverage_data
+cover_html

.travis.yml

@@ -1,3 +1,9 @@
+sudo: false
 language: node_js
 node_js:
-  - 0.8
+  - 4
+  - 6
+  - 8
+script:
+  - npm run lint
+  - npm run test

CHANGES.md

@@ -1,5 +1,65 @@
 <!-- vim:ts=4:sts=4:sw=4:et:tw=60 -->
 
+## 2.0.4
+
+Streams:
+
+ - Added support for progress observers on readable stream `read` promise.
+
+File system:
+
+ - Added support for `targetFs` argument to `copy` and `copyTree`.
+ - Fixed `canonical` by implementing in JavaScript based on `readLink`.
+   Depending on Node.js `realpath` was an error since realpath does not handle
+   path remainders.
+ - Fixed rerooted base file systems.
+ - Quietly added `rejoin` to file system, for reversing `split` properly.
+   Must consider finding a better narrative about `join`, `absolute`, `split`
+   and the distinguishing of relative and absolute paths in their split form,
+   as well as handling the issue of drive letters for Windows properly.
+
+HTTP:
+
+ - Server request's now decode `pathInfo` on demand.
+   If the encoding is invalid, accessing `pathInfo` will throw an error.
+   This change makes it possible to receive requests with file names.
+   Using an accessor is questionable.
+   A future release might elect to pass `null` for path info if it does not
+   parse properly.
+ - File service now uses the configured `listDirectory` function if overridden.
+ - The client now supports requests with all of the same properteis as the
+   options that can be passed to the Node.js request function.
+
+## 2.0.2
+
+ - Fixed problems with hanging connections, and problems with early termination
+   of streams.
+ - Added missing `node` property to Node writable stream wrapper.
+ - Removed `Reader.join`. Removed support for `Reader.prototype.join`.
+   Use `Reader(x).read()` and `Buffer.concat(buffers)`.
+ - Added `node/process` process stream wrapper.
+ - HTTP client now warns when there is a missing host header.
+ - Fix problem with HTTP agent option with Node.js v0.11.
+ - Refactored file system to use prototype inheritance pattern
+   instead of Crockford style closure constructors.
+ - Merged changes from v1 for HTTP request normalization.
+ - Added support for response.statusText
+
+## 2.0.1
+
+ - Fixed URL dependency.
+
+## 2.0.0 :warning:
+
+ - Rebased on next generation of Q and Collections
+ - Reimplements streams. Streams now support back pressure and are consumed on
+   demand. Streams must be expressly cancelled or they will stay open
+   indefinitely, or until a connection timeout.
+
+## 1.11.0
+
+ - Adds `removeDirectory` and `statLink` to the Mock file system interface.
+
 ## 1.10.7-8
 
  - Fixes support for range content requests, such that Q-IO based web serves can

README.md

@@ -1,7 +1,8 @@
+# Q-IO v2
 
-[![Build Status](https://secure.travis-ci.org/kriskowal/q-io.png)](http://travis-ci.org/kriskowal/q-io)
+[![npm version](https://img.shields.io/npm/v/q-io.svg?style=flat)](https://www.npmjs.com/package/q-io)
 
-# Q-IO
+[![Build Status](https://secure.travis-ci.org/kriskowal/q-io.png?branch=v2)](https://github.com/kriskowal/q-io/tree/v2)
 
 Interfaces for IO that make use of promises.
 
@@ -563,15 +564,7 @@ Reader instances have the following methods:
 -   `close()`
 -   `node` the underlying node reader
 
-Additionally, the `Reader` constructor has the following methods:
-
--   `read(stream, charset)` accepts any foreachable and returns either a
-    buffer or a string if given a charset.
--   `join(buffers)` consolidates an array of buffers into a single
-    buffer.  The buffers array is collapsed in place and the new first
-    and only buffer is returned.
-
-The `reader` module exports a function that accepts a Node reader and
+The `node/reader` module exports a function that accepts a Node reader and
 returns a Q reader.
 
 ### Writer
@@ -586,7 +579,7 @@ Writer instances have the following methods:
 -   `destroy()`
 -   `node` the underlying node writer
 
-The `writer` module exports a function that accepts a Node writer and
+The `node/writer` module exports a function that accepts a Node writer and
 returns a Q writer.
 
 ### Buffer

buffer-stream.js

@@ -1,59 +1,4 @@
+"use strict";
 
-var Q = require("q");
-var Reader = require("./reader");
-
-module.exports = BufferStream;
-function BufferStream(chunks, charset) {
-    if (!(this instanceof BufferStream)) {
-        return new BufferStream(chunks, charset);
-    }
-    if (!chunks) {
-        chunks = [];
-    } else if (!Array.isArray(chunks)) {
-        chunks = [chunks];
-    }
-    this._charset = charset;
-    this._chunks = chunks;
-    this._close = Q.defer();
-    this.closed = this._close.promise;
-}
-
-BufferStream.prototype.forEach = function (write, thisp) {
-    var self = this;
-    var chunks = self._chunks;
-    return Q.fcall(function () {
-        chunks.splice(0, chunks.length).forEach(write, thisp);
-    });
-};
-
-BufferStream.prototype.read = function () {
-    var result;
-    result = Reader.join(this._chunks);
-    if (this._charset) {
-        result = result.toString(this._charset);
-    }
-    return Q.resolve(result);
-};
-
-BufferStream.prototype.write = function (chunk) {
-    if (this._charset) {
-        chunk = new Buffer(String(chunk), this._charset);
-    } else {
-        if (!(chunk instanceof Buffer)) {
-            throw new Error("Can't write strings to buffer stream without a charset: " + chunk);
-        }
-    }
-    this._chunks.push(chunk);
-    return Q.resolve();
-};
-
-BufferStream.prototype.close = function () {
-    this._close.resolve();
-    return Q.resolve();
-};
-
-BufferStream.prototype.destroy = function () {
-    this._close.resolve();
-    return Q.resolve();
-};
+module.exports = require("./streams").BufferStream;
 

coverage-report.js

@@ -1,5 +1,7 @@
+/* global __dirname:false */
+
+"use strict";
 
-require("collections/shim");
 var Q = require("q");
 var FS = require("./fs");
 
@@ -22,16 +24,19 @@ FS.listTree(".coverage_data", function (name, stat) {
             console.log("        </tr>");
             console.log("    </thead>");
             console.log("    <tbody>");
-            Object.forEach(coverage.files, function (file, path) {
+            var paths = Object.keys(coverage.files);
+            for (var i = 0; i < paths.length; i++) {
+                var path = paths[i];
+                var file = coverage.files[path];
                 path = FS.relativeFromDirectory(__dirname, path);
                 if (/^spec/.test(path))
-                    return;
+                    continue;
                 console.log("        <tr>");
                 console.log("            <td><code>" + path + "</code></td>");
                 console.log("            <td>" + (file.stats.percentage * 100).toFixed(0) + "%</td>");
                 console.log("            <td>" + file.stats.missing + "</td>");
                 console.log("        </tr>");
-            });
+            }
             console.log("    </tbody>");
             console.log("</table>");
         }, function (error) {

deprecate.js

@@ -1,3 +1,5 @@
+"use strict";
+
 /**
  * @module deprecate
  */
@@ -10,9 +12,12 @@
  * @param {String} alternative - Name of alternative that should be used instead.
  * @param {Number} [stackTraceLimit] - depth of the stack trace to print out. Set to falsy value to disable stack.
  */
-exports.deprecationWarning = function deprecationWarning(name, alternative, stackTraceLimit) {
+exports.deprecationWarning = deprecationWarning;
+
+function deprecationWarning(name, alternative, stackTraceLimit) {
+    var depth;
     if (stackTraceLimit) {
-        var depth = Error.stackTraceLimit;
+        depth = Error.stackTraceLimit;
         Error.stackTraceLimit = stackTraceLimit;
     }
     if (typeof console !== "undefined" && typeof console.warn === "function") {