rdio-scanner/client/imports/app/radio/radio-select/radio-select.component.ts

import { Component, OnDestroy, OnInit } from '@angular/core';
import { Subscription } from 'rxjs';
import { RadioAvoids, RadioEvent, RadioSystem, RadioTalkgroup } from '../radio';
import { AppRadioService } from '../radio.service';

@Component({
    selector: 'app-radio-select',
    styleUrls: [
        '../radio.scss',
        './radio-select.component.scss',
    ],
    templateUrl: './radio-select.component.html',
})
export class AppRadioSelectComponent implements OnDestroy, OnInit {
    avoids: RadioAvoids;

    systems: RadioSystem[] = [];

    private _subscriptions: Subscription[] = [];

    constructor(public appRadioService: AppRadioService) {
        this.avoids = this.appRadioService.getAvoids();
    }

    ngOnInit(): void {
        this._subscribe();
    }

    ngOnDestroy(): void {
        this._unsubscribe();
    }

    avoid(system: RadioSystem | null, talkgroup: RadioTalkgroup | null, status: boolean): void {
        if (system) {
            this.appRadioService.avoid({ system, talkgroup, status });
        } else {
            this.appRadioService.avoid({ all: true, status });
        }
    }

    close(): void {
        this.appRadioService.select();
    }

    private _handleAvoidEvent(event: RadioEvent): void {
        if ('avoid' in event) {
            this.avoids[event.avoid.sys][event.avoid.tg] = event.avoid.status;
        }
    }

    private _handleAvoidsEvent(event: RadioEvent): void {
        if ('avoids' in event) {
            this.avoids = event.avoids;
        }
    }

    private _handleSystemsEvent(event: RadioEvent): void {
        if ('systems' in event) {
            this.systems.splice(0, this.systems.length, ...event.systems);
        }
    }

    private _subscribe(): void {
        this._subscriptions.push(
            this.appRadioService.event.subscribe((event: RadioEvent) => {
                this._handleAvoidEvent(event);
                this._handleSystemsEvent(event);
            })
        );
    }

    private _unsubscribe(subscriptions: Subscription[] = this._subscriptions) {
        while (subscriptions.length) {
            subscriptions.pop().unsubscribe();
        }
    }
}