- {SOURCES.map((source) => {
+ {sources.map((source) => {
const status = statuses[source.id] || "idle";
return (
diff --git a/frontend/src/hooks/useApiStatus.ts b/frontend/src/hooks/useApiStatus.ts
new file mode 100644
index 0000000..b74373d
--- /dev/null
+++ b/frontend/src/hooks/useApiStatus.ts
@@ -0,0 +1,25 @@
+import { useEffect, useState } from "react";
+import {
+ API_SOURCES,
+ checkAllApiStatuses,
+ ensureApiStatusCheckStarted,
+ getApiStatusState,
+ subscribeApiStatus,
+} from "@/lib/api-status";
+
+export function useApiStatus() {
+ const [state, setState] = useState(getApiStatusState);
+
+ useEffect(() => {
+ ensureApiStatusCheckStarted();
+ return subscribeApiStatus(() => {
+ setState(getApiStatusState());
+ });
+ }, []);
+
+ return {
+ ...state,
+ sources: API_SOURCES,
+ refreshAll: checkAllApiStatuses,
+ };
+}
diff --git a/frontend/src/hooks/useAvailability.ts b/frontend/src/hooks/useAvailability.ts
index efb7dd8..440fbe1 100644
--- a/frontend/src/hooks/useAvailability.ts
+++ b/frontend/src/hooks/useAvailability.ts
@@ -2,6 +2,7 @@ import { useState, useCallback } from "react";
import { CheckTrackAvailability } from "../../wailsjs/go/main/App";
import type { TrackAvailability } from "@/types/api";
import { logger } from "@/lib/logger";
+import { CHECK_TIMEOUT_MS, withTimeout } from "@/lib/async-timeout";
export function useAvailability() {
const [checking, setChecking] = useState(false);
const [checkingTrackId, setCheckingTrackId] = useState(null);
@@ -20,7 +21,11 @@ export function useAvailability() {
setError(null);
try {
logger.info(`Checking availability for track: ${spotifyId}`);
- const response = await CheckTrackAvailability(spotifyId);
+ const response = await withTimeout(
+ CheckTrackAvailability(spotifyId),
+ CHECK_TIMEOUT_MS,
+ `Availability check timed out after 10 seconds for ${spotifyId}`,
+ );
const availability: TrackAvailability = JSON.parse(response);
setAvailabilityMap((prev) => {
const newMap = new Map(prev);
diff --git a/frontend/src/lib/api-status.ts b/frontend/src/lib/api-status.ts
new file mode 100644
index 0000000..d958a81
--- /dev/null
+++ b/frontend/src/lib/api-status.ts
@@ -0,0 +1,133 @@
+import { CheckAPIStatus } from "../../wailsjs/go/main/App";
+import { CHECK_TIMEOUT_MS, withTimeout } from "@/lib/async-timeout";
+
+export type ApiCheckStatus = "checking" | "online" | "offline" | "idle";
+
+export interface ApiSource {
+ id: string;
+ type: string;
+ name: string;
+ url: string;
+}
+
+export const API_SOURCES: ApiSource[] = [
+ { id: "tidal1", type: "tidal", name: "Tidal A", url: "https://hifi-one.spotisaver.net" },
+ { id: "tidal2", type: "tidal", name: "Tidal B", url: "https://hifi-two.spotisaver.net" },
+ { id: "tidal3", type: "tidal", name: "Tidal C", url: "https://eu-central.monochrome.tf" },
+ { id: "tidal4", type: "tidal", name: "Tidal D", url: "https://us-west.monochrome.tf" },
+ { id: "tidal5", type: "tidal", name: "Tidal E", url: "https://api.monochrome.tf" },
+ { id: "tidal6", type: "tidal", name: "Tidal F", url: "https://monochrome-api.samidy.com" },
+ { id: "tidal7", type: "tidal", name: "Tidal G", url: "https://tidal.kinoplus.online" },
+ { id: "qobuz1", type: "qobuz", name: "Qobuz A", url: "https://dab.yeet.su" },
+ { id: "qobuz2", type: "qobuz", name: "Qobuz B", url: "https://dabmusic.xyz" },
+ { id: "qobuz3", type: "qbz", name: "Qobuz C", url: "https://qbz.afkarxyz.qzz.io" },
+ { id: "amazon1", type: "amazon", name: "Amazon Music", url: "https://amzn.afkarxyz.qzz.io" },
+];
+
+type ApiStatusState = {
+ isCheckingAll: boolean;
+ statuses: Record;
+};
+
+let apiStatusState: ApiStatusState = {
+ isCheckingAll: false,
+ statuses: {},
+};
+
+let activeCheckAll: Promise | null = null;
+
+const listeners = new Set<() => void>();
+
+function emitApiStatusChange() {
+ for (const listener of listeners) {
+ listener();
+ }
+}
+
+function setApiStatusState(updater: (current: ApiStatusState) => ApiStatusState) {
+ apiStatusState = updater(apiStatusState);
+ emitApiStatusChange();
+}
+
+async function checkSingleApiStatus(source: ApiSource): Promise {
+ setApiStatusState((current) => ({
+ ...current,
+ statuses: {
+ ...current.statuses,
+ [source.id]: "checking",
+ },
+ }));
+
+ try {
+ const isOnline = await withTimeout(
+ CheckAPIStatus(source.type, source.url),
+ CHECK_TIMEOUT_MS,
+ `API status check timed out after 10 seconds for ${source.url}`,
+ );
+
+ setApiStatusState((current) => ({
+ ...current,
+ statuses: {
+ ...current.statuses,
+ [source.id]: isOnline ? "online" : "offline",
+ },
+ }));
+ } catch {
+ setApiStatusState((current) => ({
+ ...current,
+ statuses: {
+ ...current.statuses,
+ [source.id]: "offline",
+ },
+ }));
+ }
+}
+
+export function getApiStatusState(): ApiStatusState {
+ return apiStatusState;
+}
+
+export function subscribeApiStatus(listener: () => void): () => void {
+ listeners.add(listener);
+ return () => {
+ listeners.delete(listener);
+ };
+}
+
+export function hasApiStatusResults(): boolean {
+ return API_SOURCES.some((source) => {
+ const status = apiStatusState.statuses[source.id];
+ return status === "online" || status === "offline";
+ });
+}
+
+export function ensureApiStatusCheckStarted(): void {
+ if (!activeCheckAll && !hasApiStatusResults()) {
+ void checkAllApiStatuses();
+ }
+}
+
+export async function checkAllApiStatuses(): Promise {
+ if (activeCheckAll) {
+ return activeCheckAll;
+ }
+
+ activeCheckAll = (async () => {
+ setApiStatusState((current) => ({
+ ...current,
+ isCheckingAll: true,
+ }));
+
+ try {
+ await Promise.allSettled(API_SOURCES.map((source) => checkSingleApiStatus(source)));
+ } finally {
+ setApiStatusState((current) => ({
+ ...current,
+ isCheckingAll: false,
+ }));
+ activeCheckAll = null;
+ }
+ })();
+
+ return activeCheckAll;
+}
diff --git a/frontend/src/lib/async-timeout.ts b/frontend/src/lib/async-timeout.ts
new file mode 100644
index 0000000..217deb7
--- /dev/null
+++ b/frontend/src/lib/async-timeout.ts
@@ -0,0 +1,23 @@
+export const CHECK_TIMEOUT_MS = 10 * 1000;
+
+export function withTimeout(
+ promise: Promise,
+ timeoutMs: number = CHECK_TIMEOUT_MS,
+ message: string = `Operation timed out after ${Math.round(timeoutMs / 1000)} seconds`,
+): Promise {
+ return new Promise((resolve, reject) => {
+ const timer = window.setTimeout(() => {
+ reject(new Error(message));
+ }, timeoutMs);
+
+ promise
+ .then((value) => {
+ window.clearTimeout(timer);
+ resolve(value);
+ })
+ .catch((error) => {
+ window.clearTimeout(timer);
+ reject(error);
+ });
+ });
+}