diff --git a/engine/demo/.gitignore b/engine/demo/.gitignore new file mode 100644 index 0000000..c2658d7 --- /dev/null +++ b/engine/demo/.gitignore @@ -0,0 +1 @@ +node_modules/ diff --git a/engine/demo/index.html b/engine/demo/index.html new file mode 100644 index 0000000..d179ab9 --- /dev/null +++ b/engine/demo/index.html @@ -0,0 +1,760 @@ + + + + + + + DreamStack โ€” Pixel Stream Source + + + + + + +
+

DreamStack Engine โ€” Source

+
ds-physics v0.9.0 ยท pixel streaming via ds-stream
+
+ +
+
Disconnected
+
Relay: ws://localhost:9800/source
+
+ +
+ + + + + +
+
+ +
+
+
Physics Simulation
+ +
+
FPS 0
+
Bodies 0
+
Joints 0
+
Events 0
+
+
+ +
+
CAPTURE
+
โ†“
+
+
ds-stream frame
+
โ€”
+
+
+
Header (16B)
+
โ€”
+
+
โ†“
+
WebSocket
+
โ†“
+
+
Streamed
+
โ€”
+
+
+
+ + + + + \ No newline at end of file diff --git a/engine/demo/package-lock.json b/engine/demo/package-lock.json new file mode 100644 index 0000000..5004f6e --- /dev/null +++ b/engine/demo/package-lock.json @@ -0,0 +1,37 @@ +{ + "name": "demo", + "version": "1.0.0", + "lockfileVersion": 3, + "requires": true, + "packages": { + "": { + "name": "demo", + "version": "1.0.0", + "license": "ISC", + "dependencies": { + "ws": "^8.19.0" + } + }, + "node_modules/ws": { + "version": "8.19.0", + "resolved": "https://registry.npmjs.org/ws/-/ws-8.19.0.tgz", + "integrity": "sha512-blAT2mjOEIi0ZzruJfIhb3nps74PRWTCz1IjglWEEpQl5XS/UNama6u2/rjFkDDouqr4L67ry+1aGIALViWjDg==", + "license": "MIT", + "engines": { + "node": ">=10.0.0" + }, + "peerDependencies": { + "bufferutil": "^4.0.1", + "utf-8-validate": ">=5.0.2" + }, + "peerDependenciesMeta": { + "bufferutil": { + "optional": true + }, + "utf-8-validate": { + "optional": true + } + } + } + } +} diff --git a/engine/demo/package.json b/engine/demo/package.json new file mode 100644 index 0000000..09b8bbb --- /dev/null +++ b/engine/demo/package.json @@ -0,0 +1,15 @@ +{ + "name": "demo", + "version": "1.0.0", + "main": "relay.js", + "scripts": { + "test": "echo \"Error: no test specified\" && exit 1" + }, + "keywords": [], + "author": "", + "license": "ISC", + "description": "", + "dependencies": { + "ws": "^8.19.0" + } +} diff --git a/engine/demo/receiver.html b/engine/demo/receiver.html new file mode 100644 index 0000000..2363a03 --- /dev/null +++ b/engine/demo/receiver.html @@ -0,0 +1,536 @@ + + + + + + + DreamStack โ€” Pixel Stream Receiver + + + + + + +
+

DreamStack โ€” Receiver

+
ds-stream delta receiver ยท interactive
+
+ +
+
Disconnected
+
Relay: ws://localhost:9800/stream
+
+
๐Ÿ‘† Click on the stream to interact โ€” forces sent via relay, round-trip latency measured +
+ +
+
+
Pixel Stream ยท Click to Interact
+
+ +
Waiting for source stream...
+
+ +
+
Frames 0
+
Bytes 0B
+
FPS 0
+
Decode โ€”
+
RTT โ€”
+
Saved โ€”
+
+
+ +
+
+
โฑ Round-Trip Latency
+
โ€”
+
click โ†’ source โ†’ render โ†’ back
+
Click to measure
+
+
+
๐Ÿ“ฆ Compression
+
โ€”
+
delta + RLE vs raw RGBA
+
โ€”
+
+
+
Frame Type
+
โ€”
+
+
+
Interactions
+
0 clicks sent
+
+
+
+ + + + + \ No newline at end of file diff --git a/engine/demo/relay.js b/engine/demo/relay.js new file mode 100644 index 0000000..4d90d91 --- /dev/null +++ b/engine/demo/relay.js @@ -0,0 +1,69 @@ +// DreamStack ds-stream Pixel Relay Server (bidirectional) +// Source โ†’ Receiver: pixel frames +// Receiver โ†’ Source: interaction signals (clicks, drags) +const { WebSocketServer } = require('ws'); +const http = require('http'); + +const PORT = 9800; +const sources = new Set(); +const receivers = new Set(); +let frameCount = 0; +let byteCount = 0; +let signalCount = 0; + +const server = http.createServer((req, res) => { + res.writeHead(200, { + 'Content-Type': 'text/plain', + 'Access-Control-Allow-Origin': '*', + }); + res.end(`ds-stream relay | sources: ${sources.size} | receivers: ${receivers.size} | frames: ${frameCount} | signals: ${signalCount} | bytes: ${byteCount}`); +}); + +const wss = new WebSocketServer({ server }); + +wss.on('connection', (ws, req) => { + const path = req.url || '/'; + + if (path.startsWith('/source')) { + sources.add(ws); + console.log(`[relay] source connected (${sources.size} total)`); + + ws.on('message', (data) => { + frameCount++; + byteCount += data.length; + for (const recv of receivers) { + if (recv.readyState === 1) recv.send(data); + } + }); + + ws.on('close', () => { + sources.delete(ws); + console.log(`[relay] source disconnected (${sources.size} remaining)`); + }); + } else { + receivers.add(ws); + console.log(`[relay] receiver connected (${receivers.size} total)`); + + ws.on('message', (data) => { + // Forward interaction signals from receiver โ†’ source + signalCount++; + for (const src of sources) { + if (src.readyState === 1) src.send(data); + } + }); + + ws.on('close', () => { + receivers.delete(ws); + console.log(`[relay] receiver disconnected (${receivers.size} remaining)`); + }); + } +}); + +server.listen(PORT, () => { + console.log(`\n โ•”โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•—`); + console.log(` โ•‘ ds-stream relay on :${PORT} โ•‘`); + console.log(` โ•‘ Source: ws://localhost:${PORT}/source โ•‘`); + console.log(` โ•‘ Receiver: ws://localhost:${PORT}/stream โ•‘`); + console.log(` โ•‘ Mode: bidirectional (pixels + signals) โ•‘`); + console.log(` โ•šโ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•โ•\n`); +});