Feature/domain autocomplete cross region (#415)

* Added domain autocomplete to include cluster name on select of domain

* logging error object

Author: just-at-uber

client/containers/domain-autocomplete/actions.js

@@ -21,6 +21,10 @@
 
 import { debounce } from 'lodash-es';
 import { ROUTE_PUSH } from '../route/action-types';
+import {
+  CROSS_REGION_ALLOWED_CROSS_ORIGIN,
+  CROSS_REGION_CLUSTER_ORIGIN_LIST,
+} from '../cross-region/getter-types';
 import {
   DOMAIN_AUTOCOMPLETE_FETCH_DOMAIN_LIST,
   DOMAIN_AUTOCOMPLETE_ON_CHANGE,
@@ -33,33 +37,75 @@ import {
   DOMAIN_AUTOCOMPLETE_SET_VISITED_DOMAIN_LIST,
 } from './mutation-types';
 import {
-  DOMAIN_AUTOCOMPLETE_VISITED_DOMAIN_LIST,
   DOMAIN_AUTOCOMPLETE_SEARCH_URL,
+  DOMAIN_AUTOCOMPLETE_VISITED_DOMAIN_LIST,
 } from './getter-types';
 import { DEBOUNCE_WAIT } from './constants';
-import { updateVisitedDomainList } from './helpers';
+import {
+  updateVisitedDomainList,
+  filterDuplicatesFromDomainList,
+} from './helpers';
 import { httpService } from '~services';
 
 const actions = {
   [DOMAIN_AUTOCOMPLETE_FETCH_DOMAIN_LIST]: debounce(
     async ({ commit, getters }) => {
       const searchUrl = getters[DOMAIN_AUTOCOMPLETE_SEARCH_URL];
+      const allowedCrossOrigin = getters[CROSS_REGION_ALLOWED_CROSS_ORIGIN];
+      const clusterOriginList = getters[CROSS_REGION_CLUSTER_ORIGIN_LIST];
+
+      const fetchDomainForOrigin = async ({ clusterName = '', origin }) => {
+        try {
+          const result = await httpService.get(
+            `${origin}${searchUrl}`,
+            origin && {
+              credentials: 'include',
+              mode: 'cors',
+            }
+          );
 
-      const domainList = await httpService.get(searchUrl);
+          return result;
+        } catch (error) {
+          console.warn(
+            `Failed to fetch result from cluster "${clusterName}" with origin "${origin}" with error:`,
+            error
+          );
+        }
+      };
 
-      commit(DOMAIN_AUTOCOMPLETE_SET_IS_LOADING, false);
+      if (allowedCrossOrigin && clusterOriginList) {
+        const domainListSet = await Promise.all(
+          clusterOriginList.map(fetchDomainForOrigin)
+        );
 
-      commit(DOMAIN_AUTOCOMPLETE_SET_DOMAIN_LIST, domainList);
+        const domainList = filterDuplicatesFromDomainList(
+          domainListSet.filter(result => !!result).flat()
+        );
+
+        commit(DOMAIN_AUTOCOMPLETE_SET_IS_LOADING, false);
+        commit(DOMAIN_AUTOCOMPLETE_SET_DOMAIN_LIST, domainList);
+      } else {
+        const domainList = await fetchDomainForOrigin({ origin: '' });
+
+        commit(DOMAIN_AUTOCOMPLETE_SET_IS_LOADING, false);
+        commit(DOMAIN_AUTOCOMPLETE_SET_DOMAIN_LIST, domainList);
+      }
     },
     DEBOUNCE_WAIT
   ),
-  [DOMAIN_AUTOCOMPLETE_ON_CHANGE]: ({ commit, dispatch, getters }, payload) => {
+  [DOMAIN_AUTOCOMPLETE_ON_CHANGE]: async (
+    { commit, dispatch, getters },
+    payload
+  ) => {
     if (!payload) {
       return;
     }
 
     const { value } = payload;
     const visitedDomainList = getters[DOMAIN_AUTOCOMPLETE_VISITED_DOMAIN_LIST];
+    const allowedCrossOrigin = getters[CROSS_REGION_ALLOWED_CROSS_ORIGIN];
+    const dispatchToGlobalRoute = () =>
+      dispatch(ROUTE_PUSH, `/domains/${value.domainInfo.name}`);
 
     const updatedVisitedDomainList = updateVisitedDomainList({
       value,
@@ -71,7 +117,18 @@ const actions = {
       updatedVisitedDomainList
     );
 
-    dispatch(ROUTE_PUSH, `/domains/${value.domainInfo.name}`);
+    if (
+      value.isGlobalDomain ||
+      !allowedCrossOrigin ||
+      !value.replicationConfiguration
+    ) {
+      return dispatchToGlobalRoute();
+    }
+
+    dispatch(
+      ROUTE_PUSH,
+      `/domains/${value.domainInfo.name}/${value.replicationConfiguration.activeClusterName}`
+    );
   },
   [DOMAIN_AUTOCOMPLETE_ON_SEARCH]: async ({ commit, dispatch }, payload) => {
     commit(DOMAIN_AUTOCOMPLETE_SET_SEARCH, payload);

client/containers/domain-autocomplete/connector.js

@@ -47,7 +47,9 @@ const gettersToProps = {
 };
 
 const lifecycle = {
-  mounted: ({ commit }) => commit(DOMAIN_AUTOCOMPLETE_ON_MOUNTED),
+  mounted: ({ commit }) => {
+    commit(DOMAIN_AUTOCOMPLETE_ON_MOUNTED);
+  },
 };
 
 export default connect({

client/containers/domain-autocomplete/helpers/filter-duplicates-from-domain-list.js

@@ -0,0 +1,44 @@
+// Copyright (c) 2021 Uber Technologies Inc.
+//
+//
+// Permission is hereby granted, free of charge, to any person obtaining a copy
+// of this software and associated documentation files (the "Software"), to deal
+// in the Software without restriction, including without limitation the rights
+// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+// copies of the Software, and to permit persons to whom the Software is
+// furnished to do so, subject to the following conditions:
+//
+// The above copyright notice and this permission notice shall be included in
+// all copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+// THE SOFTWARE.
+
+const filterDuplicatesFromDomainList = domainList => {
+  return domainList.reduce(
+    (accumulator, domain) => {
+      const domainName = domain.domainInfo.name;
+
+      if (
+        !domain.isGlobalDomain ||
+        !accumulator.domainNameList.includes(domainName)
+      ) {
+        if (domain.isGlobalDomain) {
+          accumulator.domainNameList.push(domainName);
+        }
+
+        accumulator.result.push(domain);
+      }
+
+      return accumulator;
+    },
+    { domainNameList: [], result: [] }
+  ).result;
+};
+
+export default filterDuplicatesFromDomainList;

client/containers/domain-autocomplete/helpers/index.js

@@ -20,6 +20,7 @@
 // THE SOFTWARE.
 
 export { default as combineDomainList } from './combine-domain-list';
+export { default as filterDuplicatesFromDomainList } from './filter-duplicates-from-domain-list';
 export { default as filterTopDomainList } from './filter-top-domain-list';
 export { default as filterVisitedDomainList } from './filter-visited-domain-list';
 export { default as formatDomainLabel } from './format-domain-label';

client/containers/domain-autocomplete/helpers/update-visited-domain-list.js

@@ -26,7 +26,9 @@ const updateVisitedDomainList = ({ value, visitedDomainList }) => {
   const uuid = value.domainInfo.uuid || null;
 
   const matchedDomainIndex = visitedDomainList.findIndex(
-    domain => domain.domainInfo.uuid === uuid || domain.domainInfo.name === name
+    domain =>
+      domain.domainInfo.uuid === uuid ||
+      ((!uuid || !domain.domainInfo.uuid) && domain.domainInfo.name === name)
   );
 
   if (matchedDomainIndex === -1) {