Add Metalk8sLocalVolumeProvider implementation and tests

Author: hervedombya

ui/public/.well-known/micro-app-configuration

@@ -31,11 +31,9 @@
       "platform_library": {
         "module": "./platformLibrary",
         "scope": "metalk8s"
-      }
-    },
-    "providers": {
-      "K8SLocalVolumeProvider": {
-        "module": "./K8SLocalVolumeProvider",
+      },
+      "Metalk8sLocalVolumeProvider": {
+        "module": "./Metalk8sLocalVolumeProvider",
         "scope": "metalk8s"
       }
     },

ui/rspack.config.ts

@@ -117,8 +117,8 @@ const config: Configuration = {
         './platformLibrary': './src/services/platformlibrary/k8s.ts',
         './AlertsNavbarUpdater':
           './src/components/AlertNavbarUpdaterComponent.tsx',
-        './K8SLocalVolumeProvider':
-          './src/services/k8s/K8SLocalVolumeProvider.ts',
+        './Metalk8sLocalVolumeProvider':
+          './src/services/k8s/Metalk8sLocalVolumeProvider.ts',
       },
       remotes: !isProduction
         ? {

…vices/k8s/K8SLocalVolumeProvider.test.ts …/k8s/Metalk8sLocalVolumeProvider.test.tsui/src/services/k8s/K8SLocalVolumeProvider.test.ts renamed to ui/src/services/k8s/Metalk8sLocalVolumeProvider.test.ts ui/src/services/k8s/K8SLocalVolumeProvider.test.ts renamed to ui/src/services/k8s/Metalk8sLocalVolumeProvider.test.ts

@@ -1,14 +1,14 @@
 import { CoreV1Api, CustomObjectsApi } from '@kubernetes/client-node';
-import K8SLocalVolumeProvider from './K8SLocalVolumeProvider';
+import Metalk8sLocalVolumeProvider from './Metalk8sLocalVolumeProvider';
 import { Metalk8sV1alpha1VolumeClient } from './Metalk8sVolumeClient.generated';
-import { updateApiServerConfig } from '../k8s/api';
+import { updateApiServerConfig } from './api';
 
 jest.mock('../k8s/api', () => ({
   updateApiServerConfig: jest.fn(),
 }));
 
 describe('K8SLocalVolumeProvider', () => {
-  let provider: K8SLocalVolumeProvider;
+  let provider: Metalk8sLocalVolumeProvider;
   const mockUrl = 'mock-url';
   const mockToken = 'mock-token';
 
@@ -31,7 +31,7 @@ describe('K8SLocalVolumeProvider', () => {
       customObjects: mockCustomObjectsApi,
     });
 
-    provider = new K8SLocalVolumeProvider(mockUrl, mockToken);
+    provider = new Metalk8sLocalVolumeProvider(mockUrl, mockToken);
     provider.k8sClient = mockCoreV1Api;
     provider.volumeClient = mockVolumeClient;
   });
@@ -101,7 +101,7 @@ describe('K8SLocalVolumeProvider', () => {
       ).rejects.toThrow('Failed to find IP for node non-existent-node');
     });
 
-    it('should raise an error if volume recovery fails', async () => {
+    it('should raise an error if volume retrieval fails', async () => {
       (mockCoreV1Api.listNode as jest.Mock).mockResolvedValue({
         body: {
           items: [

…c/services/k8s/K8SLocalVolumeProvider.ts …vices/k8s/Metalk8sLocalVolumeProvider.tsui/src/services/k8s/K8SLocalVolumeProvider.ts renamed to ui/src/services/k8s/Metalk8sLocalVolumeProvider.ts ui/src/services/k8s/K8SLocalVolumeProvider.ts renamed to ui/src/services/k8s/Metalk8sLocalVolumeProvider.ts

@@ -1,5 +1,5 @@
 import { CoreV1Api, V1PersistentVolume } from '@kubernetes/client-node';
-import * as ApiK8s from '../k8s/api';
+import * as ApiK8s from './api';
 import {
   Metalk8sV1alpha1VolumeClient,
   Result,
@@ -12,15 +12,18 @@ function isError<T>(result: Result<T>): result is { error: any } {
 type LocalPersistentVolume = V1PersistentVolume & {
   IP: string;
   devicePath: string;
+  nodeName: string;
 };
 
-export interface K8SLocalVolumeAdapter {
+export interface Metalk8sLocalVolumeAdapter {
   listLocalPersistentVolumes(
     serverName: string,
   ): Promise<LocalPersistentVolume[]>;
 }
 
-export default class K8SLocalVolumeProvider implements K8SLocalVolumeAdapter {
+export default class Metalk8sLocalVolumeProvider
+  implements Metalk8sLocalVolumeAdapter
+{
   volumeClient: Metalk8sV1alpha1VolumeClient;
   k8sClient: CoreV1Api;
   constructor(private url: string, private token: string) {
@@ -60,6 +63,7 @@ export default class K8SLocalVolumeProvider implements K8SLocalVolumeAdapter {
                 ...isLocalPv,
                 IP: nodeIP.address,
                 devicePath: item.spec?.rawBlockDevice?.devicePath,
+                nodeName: item.spec.nodeName,
               },
             ];
           },