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

Refactor the livefeed stop

Browse source
This commit is contained in:
Chrystian Huot 2020-07-22 09:41:10 -04:00
parent d6bc3c8bcf
commit ec5974cad1
1 changed files with 19 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

38
client/src/app/components/rdio-scanner/rdio-scanner.service.ts
View file

@ -607,13 +607,26 @@ export class AppRdioScannerService implements OnDestroy {
} }
private liveFeedStart(): void { private liveFeedStart(): void {
this.liveFeedActive = true;
this.event.emit({ liveFeed: true });
this.webSocketSend(WebSocketCommand.LiveFeedMap, this.liveFeedMap); this.webSocketSend(WebSocketCommand.LiveFeedMap, this.liveFeedMap);
} }
private liveFeedStop(): void { private liveFeedStop(): void {
this.webSocketSend(WebSocketCommand.LiveFeedMap, null); this.liveFeedActive = false;
this.callQueue.splice(0, this.callQueue.length);
this.event.emit({
liveFeed: false,
queue: 0,
});
this.stop(); this.stop();
this.webSocketSend(WebSocketCommand.LiveFeedMap, null);
} }
private liveFeedStore(): void { private liveFeedStore(): void {
@ -638,10 +651,14 @@ export class AppRdioScannerService implements OnDestroy {
switch (message[2]) { switch (message[2]) {
case WebSocketCallFlag.Download: case WebSocketCallFlag.Download:
this.download(message[1]); this.download(message[1]);
break; break;
case WebSocketCallFlag.Play: case WebSocketCallFlag.Play:
this.play(message[1]); if (this.liveFeedActive) {
this.play(message[1]);
}
break; break;
default: default:
@ -679,23 +696,6 @@ export class AppRdioScannerService implements OnDestroy {
break; break;
case WebSocketCommand.LiveFeedMap:
this.liveFeedActive = message[1];
if (this.liveFeedActive) {
this.event.emit({ liveFeed: this.liveFeedActive });
} else {
this.callQueue.splice(0, this.callQueue.length);
this.event.emit({
liveFeed: this.liveFeedActive,
queue: this.callQueue.length,
});
}
break;
case WebSocketCommand.Nop: case WebSocketCommand.Nop:
clearTimeout(this.webSocketTimeout); clearTimeout(this.webSocketTimeout);