aboutsummaryrefslogtreecommitdiff
path: root/source/client/index.ts
diff options
context:
space:
mode:
Diffstat (limited to 'source/client/index.ts')
-rw-r--r--source/client/index.ts192
1 files changed, 96 insertions, 96 deletions
diff --git a/source/client/index.ts b/source/client/index.ts
index 3841c8a..87421f2 100644
--- a/source/client/index.ts
+++ b/source/client/index.ts
@@ -1,130 +1,130 @@
+import { Room } from "./room"
export const servers = {
- iceServers: [
- {
- urls: ["stun:stun1.l.google.com:19302", "stun:stun2.l.google.com:19302"]
- }
- ],
+ iceServers: [{ urls: ["stun:stun1.l.google.com:19302", "stun:stun2.l.google.com:19302"] }],
iceCandidatePoolSize: 10,
}
-let remote_stream: MediaStream, local_stream: MediaStream;
-let pc: RTCPeerConnection;
+export interface User {
+ peer: RTCPeerConnection
+ stream: MediaStream,
+}
-window.onload = async () => {
+export const users: Map<string, User> = new Map()
- if (window.location.search.startsWith("?offer=")) {
- await setup_webrtc()
- await offer(window.location.search.substr("?offer=".length))
- } else if (window.location.search.startsWith("?answer=")) {
- await setup_webrtc()
- await answer(window.location.search.substr("?answer=".length))
- } else {
+window.onload = async () => {
+ if (window.location.pathname.startsWith("/room/")) {
+ const room_name = window.location.pathname.substr("/room/".length)
+ let room = new Room(room_name)
+ document.body.append(room.el)
+ } else {
+ //TODO show ui for joining rooms
}
-
}
-async function setup_webrtc() {
- document.body.innerHTML = ""
- pc = new RTCPeerConnection(servers)
- local_stream = await navigator.mediaDevices.getUserMedia({ video: true, audio: true })
- remote_stream = new MediaStream()
+// async function setup_webrtc() {
+// document.body.innerHTML = ""
- local_stream.getTracks().forEach(t => pc.addTrack(t, local_stream))
+// pc = new RTCPeerConnection(servers)
- pc.ontrack = ev => {
- console.log("peer got remote tracks", ev.streams);
- ev.streams[0].getTracks().forEach(t => remote_stream.addTrack(t))
- }
+// local_stream = await navigator.mediaDevices.getUserMedia({ video: true, audio: true })
+// remote_stream = new MediaStream()
+// local_stream.getTracks().forEach(t => pc.addTrack(t, local_stream))
- const ls_el = document.createElement("video")
- const rs_el = document.createElement("video")
- ls_el.muted = true
- ls_el.autoplay = rs_el.autoplay = true
- ls_el.setAttribute("playsinline", "1")
- rs_el.setAttribute("playsinline", "1")
- ls_el.srcObject = local_stream
- rs_el.srcObject = remote_stream
+// pc.ontrack = ev => {
+// console.log("peer got remote tracks", ev.streams);
+// ev.streams[0].getTracks().forEach(t => remote_stream.addTrack(t))
+// }
- document.body.append(ls_el, rs_el)
-}
+// const ls_el = document.createElement("video")
+// const rs_el = document.createElement("video")
+// ls_el.muted = true
+// ls_el.autoplay = rs_el.autoplay = true
+// ls_el.setAttribute("playsinline", "1")
+// rs_el.setAttribute("playsinline", "1")
+// ls_el.srcObject = local_stream
+// rs_el.srcObject = remote_stream
-interface Offer {
- sdp: any,
- type: any
-}
+// document.body.append(ls_el, rs_el)
-async function offer(id: string) {
- const ws = new WebSocket(`ws://${window.location.host}/offer/${id}`)
- ws.onclose = ev => console.log("websocket closed: " + ev.reason);
- await new Promise<void>(r => ws.onopen = () => r())
+// }
- console.log("websocket opened")
+// interface Offer {
+// sdp: any,
+// type: any
+// }
- pc.onicecandidate = ev => {
- const candidate = ev.candidate?.toJSON()
- if (!candidate) return
- ws.send(JSON.stringify({ candidate }))
- console.log("sent ice candidate", ev.candidate);
- }
+// async function offer(id: string) {
+// const ws = new WebSocket(`ws://${window.location.host}/offer/${id}`)
+// ws.onclose = ev => console.log("websocket closed: " + ev.reason);
+// await new Promise<void>(r => ws.onopen = () => r())
- const offer_description = await pc.createOffer()
- await pc.setLocalDescription(offer_description);
+// console.log("websocket opened")
- const offer: Offer = { sdp: offer_description.sdp, type: offer_description.type };
+// pc.onicecandidate = ev => {
+// const candidate = ev.candidate?.toJSON()
+// if (!candidate) return
+// ws.send(JSON.stringify({ candidate }))
+// console.log("sent ice candidate", ev.candidate);
+// }
- ws.send(JSON.stringify({ offer }))
+// const offer_description = await pc.createOffer()
+// await pc.setLocalDescription(offer_description);
- ws.onmessage = ev => {
- const s = JSON.parse(ev.data)
- if (s.answer) {
- console.log("got answer", s.answer);
- const answer_description = new RTCSessionDescription(s.answer)
- pc.setRemoteDescription(answer_description)
- }
- if (s.candidate) {
- console.log("got candidate", s.candidate);
- const candidate = new RTCIceCandidate(s.candidate)
- pc.addIceCandidate(candidate)
- }
- }
+// const offer: Offer = { sdp: offer_description.sdp, type: offer_description.type };
-}
+// ws.send(JSON.stringify({ offer }))
-async function answer(id: string) {
- const ws = new WebSocket(`ws://${window.location.host}/answer/${id}`)
- ws.onclose = ev => console.log("websocket closed: " + ev.reason);
- await new Promise<void>(r => ws.onopen = () => r())
- console.log("websocket opened");
+// ws.onmessage = ev => {
+// const s = JSON.parse(ev.data)
+// if (s.answer) {
+// console.log("got answer", s.answer);
+// const answer_description = new RTCSessionDescription(s.answer)
+// pc.setRemoteDescription(answer_description)
+// }
+// if (s.candidate) {
+// console.log("got candidate", s.candidate);
+// const candidate = new RTCIceCandidate(s.candidate)
+// pc.addIceCandidate(candidate)
+// }
+// }
+// }
- pc.onicecandidate = ev => {
- const candidate = ev.candidate?.toJSON()
- if (!candidate) return
- ws.send(JSON.stringify({ candidate }))
- console.log("sent ice candidate", candidate);
- }
+// async function answer(id: string) {
+// const ws = new WebSocket(`ws://${window.location.host}/answer/${id}`)
+// ws.onclose = ev => console.log("websocket closed: " + ev.reason);
+// await new Promise<void>(r => ws.onopen = () => r())
+// console.log("websocket opened");
- ws.onmessage = async ev => {
- const s = JSON.parse(ev.data)
- if (s.offer) {
- console.log("got offer", s.offer);
- await pc.setRemoteDescription(new RTCSessionDescription(s.offer))
- const answer_description = await pc.createAnswer()
- await pc.setLocalDescription(answer_description)
+// pc.onicecandidate = ev => {
+// const candidate = ev.candidate?.toJSON()
+// if (!candidate) return
+// ws.send(JSON.stringify({ candidate }))
+// console.log("sent ice candidate", candidate);
+// }
- const answer: Offer = { type: answer_description.type, sdp: answer_description.sdp }
- ws.send(JSON.stringify({ answer }))
- }
- if (s.candidate) {
- console.log("got candidate", s.candidate);
- pc.addIceCandidate(new RTCIceCandidate(s.candidate))
- }
- }
-}
+// ws.onmessage = async ev => {
+// const s = JSON.parse(ev.data)
+// if (s.offer) {
+// console.log("got offer", s.offer);
+// await pc.setRemoteDescription(new RTCSessionDescription(s.offer))
+
+// const answer_description = await pc.createAnswer()
+// await pc.setLocalDescription(answer_description)
+
+// const answer: Offer = { type: answer_description.type, sdp: answer_description.sdp }
+// ws.send(JSON.stringify({ answer }))
+// }
+// if (s.candidate) {
+// console.log("got candidate", s.candidate);
+// pc.addIceCandidate(new RTCIceCandidate(s.candidate))
+// }
+// }
+// }
generated by cgit v1.2.3-70-g09d2 (git 2.51.0) at 2025-10-09 05:37:18 +0000