jasontbradshaw / tailing-stream Goto Github PK

ss(socket).on('file', (stream, data) => {
    console.log('>>>Received File Emit at <<<', new Date().toString());
    console.log('data.originalName', data.originalName);

    var streamFileName = './uploads/'+data.originalName;

    stream.pipe(fs.createWriteStream( streamFileName ));
    
     var boxStream = ts.TailingReadableStream (path.join(__dirname, streamFileName),{timeout: 5000});

   function requestCallback(err, res, body) {
        console.log('Request body: ',body);
    }

      var total = 0;
      boxStream.on('data', (chunk) => {

        total += chunk.length;
        var progress = (1.0 * total) / data.size;
        console.log('Box upload progres : ', progress);
      });

      var accessToken = 'hidden';
      var parent_folder_id = 'hidden';

      var r = request.post({
          url: 'https://upload.box.com/api/2.0/files/content',
          headers: { 'Authorization': 'Bearer ' + accessToken }
          }, requestCallback);

      var form = r.form();

      form.append('parent_id', parent_folder_id);
      form.append("file", boxStream);        

});

Error [ERR_METHOD_NOT_IMPLEMENTED]: The _read() method is not implemented
    at TailingReadableStream.Readable._read (_stream_readable.js:611:24)
    at TailingReadableStream.Readable.read (_stream_readable.js:457:10)
    at flow (_stream_readable.js:957:34)
    at Mp4Frag.pipeOnDrainFunctionResult (_stream_readable.js:761:7)
    at Mp4Frag.emit (events.js:198:13)
    at onwriteDrain (_stream_writable.js:495:12)
    at afterWrite (_stream_writable.js:483:5)
    at process._tickCallback (internal/process/next_tick.js:63:19