DRAFT (for 1.3): Everest 777 topology

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

@@ -139,6 +139,18 @@ test.describe('DB Cluster creation', () => {
     await expect(page.getByText('Nº nodes: 3')).toBeVisible();
 
     await resourcesStepCheck(page);
+
+    // Same number of proxies as nodes, as user hasn't changed it
+    await expect(page.getByText('Routers (3)')).toBeVisible();
+    await page.getByTestId('proxies-accordion').getByRole('button').click();
+    await page.getByTestId('toggle-button-routers-1').click();
+    await expect(page.getByText('Routers (1)')).toBeVisible();
+    await page.getByTestId('nodes-accordion').getByRole('button').click();
+    await page.getByTestId('toggle-button-nodes-1').click();
+    await page.getByTestId('toggle-button-nodes-3').click();
+    // After used changed the number of routers, it should no more follow the number of nodes
+    await expect(page.getByText('Routers (1)')).toBeVisible();
+
     await moveForward(page);
 
     await backupsStepCheck(page);
@@ -162,7 +174,10 @@ test.describe('DB Cluster creation', () => {
     // Now we change the number of nodes
     await page.getByTestId('button-edit-preview-resources').click();
     await page.getByTestId('toggle-button-nodes-3').click();
+    await expect(page.getByText('PG Bouncers (3)')).toBeVisible();
     await page.getByTestId('toggle-button-nodes-2').click();
+    // Since we changed DB type, the number of bouncers is reset and will follow the number of nodes
+    await expect(page.getByText('PG Bouncers (2)')).toBeVisible();
     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();
@@ -261,7 +276,7 @@ test.describe('DB Cluster creation', () => {
     ).toBeVisible();
 
     await page.getByTestId('toggle-button-nodes-3').click();
-    await page.getByTestId('toggle-button-large').click();
+    await page.getByTestId('node-resources-toggle-button-large').click();
     await page.getByTestId('text-input-disk').fill('150');
     await moveForward(page);
 

ui/apps/everest/.e2e/db-cluster/db-wizard/create-db-cluster/steps/resources-step.ts

@@ -19,7 +19,7 @@ export const resourcesStepCheck = async (page: Page) => {
   await expect(page.getByTestId('step-header')).toBeVisible();
   await expect(page.getByTestId('step-description')).toBeVisible();
 
-  await page.getByTestId('toggle-button-large').click();
+  await page.getByTestId('node-resources-toggle-button-large').click();
   await page.getByTestId('text-input-cpu').fill('0.6');
   await page.getByTestId('text-input-memory').fill('1');
   await page.getByTestId('text-input-disk').fill('1');

ui/apps/everest/.e2e/utils/db-wizard.ts

@@ -98,7 +98,7 @@ export const populateResources = async (
   await expect(page.getByTestId('step-header')).toBeVisible();
   await expect(page.getByTestId('step-description')).toBeVisible();
 
-  await page.getByTestId('toggle-button-large').click();
+  await page.getByTestId('node-resources-toggle-button-large').click();
   await page.getByTestId('text-input-cpu').fill(cpu.toString());
   await page.getByTestId('text-input-memory').fill(memory.toString());
   await page.getByTestId('text-input-disk').fill(disk.toString());

ui/apps/everest/src/components/cluster-form/index.ts

@@ -0,0 +1,2 @@
+export * from './resources';
+export { default as ResourcesForm } from './resources';

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

@@ -0,0 +1,196 @@
+import { DbType } from '@percona/types';
+import { z } from 'zod';
+import { Resources } from 'shared-types/dbCluster.types';
+import { DbWizardFormFields } from 'consts';
+import { memoryParser } from 'utils/k8ResourceParser';
+import { Messages } from './messages';
+
+const resourceToNumber = (minimum = 0) =>
+  z.union([z.string().min(1), z.number()]).pipe(
+    z.coerce
+      .number({
+        invalid_type_error: 'Please enter a valid number',
+      })
+      .min(minimum)
+  );
+
+export const matchFieldsValueToResourceSize = (
+  resources?: Resources
+): ResourceSize => {
+  if (!resources) {
+    return ResourceSize.custom;
+  }
+  const memory = memoryParser(resources.memory.toString());
+
+  const res = Object.values(DEFAULT_SIZES).findIndex(
+    (item) => item.cpu === Number(resources.cpu) && item.memory === memory.value
+  );
+  return res !== -1
+    ? (Object.keys(DEFAULT_SIZES)[res] as ResourceSize)
+    : ResourceSize.custom;
+};
+
+export const NODES_DB_TYPE_MAP: Record<DbType, string[]> = {
+  [DbType.Mongo]: ['1', '3', '5'],
+  [DbType.Mysql]: ['1', '3', '5'],
+  [DbType.Postresql]: ['1', '2', '3'],
+};
+
+export enum ResourceSize {
+  small = 'small',
+  medium = 'medium',
+  large = 'large',
+  custom = 'custom',
+}
+
+export const humanizedResourceSizeMap: Record<ResourceSize, string> = {
+  [ResourceSize.small]: 'Small',
+  [ResourceSize.medium]: 'Medium',
+  [ResourceSize.large]: 'Large',
+  [ResourceSize.custom]: 'Custom',
+};
+
+export const DEFAULT_SIZES = {
+  [ResourceSize.small]: {
+    [DbWizardFormFields.cpu]: 1,
+    [DbWizardFormFields.memory]: 2,
+    [DbWizardFormFields.disk]: 25,
+  },
+  [ResourceSize.medium]: {
+    [DbWizardFormFields.cpu]: 4,
+    [DbWizardFormFields.memory]: 8,
+    [DbWizardFormFields.disk]: 100,
+  },
+  [ResourceSize.large]: {
+    [DbWizardFormFields.cpu]: 8,
+    [DbWizardFormFields.memory]: 32,
+    [DbWizardFormFields.disk]: 200,
+  },
+};
+
+export const SHARDING_DEFAULTS = {
+  [DbWizardFormFields.shardConfigServers]: {
+    min: '1',
+    max: '7',
+  },
+  [DbWizardFormFields.shardNr]: {
+    min: '1',
+  },
+};
+
+export const resourcesFormSchema = (passthrough?: boolean) => {
+  const objectShape = {
+    [DbWizardFormFields.shardNr]: z.string().optional(),
+    [DbWizardFormFields.shardConfigServers]: z.string().optional(),
+    [DbWizardFormFields.cpu]: resourceToNumber(0.6),
+    [DbWizardFormFields.memory]: resourceToNumber(0.512),
+    [DbWizardFormFields.disk]: resourceToNumber(1),
+    // we will never input this, but we need it and zod will let it pass
+    [DbWizardFormFields.diskUnit]: z.string(),
+    [DbWizardFormFields.resourceSizePerNode]: z.nativeEnum(ResourceSize),
+    [DbWizardFormFields.numberOfNodes]: z.string(),
+    [DbWizardFormFields.customNrOfNodes]: z.string().optional(),
+    [DbWizardFormFields.proxyCpu]: resourceToNumber(0.6),
+    [DbWizardFormFields.proxyMemory]: resourceToNumber(0.512),
+    [DbWizardFormFields.resourceSizePerProxy]: z.nativeEnum(ResourceSize),
+    [DbWizardFormFields.numberOfProxies]: z.string(),
+    [DbWizardFormFields.customNrOfProxies]: z.string().optional(),
+  };
+
+  const zObject = passthrough
+    ? z.object(objectShape).passthrough()
+    : z.object(objectShape);
+
+  return zObject.superRefine(
+    (
+      {
+        sharding,
+        shardConfigServers,
+        shardNr,
+        numberOfNodes,
+        numberOfProxies,
+        customNrOfNodes = '',
+        customNrOfProxies = '',
+      },
+      ctx
+    ) => {
+      [
+        [numberOfNodes, customNrOfNodes, DbWizardFormFields.customNrOfNodes],
+        [
+          numberOfProxies,
+          customNrOfProxies,
+          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],
+            });
+          }
+        }
+      });
+
+      if (sharding as boolean) {
+        const intShardNr = parseInt(shardNr || '', 10);
+        const intShardNrMin =
+          +SHARDING_DEFAULTS[DbWizardFormFields.shardNr].min;
+        const intShardConfigServers = parseInt(shardConfigServers || '', 10);
+        const intShardConfigServersMin =
+          +SHARDING_DEFAULTS[DbWizardFormFields.shardNr].min;
+        const intShardConfigServersMax =
+          +SHARDING_DEFAULTS[DbWizardFormFields.shardConfigServers].max;
+
+        if (Number.isNaN(intShardNr) || intShardNr < 0) {
+          ctx.addIssue({
+            code: z.ZodIssueCode.custom,
+            message: Messages.sharding.invalid,
+            path: [DbWizardFormFields.shardNr],
+          });
+        } else {
+          if (intShardNr < intShardNrMin) {
+            ctx.addIssue({
+              code: z.ZodIssueCode.custom,
+              message: Messages.sharding.min(intShardNrMin),
+              path: [DbWizardFormFields.shardNr],
+            });
+          }
+        }
+
+        if (Number.isNaN(intShardConfigServers) || intShardConfigServers <= 0) {
+          ctx.addIssue({
+            code: z.ZodIssueCode.custom,
+            message: Messages.sharding.invalid,
+            path: [DbWizardFormFields.shardConfigServers],
+          });
+        } else {
+          if (intShardConfigServers < intShardConfigServersMin) {
+            ctx.addIssue({
+              code: z.ZodIssueCode.custom,
+              message: Messages.sharding.min(intShardConfigServersMin),
+              path: [DbWizardFormFields.shardConfigServers],
+            });
+          } else if (!(intShardConfigServers % 2)) {
+            ctx.addIssue({
+              code: z.ZodIssueCode.custom,
+              message: Messages.sharding.odd,
+              path: [DbWizardFormFields.shardConfigServers],
+            });
+          } else if (intShardConfigServers > intShardConfigServersMax) {
+            ctx.addIssue({
+              code: z.ZodIssueCode.custom,
+              message: Messages.sharding.max(intShardConfigServersMax),
+              path: [DbWizardFormFields.shardConfigServers],
+            });
+          }
+        }
+      }
+    }
+  );
+};
+
+export const CUSTOM_NR_UNITS_INPUT_VALUE = 'custom-units-nr';

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

@@ -0,0 +1,2 @@
+export { default } from './resources';
+export * from './constants';

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

@@ -0,0 +1,8 @@
+export const Messages = {
+  sharding: {
+    invalid: 'Please fill in valid values for sharding',
+    min: (val: number) => `The value cannot be less than ${val}`,
+    max: (val: number) => `The value cannot be more than ${val}`,
+    odd: 'The value cannot be even',
+  },
+};