notification-service-server.ts

import { injectable } from 'inversify';
import { NotificationServiceServer, NotificationServiceClient, AttachedBoardsChangeEvent, BoardsPackage, LibraryPackage, Config, Sketch } from '../common/protocol';

@injectable()
export class NotificationServiceServerImpl implements NotificationServiceServer {

    protected readonly clients: NotificationServiceClient[] = [];

    notifyIndexUpdated(): void {
        this.clients.forEach(client => client.notifyIndexUpdated());
    }

    notifyDaemonStarted(): void {
        this.clients.forEach(client => client.notifyDaemonStarted());
    }

    notifyDaemonStopped(): void {
        this.clients.forEach(client => client.notifyDaemonStopped());
    }

    notifyPlatformInstalled(event: { item: BoardsPackage }): void {
        this.clients.forEach(client => client.notifyPlatformInstalled(event));
    }

    notifyPlatformUninstalled(event: { item: BoardsPackage }): void {
        this.clients.forEach(client => client.notifyPlatformUninstalled(event));
    }

    notifyLibraryInstalled(event: { item: LibraryPackage }): void {
        this.clients.forEach(client => client.notifyLibraryInstalled(event));
    }

    notifyLibraryUninstalled(event: { item: LibraryPackage }): void {
        this.clients.forEach(client => client.notifyLibraryUninstalled(event));
    }

    notifyAttachedBoardsChanged(event: AttachedBoardsChangeEvent): void {
        this.clients.forEach(client => client.notifyAttachedBoardsChanged(event));
    }

    notifyConfigChanged(event: { config: Config | undefined }): void {
        this.clients.forEach(client => client.notifyConfigChanged(event));
    }

    notifyRecentSketchesChanged(event: { sketches: Sketch[] }): void {
        this.clients.forEach(client => client.notifyRecentSketchesChanged(event));
    }

    setClient(client: NotificationServiceClient): void {
        this.clients.push(client);
    }

    disposeClient(client: NotificationServiceClient): void {
        const index = this.clients.indexOf(client);
        if (index === -1) {
            console.warn(`Could not dispose notification service client. It was not registered.`);
            return;
        }
        this.clients.splice(index, 1);
    }

    dispose(): void {
        for (const client of this.clients) {
            this.disposeClient(client);
        }
        this.clients.length = 0;
    }

}