feat: introduce method to fetch origin config

kubeshop · Nov 15, 2023 · 282aebf · 282aebf
1 parent 9182e70
commit 282aebf
Show file tree

Hide file tree

Showing 2 changed files with 66 additions and 9 deletions.
diff --git a/packages/synchronizer/src/handlers/apiHandler.ts b/packages/synchronizer/src/handlers/apiHandler.ts
@@ -3,6 +3,7 @@ import fetch from 'node-fetch';
 import {SuppressionStatus} from '@monokle/types';
 import {DEFAULT_API_URL} from '../constants.js';
 import type {TokenInfo} from './storageHandlerAuth.js';
+import { OriginConfig } from '../utils/fetcher.js';
 
 const getUserQuery = `
   query getUser {
@@ -176,8 +177,24 @@ export type ApiRepoIdData = {
 };
 
 export class ApiHandler {
-  constructor(private _apiUrl: string = DEFAULT_API_URL) {
-    if ((_apiUrl || '').length === 0) {
+  private _apiUrl: string;
+  private _originConfig?: OriginConfig;
+
+  constructor();
+  constructor(_apiUrl: string);
+  constructor(_originConfig: OriginConfig);
+  constructor(_apiUrlOrOriginConfig: string | OriginConfig = DEFAULT_API_URL) {
+
+    if (typeof _apiUrlOrOriginConfig === 'string') {
+      this._apiUrl = _apiUrlOrOriginConfig;
+    } else if (typeof _apiUrlOrOriginConfig === 'object') {
+      this._originConfig = _apiUrlOrOriginConfig;
+      this._apiUrl = _apiUrlOrOriginConfig.apiOrigin;
+    } else {
+      this._apiUrl = DEFAULT_API_URL;
+    }
+
+    if ((this._apiUrl || '').length === 0) {
       this._apiUrl = DEFAULT_API_URL;
     }
   }
@@ -207,15 +224,19 @@ export class ApiHandler {
   }
 
   generateDeepLink(path: string) {
-    if (this.apiUrl.includes('staging.monokle.com')) {
-      return normalizeUrl(`https://app.staging.monokle.com/${path}`);
-    } else if (this.apiUrl.includes('.monokle.com')) {
-      return normalizeUrl(`https://app.monokle.com/${path}`);
+    let appUrl = this._originConfig?.origin;
+
+    if (!appUrl) {
+      if (this.apiUrl.includes('staging.monokle.com')) {
+        appUrl = 'https://app.staging.monokle.com/';
+      } else if (this.apiUrl.includes('.monokle.com')) {
+        appUrl = 'https://app.monokle.com/';
+      } else {
+        appUrl = this.apiUrl;
+      }
     }
 
-    // For any custom base urls we just append the path.
-    // @TODO this might need adjustment in the future for self-hosted solutions.
-    return normalizeUrl(`${this.apiUrl}/${path}`);
+    return normalizeUrl(`${appUrl}/${path}`);
   }
 
   async queryApi<OUT>(query: string, tokenInfo: TokenInfo, variables = {}): Promise<OUT | undefined> {

diff --git a/packages/synchronizer/src/utils/fetcher.ts b/packages/synchronizer/src/utils/fetcher.ts
@@ -1,3 +1,5 @@
+import normalizeUrl from 'normalize-url';
+import fetch from 'node-fetch';
 import {EventEmitter} from 'events';
 import {ApiHandler} from '../handlers/apiHandler.js';
 import {TokenInfo} from '../handlers/storageHandlerAuth.js';
@@ -13,13 +15,47 @@ export type QueryResult<T_DATA> = {
   error?: string;
 };
 
+export type OriginConfig = {
+  origin: string;
+  apiOrigin: string;
+  authOrigin: string;
+  authClientId: string;
+  [key: string]: string;
+};
+
 export class Fetcher extends EventEmitter {
   private _token: TokenInfo | undefined;
 
   constructor(private _apiHandler: ApiHandler) {
     super();
   }
 
+  static async getOriginConfig(origin: string): Promise<OriginConfig | undefined> {
+    try {
+      const configUrl = normalizeUrl(`${origin}/config.js`);
+      const response = await fetch(configUrl);
+      const responseText = await response.text();
+
+      const values = responseText.match(/([A-Z_]+)\s*:\s*"(.*?)"/gm)?.reduce((acc: Record<string, string>, match) => {
+        if (match[1] && match[2]) {
+          acc[match[1]] = match[2];
+        }
+        return acc;
+      }, {});
+
+      if (values) {
+        values.origin = origin;
+        values.apiOrigin = values.API_ORIGIN;
+        values.authOrigin = values.OIDC_DISCOVERY_URL;
+        values.authClientId = values.CLIENT_ID;
+      }
+
+      return values as OriginConfig;
+    } catch (error: any) {
+      return undefined;
+    }
+  }
+
   useBearerToken(token: string) {
     this._token = {
       accessToken: token,