[Draft] [MWPW-179252] Add pageConfig call for optimal endpoint

unitylibs/core/workflow/workflow-acrobat/action-binder.js

@@ -109,6 +109,7 @@ export default class ActionBinder {
     upload_warn_delete_asset: -603,
     validation_warn_validate_files: -604,
     warn_fetch_experiment: -605,
+    warn_page_config_call_failed: -606,
   };
 
   static NEW_TO_OLD_ERROR_KEY_MAP = {
@@ -215,13 +216,17 @@ export default class ActionBinder {
     });
   }
 
-  getAcrobatApiConfig() {
-    unityConfig.acrobatEndpoint = {
-      createAsset: `${unityConfig.apiEndPoint}/asset`,
-      finalizeAsset: `${unityConfig.apiEndPoint}/asset/finalize`,
-      getMetadata: `${unityConfig.apiEndPoint}/asset/metadata`,
+  getAcrobatApiConfig(newAPIEndpoint) {
+    const apiEndPoint = newAPIEndpoint || unityConfig.apiEndPoint;
+    return {
+      acrobatEndpoint: {
+        createAsset: `${apiEndPoint}/asset`,
+        finalizeAsset: `${apiEndPoint}/asset/finalize`,
+        getMetadata: `${apiEndPoint}/asset/metadata`,
+        connector: `${apiEndPoint}/asset/connector`,
+        log: `${apiEndPoint}/log`,
+      },
     };
-    return unityConfig;
   }
 
   getAdditionalHeaders() {
@@ -281,6 +286,7 @@ export default class ActionBinder {
             subCode: ActionBinder.ERROR_MAP[errorMetaData.subCode] || errorMetaData.subCode || status,
             desc: errorMetaData.desc || message || info || undefined,
           },
+          logEndPoint: this.acrobatApiConfig?.acrobatEndpoint?.log,
           sendToSplunk,
         },
       },
@@ -289,7 +295,7 @@ export default class ActionBinder {
 
   async dispatchAnalyticsEvent(eventName, data = null) {
     const sendToSplunk = this.workflowCfg.targetCfg.sendSplunkAnalytics;
-    const detail = { event: eventName, ...(data && { data }), sendToSplunk };
+    const detail = { event: eventName, ...(data && { data }), logEndPoint: this.acrobatApiConfig?.acrobatEndpoint?.log, sendToSplunk };
     this.block.dispatchEvent(new CustomEvent(unityConfig.trackAnalyticsEvent, { detail }));
   }
 
@@ -426,7 +432,7 @@ export default class ActionBinder {
     const postOpts = await getApiCallOptions('POST', unityConfig.apiKey, this.getAdditionalHeaders() || {}, { body: JSON.stringify(cOpts) });
     this.promiseStack.push(
       this.networkUtils.fetchFromServiceWithRetry(
-        this.acrobatApiConfig.connectorApiEndPoint,
+        this.acrobatApiConfig.acrobatEndpoint.connector,
         postOpts,
       ),
     );
@@ -511,6 +517,7 @@ export default class ActionBinder {
     const { isValid, validFiles } = await this.validateFiles(sanitizedFiles);
     if (!isValid) return;
     await this.initUploadHandler();
+    await this.ensureOptimalEndpoint();
     if (files.length === 1 || (validFiles.length === 1 && !verbsWithoutFallback.includes(this.workflowCfg.enabledFeatures[0]))) {
       await this.handleSingleFileUpload(validFiles);
     } else {
@@ -682,6 +689,25 @@ export default class ActionBinder {
     this.filesData.assetId = assetId;
   }
 
+  async ensureOptimalEndpoint() {
+    if (this.pageConfigPromise) {
+      await this.pageConfigPromise;
+    }
+  }
+
+  async checkandUpdatePageConfigEndpoint() {
+    await this.networkUtils.checkandUpdatePageConfigEndpoint(
+      (newEndpoint) => {
+        // send analytics event before updating the endpoint, where the pageConfig call is made.
+        this.dispatchAnalyticsEvent('pageConfigUpdated', { newEndpoint });
+        this.acrobatApiConfig = this.getAcrobatApiConfig(newEndpoint);
+      },
+      (failure) => {
+        this.dispatchErrorToast('warn_page_config_call_failed', null, null, true, true, { code: 'warn_page_config_call_failed', subCode: failure?.status, desc: failure?.type });
+      },
+    );
+  }
+
   async initActionListeners(b = this.block, actMap = this.actionMap) {
     for (const [key, value] of Object.entries(actMap)) {
       const el = b.querySelector(key);
@@ -714,5 +740,8 @@ export default class ActionBinder {
     if (b === this.block) {
       this.loadTransitionScreen();
     }
+    if (!this.pageConfigPromise) {
+      this.pageConfigPromise = this.checkandUpdatePageConfigEndpoint();
+    }
   }
 }

unitylibs/utils/NetworkUtils.js

@@ -1,3 +1,5 @@
+import { unityConfig, getApiCallOptions } from '../scripts/utils.js';
+
 export default class NetworkUtils {
   handleAbortedRequest(url, options) {
     if (!(options?.signal?.aborted)) return;
@@ -151,4 +153,30 @@ export default class NetworkUtils {
       throw error;
     }
   }
+
+  async checkandUpdatePageConfigEndpoint(updateConfigCallback, onFailure) {
+    try {
+      const TIMEOUT_MS = 5000;
+      const getOpts = await getApiCallOptions('GET', unityConfig.apiKey, {}, {});
+      const pageConfigUrl = `${unityConfig.apiEndPoint}/pageConfig`;
+      const pageConfigResponse = await this.fetchWithTimeout(pageConfigUrl, getOpts, TIMEOUT_MS);
+      if (pageConfigResponse.ok) {
+        const locationHeader = pageConfigResponse.headers.get('location');
+        if (locationHeader) {
+          const newEndpoint = `${locationHeader}/api/v1`;
+          if (typeof updateConfigCallback === 'function') updateConfigCallback(newEndpoint);
+          return;
+        }
+        console.warn('No location header found, keeping existing API endpoint');
+        if (typeof onFailure === 'function') onFailure({ type: 'no-location-header', status: pageConfigResponse.status });
+        return;
+      }
+      console.error('pageConfig call failed with status:', pageConfigResponse.status);
+      if (typeof onFailure === 'function') onFailure({ type: 'non-ok-status', status: pageConfigResponse.status });
+      return;
+    } catch (error) {
+      console.error('pageConfig call failed with error:', error);
+      if (typeof onFailure === 'function') onFailure({ type: `Network-error - ${error.message}` });
+    }
+  }
 }