Skip to content

Commit

Permalink
chore: build dist
Browse files Browse the repository at this point in the history
  • Loading branch information
pemrouz committed Aug 5, 2016
1 parent 2cd0007 commit d19a416
Showing 1 changed file with 15 additions and 13 deletions.
28 changes: 15 additions & 13 deletions dist/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,10 @@ var _to = require('utilise/to');

var _to2 = _interopRequireDefault(_to);

var _socket = require('socket.io-stream');

var _socket2 = _interopRequireDefault(_socket);

/* istanbul ignore next */
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

Expand All @@ -42,13 +46,13 @@ function upload(ripple) {
ripple.upload = up(ripple), ripple;
ripple.upload.log = [];
} else {
ripple.io.on('connection', connected(require('socket.io-stream')));
ripple.io.on('connection', connected(ripple, _socket2.default));
}

return ripple;
}

var connected = function connected(ss) {
var connected = function connected(ripple, ss) {
return function (socket) {
socket.on('upload', function (meta, res) {
var id = socket.ip + '-' + meta.time;
Expand Down Expand Up @@ -77,18 +81,16 @@ var connected = function connected(ss) {
});

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 _buffer$id2 = buffer[id];
var resource = _buffer$id2.resource;
var fields = _buffer$id2.fields;
var time = _buffer$id2.time;
var res = _buffer$id2.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);
from({ name: resource, type: 'upload', value: fields, socket: socket }, res);
delete buffer[id];
};
};
Expand Down Expand Up @@ -121,10 +123,10 @@ var up = function up(ripple) {
var file = data[name][i],
size = file.size,
filename = file.name,
stream = ss.createStream();
stream = _socket2.default.createStream();

ss(ripple.io).emit('file', stream, { filename: filename, size: size, name: name, i: i, time: time });
ss.createBlobReadStream(file).on('data', function (chunk) {
(0, _socket2.default)(ripple.io).emit('file', stream, { filename: filename, size: size, name: name, i: i, time: time });
_socket2.default.createBlobReadStream(file).on('data', function (chunk) {
uploadedSize += chunk.length;
ret.emit('progress', ~~(uploadedSize / totalSize * 100));
}).pipe(stream);
Expand Down

0 comments on commit d19a416

Please sign in to comment.