@@ -86,19 +127,162 @@ function RoomHeader({ ev }: { ev: TaggedNostrEvent }) {
);
}
-function ParticipantList({ ev }: { ev: TaggedNostrEvent }) {
- const participants = useParticipants();
+function RoomBody({ ev, tab, onSelectTab }: { ev: TaggedNostrEvent; tab: RoomTab; onSelectTab: (t: RoomTab) => void }) {
+ const participants = useParticipants({
+ updateOnlyOn: [
+ RoomEvent.ParticipantConnected,
+ RoomEvent.ParticipantDisconnected,
+ RoomEvent.ParticipantPermissionsChanged,
+ RoomEvent.TrackMuted,
+ RoomEvent.TrackPublished,
+ RoomEvent.TrackUnmuted,
+ RoomEvent.TrackUnmuted,
+ ],
+ });
return (
-
-
-
-
- {participants.map(a => (
-
- ))}
+
+
+
onSelectTab(RoomTab.Participants)}>
+
+
+
onSelectTab(RoomTab.Chat)}>
+
+
+ {tab === RoomTab.Participants && (
+
+ {participants.map(a => (
+
+ ))}
+
+ )}
+ {tab === RoomTab.Chat && (
+ <>
+
+
+
+ )}
+
+ );
+}
+
+function MyControls() {
+ const room = useEnsureRoom();
+ const p = room.localParticipant;
+ const permissions = useParticipantPermissions({
+ participant: p,
+ });
+ useEffect(() => {
+ if (permissions && p instanceof LocalParticipant) {
+ const handler = (lt: LocalTrackPublication) => {
+ lt.mute();
+ };
+ p.on("localTrackPublished", handler);
+ if (permissions.canPublish && p.audioTrackPublications.size === 0) {
+ p.setMicrophoneEnabled(true);
+ }
+ return () => {
+ p.off("localTrackPublished", handler);
+ };
+ }
+ }, [p, permissions]);
+ const isMuted = p.getTrackPublication(Track.Source.Microphone)?.isMuted ?? true;
+
+ return (
+
+ {p.permissions?.canPublish && (
+ {
+ if (isMuted) {
+ await p.setMicrophoneEnabled(true);
+ } else {
+ await p.setMicrophoneEnabled(false);
+ }
+ }}
+ />
+ )}
+ {/**/}
+
+ );
+}
+
+function RoomChat({ ev }: { ev: TaggedNostrEvent }) {
+ const link = NostrLink.fromEvent(ev);
+ const sub = useMemo(() => {
+ const sub = new RequestBuilder(`room-chat:${link.tagKey}`);
+ sub.withOptions({ leaveOpen: true, replaceable: true });
+ sub.withFilter().replyToLink([link]).kinds([EventKind.LiveEventChat]).limit(100);
+ return sub;
+ }, [link.tagKey]);
+ const chat = useRequestBuilder(sub);
+
+ return (
+
+
+ {chat
+ .sort((a, b) => b.created_at - a.created_at)
+ .map(e => (
+
+ ))}
+
+
+ );
+}
+
+function ChatMessage({ ev }: { ev: TaggedNostrEvent }) {
+ return (
+
+ );
+}
+
+function WriteChatMessage({ ev }: { ev: TaggedNostrEvent }) {
+ const link = NostrLink.fromEvent(ev);
+ const [chat, setChat] = useState("");
+ const { publisher, system } = useEventPublisher();
+ const { formatMessage } = useIntl();
+
+ async function sendMessage() {
+ if (!publisher || !system || chat.length < 2) return;
+ const eChat = await publisher.generic(eb => eb.kind(EventKind.LiveEventChat).tag(link.toEventTag()!).content(chat));
+ await system.BroadcastEvent(eChat);
+ setChat("");
+ }
+
+ return (
+
+ setChat(e.target.value)}
+ className="grow"
+ onKeyDown={e => {
+ if (e.key === "Enter") {
+ sendMessage();
+ }
+ }}
+ />
+
);
}
@@ -116,16 +300,27 @@ function NostrParticipants({ ev }: { ev: TaggedNostrEvent }) {
}, [link.tagKey]);
const presense = useRequestBuilder(sub);
- return
a.pubkey))} size={32} />;
+ const filteredPresence = presense.filter(ev => ev.created_at > unixNow() - 600);
+ return a.pubkey))} size={32} />;
}
function LiveKitUser({ p }: { p: RemoteParticipant | LocalParticipant }) {
const pubkey = p.identity.startsWith("guest-") ? "anon" : p.identity;
const profile = useUserProfile(pubkey);
+ const mic = p.getTrackPublication(Track.Source.Microphone);
+
return (
-
-
+
+ {mic?.audioTrack?.mediaStreamTrack && (
+
+ )}
+
+
+
+
+ {p.permissions?.canPublish &&
Speaker
}
+