Merge pull request #138 from StarfilesFileSharing/alpha

Alpha

deno.jsonc

@@ -1,6 +1,6 @@
 {
 	"name": "@starfiles/hydrafiles",
-	"version": "0.7.28",
+	"version": "0.7.29",
 	"description": "The web privacy layer.",
 	"main": "src/hydrafiles.ts",
 	"exports": {
@@ -39,7 +39,26 @@
 		"include": ["src/"],
 		"rules": {
 			"tags": ["recommended"],
-			"include": ["camelcase", "default-param-last", "eqeqeq", "explicit-function-return-type", "explicit-module-boundary-types", "guard-for-in", "no-const-assign", "no-inferrable-types", "no-non-null-assertion", "no-self-compare", "no-sparse-arrays", "no-sync-fn-in-async-fn", "no-throw-literal", "no-undef", "constructor-super", "no-async-promise-executor", "no-await-in-sync-fn", "valid-typeof"]
+			"include": [
+				"camelcase",
+				"default-param-last",
+				"eqeqeq",
+				"explicit-function-return-type",
+				"explicit-module-boundary-types",
+				"guard-for-in",
+				"no-const-assign",
+				"no-inferrable-types",
+				"no-non-null-assertion",
+				"no-self-compare",
+				"no-sparse-arrays",
+				"no-sync-fn-in-async-fn",
+				"no-throw-literal",
+				"no-undef",
+				"constructor-super",
+				"no-async-promise-executor",
+				"no-await-in-sync-fn",
+				"valid-typeof"
+			]
 		}
 	},
 	"fmt": {

src/peers/RTCPeers.ts

@@ -198,7 +198,7 @@ class RTCPeers {
 			return;
 		}
 
-		console.log(`WebRTC: (4/12): ${from} Received offer`, extractIPAddress(offer.sdp));
+		console.log(`WebRTC: (4/12): ${from} Received offer from`, extractIPAddress(offer.sdp));
 
 		this.peerConnections[from].answered = await this.createPeerConnection(from);
 		if (this.peerConnections[from].answered.conn.signalingState !== "stable" && this.peerConnections[from].answered.conn.signalingState !== "have-remote-offer") {

src/server.ts

@@ -26,7 +26,7 @@ export const handleRequest = async (req: Request, client: Hydrafiles): Promise<R
 			socket.addEventListener("message", ({ data }) => {
 				const message = JSON.parse(data) as Message;
 				for (let i = 0; i < sockets.length; i++) {
-					if (sockets[i].socket !== socket && (!("to" in message) || message.to === sockets[i].id)) {
+					if (sockets[i].socket !== socket && (message && !("to" in message) || message.to === sockets[i].id)) {
 						if (sockets[i].socket.readyState === 1) sockets[i].socket.send(data);
 					} else if ("from" in message) {
 						sockets[i].id = message.from;