init commit

Author: pemrouz

.babelrc

@@ -0,0 +1,3 @@
+{
+  "presets": ["es2015"]
+}

.gitignore

@@ -0,0 +1,3 @@
+node_modules
+coverage
+*.log

.travis.yml

@@ -0,0 +1,6 @@
+sudo: false
+language: node_js
+node_js:
+  - "stable"
+
+after_script: NODE_ENV=test istanbul cover ./node_modules/mocha/bin/_mocha --report lcovonly -- -R spec && cat ./coverage/lcov.info | ./node_modules/coveralls/bin/coveralls.js && rm -rf ./coverage

README.md

@@ -0,0 +1,77 @@
+# Ripple | Upload
+[![Coverage Status](https://coveralls.io/repos/rijs/upload/badge.svg?branch=master&service=github)](https://coveralls.io/github/rijs/upload?branch=master)
+[![Build Status](https://travis-ci.org/rijs/upload.svg)](https://travis-ci.org/rijs/upload)
+
+This module makes uploading forms nicer to deal with. In particlar, it turns `type="file"` elements into a native Stream (with backpressure and all) on the server-side so you can then simply pipe them.
+
+First, use [utilise/form](https://github.com/utilise/utilise#--form) to turn your form element into a simple plain JSON object.
+
+```js
+const { values } = form(formElement)
+```
+
+Then upload. You get two events for updates: `progress` and `response`.
+
+```js
+ripple.upload('resource', values)
+  .on('progress', progress => ...)
+  .on('progress', response => ...)
+```
+
+The `resource` identifies which handler to use on the server-side. For example, let's say you registered an `events` resource, then its `from` function would receive the upload. Complete example:
+
+```html
+<form>
+  <input type="text" name="title">
+  <input type="file" name="photos"> 
+</form>
+```
+
+```js
+
+// server
+ripple('events', [], { from })
+
+function from(req, res){
+  if (!req.type == 'upload') return
+
+  // req.value contains everything you need to process
+  req.value == {
+    name: ... // some text
+    photos: [...] // An array of streams, one for each file
+  }
+
+  // Use res to respond directly to the upload. 
+  // You can pass any arguments you like.
+  // This is what the "response" event on the client receives
+  if (success) 
+    res(200, '/event/123')
+  else
+    res(500, 'error')
+}
+
+// client
+const { values } = form(formElement)
+
+ripple.upload('events', values)
+  .on('progress', progress => {
+    swal({
+      title: 'Uploading Event..'
+    , content: progress + '%'
+    , type: 'working'
+    })
+  })
+  .on('response', (status, url) => {
+    const title   = status == 200 ? 'Done' : 'Error'
+        , type    = status == 200 ? 'success' : 'error' 
+        , content = status == 200 
+            ? 'Great - Your event has now been published!'
+            : 'Uh oh, something went wrong! Please try again later'
+        , buttons = [{ type: 'primary', text: 'Close' }]
+
+    go(url)
+    swal({ title, type, content, buttons })
+  })
+```
+
+(NB: `swal` comes from [pemrouz/sweet-alert](https://github.com/pemrouz/sweet-alert) and `go` from [pemrouz/decouter](https://github.com/pemrouz/decouter))

dist/index.js

@@ -0,0 +1,146 @@
+'use strict';
+
+Object.defineProperty(exports, "__esModule", {
+  value: true
+});
+exports.default = upload;
+
+var _emitterify = require('utilise/emitterify');
+
+var _emitterify2 = _interopRequireDefault(_emitterify);
+
+var _values = require('utilise/values');
+
+var _values2 = _interopRequireDefault(_values);
+
+var _client = require('utilise/client');
+
+var _client2 = _interopRequireDefault(_client);
+
+var _keys = require('utilise/keys');
+
+var _keys2 = _interopRequireDefault(_keys);
+
+var _key = require('utilise/key');
+
+var _key2 = _interopRequireDefault(_key);
+
+var _to = require('utilise/to');
+
+var _to2 = _interopRequireDefault(_to);
+
+/* istanbul ignore next */
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+// -------------------------------------------
+// Streams Forms
+// -------------------------------------------
+function upload(ripple) {
+  log('creating');
+
+  if (_client2.default) {
+    ripple.upload = up(ripple), ripple;
+    ripple.upload.log = [];
+  } else {
+    ripple.io.on('connection', connected(require('socket.io-stream')));
+  }
+
+  return ripple;
+}
+
+var connected = function connected(ss) {
+  return function (socket) {
+    socket.on('upload', function (meta, res) {
+      var id = socket.ip + '-' + meta.time;
+      log('uploading form', id);
+      meta.res = res;
+      buffer[id] = meta;
+      if (!(0, _values2.default)(meta.files).some(Boolean)) end(socket, id);
+    });
+
+    ss(socket).on('file', function (stream, data) {
+      var filename = data.filename;
+      var size = data.size;
+      var name = data.name;
+      var i = data.i;
+      var time = data.time;
+      var id = socket.ip + '-' + time;
+      var _buffer$id = buffer[id];
+      var files = _buffer$id.files;
+      var fields = _buffer$id.fields;
+      var resource = _buffer$id.resource;
+
+
+      fields[name][i] = stream;
+      if (fields[name].filter(Boolean).length == files[name]) delete files[name];
+      if (!(0, _values2.default)(files).some(Boolean)) end(socket, id);
+    });
+
+    var end = function end(socket, id) {
+      var type = 'upload';
+      var resource = buffer[id].resource;
+      var value = buffer[id].fields;
+      var time = buffer[id].time;
+      var res = buffer[id].res;
+      var from = (0, _key2.default)('resources.' + resource + '.headers.from')(ripple);
+      var name = resource.name;
+
+
+      log('finished', id, time);
+      if (!from) return err('no handler for', resource);
+      from({ name: name, type: type, value: value, socket: socket }, res);
+      delete buffer[id];
+    };
+  };
+};
+
+var up = function up(ripple) {
+  return function (resource, data) {
+    var files = {},
+        fields = {},
+        ret = (0, _emitterify2.default)({}),
+        time = ripple.upload.log.push(ret) - 1,
+        meta = { files: files, fields: fields, resource: resource, time: time },
+        count = function count(d) {
+      return totalSize += d.size;
+    };
+
+    var totalSize = 0,
+        uploadedSize = 0;
+
+    (0, _keys2.default)(data).map(function (name) {
+      return data[name] instanceof FileList ? (files[name] = _to2.default.arr(data[name]).map(count).length, fields[name] = []) : fields[name] = data[name];
+    });
+
+    log('uploading form', meta, totalSize);
+    ripple.io.emit('upload', meta, done);
+
+    (0, _keys2.default)(files).map(function (name) {
+      var i = files[name];
+      while (i--) {
+        var file = data[name][i],
+            size = file.size,
+            filename = file.name,
+            stream = ss.createStream();
+
+        ss(ripple.io).emit('file', stream, { filename: filename, size: size, name: name, i: i, time: time });
+        ss.createBlobReadStream(file).on('data', function (chunk) {
+          uploadedSize += chunk.length;
+          ret.emit('progress', ~~(uploadedSize / totalSize * 100));
+        }).pipe(stream);
+      }
+    });
+
+    function done() {
+      log('uploaded', time, arguments);
+      ret.emit('response', arguments);
+      delete ripple.upload.log[time];
+    }
+
+    return ret;
+  };
+};
+
+var log = require('utilise/log')('[ri/upload]'),
+    err = require('utilise/err')('[ri/upload]'),
+    buffer = {};

package.json

@@ -0,0 +1,49 @@
+{
+  "name": "rijs.upload",
+  "version": "0.0.0",
+  "main": "dist",
+  "author": "Pedram Emrouznejad (https://github.com/pemrouz)",
+  "repository": {
+    "type": "git",
+    "url": "git://github.com/rijs/upload.git"
+  },
+  "scripts": {
+    "ignore": "find ./dist -type f -exec sed -i -E \"s/(function _interopRequire)/\\/* istanbul ignore next *\\/\\n\\1/g\" {} ';'",
+    "babel": "babel src -d dist",
+    "clean": "rm -rf dist && mkdir dist",
+    "build": "npm run clean && npm run babel && npm run ignore",
+    "test": "istanbul test ./node_modules/mocha/bin/_mocha --report html -- -R spec --colors",
+    "coverage": "istanbul cover ./node_modules/mocha/bin/_mocha --report lcovonly -- -R spec && rm -rf ./coverage --colors",
+    "cov": "istanbul cover ./node_modules/mocha/bin/_mocha -- -R spec --colors",
+    "test-popper": "popper",
+    "version": "npm run build && git add -A",
+    "postversion": "git push && git push --tags"
+  },
+  "license": "pemrouz.mit-license.org",
+  "devDependencies": {
+    "babel-cli": "*",
+    "babel-preset-es2015": "*",
+    "browserify": "*",
+    "browserenv": "*",
+    "chai": "*",
+    "coveralls": "*",
+    "istanbul": "*",
+    "mocha": "*",
+    "mocha-lcov-reporter": "*",
+    "mockery": "^1.4.0",
+    "popper": "*",
+    "rijs.components": "*",
+    "rijs.core": "*",
+    "rijs.css": "*",
+    "rijs.data": "*",
+    "rijs.fn": "*",
+    "rijs.serve": "*",
+    "rijs.shadow": "*",
+    "rijs.sync": "*",
+    "uglify-js": "*"
+  },
+  "dependencies": {
+    "socket.io-stream": "^0.9.0",
+    "utilise": "*"
+  }
+}