feat: LEAP-58: Proxy URL for Taxonomy if possible (#1592)

* feat: LEAP-58: Proxy URL for Taxonomy if possible

onProxyUrl should be provided to LSF from LS.
TODO: can be not the correct way to call it, check how events invoke.

* Add `events` to store to have access anywhere

So events can be triggered and caught by any internal and external code

* additional work to get proxyurl working

* lint + merge fixes

* use new project scoped presigning path

* Update src/stores/AppStore.js

Co-authored-by: hlomzik <[email protected]>

* Update src/tags/control/Taxonomy/Taxonomy.js

Co-authored-by: hlomzik <[email protected]>

* empty commit to trigger build workflow

* trigger CI

---------

Co-authored-by: Jo Booth <[email protected]>
Co-authored-by: MihajloHoma <[email protected]>

Author: 3 people

src/env/development.js

@@ -152,6 +152,7 @@ function configureApplication(params) {
     onDeleteAnnotation: params.onDeleteAnnotation ? params.onDeleteAnnotation : External.onDeleteAnnotation,
     onSkipTask: params.onSkipTask ? params.onSkipTask : External.onSkipTask,
     onUnskipTask: params.onUnskipTask ? params.onUnskipTask : External.onUnskipTask,
+    onPresignUrlForProject: params.onPresignUrlForProject,
     onSubmitDraft: params.onSubmitDraft,
     onTaskLoad: params.onTaskLoad ? params.onTaskLoad : External.onTaskLoad,
     onLabelStudioLoad: params.onLabelStudioLoad ? params.onLabelStudioLoad : External.onLabelStudioLoad,

src/env/production.js

@@ -65,6 +65,7 @@ function configureApplication(params) {
     onSkipTask: params.onSkipTask ? params.onSkipTask : External.onSkipTask,
     onUnskipTask: params.onUnskipTask ? params.onUnskipTask : External.onUnskipTask,
     onSubmitDraft: params.onSubmitDraft,
+    onPresignUrlForProject: params.onPresignUrlForProject,
     onTaskLoad: params.onTaskLoad || External.onTaskLoad,
     onLabelStudioLoad: params.onLabelStudioLoad || External.onLabelStudioLoad,
     onEntityCreate: params.onEntityCreate || External.onEntityCreate,

src/stores/AppStore.js

@@ -22,7 +22,7 @@ import AnnotationStore from './Annotation/store';
 import Project from './ProjectStore';
 import Settings from './SettingsStore';
 import Task from './TaskStore';
-import { UserExtended } from './UserStore'; 
+import { UserExtended } from './UserStore';
 import { UserLabels } from './UserLabels';
 import { FF_DEV_1536, FF_DEV_2715, FF_LLM_EPIC, FF_LSDV_4620_3_ML, FF_LSDV_4998, isFF } from '../utils/feature-flags';
 import { CommentStore } from './Comment/CommentStore';
@@ -154,9 +154,9 @@ export default types
     users: types.optional(types.array(UserExtended), []),
 
     userLabels: isFF(FF_DEV_1536) ? types.optional(UserLabels, { controls: {} }) : types.undefined,
-    
+
     queueTotal: types.optional(types.number, 0),
-    
+
     queuePosition: types.optional(types.number, 0),
   })
   .preProcessSnapshot((sn) => {
@@ -189,6 +189,9 @@ export default types
     suggestionsRequest: null,
   }))
   .views(self => ({
+    get events() {
+      return getEnv(self).events;
+    },
     get hasSegmentation() {
       // not an object and not a classification
       const isSegmentation = t => !t.getAvailableStates && !t.perRegionVisible;
@@ -622,6 +625,18 @@ export default types
       }, 'Error during reject, try again');
     }
 
+    /**
+     * Exchange storage url for presigned url for task
+     */
+    async function presignUrlForProject(url) {
+      // Event invocation returns array of results for all handlers.
+      const urls = await self.events.invoke('presignUrlForProject', self, url);
+
+      const presignUrl = urls?.[0];
+
+      return presignUrl;
+    }
+
     /**
      * Reset annotation store
      */
@@ -772,7 +787,7 @@ export default types
     }
 
     function nextTask() {
-      
+
       if (self.canGoNextTask) {
         const { taskId, annotationId } = self.taskHistory[self.taskHistory.findIndex((x) => x.taskId === self.task.id) + 1];
 
@@ -831,6 +846,7 @@ export default types
       updateAnnotation,
       acceptAnnotation,
       rejectAnnotation,
+      presignUrlForProject,
       setUsers,
       mergeUsers,
 

src/tags/control/Taxonomy/Taxonomy.js

@@ -549,6 +549,8 @@ const Model = types
         if (!self.isLoadedByApi) return Super.updateValue?.(store);
 
         self._api = parseValue(self.apiurl, store.task.dataObj);
+        // trying to presign this url if needed and if handler is passed into LSF
+        self._api = (yield store.presignUrlForProject(self._api)) ?? self._api;
 
         yield self.loadItems();
       }),