homeio

1"use client";
2
3import { useMutation, useQueryClient } from "@tanstack/react-query";
4import type { NetworkStatus } from "@/lib/shared/contracts/network";
5import { queryKeys } from "@/lib/shared/query-keys";
6
7type NetworkMutationResponse = {
8  data: NetworkStatus;
9};
10
11type ErrorResponsePayload = {
12  error?: string;
13  code?: string;
14};
15
16function toNetworkActionErrorMessage(
17  endpoint: string,
18  status: number,
19  payload: ErrorResponsePayload | null,
20) {
21  const baseMessage = payload?.error?.trim() || `Network action failed (${status}) for ${endpoint}`;
22  const code = payload?.code?.trim();
23  if (!code) return baseMessage;
24
25  if (code === "helper_unavailable") {
26    return "DBus helper unavailable. Check home-server-dbus service status.";
27  }
28
29  if (code === "network_manager_unavailable") {
30    return "NetworkManager is unavailable on this server.";
31  }
32
33  if (code === "auth_failed") {
34    return "Wi-Fi authentication failed. Check the network password.";
35  }
36
37  return `${baseMessage} [${code}]`;
38}
39
40async function parseErrorPayload(response: Response) {
41  try {
42    return (await response.json()) as ErrorResponsePayload;
43  } catch {
44    return null;
45  }
46}
47
48async function postNetworkAction(
49  endpoint: string,
50  payload: Record<string, unknown>,
51) {
52  const response = await fetch(endpoint, {
53    method: "POST",
54    headers: {
55      "Content-Type": "application/json",
56    },
57    body: JSON.stringify(payload),
58  });
59
60  if (!response.ok) {
61    const errorPayload = await parseErrorPayload(response);
62    throw new Error(
63      toNetworkActionErrorMessage(endpoint, response.status, errorPayload),
64    );
65  }
66
67  const json = (await response.json()) as NetworkMutationResponse;
68  return json.data;
69}
70
71export function useNetworkActions() {
72  const queryClient = useQueryClient();
73
74  const connectMutation = useMutation({
75    mutationFn: (input: { ssid: string; password?: string }) =>
76      postNetworkAction(
77        "/api/v1/network/connect",
78        {
79          ssid: input.ssid,
80          password: input.password,
81        },
82      ),
83    onSuccess: () => {
84      void Promise.all([
85        queryClient.invalidateQueries({ queryKey: queryKeys.networkStatus }),
86        queryClient.invalidateQueries({ queryKey: queryKeys.networkNetworks }),
87      ]);
88    },
89  });
90
91  const disconnectMutation = useMutation({
92    mutationFn: (input?: { iface?: string }) =>
93      postNetworkAction(
94        "/api/v1/network/disconnect",
95        input ?? {},
96      ),
97    onSuccess: () => {
98      void Promise.all([
99        queryClient.invalidateQueries({ queryKey: queryKeys.networkStatus }),
100        queryClient.invalidateQueries({ queryKey: queryKeys.networkNetworks }),
101      ]);
102    },
103  });
104
105  return {
106    connectNetwork: connectMutation.mutateAsync,
107    disconnectNetwork: disconnectMutation.mutateAsync,
108    isConnecting: connectMutation.isPending,
109    isDisconnecting: disconnectMutation.isPending,
110    actionError: connectMutation.error ?? disconnectMutation.error ?? null,
111  };
112}
113