),
@@ -56,14 +57,19 @@ export function Instances() {
size: 90,
header: 'Name',
},
- !isSelfManaged && {
+ {
accessorKey: 'status',
header: 'Status',
size: 1,
minSize: 1,
cell: (cell) => {
const status = cell.getValue() as string;
- return
+ );
},
},
!isSelfManaged && {
@@ -128,7 +134,7 @@ export function Instances() {
return (
<>
+
{clusterIsLoading
diff --git a/src/features/clusters/components/ClusterCard.tsx b/src/features/clusters/components/ClusterCard.tsx
index ae8f3d5a8..9c47a2670 100644
--- a/src/features/clusters/components/ClusterCard.tsx
+++ b/src/features/clusters/components/ClusterCard.tsx
@@ -48,7 +48,7 @@ export function ClusterCard({ cluster }: { cluster: Cluster }) {
const router = useRouter();
const queryClient = useQueryClient();
const operationsUrl = useMemo(() => getOperationsUrlForCluster(cluster), [cluster]);
- const instanceClient = useInstanceClient(operationsUrl);
+ const instanceClient = useInstanceClient({ operationsUrl });
const auth = useInstanceAuth(cluster.id);
const [, setSavedClusterState] = useLocalStorage(LocalStorageKeys.SavedClusterState, null);
diff --git a/src/integrations/api/instance/status/getStatus.test.ts b/src/integrations/api/instance/status/getStatus.test.ts
new file mode 100644
index 000000000..15e5092c1
--- /dev/null
+++ b/src/integrations/api/instance/status/getStatus.test.ts
@@ -0,0 +1,64 @@
+import { describe, expect, it } from 'vitest';
+import { getSystemStatusById } from './getStatus';
+
+describe('getSystemStatusById', () => {
+ it('returns the status for a given id when it exists', () => {
+ const mockStatusResponse = {
+ systemStatus: [
+ {
+ id: 'availability',
+ status: 'Available',
+ __updatedtime__: 123456789,
+ __createdtime__: 123456780,
+ },
+ {
+ id: 'maintenance',
+ status: 'Unavailable',
+ __updatedtime__: 123456790,
+ __createdtime__: 123456780,
+ },
+ ],
+ restartRequired: false,
+ componentStatus: [],
+ };
+
+ expect(getSystemStatusById(mockStatusResponse, 'availability')).toBe('Available');
+ expect(getSystemStatusById(mockStatusResponse, 'maintenance')).toBe('Unavailable');
+ });
+
+ it('returns undefined if statusResponse is undefined', () => {
+ expect(getSystemStatusById(undefined, 'availability')).toBeUndefined();
+ });
+
+ it('returns undefined if systemStatus array is missing', () => {
+ // @ts-expect-error - testing invalid input
+ expect(getSystemStatusById({}, 'availability')).toBeUndefined();
+ });
+
+ it('returns undefined if the id is not found in systemStatus', () => {
+ const mockStatusResponse = {
+ systemStatus: [
+ {
+ id: 'availability',
+ status: 'Available',
+ __updatedtime__: 123456789,
+ __createdtime__: 123456780,
+ },
+ ],
+ restartRequired: false,
+ componentStatus: [],
+ };
+
+ expect(getSystemStatusById(mockStatusResponse, 'non-existent')).toBeUndefined();
+ });
+
+ it('returns undefined if systemStatus is empty', () => {
+ const mockStatusResponse = {
+ systemStatus: [],
+ restartRequired: false,
+ componentStatus: [],
+ };
+
+ expect(getSystemStatusById(mockStatusResponse, 'availability')).toBeUndefined();
+ });
+});
diff --git a/src/integrations/api/instance/status/getStatus.ts b/src/integrations/api/instance/status/getStatus.ts
index 11d2c6777..abd2cc788 100644
--- a/src/integrations/api/instance/status/getStatus.ts
+++ b/src/integrations/api/instance/status/getStatus.ts
@@ -1,7 +1,7 @@
import { InstanceClientIdConfig } from '@/config/instanceClientConfig';
import { queryOptions } from '@tanstack/react-query';
-interface SystemStatus {
+export interface SystemStatus {
id: 'availability' | 'maintenance' | 'primary' | string;
status: 'Available' | 'Unavailable' | string;
__updatedtime__: number;
@@ -53,3 +53,11 @@ export function getStatusQueryOptions({ entityId, instanceClient }: InstanceClie
},
});
}
+
+export function getSystemStatusById(
+ statusResponse: StatusResponse | undefined,
+ id: SystemStatus['id'],
+): SystemStatus['status'] | undefined {
+ const systemStatus = statusResponse?.systemStatus?.find(s => s.id === id);
+ return systemStatus?.status;
+}
diff --git a/src/integrations/api/instance/status/setStatus.ts b/src/integrations/api/instance/status/setStatus.ts
new file mode 100644
index 000000000..a9f43e069
--- /dev/null
+++ b/src/integrations/api/instance/status/setStatus.ts
@@ -0,0 +1,28 @@
+import { InstanceClientIdConfig } from '@/config/instanceClientConfig';
+import { SystemStatus } from '@/integrations/api/instance/status/getStatus';
+import { ReplicatedResponse } from '@/integrations/api/replication';
+import { queryClient } from '@/react-query/queryClient';
+import { useMutation } from '@tanstack/react-query';
+
+interface SetConfigurationParams extends Pick, InstanceClientIdConfig {
+}
+
+async function setStatus({
+ instanceClient,
+ id,
+ status,
+}: SetConfigurationParams): Promise {
+ const { data } = await instanceClient.post('/', {
+ operation: 'set_status',
+ id,
+ status,
+ });
+ return data;
+}
+
+export function useSetStatus() {
+ return useMutation({
+ mutationFn: setStatus,
+ onSuccess: (_data, variables) => queryClient.invalidateQueries({ queryKey: [variables.entityId, 'get_status'] }),
+ });
+}
diff --git a/src/lib/urls/getRestUrlForInstance.ts b/src/lib/urls/getRestUrlForInstance.ts
new file mode 100644
index 000000000..0a9f222ef
--- /dev/null
+++ b/src/lib/urls/getRestUrlForInstance.ts
@@ -0,0 +1,12 @@
+import { Instance } from '@/integrations/api/api.patch';
+
+export function getRestUrlForInstance(
+ instance: Pick,
+): string {
+ let fqdn = instance.instanceFqdn;
+ if (!fqdn.match(/^https?:\/\//i)) {
+ fqdn = `https://${fqdn}`;
+ }
+ const url = new URL(fqdn);
+ return url.toString();
+}