notification-center.ts

import{
inject,
injectable,
postConstruct,
}from'@theia/core/shared/inversify';
import{Emitter}from'@theia/core/lib/common/event';
import{JsonRpcProxy}from'@theia/core/lib/common/messaging/proxy-factory';
import{DisposableCollection}from'@theia/core/lib/common/disposable';
import{FrontendApplicationContribution}from'@theia/core/lib/browser/frontend-application-contribution';
import{
IndexUpdateDidCompleteParams,
IndexUpdateDidFailParams,
IndexUpdateWillStartParams,
NotificationServiceClient,
NotificationServiceServer,
}from'../common/protocol/notification-service';
importtype{
BoardsPackage,
LibraryPackage,
ConfigState,
Sketch,
ProgressMessage,
DetectedPorts,
}from'../common/protocol';
import{
FrontendApplicationStateService,
FrontendApplicationState,
}from'@theia/core/lib/browser/frontend-application-state';

@injectable()
exportclassNotificationCenter
implementsNotificationServiceClient,FrontendApplicationContribution
{
 @inject(NotificationServiceServer)
privatereadonlyserver: JsonRpcProxy<NotificationServiceServer>;

 @inject(FrontendApplicationStateService)
privatereadonlyappStateService: FrontendApplicationStateService;

privatereadonlydidReinitializeEmitter=newEmitter<void>();
privatereadonlyindexUpdateDidCompleteEmitter=
newEmitter<IndexUpdateDidCompleteParams>();
privatereadonlyindexUpdateWillStartEmitter=
newEmitter<IndexUpdateWillStartParams>();
privatereadonlyindexUpdateDidProgressEmitter=
newEmitter<ProgressMessage>();
privatereadonlyindexUpdateDidFailEmitter=
newEmitter<IndexUpdateDidFailParams>();
privatereadonlydaemonDidStartEmitter=newEmitter<number>();
privatereadonlydaemonDidStopEmitter=newEmitter<void>();
privatereadonlyconfigDidChangeEmitter=newEmitter<ConfigState>();
privatereadonlyplatformDidInstallEmitter=newEmitter<{
item: BoardsPackage;
}>();
privatereadonlyplatformDidUninstallEmitter=newEmitter<{
item: BoardsPackage;
}>();
privatereadonlylibraryDidInstallEmitter=newEmitter<{
item: LibraryPackage|'zip-install';
}>();
privatereadonlylibraryDidUninstallEmitter=newEmitter<{
item: LibraryPackage;
}>();
privatereadonlydetectedPortsDidChangeEmitter=newEmitter<{
detectedPorts: DetectedPorts;
}>();
privatereadonlyrecentSketchesChangedEmitter=newEmitter<{
sketches: Sketch[];
}>();
privatereadonlyonAppStateDidChangeEmitter=
newEmitter<FrontendApplicationState>();

privatereadonlytoDispose=newDisposableCollection(
this.didReinitializeEmitter,
this.indexUpdateWillStartEmitter,
this.indexUpdateDidProgressEmitter,
this.indexUpdateDidCompleteEmitter,
this.indexUpdateDidFailEmitter,
this.daemonDidStartEmitter,
this.daemonDidStopEmitter,
this.configDidChangeEmitter,
this.platformDidInstallEmitter,
this.platformDidUninstallEmitter,
this.libraryDidInstallEmitter,
this.libraryDidUninstallEmitter,
this.detectedPortsDidChangeEmitter
);

readonlyonDidReinitialize=this.didReinitializeEmitter.event;
readonlyonIndexUpdateDidComplete=this.indexUpdateDidCompleteEmitter.event;
readonlyonIndexUpdateWillStart=this.indexUpdateWillStartEmitter.event;
readonlyonIndexUpdateDidProgress=this.indexUpdateDidProgressEmitter.event;
readonlyonIndexUpdateDidFail=this.indexUpdateDidFailEmitter.event;
readonlyonDaemonDidStart=this.daemonDidStartEmitter.event;
readonlyonDaemonDidStop=this.daemonDidStopEmitter.event;
readonlyonConfigDidChange=this.configDidChangeEmitter.event;
readonlyonPlatformDidInstall=this.platformDidInstallEmitter.event;
readonlyonPlatformDidUninstall=this.platformDidUninstallEmitter.event;
readonlyonLibraryDidInstall=this.libraryDidInstallEmitter.event;
readonlyonLibraryDidUninstall=this.libraryDidUninstallEmitter.event;
readonlyonDetectedPortsDidChange=this.detectedPortsDidChangeEmitter.event;
readonlyonRecentSketchesDidChange=this.recentSketchesChangedEmitter.event;
readonlyonAppStateDidChange=this.onAppStateDidChangeEmitter.event;

 @postConstruct()
protectedinit(): void{
this.server.setClient(this);
this.toDispose.push(
this.appStateService.onStateChanged((state)=>
this.onAppStateDidChangeEmitter.fire(state)
)
);
}

onStop(): void{
this.toDispose.dispose();
}

notifyDidReinitialize(): void{
this.didReinitializeEmitter.fire();
}

notifyIndexUpdateWillStart(params: IndexUpdateWillStartParams): void{
this.indexUpdateWillStartEmitter.fire(params);
}

notifyIndexUpdateDidProgress(progressMessage: ProgressMessage): void{
this.indexUpdateDidProgressEmitter.fire(progressMessage);
}

notifyIndexUpdateDidComplete(params: IndexUpdateDidCompleteParams): void{
this.indexUpdateDidCompleteEmitter.fire(params);
}

notifyIndexUpdateDidFail(params: IndexUpdateDidFailParams): void{
this.indexUpdateDidFailEmitter.fire(params);
}

notifyDaemonDidStart(port: number): void{
this.daemonDidStartEmitter.fire(port);
}

notifyDaemonDidStop(): void{
this.daemonDidStopEmitter.fire();
}

notifyConfigDidChange(event: ConfigState): void{
this.configDidChangeEmitter.fire(event);
}

notifyPlatformDidInstall(event: {item: BoardsPackage}): void{
this.platformDidInstallEmitter.fire(event);
}

notifyPlatformDidUninstall(event: {item: BoardsPackage}): void{
this.platformDidUninstallEmitter.fire(event);
}

notifyLibraryDidInstall(event: {
item: LibraryPackage|'zip-install';
}): void{
this.libraryDidInstallEmitter.fire(event);
}

notifyLibraryDidUninstall(event: {item: LibraryPackage}): void{
this.libraryDidUninstallEmitter.fire(event);
}

notifyDetectedPortsDidChange(event: {detectedPorts: DetectedPorts}): void{
this.detectedPortsDidChangeEmitter.fire(event);
}

notifyRecentSketchesDidChange(event: {sketches: Sketch[]}): void{
this.recentSketchesChangedEmitter.fire(event);
}
}