feat(append): add support for beforeComplete

package.json

@@ -1,6 +1,6 @@
 {
   "name": "fs-tus-store",
-  "version": "1.2.0",
+  "version": "1.2.1",
   "description": "",
   "main": "./lib/index.js",
   "directories": {
@@ -64,7 +64,7 @@
     }
   },
   "dependencies": {
-    "abstract-tus-store": "^1.4.0",
+    "abstract-tus-store": "^1.5.0",
     "common-streams": "^1.2.0",
     "concat-stream": "^1.5.2",
     "debug": "^2.2.0",
@@ -74,4 +74,4 @@
     "string-to-stream": "^1.1.0",
     "uuid": "^2.0.3"
   }
-}
+}

src/index.js

@@ -154,7 +154,8 @@ export default ({
     return meterStream
   }
 
-  const completeUpload = async (uploadId, upload) => {
+  const completeUpload = async (uploadId, upload, beforeComplete) => {
+    await beforeComplete(upload, uploadId)
     const oldPath = keyToPath(uploadIdToDataKey(uploadId))
     const newPath = keyToPath(upload.key)
     const uploadResourcePath = keyToPath(uploadIdToKey(uploadId))
@@ -175,6 +176,7 @@ export default ({
       }
       return { expectedOffset: arg3, opts: arg4 }
     })()
+    const { beforeComplete = async () => {} } = opts
     // need to do this asap to make sure we don't miss reads
     const through = rs.pipe(new PassThrough())
 
@@ -203,7 +205,7 @@ export default ({
     })
     const newOffset = offset + bytesWritten
     if (newOffset === upload.uploadLength) {
-      await completeUpload(uploadId, upload)
+      await completeUpload(uploadId, upload, beforeComplete)
       return {
         offset: newOffset,
         complete: true,