feat(getters): add getters for busy services

Author: JulienChampagnol

stores/cloud.js

@@ -26,6 +26,9 @@ export const use_cloud_store = defineStore('cloud', {
       viewer_url = viewer_url + '/ws'
       return viewer_url
     },
+    api_busy: (state) => {
+      return state.request_counter > 0
+    }
   },
   actions: {
     async create_connexion () {

stores/viewer.js

@@ -19,128 +19,146 @@ export const use_viewer_store = defineStore('viewer', {
     async create_object_pipeline (params) {
       const websocket_store = use_websocket_store()
       if (websocket_store.client) {
-        use_websocket_store().client
+        websocket_store.start_request()
+        websocket_store.client
           .getRemote()
           .vtk.create_object_pipeline(params)
           .catch(console.error);
+        websocket_store.stop_request()
       }
     },
     async delete_object_pipeline (params) {
       const websocket_store = use_websocket_store()
       if (websocket_store.client) {
-        use_websocket_store().client
+        websocket_store.start_request()
+        websocket_store.client
           .getRemote()
           .vtk.delete_object_pipeline(params)
           .catch(console.error);
+        websocket_store.stop_request()
       }
     },
     async reset_camera () {
       const websocket_store = use_websocket_store()
       if (websocket_store.client) {
-        use_websocket_store().client
+        websocket_store.start_request()
+        websocket_store.client
           .getRemote()
           .vtk.reset_camera()
           .catch(console.error);
+        websocket_store.stop_request()
       }
     },
     async toggle_object_visibility (params) {
       const websocket_store = use_websocket_store()
       if (websocket_store.client) {
-        use_websocket_store().client
+        websocket_store.start_request()
+        websocket_store.client
           .getRemote()
           .vtk.toggle_object_visibility(params)
           .catch(console.error);
+        websocket_store.stop_request()
       }
     },
     async toggle_edge_visibility (params) {
       const websocket_store = use_websocket_store()
       if (websocket_store.client) {
-        use_websocket_store().client
+        websocket_store.start_request()
+        websocket_store.client
           .getRemote()
           .vtk.toggle_edge_visibility(params)
           .catch(console.error);
+        websocket_store.stop_request()
       }
     },
     async toggle_point_visibility (params) {
       const websocket_store = use_websocket_store()
       if (websocket_store.client) {
-        use_websocket_store().client
+        websocket_store.start_request()
+        websocket_store.client
           .getRemote()
           .vtk.toggle_point_visibility(params)
           .catch(console.error);
+        websocket_store.stop_request()
       }
     },
     async point_size (params) {
       const websocket_store = use_websocket_store()
       if (websocket_store.client) {
-        use_websocket_store().client
+        websocket_store.start_request()
+        websocket_store.client
           .getRemote()
           .vtk.point_size(params)
           .catch(console.error);
+        websocket_store.stop_request()
       }
     },
     async set_color (params) {
       const websocket_store = use_websocket_store()
       if (websocket_store.client) {
-        use_websocket_store().client
+        websocket_store.start_request()
+        websocket_store.client
           .getRemote()
           .vtk.set_color(params)
           .catch(console.error);
+        websocket_store.stop_request()
       }
     },
     async set_vertex_attribute (params) {
       const websocket_store = use_websocket_store()
       if (websocket_store.client) {
-        use_websocket_store().client
+        websocket_store.start_request()
+        websocket_store.client
           .getRemote()
           .vtk.set_vertex_attribute(params)
           .catch(console.error);
+        websocket_store.stop_request()
       }
     },
     async apply_textures (params) {
       const websocket_store = use_websocket_store()
       if (websocket_store.client) {
-        websocket_store.$patch({ busy: true })
-        use_websocket_store().client
+        websocket_store.start_request()
+        websocket_store.client
           .getRemote()
           .vtk.apply_textures(params)
           .catch(console.error);
-        websocket_store.$patch({ busy: false })
+        websocket_store.stop_request()
       }
     },
     async get_point_position (params) {
       const websocket_store = use_websocket_store()
       if (websocket_store.client) {
-        websocket_store.$patch({ busy: true })
-        const response = await use_websocket_store().client
+        websocket_store.start_request()
+        const response = await websocket_store.client
           .getRemote()
           .vtk.get_point_position(params)
           .catch(console.error);
-        websocket_store.$patch({ busy: false })
+        websocket_store.stop_request()
         return response
       }
     },
     async update_data (params) {
       const websocket_store = use_websocket_store()
       if (websocket_store.client) {
-        websocket_store.$patch({ busy: true })
-        const response = await use_websocket_store().client
+        websocket_store.start_request()
+        const response = await websocket_store.client
           .getRemote()
           .vtk.update_data(params)
           .catch(console.error);
-        websocket_store.$patch({ busy: false })
+        websocket_store.stop_request()
         return response
       }
     },
     async reset () {
       const websocket_store = use_websocket_store()
       if (websocket_store.client) {
-        websocket_store.$patch({ busy: true })
-        const response = await use_websocket_store().client
+        websocket_store.start_request()
+        const response = await websocket_store.client
           .getRemote()
           .vtk.reset()
           .catch(console.error);
-        websocket_store.$patch({ busy: false })
+        websocket_store.stop_request()
         return response
       }
     }

stores/websocket.js

@@ -16,9 +16,14 @@ export const use_websocket_store = defineStore('websocket', {
   state: () => ({
     client: {},
     config: null,
-    busy: false,
+    request_counter: 0,
     is_client_created: false
   }),
+  getters: {
+    websocket_busy: (state) => {
+      return state.request_counter > 0
+    }
+  },
   actions: {
     ws_connect () {
       const config = { application: 'cone' };
@@ -91,4 +96,10 @@ export const use_websocket_store = defineStore('websocket', {
       }
     },
   },
+  start_request (state) {
+    state.request_counter++
+  },
+  stop_request (state) {
+    state.request_counter--
+  }
 })