@uppy/transloadit - npm Package Compare versions

Comparing version 4.1.1 to 4.1.2

CHANGELOG.md

 # @uppy/transloadit
 
+## 4.1.2
+
+Released: 2024-09-30
+Included in: Uppy v4.4.1
+
+- @uppy/transloadit: fix multiple upload batches & run again (Merlijn Vos / #5478)
+
 ## 4.1.0
@@ -4,0 +11,0 @@

lib/index.js

@@ -16,3 +16,3 @@ function _classPrivateFieldLooseBase(e, t) { if (!{}.hasOwnProperty.call(e, t)) throw new TypeError("attempted to use private field on non-instance"); return e; }
 const packageJson = {
-  "version": "4.1.1"
+  "version": "4.1.2"
 }; // eslint-disable-next-line @typescript-eslint/no-unused-vars
@@ -253,8 +253,9 @@ const defaultOptions = {
           });
+          return files;
         };
 
         // Set up the Assembly instances and AssemblyWatchers for existing Assemblies.
-        const restoreAssemblies = () => {
+        const restoreAssemblies = ids => {
           _classPrivateFieldLooseBase(this, _createAssemblyWatcher)[_createAssemblyWatcher](previousAssembly.assembly_id);
-          _classPrivateFieldLooseBase(this, _connectAssembly)[_connectAssembly](this.assembly);
+          _classPrivateFieldLooseBase(this, _connectAssembly)[_connectAssembly](this.assembly, ids);
         };
@@ -270,4 +271,4 @@
         this.restored = (async () => {
-          restoreState();
-          restoreAssemblies();
+          const files = restoreState();
+          restoreAssemblies(Object.keys(files));
           await updateAssembly();
@@ -301,3 +302,3 @@ this.restored = null;
           _classPrivateFieldLooseBase(this, _createAssemblyWatcher)[_createAssemblyWatcher](assembly.status.assembly_id);
-          _classPrivateFieldLooseBase(this, _connectAssembly)[_connectAssembly](assembly);
+          _classPrivateFieldLooseBase(this, _connectAssembly)[_connectAssembly](assembly, fileIDs);
         } catch (err) {
@@ -759,3 +760,3 @@ fileIDs.forEach(fileID => {
 }
-function _connectAssembly2(assembly) {
+function _connectAssembly2(assembly, ids) {
   const {
@@ -788,3 +789,3 @@ status
       // files are not registered with Uppy.
-      for (const file of this.uppy.getFiles()) {
+      for (const file of this.uppy.getFilesByIds(ids)) {
         this.uppy.emit('postprocess-progress', file, {
@@ -791,0 +792,0 @@ mode: 'determinate',

package.json

 {
   "name": "@uppy/transloadit",
   "description": "The Transloadit plugin can be used to upload files to Transloadit for all kinds of processing, such as transcoding video, resizing images, zipping/unzipping, and more",
-  "version": "4.1.1",
+  "version": "4.1.2",
   "license": "MIT",
@@ -37,3 +37,3 @@ "main": "lib/index.js",
   "peerDependencies": {
-    "@uppy/core": "^4.2.0"
+    "@uppy/core": "^4.2.1"
   },
@@ -40,0 +40,0 @@ "devDependencies": {

src/index.ts

@@ -699,8 +699,9 @@ import hasProperty from '@uppy/utils/lib/hasProperty'
       this.setPluginState({ files, results })
+      return files
     }
 
     // Set up the Assembly instances and AssemblyWatchers for existing Assemblies.
-    const restoreAssemblies = () => {
+    const restoreAssemblies = (ids: string[]) => {
       this.#createAssemblyWatcher(previousAssembly.assembly_id)
-      this.#connectAssembly(this.assembly!)
+      this.#connectAssembly(this.assembly!, ids)
     }
@@ -715,4 +716,4 @@
     this.restored = (async () => {
-      restoreState()
-      restoreAssemblies()
+      const files = restoreState()
+      restoreAssemblies(Object.keys(files))
       await updateAssembly()
@@ -727,3 +728,3 @@ this.restored = null
 
-  #connectAssembly(assembly: Assembly) {
+  #connectAssembly(assembly: Assembly, ids: UppyFile<M, B>['id'][]) {
     const { status } = assembly
@@ -760,3 +761,3 @@ const id = status.assembly_id
           // files are not registered with Uppy.
-          for (const file of this.uppy.getFiles()) {
+          for (const file of this.uppy.getFilesByIds(ids)) {
             this.uppy.emit('postprocess-progress', file, {
@@ -823,3 +824,3 @@ mode: 'determinate',
       this.#createAssemblyWatcher(assembly.status.assembly_id)
-      this.#connectAssembly(assembly)
+      this.#connectAssembly(assembly, fileIDs)
     } catch (err) {
@@ -826,0 +827,0 @@ fileIDs.forEach((fileID) => {

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

Improved metrics

Total package byte prevSize

250691

increased by0.24%

Lines of code

3471

increased by0.06%

No dependency changes