Provide osd migration status alert for dr brownfield

Signed-off-by: Timothy Asir Jeyasingh <[email protected]>

locales/en/plugin__odf-console.json

@@ -277,7 +277,6 @@
   "{{async}}, interval: {{interval}}": "{{async}}, interval: {{interval}}",
   "In use: {{targetClusters}}": "In use: {{targetClusters}}",
   "Used: {{targetClusters}}": "Used: {{targetClusters}}",
-  "View documentation": "View documentation",
   "StorageSystems": "StorageSystems",
   "StorageSystem details": "StorageSystem details",
   "Edit BlockPool": "Edit BlockPool",
@@ -442,6 +441,12 @@
   "This card shows the requested capacity for different Kubernetes resources. The figures shown represent the usable storage, meaning that data replication is not taken into consideration.": "This card shows the requested capacity for different Kubernetes resources. The figures shown represent the usable storage, meaning that data replication is not taken into consideration.",
   "Internal": "Internal",
   "Raw capacity is the absolute total disk space available to the array subsystem.": "Raw capacity is the absolute total disk space available to the array subsystem.",
+  "Cluster ready for Regional-DR setup.": "Cluster ready for Regional-DR setup.",
+  "Setting up disaster recovery": "Setting up disaster recovery",
+  "Cluster OSDs are being migrated": "Cluster OSDs are being migrated",
+  "{{ percentageComplete }}% completed ({{ migratedDevices }}/ {{ totalOsd }} remaining)": "{{ percentageComplete }}% completed ({{ migratedDevices }}/ {{ totalOsd }} remaining)",
+  "Could not migrate cluster OSDs.": "Could not migrate cluster OSDs.",
+  "Check documentation": "Check documentation",
   "Troubleshoot": "Troubleshoot",
   "Active health checks": "Active health checks",
   "Progressing": "Progressing",
@@ -1048,6 +1053,7 @@
   "Owner": "Owner",
   "No labels": "No labels",
   "No owner": "No owner",
+  "View documentation": "View documentation",
   "Select input": "Select input",
   "Select options": "Select options",
   "No results found": "No results found",

packages/mco/components/modals/app-failover-relocate/error-messages.tsx

@@ -1,8 +1,8 @@
 import * as React from 'react';
+import { DOC_LINKS, ViewDocumentation } from '@odf/shared/doc/doc-utils';
 import { TFunction } from 'i18next';
 import { Trans } from 'react-i18next';
 import { AlertVariant } from '@patternfly/react-core';
