EVEREST-1559 | remove proxy config for mongo with no sharding

ui/apps/everest/.e2e/pr/db-cluster/db-wizard/create-db-cluster/create-db-cluster.e2e.ts

@@ -139,7 +139,16 @@ test.describe('DB Cluster creation', () => {
 
     await resourcesStepCheck(page);
 
-    // Same number of proxies as nodes, as user hasn't changed it
+    // Sharding off, no routers available
+    await expect(page.getByText('Routers (3)')).not.toBeVisible();
+
+    await moveBack(page);
+    await page
+      .getByTestId('switch-input-sharding-label')
+      .getByRole('checkbox')
+      .check();
+    await moveForward(page);
+
     await expect(page.getByText('Routers (3)')).toBeVisible();
     await page.getByTestId('proxies-accordion').getByRole('button').click();
     await page.getByTestId('toggle-button-routers-1').click();
@@ -180,6 +189,10 @@ test.describe('DB Cluster creation', () => {
     await page.getByTestId('button-edit-preview-basic-information').click();
     // Because 2 nodes is not valid for MongoDB, the default will be picked
     await page.getByTestId('mongodb-toggle-button').click();
+    await page
+      .getByTestId('switch-input-sharding-label')
+      .getByRole('checkbox')
+      .check();
     await expect(page.getByText('Nº nodes: 3')).toBeVisible();
     await page.getByTestId('button-edit-preview-backups').click();
 

ui/apps/everest/src/components/cluster-form/resources/constants.ts

@@ -162,6 +162,25 @@ export const getDefaultNumberOfconfigServersByNumberOfNodes = (
   } else return '7';
 };
 
+const numberOfResourcesValidator = (
+  numberOfResourcesStr: string,
+  customNrOfResoucesStr: string,
+  fieldPath: string,
+  ctx: z.RefinementCtx
+) => {
+  if (numberOfResourcesStr === CUSTOM_NR_UNITS_INPUT_VALUE) {
+    const intNr = parseInt(customNrOfResoucesStr, 10);
+
+    if (Number.isNaN(intNr) || intNr < 1) {
+      ctx.addIssue({
+        code: z.ZodIssueCode.custom,
+        message: 'Please enter a valid number',
+        path: [fieldPath],
+      });
+    }
+  }
+};
+
 export const resourcesFormSchema = (passthrough?: boolean) => {
   const objectShape = {
     [DbWizardFormFields.shardNr]: z.string().optional(),
@@ -199,26 +218,21 @@ export const resourcesFormSchema = (passthrough?: boolean) => {
       },
       ctx
     ) => {
-      [
-        [numberOfNodes, customNrOfNodes, DbWizardFormFields.customNrOfNodes],
-        [
+      numberOfResourcesValidator(
+        numberOfNodes,
+        customNrOfNodes,
+        DbWizardFormFields.customNrOfNodes,
+        ctx
+      );
+
+      if (dbType !== DbType.Mongo || (dbType === DbType.Mongo && !!sharding)) {
+        numberOfResourcesValidator(
           numberOfProxies,
-          customNrOfProxies,
+          customNrOfNodes,
           DbWizardFormFields.customNrOfProxies,
-        ],
-      ].forEach(([nr, customNr, path]) => {
-        if (nr === CUSTOM_NR_UNITS_INPUT_VALUE) {
-          const intNr = parseInt(customNr, 10);
-
-          if (Number.isNaN(intNr) || intNr < 1) {
-            ctx.addIssue({
-              code: z.ZodIssueCode.custom,
-              message: 'Please enter a valid number',
-              path: [path],
-            });
-          }
-        }
-      });
+          ctx
+        );
+      }
 
       if (
         numberOfNodes === CUSTOM_NR_UNITS_INPUT_VALUE &&

ui/apps/everest/src/components/cluster-form/resources/resources.tsx

@@ -189,13 +189,13 @@
       }
       setValue(memoryInputName, sizeOptions[resourceSizePerUnit].memory);
     }
   }, [resourceSizePerUnit, allowDiskInputUpdate, setValue]);
 
   useEffect(() => {
     if (diskCapacityExceeded) {
       setError(diskInputName, { type: 'custom' });
     } else clearErrors(diskInputName);
   }, [diskCapacityExceeded, clearErrors, setError]);
 
   useEffect(() => {
     if (
@@ -204,7 +204,7 @@
     ) {
       setValue(resourceSizePerUnitInputName, ResourceSize.custom);
     }
   }, [cpu, setValue]);
 
   useEffect(() => {
     if (
@@ -213,7 +213,7 @@
     ) {
       setValue(resourceSizePerUnitInputName, ResourceSize.custom);
     }
   }, [disk, setValue]);
 
   useEffect(() => {
     if (
@@ -222,7 +222,7 @@
     ) {
       setValue(resourceSizePerUnitInputName, ResourceSize.custom);
     }
   }, [memory, setValue]);
 
   return (
     <FormGroup sx={{ mt: 3 }}>
@@ -423,8 +423,10 @@
   allowDiskInputUpdate,
   pairProxiesWithNodes,
   showSharding,
+  hideProxies = false,
 }: {
   dbType: DbType;
+  hideProxies?: boolean;
   disableDiskInput?: boolean;
   allowDiskInputUpdate?: boolean;
   pairProxiesWithNodes?: boolean;
@@ -485,7 +487,7 @@
       setValue(DbWizardFormFields.numberOfProxies, CUSTOM_NR_UNITS_INPUT_VALUE);
       setValue(DbWizardFormFields.customNrOfProxies, customNrOfNodes);
     }
   }, [setValue, getFieldState, customNrOfNodes, dbType, numberOfNodes]);
 
   useEffect(() => {
     const { isDirty: isConfigServersDirty } = getFieldState(
@@ -508,7 +510,7 @@
     }
 
     trigger(DbWizardFormFields.shardConfigServers);
   }, [setValue, getFieldState, numberOfNodes, customNrOfNodes]);
 
   return (
     <>
@@ -559,37 +561,41 @@
           disableCustom={dbType === DbType.Mysql}
         />
       </Accordion>
-      <Accordion
-        expanded={expanded === 'proxies'}
-        data-testid="proxies-accordion"
-        onChange={handleAccordionChange('proxies')}
-        sx={{
-          px: 2,
-        }}
-      >
-        <CustomAccordionSummary
-          unitPlural={proxyUnitNames.plural}
-          nr={parseInt(proxiesAccordionSummaryNumber, 10)}
-        />
-        <Divider />
-        <ResourcesToggles
-          dbType={dbType}
-          unit={proxyUnitNames.singular}
-          unitPlural={proxyUnitNames.plural}
-          options={NODES_DB_TYPE_MAP[dbType]}
-          sizeOptions={PROXIES_DEFAULT_SIZES[dbType]}
-          resourceSizePerUnitInputName={DbWizardFormFields.resourceSizePerProxy}
-          cpuInputName={DbWizardFormFields.proxyCpu}
-          memoryInputName={DbWizardFormFields.proxyMemory}
-          numberOfUnitsInputName={DbWizardFormFields.numberOfProxies}
-          customNrOfUnitsInputName={DbWizardFormFields.customNrOfProxies}
-        />
-        {proxyFieldError && (
-          <FormHelperText error={true}>
-            {proxyFieldError?.message}
-          </FormHelperText>
-        )}
-      </Accordion>
+      {!hideProxies && (
+        <Accordion
+          expanded={expanded === 'proxies'}
+          data-testid="proxies-accordion"
+          onChange={handleAccordionChange('proxies')}
+          sx={{
+            px: 2,
+          }}
+        >
+          <CustomAccordionSummary
+            unitPlural={proxyUnitNames.plural}
+            nr={parseInt(proxiesAccordionSummaryNumber, 10)}
+          />
+          <Divider />
+          <ResourcesToggles
+            dbType={dbType}
+            unit={proxyUnitNames.singular}
+            unitPlural={proxyUnitNames.plural}
+            options={NODES_DB_TYPE_MAP[dbType]}
+            sizeOptions={PROXIES_DEFAULT_SIZES[dbType]}
+            resourceSizePerUnitInputName={
+              DbWizardFormFields.resourceSizePerProxy
+            }
+            cpuInputName={DbWizardFormFields.proxyCpu}
+            memoryInputName={DbWizardFormFields.proxyMemory}
+            numberOfUnitsInputName={DbWizardFormFields.numberOfProxies}
+            customNrOfUnitsInputName={DbWizardFormFields.customNrOfProxies}
+          />
+          {proxyFieldError && (
+            <FormHelperText error={true}>
+              {proxyFieldError?.message}
+            </FormHelperText>
+          )}
+        </Accordion>
+      )}
       {!!showSharding && !!sharding && (
         <CustomPaper sx={{ mt: 2 }}>
           <Typography variant="sectionHeading">

ui/apps/everest/src/hooks/api/db-cluster/useCreateDbCluster.ts

@@ -111,6 +111,7 @@ const formValuesToPayloadMapping = (
         dbPayload.externalAccess,
         dbPayload.proxyCpu,
         dbPayload.proxyMemory,
+        dbPayload.sharding,
         dbPayload.sourceRanges || []
       ),
       ...(dbPayload.dbType === DbType.Mongo && {

ui/apps/everest/src/hooks/api/db-cluster/useUpdateDbCluster.ts

@@ -15,12 +15,13 @@
 
 import { UseMutationOptions, useMutation } from '@tanstack/react-query';
 import { updateDbClusterFn } from 'api/dbClusterApi';
-import { DbCluster } from 'shared-types/dbCluster.types';
+import { DbCluster, Proxy } from 'shared-types/dbCluster.types';
 import { DbWizardType } from 'pages/database-form/database-form-schema.ts';
 import cronConverter from 'utils/cron-converter';
 import { CUSTOM_NR_UNITS_INPUT_VALUE } from 'components/cluster-form';
 import { getProxySpec } from './utils';
 import { DbType } from '@percona/types';
+import { DbEngineType } from 'shared-types/dbEngines.types';
 
 type UpdateDbClusterArgType = {
   dbPayload: DbWizardType;
@@ -95,31 +96,35 @@ const formValuesToPayloadOverrides = (
           monitoringConfigName: dbPayload?.monitoringInstance!,
         }),
       },
-      proxy: {
-        ...dbCluster.spec.proxy,
-        ...getProxySpec(
-          dbPayload.dbType,
-          dbPayload.numberOfProxies,
-          dbPayload.customNrOfProxies || '',
-          dbPayload.externalAccess,
-          dbPayload.proxyCpu,
-          dbPayload.proxyMemory,
-          dbPayload.sourceRanges || []
-        ),
-        // replicas: numberOfNodes,
-        // expose: {
-        //   ...dbCluster.spec.proxy.expose,
-        //   type: dbPayload.externalAccess
-        //     ? ProxyExposeType.external
-        //     : ProxyExposeType.internal,
-        //   ...(!!dbPayload.externalAccess &&
-        //     dbPayload.sourceRanges && {
-        //       ipSourceRanges: dbPayload.sourceRanges.flatMap((source) =>
-        //         source.sourceRange ? [source.sourceRange] : []
-        //       ),
-        //     }),
-        // },
-      },
+      proxy:
+        dbPayload.dbType === DbType.Mongo && !dbPayload.sharding
+          ? {}
+          : {
+              ...dbCluster.spec.proxy,
+              ...getProxySpec(
+                dbPayload.dbType,
+                dbPayload.numberOfProxies,
+                dbPayload.customNrOfProxies || '',
+                dbPayload.externalAccess,
+                dbPayload.proxyCpu,
+                dbPayload.proxyMemory,
+                dbPayload.sharding,
+                dbPayload.sourceRanges || []
+              ),
+              // replicas: numberOfNodes,
+              // expose: {
+              //   ...dbCluster.spec.proxy.expose,
+              //   type: dbPayload.externalAccess
+              //     ? ProxyExposeType.external
+              //     : ProxyExposeType.internal,
+              //   ...(!!dbPayload.externalAccess &&
+              //     dbPayload.sourceRanges && {
+              //       ipSourceRanges: dbPayload.sourceRanges.flatMap((source) =>
+              //         source.sourceRange ? [source.sourceRange] : []
+              //       ),
+              //     }),
+              // },
+            },
       ...(dbPayload.dbType === DbType.Mongo && {
         sharding: {
           enabled: dbPayload.sharding,
@@ -235,6 +240,7 @@ export const useUpdateDbClusterResources = () =>
     mutationFn: ({
       dbCluster,
       newResources,
+      sharding,
     }: {
       dbCluster: DbCluster;
       newResources: {
@@ -247,6 +253,7 @@ export const useUpdateDbClusterResources = () =>
         proxyMemory: number;
         numberOfProxies: number;
       };
+      sharding: boolean;
     }) =>
       updateDbClusterFn(dbCluster.metadata.name, dbCluster.metadata.namespace, {
         ...dbCluster,
@@ -264,14 +271,17 @@ export const useUpdateDbClusterResources = () =>
               size: `${newResources.disk}${newResources.diskUnit}`,
             },
           },
-          proxy: {
-            ...dbCluster.spec.proxy,
-            replicas: newResources.numberOfProxies,
-            resources: {
-              cpu: `${newResources.proxyCpu}`,
-              memory: `${newResources.proxyMemory}G`,
-            },
-          },
+          proxy:
+            dbCluster.spec.engine.type === DbEngineType.PSMDB && !sharding
+              ? {}
+              : ({
+                  ...dbCluster.spec.proxy,
+                  replicas: newResources.numberOfProxies,
+                  resources: {
+                    cpu: `${newResources.proxyCpu}`,
+                    memory: `${newResources.proxyMemory}G`,
+                  },
+                } as Proxy),
         },
       }),
   });

ui/apps/everest/src/hooks/api/db-cluster/utils.ts

@@ -10,14 +10,24 @@ export const getProxySpec = (
   externalAccess: boolean,
   cpu: number,
   memory: number,
+  sharding: boolean,
   sourceRanges?: Array<{ sourceRange?: string }>
-): Proxy => {
+): Proxy | Record<string, never> => {
+  console.log('dbType', dbType);
+  console.log('sharding', sharding);
+  if (dbType === DbType.Mongo && !sharding) {
+    console.log('returning empty object');
+    return {};
+  }
   const proxyNr = parseInt(
     numberOfProxies === CUSTOM_NR_UNITS_INPUT_VALUE
       ? customNrOfProxies
       : numberOfProxies,
     10
   );
+  // const showResources =
+  //   dbType !== DbType.Mongo || (dbType === DbType.Mongo && !sharding);
+
   return {
     type: dbTypeToProxyType(dbType),
     replicas: proxyNr,

ui/apps/everest/src/pages/database-form/database-form-body/steps/resources/resources-step.tsx

@@ -10,6 +10,7 @@ export const ResourcesStep = () => {
   const { watch } = useFormContext();
   const mode = useDatabasePageMode();
   const dbType: DbType = watch(DbWizardFormFields.dbType);
+  const shardingEnabled = watch(DbWizardFormFields.sharding);
 
   return (
     <>
@@ -23,6 +24,7 @@ export const ResourcesStep = () => {
         disableDiskInput={mode === 'edit'}
         allowDiskInputUpdate={mode !== 'edit'}
         showSharding={dbType === DbType.Mongo}
+        hideProxies={dbType === DbType.Mongo && !shardingEnabled}
       />
     </>
   );

ui/apps/everest/src/pages/database-form/database-form.utils.ts

@@ -49,7 +49,7 @@ export const DbClusterPayloadToFormValues = (
 ): DbWizardType => {
   const backup = dbCluster?.spec?.backup;
   const replicas = dbCluster?.spec?.engine?.replicas.toString();
-  const proxies = dbCluster?.spec?.proxy?.replicas.toString();
+  const proxies = (dbCluster?.spec?.proxy?.replicas || 0).toString();
   const diskValues = memoryParser(
     dbCluster?.spec?.engine?.storage?.size.toString()
   );

ui/apps/everest/src/pages/databases/DbClusterView.utils.ts

@@ -18,6 +18,7 @@ import { DbClusterForNamespaceResult } from '../../hooks/api/db-clusters/useDbCl
 import { Messages } from './dbClusterView.messages';
 import { DbClusterTableElement } from './dbClusterView.types';
 import { Backup, BackupStatus } from 'shared-types/backups.types';
+import { isProxy } from 'utils/db';
 
 const DB_CLUSTER_STATUS_HUMANIFIED: Record<DbClusterStatus, string> = {
   [DbClusterStatus.ready]: Messages.statusProvider.up,
@@ -55,7 +56,9 @@ export const convertDbClusterPayloadToTableFormat = (
           storage: cluster.spec.engine.storage.size,
           nodes: cluster.spec.engine.replicas,
           hostName: cluster.status ? cluster.status.hostname : '',
-          exposetype: cluster.spec.proxy.expose.type,
+          exposetype: isProxy(cluster.spec.proxy)
+            ? cluster.spec.proxy.expose.type
+            : undefined,
           port: cluster.status?.port,
           monitoringConfigName:
             cluster.spec.monitoring?.monitoringConfigName ?? '',

ui/apps/everest/src/pages/databases/dbClusterView.types.ts

@@ -38,7 +38,7 @@ export interface DbClusterTableElement {
   nodes: number;
   hostName: string;
   port?: number;
-  exposetype: ProxyExposeType;
+  exposetype?: ProxyExposeType;
   monitoringConfigName?: string;
   raw: DbCluster;
 }