Archive/rdio-scanner
1
0
Fork 0
mirror of https://github.com/chuot/rdio-scanner.git synced 2026-08-13 16:33:01 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix bug due to async decodeAudioData

Browse source
This commit is contained in:
Chrystian Huot 2019-08-30 10:12:31 -04:00
parent b8acccfccc
commit 97399ba4c9
2 changed files with 51 additions and 69 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
client/imports/app/radio/radio-display/radio-display.component.ts
View file

@ -69,10 +69,10 @@ export class AppRadioDisplayComponent implements OnDestroy, OnInit {
private handleRadioTimeEvent(event: RadioEvent): void {
if ('time' in event) {
const currentFreq = this.currentCall.freqList
.reduce((cur: RadioCallFreq, freq: RadioCallFreq) => freq.pos < event.time ? freq : cur, null);
.reduce((cur: RadioCallFreq, freq: RadioCallFreq) => freq.pos <= event.time ? freq : cur, null);
const currentSrc = this.currentCall.srcList
.reduce((cur: RadioCallSrc, src: RadioCallSrc) => src.pos < event.time ? src : cur, null);
.reduce((cur: RadioCallSrc, src: RadioCallSrc) => src.pos <= event.time ? src : cur, null);
const currentError = currentFreq && currentFreq.errorCount;
const currentFrequency = (currentFreq && currentFreq.freq);

116
client/imports/app/radio/radio.service.ts
View file

@ -69,6 +69,10 @@ export class AppRadioService implements OnDestroy {
}
ngOnDestroy(): void {
if (this.audioContext) {
this.audioContext.close();
}
this.event.complete();
this.unsubscribe();
@ -200,14 +204,17 @@ export class AppRadioService implements OnDestroy {
if (this.audioContext && !this.paused) {
if (!call && !this.call.current && this.call.queue.length) {
call = this.call.queue.shift();
this.emitQueueEvent();
}
if (call && call.audio) {
this.call.previous = this.call.current;
this.stop();
this.call.current = call;
this.emitCallEvent();
this.emitTimeEvent();
const audio = /^data:[^;]+;base64,/.test(call.audio) ? atob(call.audio.replace(/^[^,]*,/, '')) : call.audio;
const arrayBuffer = new ArrayBuffer(audio.length);
@ -217,39 +224,32 @@ export class AppRadioService implements OnDestroy {
arrayBufferView[i] = audio.charCodeAt(i);
}
this.audioContext.decodeAudioData(arrayBuffer, (buffer) => {
if (this.audioSource) {
this.audioSource.disconnect();
this.audioContext.decodeAudioData(arrayBuffer).then((buffer) => {
if (this.call.current) {
this.audioSource = this.audioContext.createBufferSource();
this.audioSource.buffer = buffer;
this.audioSource.connect(this.audioContext.destination);
this.audioSource.onended = () => this.skip();
this.audioSource.start();
this.audioTimer = setInterval(() => this.emitTimeEvent(), 500);
if (this.audioContext.state === 'suspended') {
const resume = () => {
this.audioContext.resume();
setTimeout(() => {
if (this.audioContext.state === 'running') {
EVENTS.forEach((event) => document.body.removeEventListener(event, resume));
}
});
};
EVENTS.forEach((event) => document.body.addEventListener(event, resume));
}
}
this.audioSource = this.audioContext.createBufferSource();
this.audioSource.buffer = buffer;
this.audioSource.connect(this.audioContext.destination);
this.audioSource.onended = () => this.skip();
this.audioSource.start();
if (this.audioContext.state === 'suspended') {
const resume = () => {
this.audioContext.resume();
setTimeout(() => {
if (this.audioContext.state === 'running') {
EVENTS.forEach((event) => document.body.removeEventListener(event, resume));
}
}, 0);
};
EVENTS.forEach((event) => document.body.addEventListener(event, resume));
}
this.resetAudioTimer();
}, (error: Error) => {
this.skip(true);
throw (error);
});
}).catch(() => this.skip(true));
}
}
}
@ -270,8 +270,6 @@ export class AppRadioService implements OnDestroy {
replay(): void {
if (!this.paused) {
this.stopAudioTimer();
this.play(this.call.current || this.call.previous);
}
}
@ -296,21 +294,25 @@ export class AppRadioService implements OnDestroy {
}
stop(): void {
this.stopAudioTimer();
if (this.audioSource) {
this.audioSource.disconnect();
this.audioSource = null;
}
this.audioStartTime = NaN;
if (this.call.current) {
if (this.audioTimer !== null) {
clearInterval(this.audioTimer);
this.audioTimer = null;
}
if (this.audioSource) {
this.audioSource.onended = null;
this.audioSource.stop();
this.audioSource.disconnect();
}
this.audioStartTime = NaN;
this.call.previous = this.call.current;
this.call.current = null;
}
this.emitCallEvent();
this.emitCallEvent();
}
}
transform(call: RadioCall): RadioCall {
@ -332,7 +334,7 @@ export class AppRadioService implements OnDestroy {
this.audioContext = new AudioContext();
}
if (this.audioContext.state === 'suspended') {
if (this.audioContext && this.audioContext.state === 'suspended') {
this.audioContext.resume();
}
}
@ -462,26 +464,6 @@ export class AppRadioService implements OnDestroy {
}
}
private resetAudioTimer(): void {
this.stopAudioTimer();
this.startAudioTimer();
}
private startAudioTimer(): void {
if (this.audioTimer === null) {
this.emitTimeEvent();
this.audioTimer = setInterval(() => this.emitTimeEvent(), 500);
}
}
private stopAudioTimer(): void {
if (this.audioTimer !== null) {
clearInterval(this.audioTimer);
this.audioTimer = null;
}
}
private subscribeLiveFeed(): void {
if (!this.subscriptions.liveFeed.length) {
const options = {