radio95/RadioPlayer
0
1
Fork 0
mirror of https://github.com/radio95-rnt/RadioPlayer.git synced 2026-07-29 15:29:14 +02:00
Code Issues Activity

go back to non reader.js

Browse Source
This commit is contained in:
kuba
2026-04-20 21:01:50 +02:00
parent 1a0b6637bd
commit ead73e573e
2 changed files with 45 additions and 54 deletions
Download Patch File Download Diff File Expand all files Collapse all files
modules/web/index.html
+1 -3
View File
@@ -167,14 +167,12 @@
#keybinds {display: none;}
}
</style>
<script defer src="./reader.js"></script>
</head>
<body>
<div class="container">
<div style="display:flex;align-items:center;justify-content:space-between;">
<div>
<h1>RadioPlayer status</h1>
<noscript><h1> - NO SCRIPTING - </h1></noscript>
<h1>RadioPlayer status <noscript> - NO SCRIPTING - </noscript></h1>
</div>
</div>
modules/web/web.js
+35 -42
View File
@@ -340,7 +340,7 @@ document.addEventListener("keydown", e => {
else if (e.key.toLowerCase() === "j") ws.send(JSON.stringify({action:"jingle", top: e.shiftKey}));
});
let whepReader = null;
let whepPc = null;
let whepAudio = null;
let whepConnected = false;
@@ -375,24 +375,14 @@ function whepSetVol(v) {
}
function whepToggle() {
if(whepConnected) whepDisconnect();
else whepConnect();
if (whepConnected || whepPc) { whepDisconnect(); return; }
whepConnect();
}
function whepDisconnect() {
whepConnected = false;
if (whepReader) {
try { whepReader.stop(); } catch(e){}
whepReader = null;
}
if (whepAudio) {
whepAudio.pause();
whepAudio.srcObject = null;
whepAudio = null;
}
if (whepPc) { try { whepPc.close(); } catch(e){} whepPc = null; }
if (whepAudio) { whepAudio.pause(); whepAudio.srcObject = null; whepAudio = null; }
whepSetDot('idle');
whepLog('Disconnected');
}
@@ -400,52 +390,55 @@ function whepDisconnect() {
async function whepConnect() {
const url = document.getElementById('whep-url-input').value.trim();
if (!url) return;
whepSetDot('connecting');
whepLog('Starting MediaMTX reader…');
whepLog('Creating peer connection…');
try {
whepReader = new MediaMTXWebRTCReader({
url: url,
onTrack: (evt) => {
if(evt.track.kind !== "audio") return;
whepPc = new RTCPeerConnection();
whepPc.ontrack = (e) => {
whepLog('Track received, starting playback', 'ok');
whepAudio = new Audio();
whepAudio.srcObject = evt.streams[0];
whepAudio.srcObject = e.streams[0];
whepAudio.volume = parseFloat(document.getElementById('whep-vol').value);
whepAudio.play().then(() => {
whepLog('Audio playing', 'ok');
whepConnected = true;
whepSetDot('connected');
}).catch(() => {
whepLog('Autoplay blocked — click anywhere', 'err');
document.addEventListener('click', () => whepAudio?.play(), { once: true });
whepLog('Autoplay blocked — click anywhere to resume', 'err');
document.addEventListener('click', () => whepAudio && whepAudio.play(), { once: true });
});
},
onError: (err) => {
whepLog('Error: ' + err, 'err');
};
whepPc.onconnectionstatechange = () => {
whepLog('State: ' + whepPc.connectionState);
if (whepPc.connectionState === 'failed' || whepPc.connectionState === 'disconnected') {
whepLog('Connection lost', 'err');
whepDisconnect();
whepSetDot('error');
},
onStateChange: (state) => {
whepLog('State: ' + state);
if (state === 'closed') whepDisconnect();
}
};
whepPc.oniceconnectionstatechange = () => whepLog('ICE: ' + whepPc.iceConnectionState);
whepPc.addTransceiver('audio', { direction: 'recvonly' });
const offer = await whepPc.createOffer();
offer.sdp = offer.sdp
.replace(/useinbandfec=1/g, 'useinbandfec=1;stereo=1;sprop-stereo=1')
.replace(/minptime=10/g, 'minptime=10;ptime=10;maxptime=10');
await whepPc.setLocalDescription(offer);
whepLog('Sending offer to ' + url);
const resp = await fetch(url, {
method: 'POST',
headers: { 'Content-Type': 'application/sdp', 'Accept': 'application/sdp' },
body: whepPc.localDescription.sdp
});
whepLog('Reader started, waiting for media…');
} catch (err) {
if (!resp.ok) throw new Error(`Server returned ${resp.status} ${resp.statusText}`);
const answerSdp = await resp.text();
whepLog(`Got SDP answer (${answerSdp.length} bytes)`, 'ok');
await whepPc.setRemoteDescription({ type: 'answer', sdp: answerSdp });
whepLog('Waiting for ICE + track…');
} catch(err) {
whepLog('Error: ' + err.message, 'err');
whepDisconnect();
whepSetDot('error');
}
}
initLayout();
setTimeout(connectWs, 100);