indexes-update-progress.ts

import{Progress}from'@theia/core/lib/common/message-service-protocol';
import{ProgressService}from'@theia/core/lib/common/progress-service';
import{inject,injectable}from'@theia/core/shared/inversify';
import{ProgressMessage}from'../../common/protocol';
import{NotificationCenter}from'../notification-center';
import{Contribution}from'./contribution';

@injectable()
exportclassIndexesUpdateProgressextendsContribution{
 @inject(NotificationCenter)
privatereadonlynotificationCenter: NotificationCenter;
 @inject(ProgressService)
privatereadonlyprogressService: ProgressService;
privatecurrentProgress:
|(Progress&Readonly<{progressId: string}>)
|undefined;

overrideonStart(): void{
this.notificationCenter.onIndexUpdateWillStart(({ progressId })=>
this.getOrCreateProgress(progressId)
);
this.notificationCenter.onIndexUpdateDidProgress((progress)=>{
this.getOrCreateProgress(progress).then((delegate)=>
delegate.report(progress)
);
});
this.notificationCenter.onIndexUpdateDidComplete(({ progressId })=>{
this.cancelProgress(progressId);
});
this.notificationCenter.onIndexUpdateDidFail(({ progressId, message })=>{
this.cancelProgress(progressId);
this.messageService.error(message);
});
}

privateasyncgetOrCreateProgress(
progressOrId: ProgressMessage|string
): Promise<Progress&{progressId: string}>{
constprogressId=ProgressMessage.is(progressOrId)
 ? progressOrId.progressId
 : progressOrId;
if(this.currentProgress?.progressId===progressId){
returnthis.currentProgress;
}
if(this.currentProgress){
this.currentProgress.cancel();
}
this.currentProgress=undefined;
constprogress=awaitthis.progressService.showProgress({
text: '',
options: {location: 'notification'},
});
if(ProgressMessage.is(progressOrId)){
progress.report(progressOrId);
}
this.currentProgress={ ...progress, progressId };
returnthis.currentProgress;
}

privatecancelProgress(progressId: string){
if(this.currentProgress){
if(this.currentProgress.progressId!==progressId){
console.warn(
`Mismatching progress IDs. Expected ${progressId}, got ${this.currentProgress.progressId}. Canceling anyway.`
);
}
this.currentProgress.cancel();
this.currentProgress=undefined;
}
}
}