46 lines
1.5 KiB
JavaScript
46 lines
1.5 KiB
JavaScript
import { addVideoStream, connectToNewUser, showNoVideoPrompt } from "./utils.js"
|
|
const socket = io("/")
|
|
const myPeer = new Peer()
|
|
const template = document.querySelector("#video-template")
|
|
|
|
myPeer.on("open", async (id) => {
|
|
try {
|
|
while (!localStorage.getItem("name")) {
|
|
await new Promise((resolve) => setTimeout(resolve, 2000))
|
|
}
|
|
const yourName = localStorage.getItem("name")
|
|
|
|
const stream = await navigator.mediaDevices.getUserMedia({
|
|
video: true,
|
|
audio: true,
|
|
})
|
|
|
|
const myVideo = template.content.firstElementChild.cloneNode(true)
|
|
addVideoStream(myVideo, yourName, stream, true)
|
|
myPeer.on("call", (call) => {
|
|
call.answer(stream)
|
|
const video = template.content.firstElementChild.cloneNode(true)
|
|
call.on("close", () => video.remove())
|
|
call.on("stream", (userVideoStream) =>
|
|
socket.emit("get-username", call.peer, (username) =>
|
|
addVideoStream(video, username, userVideoStream)
|
|
)
|
|
)
|
|
})
|
|
|
|
socket.on("user-connected", (userId, username) =>
|
|
connectToNewUser(userId, username, stream, myPeer)
|
|
)
|
|
} catch (error) {
|
|
if (error instanceof DOMException) return showNoVideoPrompt()
|
|
|
|
throw error
|
|
}
|
|
|
|
socket.emit("join-room", ROOM_ID, id, yourName)
|
|
})
|
|
|
|
socket.on("user-disconnected", (userId) => {
|
|
const call = myPeer.connections[userId]
|
|
if (call) call[0].close()
|
|
})
|