From b529a372644fab22b34007353cc69caf3de5331c Mon Sep 17 00:00:00 2001
From: Madeline <46743919+MaddyUnderStars@users.noreply.github.com>
Date: Mon, 7 Mar 2022 19:15:33 +1100
Subject: augh

---
 webrtc/src/Server.ts | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

(limited to 'webrtc/src/Server.ts')

diff --git a/webrtc/src/Server.ts b/webrtc/src/Server.ts
index 0145a221..1d18d6d1 100644
--- a/webrtc/src/Server.ts
+++ b/webrtc/src/Server.ts
@@ -6,6 +6,8 @@ import { setHeartbeat } from "./util";
 import * as mediasoup from "mediasoup";
 import { types as MediasoupTypes } from "mediasoup";
 
+import Net from "net";
+
 var port = Number(process.env.PORT);
 if (isNaN(port)) port = 3004;
 
@@ -13,7 +15,7 @@ export class Server {
 	public ws: WebSocketServer;
 	public mediasoupWorkers: MediasoupTypes.Worker[] = [];
 	public mediasoupRouters: MediasoupTypes.Router[] = [];
-	public mediasoupTransports: MediasoupTypes.Transport[] = [];
+	public mediasoupTransports: MediasoupTypes.WebRtcTransport[] = [];
 
 	constructor() {
 		this.ws = new WebSocketServer({
@@ -26,7 +28,7 @@ export class Server {
 			socket.on("message", async (message: string) => {
 				const payload: Payload = JSON.parse(message);
 
-				console.log(payload);
+				// console.log(payload);
 
 				if (OPCodeHandlers[payload.op])
 					try {
@@ -68,9 +70,13 @@ export class Server {
 
 				this.mediasoupRouters.push(router);
 
-				router.observer.on("newtransport", async (transport: MediasoupTypes.Transport) => {
+				router.observer.on("newtransport", async (transport: MediasoupTypes.WebRtcTransport) => {
 					console.log("new transport created [id:%s]", transport.id);
 
+					transport.observer.on("sctpstatechange", (state) => {
+						console.log(state)
+					});
+
 					await transport.enableTraceEvent();
 
 					transport.observer.on("newproducer", (producer: MediasoupTypes.Producer) => {
-- 
cgit 1.5.1