febs - npm Package Compare versions

Comparing version 0.2.10 to 0.2.11

HISTORY.md

@@ -45,2 +45,6 @@
 ==================
-  - [feature] febs.utils.getTimeStringFromNow
+  - [feature] febs.utils.getTimeStringFromNow
+
+0.2.11
+==================
+  - [bugfix] control upload.

package.json

@@ -45,3 +45,3 @@ {
   "name": "febs",
-  "version": "0.2.10"
+  "version": "0.2.11"
 }

README.md

@@ -0,0 +0,0 @@ febs 库是一些常用的工具的合集;

server/controls/index.js

 exports.upload = require('./upload');

server/controls/upload.js

@@ -32,3 +32,2 @@ 'use strict';
 function save_to(stream, writeStream, writeStreamPath, size, crc32, done) {
-
   // streams2+: assert the stream encoding is buffer.
@@ -133,2 +132,4 @@ var state = stream._readableState;
     writeStream.removeListener('close', onFinish)
+    
+    writeStream.end()
 
@@ -150,3 +151,3 @@ stream = writeStream = null
  */
-exports.accept = async function(app, conditionCB)
+exports.accept = function(app, conditionCB)
 {
@@ -192,12 +193,15 @@ assert(conditionCB);
 
-    co(function* () {
-      // yield each part as a stream
-      var part;
-      while (part = yield parts) {
-        var srcStream = part;
+    parts(function(err, part){
+      if (err) {
+        reject(err);
+        return;
+      }
 
-        conditionCB(query.data, Number(query.size), part.filename, part.mimeType)
+      var srcStream = part;
+      conditionCB(query.data, Number(query.size), part.filename, part.mimeType)
         .then(fn=>{
           if (!fn)
           {
+            console.debug('febs upload.accpet un return a filename');
+
             if (typeof srcStream.pause === 'function')
@@ -227,23 +231,17 @@ srcStream.pause();
 
-          co(function* () {
-            var ret = yield save_to(srcStream, destStream, fn, Number(query.size), Number(query.crc32));
-            return ret;
-          }).then(function (value) {
-            resolve(value);
-          }, function (err) {
-            reject(err);
+          save_to(srcStream, destStream, fn, Number(query.size), Number(query.crc32), (err, ret)=>{
+            if (err)
+              reject(err);
+            else
+              resolve(ret);
           });
-
         })
+        .then(ret=>{
+        })
         .catch(err=>{
           reject(err);
         });
-
-        return;
-      }
-    }).then(function (value) {
-    }, function (err) {
-      reject(err);
     });
+      
   });
 };

server/crypt.js

@@ -0,0 +0,0 @@ 'use strict';

server/exception.js

@@ -0,0 +0,0 @@ 'use strict';

server/file.js

@@ -0,0 +0,0 @@ 'use strict';

server/index.js

@@ -0,0 +0,0 @@

server/string.js

@@ -0,0 +0,0 @@ 'use strict';

server/utils.js

@@ -0,0 +0,0 @@ 'use strict';

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

325788

decreased by-0.71%

Lines of code

1846

decreased by-0.11%

No dependency changes