added Audio permission

apps/dispatch/app/_store/audioStore.ts

@@ -12,7 +12,8 @@ let interval: NodeJS.Timeout;
 
 type TalkState = {
 	isTalking: boolean;
-	state: "connecting" | "connected" | "disconnected";
+	state: "connecting" | "connected" | "disconnected" | "error";
+	message: string | null;
 	connectionQuality: ConnectionQuality;
 	remoteParticipants: number;
 	toggleTalking: () => void;
@@ -21,60 +22,73 @@ type TalkState = {
 	disconnect: () => void;
 	room: Room | null;
 };
-const getToken = async (roomName: string) => {
-	const response = await fetch(
-		`${process.env.NEXT_PUBLIC_DISPATCH_SERVER_URL}/livekit/token?roomName=${roomName}`,
-	);
+const getToken = async () => {
+	const response = await fetch(`/api/livekit/token`);
 	const data = await response.json();
 	return data.token;
 };
 
 export const useAudioStore = create<TalkState>((set, get) => ({
 	isTalking: false,
+	message: null,
 	state: "disconnected",
 	remoteParticipants: 0,
 	connectionQuality: ConnectionQuality.Unknown,
 	room: null,
 	toggleTalking: () => set((state) => ({ isTalking: !state.isTalking })),
 	connect: async (roomName) => {
-		const connectedRoom = get().room;
-		if (interval) clearInterval(interval);
-		if (connectedRoom) {
-			connectedRoom.disconnect();
-			connectedRoom.removeAllListeners();
+		try {
+			// Clean old room
+			const connectedRoom = get().room;
+			if (interval) clearInterval(interval);
+			if (connectedRoom) {
+				connectedRoom.disconnect();
+				connectedRoom.removeAllListeners();
+			}
+
+			set({ state: "connecting" });
+			const url = process.env.NEXT_PUBLIC_LIVEKIT_URL;
+			if (!url) return console.error("NEXT_PUBLIC_LIVEKIT_URL not set");
+
+			const token = await getToken();
+			if (!token) throw new Error("Fehlende Berechtigung");
+			console.log("Token: ", token);
+			const room = new Room();
+			await room.prepareConnection(url, token);
+			room
+				// Connection events
+				.on(RoomEvent.Connected, () => {
+					set({ state: "connected", room, message: null });
+				})
+				.on(RoomEvent.Disconnected, () => {
+					set({ state: "disconnected" });
+
+					handleDisconnect();
+				})
+				.on(RoomEvent.ConnectionQualityChanged, (connectionQuality) =>
+					set({ connectionQuality }),
+				)
+
+				// Track events
+				.on(RoomEvent.TrackSubscribed, handleTrackSubscribed)
+				.on(RoomEvent.TrackUnsubscribed, handleTrackUnsubscribed)
+				.on(RoomEvent.ActiveSpeakersChanged, handleActiveSpeakerChange)
+				.on(RoomEvent.LocalTrackUnpublished, handleLocalTrackUnpublished);
+			await room.connect(url, token);
+			interval = setInterval(() => {
+				set({
+					remoteParticipants:
+						room.numParticipants === 0 ? 0 : room.numParticipants - 1, // Unreliable and delayed
+				});
+			}, 500);
+		} catch (error: Error | unknown) {
+			console.error("Error occured: ", error);
+			if (error instanceof Error) {
+				set({ state: "error", message: error.message });
+			} else {
+				set({ state: "error", message: "Unknown error" });
+			}
 		}
-		set({ state: "connecting" });
-		const url = process.env.NEXT_PUBLIC_LIVEKIT_URL;
-		if (!url) return console.error("NEXT_PUBLIC_LIVEKIT_URL not set");
-		const token = await getToken(roomName);
-		const room = new Room();
-		await room.prepareConnection(url, token);
-		room
-			// Connection events
-			.on(RoomEvent.Connected, () => {
-				set({ state: "connected", room });
-			})
-			.on(RoomEvent.Disconnected, () => {
-				set({ state: "disconnected" });
-
-				handleDisconnect();
-			})
-			.on(RoomEvent.ConnectionQualityChanged, (connectionQuality) =>
-				set({ connectionQuality }),
-			)
-
-			// Track events
-			.on(RoomEvent.TrackSubscribed, handleTrackSubscribed)
-			.on(RoomEvent.TrackUnsubscribed, handleTrackUnsubscribed)
-			.on(RoomEvent.ActiveSpeakersChanged, handleActiveSpeakerChange)
-			.on(RoomEvent.LocalTrackUnpublished, handleLocalTrackUnpublished);
-		await room.connect(url, token);
-		interval = setInterval(() => {
-			set({
-				remoteParticipants:
-					room.numParticipants === 0 ? 0 : room.numParticipants - 1, // Unreliable and delayed
-			});
-		}, 500);
 	},
 	disconnect: () => {
 		get().room?.disconnect();