double flushPromises

Author: JulienChampagnol

components/FileUploader.vue

@@ -56,39 +56,31 @@
   const toggle_loading = useToggle(loading)
 
   async function upload_files() {
-    console.log("upload_files", schema)
     toggle_loading()
     var promise_array = []
     for (const file of internal_files.value) {
-      console.log("upload_files", file)
       const promise = new Promise((resolve, reject) => {
         upload_file(
           { route: schema.$id, file },
           {
             request_error_function: () => {
-              console.log("upload_files request_error_function")
               reject()
             },
             response_function: () => {
-              console.log("upload_files response_function")
               resolve()
             },
             response_error_function: () => {
-              console.log("upload_files response_error_function")
               reject()
             },
           },
         )
       })
       promise_array.push(promise)
     }
-    console.log("upload_files before await")
     await Promise.all(promise_array)
-    console.log("upload_files after await")
     files_uploaded.value = true
     emit("files_uploaded", internal_files.value)
 
-    console.log("emitted", internal_files.value)
     toggle_loading()
   }
 

components/ObjectSelector.vue

@@ -72,25 +72,14 @@
     var promise_array = []
     for (const filename of filenames) {
       const params = { filename, supported_feature }
-      const promise = new Promise((resolve, reject) => {
-        api_fetch(
-          { schema, params },
-          {
-            request_error_function: () => {
-              reject()
-            },
-            response_function: (response) => {
-              resolve(response._data.allowed_objects)
-            },
-            response_error_function: () => {
-              reject()
-            },
-          },
-        )
-      })
+      const promise = api_fetch({ schema, params })
       promise_array.push(promise)
     }
-    const values = await Promise.all(promise_array)
+    const responses = await Promise.all(promise_array)
+    let values = []
+    for (const response of responses) {
+      values.push(response.data.value.allowed_objects)
+    }
     const all_keys = [...new Set(values.flatMap((value) => Object.keys(value)))]
     const common_keys = all_keys.filter(
       (i) => !values.some((j) => !Object.keys(j).includes(i)),
@@ -119,7 +108,6 @@
       emit("increment_step")
     }
   }
-
   await get_allowed_objects()
 </script>
 

composables/api_fetch.js

@@ -29,46 +29,41 @@ export function api_fetch(
   if (schema.max_retry) {
     request_options.max_retry = schema.max_retry
   }
-  return new Promise((resolve, reject) => {
-    useFetch(schema.$id, {
-      baseURL: geode_store.base_url,
-      ...request_options,
-      async onRequestError({ error }) {
+  return useFetch(schema.$id, {
+    baseURL: geode_store.base_url,
+    ...request_options,
+    async onRequestError({ error }) {
+      await geode_store.stop_request()
+      await feedback_store.add_error(
+        error.code,
+        schema.$id,
+        error.message,
+        error.stack,
+      )
+      if (request_error_function) {
+        await request_error_function(error)
+      }
+    },
+    async onResponse({ response }) {
+      if (response.ok) {
         await geode_store.stop_request()
-        await feedback_store.add_error(
-          error.code,
-          schema.$id,
-          error.message,
-          error.stack,
-        )
-        if (request_error_function) {
-          await request_error_function(error)
+        if (response_function) {
+          await response_function(response)
         }
-        reject(error)
-      },
-      async onResponse({ response }) {
-        if (response.ok) {
-          await geode_store.stop_request()
-          if (response_function) {
-            await response_function(response)
-          }
-          resolve(response)
-        }
-      },
-      async onResponseError({ response }) {
-        await geode_store.stop_request()
-        await feedback_store.add_error(
-          response.status,
-          schema.$id,
-          response._data.name,
-          response._data.description,
-        )
-        if (response_error_function) {
-          await response_error_function(response)
-        }
-        reject(response)
-      },
-    })
+      }
+    },
+    async onResponseError({ response }) {
+      await geode_store.stop_request()
+      await feedback_store.add_error(
+        response.status,
+        schema.$id,
+        response._data.name,
+        response._data.description,
+      )
+      if (response_error_function) {
+        await response_error_function(response)
+      }
+    },
   })
 }
 

composables/upload_file.js

@@ -1,3 +1,5 @@
+import { useAppConfig } from "nuxt/app"
+
 export async function upload_file(
   { route, file },
   { request_error_function, response_function, response_error_function } = {},
@@ -18,8 +20,7 @@ export async function upload_file(
   }
 
   geode_store.start_request()
-  console.log("upload_file start request")
-  return useFetch(route, {
+  return $fetch(route, {
     baseURL: geode_store.base_url,
     ...request_options,
     onRequest({ request }) {