-import { ViewDocumentation, DOC_LINKS } from '../../../utils';
 
 export enum ErrorMessageType {
   // Priority wise error messages

packages/mco/components/modals/app-failover-relocate/subscriptions/error-messages.tsx

@@ -1,8 +1,8 @@
 import * as React from 'react';
+import { ViewDocumentation, DOC_LINKS } from '@odf/shared/doc/doc-utils';
 import { TFunction } from 'i18next';
 import { Trans } from 'react-i18next';
 import { AlertVariant } from '@patternfly/react-core';
-import { ViewDocumentation, DOC_LINKS } from '../../../../utils/doc-utils';
 
 export enum ErrorMessageType {
   // Priority wise error messages

packages/mco/utils/index.ts

@@ -1,3 +1,2 @@
 export * from './disaster-recovery';
 export * from './common';
-export * from './doc-utils';

packages/ocs/dashboards/persistent-internal/status-card/osd-migration/osd-migration-status.spec.tsx

@@ -0,0 +1,82 @@
+import React from 'react';
+import { BLUESTORE, BLUESTORE_RDR } from '@odf/core/constants';
+import { cleanup, render, screen, waitFor } from '@testing-library/react';
+import '@testing-library/jest-dom/extend-expect';
+import { MemoryRouter } from 'react-router-dom';
+import * as migrationStatus from '../../../../utils/osd-migration';
+import { OSDMigration } from './osd-migration-status';
+
+jest.mock('@odf/shared/status/icons', () => ({
+  RedExclamationCircleIcon: 'div',
+}));
+
+jest.mock('@openshift-console/dynamic-plugin-sdk-internal', () => ({
+  HealthBody: 'div',
+  HealthItem: ({ title }) => <div>{title}</div>,
+  ViewDocumentation: ({ text, doclink }) => <a href={doclink}>{text}</a>,
+  HealthState: {
+    OK: 'OK',
+  },
+}));
+
+jest.mock('../../../../utils/osd-migration');
+afterEach(cleanup);
+
+describe('OSDMigrationStatus', () => {
+  test('renders the component with COMPLETED status', async () => {
+    const cephData = {
+      status: {
+        storage: {
+          osd: {
+            storeType: {
+              [BLUESTORE_RDR]: 5,
+            },
+          },
+        },
+      },
+    };
+
+    migrationStatus.getOSDMigrationStatus.mockReturnValue('Completed');
+
+    render(
+      <MemoryRouter>
+        <OSDMigration cephData={cephData} />
+      </MemoryRouter>
+    );
+
+    await waitFor(() => {
+      expect(
+        screen.getByText('Cluster ready for Regional-DR setup.')
+      ).toBeInTheDocument();
+    });
+  });
+
+  test('renders the component with PENDING status', async () => {
+    const cephData = {
+      status: {
+        storage: {
+          osd: {
+            storeType: {
+              [BLUESTORE]: 10,
+              [BLUESTORE_RDR]: 5,
+            },
+          },
+        },
+      },
+    };
+
+    migrationStatus.getOSDMigrationStatus.mockReturnValue('In Progress');
+
+    render(
+      <MemoryRouter>
+        <OSDMigration cephData={cephData} />
+      </MemoryRouter>
+    );
+
+    await waitFor(() => {
+      expect(
+        screen.getByText('Cluster OSDs are being migrated')
+      ).toBeInTheDocument();
+    });
+  });
+});

packages/ocs/dashboards/persistent-internal/status-card/osd-migration/osd-migration-status.tsx

@@ -0,0 +1,119 @@
+import * as React from 'react';
+import {
+  OSDMigrationStatus,
+  BLUESTORE,
+  BLUESTORE_RDR,
+} from '@odf/core/constants';
+import { DOC_LINKS, ViewDocumentation } from '@odf/shared/doc/doc-utils';
+import { RedExclamationCircleIcon } from '@odf/shared/status/icons';
+import { CephClusterKind } from '@odf/shared/types';
+import { useCustomTranslation } from '@odf/shared/useCustomTranslationHook';
+import { HealthState } from '@openshift-console/dynamic-plugin-sdk';
+import {
+  HealthBody,
+  HealthItem,
+} from '@openshift-console/dynamic-plugin-sdk-internal';
+import { Divider, Flex, FlexItem } from '@patternfly/react-core';
+import { InProgressIcon } from '@patternfly/react-icons';
+import { getOSDMigrationStatus } from '../../../../utils/osd-migration';
+
+const calculateOSDMigration = (
+  cephData: CephClusterKind
+): [number, number, number] => {
+  const migratedDevices =
+    cephData?.status?.storage?.osd?.storeType?.[BLUESTORE_RDR] || 0;
+  const totalOsd =
+    (cephData?.status?.storage?.osd?.storeType?.[BLUESTORE] || 0) +
+    migratedDevices;
+  const percentageComplete =
+    totalOsd !== 0 ? Math.round((migratedDevices / totalOsd) * 100) : 0;
+
+  return [migratedDevices, totalOsd, percentageComplete];
+};
+
+export const OSDMigration: React.FC<OSDMigrationStatusProps> = ({
+  cephData,
+}) => {
+  const { t } = useCustomTranslation();
+  const [migratedDevices, totalOsd, percentageComplete] =
+    calculateOSDMigration(cephData);
+  const migrationStatus: string = getOSDMigrationStatus(cephData);
+
+  return (
+    <>
+      {migrationStatus !== OSDMigrationStatus.COMPLETED && <Divider />}
+      <HealthBody>
+        <Flex alignItems={{ default: 'alignItemsCenter' }}>
+          {migrationStatus === OSDMigrationStatus.COMPLETED && (
+            <>
+              <HealthItem
+                title={t('Cluster ready for Regional-DR setup.')}
+                state={HealthState.OK}
+              />
+              <ViewDocumentation
+                text={t('Setting up disaster recovery')}
+                doclink={DOC_LINKS.APPLY_POLICY}
+              />
+            </>
+          )}
+
+          {migrationStatus === OSDMigrationStatus.IN_PROGRESS && (
+            <>
+              <FlexItem>
+                <HealthItem
+                  icon={<InProgressIcon className="co-dashboard-icon" />}
+                  state={HealthState.OK}
+                  title={t('Cluster OSDs are being migrated')}
+                />
+              </FlexItem>
+              <FlexItem>
+                {t(
+                  '{{ percentageComplete }}% completed ({{ migratedDevices }}/ {{ totalOsd }} remaining)',
+                  {
+                    percentageComplete,
+                    migratedDevices,
+                    totalOsd,
+                  }
+                )}
+              </FlexItem>
+            </>
+          )}
+
+          {migrationStatus === OSDMigrationStatus.FAILED && (
+            <>
+              <FlexItem>
+                <HealthItem
+                  state={HealthState.OK}
+                  icon={
+                    <RedExclamationCircleIcon className="co-dashboard-icon" />
+                  }
+                  title={t('Could not migrate cluster OSDs.')}
+                />
+              </FlexItem>
+              <FlexItem>
+                <ViewDocumentation
+                  text={t('Check documentation')}
+                  doclink={DOC_LINKS.APPLY_POLICY}
+                />
+              </FlexItem>
+              <FlexItem align={{ default: 'alignRight' }}>
+                {t(
+                  '{{ percentageComplete }}% completed ({{ migratedDevices }}/ {{ totalOsd }} remaining)',
+                  {
+                    percentageComplete,
+                    migratedDevices,
+                    totalOsd,
+                  }
+                )}
+              </FlexItem>
+            </>
+          )}
+        </Flex>
+      </HealthBody>
+    </>
+  );
+};
+
+type OSDMigrationStatusProps = {
+  cephData?: CephClusterKind;
+};

packages/ocs/dashboards/persistent-internal/status-card/status-card.tsx

@@ -33,6 +33,7 @@ import {
 } from '@patternfly/react-core';
 import { CephClusterModel } from '../../../models';
 import { DATA_RESILIENCY_QUERY, StorageDashboardQuery } from '../../../queries';
+import { OSDMigration } from './osd-migration/osd-migration-status';
 import { getCephHealthState, getDataResiliencyState } from './utils';
 import { whitelistedHealthChecksRef } from './whitelisted-health-checks';
 import './healthchecks.scss';
@@ -183,6 +184,7 @@ export const StatusCard: React.FC = () => {
           </GalleryItem>
         </Gallery>
       </HealthBody>
+      <OSDMigration cephData={data?.[0]} />
       <CephAlerts />
     </Card>
   );

packages/ocs/utils/osd-migration.ts

@@ -0,0 +1,33 @@
+import {
+  BLUESTORE,
+  BLUESTORE_RDR,
+  DISASTER_RECOVERY_TARGET_ANNOTATION,
+  OSDMigrationStatus,
+} from '@odf/core/constants';
+import { getAnnotations } from '@odf/shared/selectors';
+import { CephClusterKind } from '@odf/shared/types';
+
+export const getOSDMigrationStatus = (ceph: CephClusterKind) => {
+  if (!!ceph) {
+    const bluestoreCount = ceph?.status?.storage?.osd?.storeType?.[BLUESTORE];
+    const bluestoreRdrCount =
+      ceph?.status?.storage?.osd?.storeType?.[BLUESTORE_RDR];
+
+    const isDisasterRecoveryTarget =
+      getAnnotations(ceph)?.[DISASTER_RECOVERY_TARGET_ANNOTATION] === 'true';
+
+    if (bluestoreCount > 0) {
+      if (bluestoreRdrCount > 0 || isDisasterRecoveryTarget) {
+        return OSDMigrationStatus.IN_PROGRESS;
+      } else {
+        return OSDMigrationStatus.PENDING;
+      }
+    } else if (bluestoreRdrCount > 0) {
+      return OSDMigrationStatus.COMPLETED;
+    }
+  } else {
+    return OSDMigrationStatus.FAILED;
+  } // TODO Add condition for migration failure
+
+  return '';
+};

packages/odf/constants/dataProtection.ts

@@ -1,2 +1,12 @@
 export const DISASTER_RECOVERY_TARGET_ANNOTATION =
   'ocs.openshift.io/clusterIsDisasterRecoveryTarget';
+
+export enum OSDMigrationStatus {
+  IN_PROGRESS = 'In Progress',
+  PENDING = 'Pending',
+  COMPLETED = 'Completed',
+  FAILED = 'Failed',
+}
+
+export const BLUESTORE_RDR = 'bluestore-rdr';
+export const BLUESTORE = 'bluestore';

packages/shared/src/types/storage.ts

@@ -104,7 +104,13 @@ type CephDeviceClass = {
 
 export type CephClusterKind = K8sResourceCommon & {
   status?: {
-    storage: {
+    storage?: {
+      osd?: {
+        storeType?: {
+          bluestore?: number;
+          'bluestore-rdr'?: number;
+        };
+      };
       deviceClasses: CephDeviceClass[];
     };
     ceph?: {