b

1 files changed, 20 insertions, 62 deletions

diff --git a/source/client/user.ts b/source/client/user.ts
index 7848c8c..b7ee24a 100644
--- a/source/client/user.ts
+++ b/source/client/user.ts
@@ -1,80 +1,38 @@
-import { local_media } from "."
-import { log } from "./logger"
 import { Room } from "./room"
 
 
-
-export class User {
-    el: HTMLElement
-    el_video: HTMLVideoElement
-
+export abstract class User {
     name: string
+    room: Room
 
-    peer: RTCPeerConnection
+    el: HTMLElement
+    view_el?: HTMLElement
 
-    room: Room
-    stream: MediaStream
+    local: boolean = false
 
+    stream: MediaStream = new MediaStream()
 
-    constructor(room: Room, name: string, offer: boolean) {
+    constructor(room: Room, name: string) {
         this.name = name
         this.room = room
-        this.stream = new MediaStream()
         this.el = document.createElement("div")
-        this.el_video = document.createElement("video")
-        this.el.append(this.el_video)
-        this.el_video.autoplay = true
-        this.el_video.setAttribute("playsinline", "1")
-        this.room.el.appendChild(this.el)
-
-        this.peer = new RTCPeerConnection()
-        local_media.getTracks().forEach(t => this.peer.addTrack(t, local_media))
-        this.peer.onicecandidate = ev => {
-            if (!ev.candidate) return
-            room.websocket_send({ ice_candiate: ev.candidate.toJSON(), receiver: this.name })
-        }
-        this.peer.ontrack = ev => {
-            log("media", "remote track", ev.streams)
-            if (!ev.streams.length) return console.warn("no remote tracks")
-            ev.streams[0].getTracks().forEach(t => {
-                this.stream.addTrack(t)
-            })
-        }
-        if (offer) this.offer()
+        this.room.el.append(this.el)
+        this.update_view()
     }
 
-    async offer() {
-        const offer_description = await this.peer.createOffer()
-        await this.peer.setLocalDescription(offer_description)
-        const offer = { type: offer_description.type, sdp: offer_description.sdp }
-        log("webrtc", "sent offer", offer)
-        this.room.websocket_send({ receiver: this.name, offer })
-    }
-    async on_offer(offer: RTCSessionDescriptionInit) {
-        log("webrtc", "got offer", offer)
-        const offer_description = new RTCSessionDescription(offer)
-        await this.peer.setRemoteDescription(offer_description)
-        this.answer(offer)
-    }
-    async answer(offer: RTCSessionDescriptionInit) {
-        const answer_description = await this.peer.createAnswer()
-        await this.peer.setLocalDescription(answer_description)
-        const answer = { type: answer_description.type, sdp: answer_description.sdp }
-        log("webrtc", "sent answer", answer)
-        this.room.websocket_send({ receiver: this.name, answer })
-    }
-    async on_answer(answer: RTCSessionDescriptionInit) {
-        log("webrtc", "got answer", answer)
-        const answer_description = new RTCSessionDescription(answer)
-        await this.peer.setRemoteDescription(answer_description)
+    update_view() {
+        if (this.view_el) this.el.removeChild(this.view_el)
+        this.view_el = this.create_view()
+        this.el.appendChild(this.view_el)
     }
 
-    add_ice_candidate(candidate: RTCIceCandidateInit) {
-        this.peer.addIceCandidate(new RTCIceCandidate(candidate))
-    }
+    create_view() {
+        const el = document.createElement("video")
+        el.autoplay = true
+        el.toggleAttribute("playsinline")
+        el.srcObject = this.stream
+        console.log(el);
 
-    leave() {
-        this.peer.close()
-        this.room.el.removeChild(this.el)
+        return el
     }
 }
\ No newline at end of file