client/stream.js

@@ -64,12 +64,12 @@ async function stream() {
 			});
 		};
 		r.onstart = () => {
-			setTimeout(() => r.state === 'recording' && r.stop(), 500);
+			setTimeout(() => r.state === 'recording' && r.stop(), 100);
 		};
 		r.start();
 	}
 	record();
-	handle = setInterval(record, 500);
+	handle = setInterval(record, 100);
 }
 
 let audioctx;
@@ -114,14 +114,15 @@ function loadStreams() {
 		render(div, html.node`
 			<button id='streaming' onclick=${stream}>start streaming</button>
 			<span>stream name:</span>
-			<input id='streamname' oninput=${event => {
+			<input id='streamname'>`);
-				if (handle)
+		div.children['streamname'].oninput = event => {
-					window.emit('stream', {
+			if (handle)
-						id: streamid,
+				window.emit('stream', {
-						thread: window.currentThread.id,
+					id: streamid,
-						name: event.target.value
+					thread: window.currentThread.id,
-					});
+					name: div.children['streamname'].value
-			}}>`);
+				});
+		};
 	}
 	div.insertAdjacentHTML('beforeend', `
 		<p>streams:</p>

src/events/stream.js

@@ -60,7 +60,7 @@ async function stream(msg, respond, socket) {
 		stream = {
 			id: newstreamid++,
 			thread: msg.thread,
-			user: msg.auth_user.displayname,
+			user: msg.auth_user.name,
 			name: msg.name
 		};
 		thread.streams.push(stream);
@@ -98,11 +98,7 @@ async function streamdata(msg, respond) {
 		});
 	}
 	for (let id in stream.listeners)
-		stream.listeners[id].emit('streamdata', {
+		stream.listeners[id].emit('streamdata', msg);
-			id: msg.id,
-			audio: msg.audio,
-			video: msg.video
-		});
 	respond({
 		success: true
 	});