|
@@ -696,12 +696,13 @@ export default class Transloadit<
|
|
|
this.assembly = new Assembly(previousAssembly, this.#rateLimitedQueue)
|
|
|
this.assembly.status = previousAssembly
|
|
|
this.setPluginState({ files, results })
|
|
|
+ return files
|
|
|
}
|
|
|
|
|
|
|
|
|
- const restoreAssemblies = () => {
|
|
|
+ const restoreAssemblies = (ids: string[]) => {
|
|
|
this.#createAssemblyWatcher(previousAssembly.assembly_id)
|
|
|
- this.#connectAssembly(this.assembly!)
|
|
|
+ this.#connectAssembly(this.assembly!, ids)
|
|
|
}
|
|
|
|
|
|
|
|
@@ -711,8 +712,8 @@ export default class Transloadit<
|
|
|
|
|
|
|
|
|
this.restored = (async () => {
|
|
|
- restoreState()
|
|
|
- restoreAssemblies()
|
|
|
+ const files = restoreState()
|
|
|
+ restoreAssemblies(Object.keys(files))
|
|
|
await updateAssembly()
|
|
|
this.restored = null
|
|
|
})()
|
|
@@ -722,7 +723,7 @@ export default class Transloadit<
|
|
|
})
|
|
|
}
|
|
|
|
|
|
- #connectAssembly(assembly: Assembly) {
|
|
|
+ #connectAssembly(assembly: Assembly, ids: UppyFile<M, B>['id'][]) {
|
|
|
const { status } = assembly
|
|
|
const id = status.assembly_id
|
|
|
this.assembly = assembly
|
|
@@ -754,7 +755,7 @@ export default class Transloadit<
|
|
|
|
|
|
|
|
|
|
|
|
- for (const file of this.uppy.getFiles()) {
|
|
|
+ for (const file of this.uppy.getFilesByIds(ids)) {
|
|
|
this.uppy.emit('postprocess-progress', file, {
|
|
|
mode: 'determinate',
|
|
|
value: details.progress_combined / 100,
|
|
@@ -816,7 +817,7 @@ export default class Transloadit<
|
|
|
this.uppy.emit('preprocess-complete', file)
|
|
|
})
|
|
|
this.#createAssemblyWatcher(assembly.status.assembly_id)
|
|
|
- this.#connectAssembly(assembly)
|
|
|
+ this.#connectAssembly(assembly, fileIDs)
|
|
|
} catch (err) {
|
|
|
fileIDs.forEach((fileID) => {
|
|
|
const file = this.uppy.getFile(fileID)
|