ash/WebStudio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Do the news noises every hour (when we're live)

Browse source
This commit is contained in:
Marks Polakovs 2020-04-14 09:46:08 +02:00
parent d807b62667
commit bf774bae11
1 changed files with 11 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/broadcast/rtc_streamer.ts
View file

@ -24,6 +24,7 @@ export class WebRTCStreamer extends Streamer {
newsInTimeout?: number; newsInTimeout?: number;
newsOutTimeout?: number; newsOutTimeout?: number;
newsInterval?: number;
constructor(stream: MediaStream, dispatch: Dispatch<any>) { constructor(stream: MediaStream, dispatch: Dispatch<any>) {
super(); super();
@ -61,12 +62,17 @@ export class WebRTCStreamer extends Streamer {
} }
console.log("ICE Connection state change: " + this.pc.iceConnectionState); console.log("ICE Connection state change: " + this.pc.iceConnectionState);
this.onStateChange(this.mapStateToConnectionState()); this.onStateChange(this.mapStateToConnectionState());
if (this.mapStateToConnectionState() === "CONNECTED") {
this.doTheNews();
}
}; };
this.stream.getAudioTracks().forEach(track => this.pc!.addTrack(track)); this.stream.getAudioTracks().forEach(track => this.pc!.addTrack(track));
this.addConnectionStateListener(state => {
if (state === "CONNECTED") {
this.newsInterval = window.setInterval(this.doTheNews, 1000 * 60);
} else if (state === "CONNECTION_LOST" || state === "NOT_CONNECTED") {
window.clearInterval(this.newsInterval);
}
});
console.log("PC created"); console.log("PC created");
this.ws = new WebSocket(process.env.REACT_APP_WS_URL!); this.ws = new WebSocket(process.env.REACT_APP_WS_URL!);
this.ws.onopen = e => { this.ws.onopen = e => {
@ -99,7 +105,7 @@ export class WebRTCStreamer extends Streamer {
const now = new Date(); const now = new Date();
if ( if (
now.getMinutes() < 59 || now.getMinutes() < 59 ||
(now.getMinutes() === 59 && now.getSeconds() < 45) (now.getMinutes() === 59 && now.getSeconds() < 44)
) { ) {
const newsTime = DateFns.set(now, { const newsTime = DateFns.set(now, {
minutes: 59, minutes: 59,
@ -114,7 +120,7 @@ export class WebRTCStreamer extends Streamer {
if ( if (
now.getMinutes() < 1 || now.getMinutes() < 1 ||
now.getMinutes() >= 2 || now.getMinutes() >= 2 ||
(now.getMinutes() === 1 && now.getSeconds() < 50) (now.getMinutes() === 1 && now.getSeconds() < 54)
) { ) {
let newsEndTime = DateFns.set(now, { let newsEndTime = DateFns.set(now, {
minutes: 1, minutes: 1,