feat: make emu work with NTC

timotheeg · Aug 5, 2024 · 0971329 · 0971329
1 parent 1351c3c
commit 0971329
Show file tree

Hide file tree

Showing 4 changed files with 70 additions and 17 deletions.
diff --git a/public/emu/index.html b/public/emu/index.html
@@ -2,12 +2,12 @@
 <html>
 	<head>
 		<meta charset="utf-8" />
-		<link href="style.css" rel="stylesheet" />
-		<link href="embed.css" rel="stylesheet" />
-		<script src="./rustico_wasm.js"></script>
-		<script src="./touch.js"></script>
-		<script src="./input.js"></script>
-		<script type="module" src="./main.js"></script>
+		<link href="/emu/style.css" rel="stylesheet" />
+		<link href="/emu/embed.css" rel="stylesheet" />
+		<script src="/emu/rustico_wasm.js"></script>
+		<script src="/emu/touch.js"></script>
+		<script src="/emu/input.js"></script>
+		<script type="module" src="/emu/main.js"></script>
 	</head>
 	<body>
 		<div id="navbar">

diff --git a/public/emu/main.js b/public/emu/main.js
@@ -1,5 +1,8 @@
 import { MarcFile, parseBPSFile } from '/emu/bps.js';
 import { address_maps, getDataAddresses, assignData } from '/emu/addresses.js';
+import Connection from '/js/connection.js';
+import BinaryFrame from '/js/BinaryFrame.js';
+import EDGameTracker from '/ocr/EDGameTracker.js';
 
 // ========== Global Application State ==========
 
@@ -39,6 +42,41 @@ let g_decrease_frameskip_headroom = 1.5; // percent of the time taken to render
 let g_gymFile = null;
 let g_gym_addresses = getDataAddresses(address_maps.gym6);
 
+const g_connection = new Connection();
+const g_edGameTracker = new EDGameTracker();
+
+let last_frame = { field: [] };
+
+g_connection.onMessage = () => {}; // ignore everything for now
+
+g_edGameTracker.onFrame = data => {
+	if (!data) return;
+
+	// 6. transmit frame to NTC server if necessary
+	check_equal: do {
+		for (let key in data) {
+			if (key[0] === '_') continue;
+			if (key === 'ctime') continue;
+			if (key === 'field') {
+				if (!data.field.every((v, i) => last_frame.field[i] === v)) {
+					break check_equal;
+				}
+			} else if (data[key] != last_frame[key]) {
+				break check_equal;
+			}
+		}
+
+		// all fields equal, do a sanity check on time
+		if (data.ctime - last_frame.ctime >= 250) break; // max 1 in 15 frames (4fps)
+
+		// no need to send frame
+		return;
+	} while (false);
+
+	last_frame = data;
+	g_connection.send(BinaryFrame.encode(data));
+};
+
 // ========== Init which does not depend on DOM ========
 
 for (let i = 0; i < g_total_buffers; i++) {
@@ -67,7 +105,7 @@ function rpc(task, args) {
 }
 
 function startWorker() {
-	worker = new Worker('emu_worker.js');
+	worker = new Worker('/emu/emu_worker.js');
 
 	worker.onmessage = function (e) {
 		if (e.data.type == 'init') {
@@ -106,8 +144,7 @@ function startWorker() {
 				g_rendered_frames.shift(); // and throw it away
 			}
 
-			const ramData = assignData(e.data.mem_values, address_maps.gym6);
-			console.log(ramData);
+			g_edGameTracker.setData(e.data.mem_values);
 		}
 
 		if (e.data.type == 'reportPerformance') {
@@ -216,7 +253,7 @@ async function init_audio_context() {
 		latencyHint: 'interactive',
 		sampleRate: 44100,
 	});
-	await g_audio_context.audioWorklet.addModule('audio_processor.js');
+	await g_audio_context.audioWorklet.addModule('/emu/audio_processor.js');
 	g_nes_audio_node = new AudioWorkletNode(
 		g_audio_context,
 		'nes-audio-processor'

diff --git a/routes/routes.js b/routes/routes.js
@@ -66,27 +66,42 @@ router.get(
 /**/
 
 router.get(
-	'/room/producer',
+	/^\/room\/(producer|emu)/,
 	middlewares.assertSession,
 	middlewares.checkToken,
 	(req, res) => {
-		res.sendFile(path.join(path.resolve(), 'public/ocr/ocr.html'));
+		req.originalUrl;
+		res.sendFile(
+			path.join(
+				path.resolve(),
+				`public${
+					/producer/.test(req.path) ? '/ocr/ocr.html' : '/emu/index.html'
+				}`
+			)
+		);
 	}
 );
 
 router.get(
-	'/room/u/:login/producer',
+	/^\/room\/u\/([a-zA-Z0-9]+)\/(producer|emu)/,
 	middlewares.assertSession,
 	middlewares.checkToken,
 	async (req, res) => {
-		const target_user = await UserDAO.getUserByLogin(req.params.login);
+		const target_user = await UserDAO.getUserByLogin(req.params[0]);
 
 		if (!target_user) {
 			res.status(404).send('Target User Not found');
 			return;
 		}
 
-		res.sendFile(path.join(path.resolve(), 'public/ocr/ocr.html'));
+		res.sendFile(
+			path.join(
+				path.resolve(),
+				`public${
+					/producer/.test(req.path) ? '/ocr/ocr.html' : '/emu/index.html'
+				}`
+			)
+		);
 	}
 );
 

diff --git a/routes/websocket.js b/routes/websocket.js
@@ -304,7 +304,7 @@ export default function init(server, wss) {
 		} else if (pathname.startsWith('/ws/room/admin')) {
 			console.log(`MatchRoom: ${user.login}: Admin connected`);
 			user.getHostRoom().setAdmin(connection);
-		} else if (pathname.startsWith('/ws/room/producer')) {
+		} else if (/^\/ws\/room\/(producer|emu)/.test(pathname)) {
 			console.log(`PrivateRoom: ${user.login}: Producer connected`);
 			user.setProducerConnection(connection, {
 				match: false,
@@ -342,7 +342,8 @@ export default function init(server, wss) {
 				}
 				/** */
 
-				case 'producer': {
+				case 'producer':
+				case 'emu': {
 					console.log(
 						`MatchRoom: ${target_user.login}: Producer ${user.login} connected`
 					);