Procházet zdrojové kódy

transloadit: reduce excessive polling (#1689)

Renée Kooi před 5 roky
rodič
revize
d60e67becd
1 změnil soubory, kde provedl 6 přidání a 3 odebrání
  1. 6 3
      packages/@uppy/transloadit/src/Assembly.js

+ 6 - 3
packages/@uppy/transloadit/src/Assembly.js

@@ -88,12 +88,11 @@ class TransloaditAssembly extends Emitter {
 
 
     socket.on('assembly_upload_finished', (file) => {
     socket.on('assembly_upload_finished', (file) => {
       this.emit('upload', file)
       this.emit('upload', file)
-      this._fetchStatus({ diff: false })
+      this.status.uploads.push(file)
     })
     })
 
 
     socket.on('assembly_uploading_finished', () => {
     socket.on('assembly_uploading_finished', () => {
       this.emit('executing')
       this.emit('executing')
-      this._fetchStatus({ diff: false })
     })
     })
 
 
     socket.on('assembly_upload_meta_data_extracted', () => {
     socket.on('assembly_upload_meta_data_extracted', () => {
@@ -103,11 +102,15 @@ class TransloaditAssembly extends Emitter {
 
 
     socket.on('assembly_result_finished', (stepName, result) => {
     socket.on('assembly_result_finished', (stepName, result) => {
       this.emit('result', stepName, result)
       this.emit('result', stepName, result)
-      this._fetchStatus({ diff: false })
+      if (!this.status.results[stepName]) {
+        this.status.results[stepName] = []
+      }
+      this.status.results[stepName].push(result)
     })
     })
 
 
     socket.on('assembly_error', (err) => {
     socket.on('assembly_error', (err) => {
       this._onError(err)
       this._onError(err)
+      // Refetch for updated status code
       this._fetchStatus({ diff: false })
       this._fetchStatus({ diff: false })
     })
     })