debug-configuration-manager.ts

import{FrontendApplicationStateService}from'@theia/core/lib/browser/frontend-application-state';
import{Disposable}from'@theia/core/lib/common/disposable';
import{Emitter,Event}from'@theia/core/lib/common/event';
importURIfrom'@theia/core/lib/common/uri';
import{inject,injectable}from'@theia/core/shared/inversify';
import{DebugConfigurationManagerasTheiaDebugConfigurationManager}from'@theia/debug/lib/browser/debug-configuration-manager';
import{DebugConfigurationModelasTheiaDebugConfigurationModel}from'@theia/debug/lib/browser/debug-configuration-model';
import{DebugConfiguration}from'@theia/debug/lib/common/debug-common';
import{FileService}from'@theia/filesystem/lib/browser/file-service';
import{
FileOperationError,
FileOperationResult,
}from'@theia/filesystem/lib/common/files';
importdebouncefrom'p-debounce';
import{SketchesService}from'../../../common/protocol';
import{
CurrentSketch,
SketchesServiceClientImpl,
}from'../../sketches-service-client-impl';
import{maybeUpdateReadOnlyState}from'../monaco/monaco-editor-provider';
import{DebugConfigurationModel}from'./debug-configuration-model';

@injectable()
exportclassDebugConfigurationManagerextendsTheiaDebugConfigurationManager{
 @inject(SketchesService)
privatereadonlysketchesService: SketchesService;
 @inject(SketchesServiceClientImpl)
privatereadonlysketchesServiceClient: SketchesServiceClientImpl;
 @inject(FrontendApplicationStateService)
privatereadonlyappStateService: FrontendApplicationStateService;
 @inject(FileService)
privatereadonlyfileService: FileService;

privateonTempContentDidChangeEmitter=
newEmitter<TheiaDebugConfigurationModel.JsonContent>();
getonTempContentDidChange(): Event<TheiaDebugConfigurationModel.JsonContent>{
returnthis.onTempContentDidChangeEmitter.event;
}

protectedoverrideasyncdoInit(): Promise<void>{
this.watchLaunchConfigEditor();
this.appStateService.reachedState('ready').then(async()=>{
consttempContent=awaitthis.getTempLaunchJsonContent();
if(!tempContent){
// No active sketch.
return;
}
// Watch the file of the container folder.
this.fileService.watch(
tempContentinstanceofURI ? tempContent : tempContent.uri
);
// Use the normalized temp folder name. We cannot compare Theia URIs here.
// /var/folders/k3/d2fkvv1j16v3_rz93k7f74180000gn/T/arduino-ide2-a0337d47f86b24a51df3dbcf2cc17925/launch.json
// /private/var/folders/k3/d2fkvv1j16v3_rz93k7f74180000gn/T/arduino-ide2-A0337D47F86B24A51DF3DBCF2CC17925/launch.json
consttempFolderName=(
tempContentinstanceofURI ? tempContent : tempContent.uri.parent
).path.base.toLowerCase();
this.fileService.onDidFilesChange((event)=>{
for(const{ resource }ofevent.changes){
if(
resource.path.base==='launch.json'&&
resource.parent.path.base.toLowerCase()===tempFolderName
){
this.getTempLaunchJsonContent().then((config)=>{
if(config&&!(configinstanceofURI)){
this.onTempContentDidChangeEmitter.fire(config);
}
});
break;
}
}
});
this.updateModels();
});
returnsuper.doInit();
}

/**
 * Sets a listener on current sketch change, and maybe updates the readonly state of the editor showing the debug configuration. aka the `launch.json`.
 */
privatewatchLaunchConfigEditor(): Disposable{
returnthis.sketchesServiceClient.onCurrentSketchDidChange(()=>{
for(constwidgetofthis.editorManager.all){
maybeUpdateReadOnlyState(widget,(uri)=>
this.sketchesServiceClient.isReadOnly(uri)
);
}
});
}

protectedoverrideupdateModels=debounce(async()=>{
awaitthis.appStateService.reachedState('ready');
constroots=awaitthis.workspaceService.roots;
consttoDelete=newSet(this.models.keys());
for(constrootStatofroots){
constkey=rootStat.resource.toString();
toDelete.delete(key);
if(!this.models.has(key)){
consttempContent=awaitthis.getTempLaunchJsonContent();
if(!tempContent){
continue;
}
constconfigurations: DebugConfiguration[]=
tempContentinstanceofURI ? [] : tempContent.configurations;
consturi=tempContentinstanceofURI ? undefined : tempContent.uri;
constmodel=newDebugConfigurationModel(
key,
this.preferences,
configurations,
uri,
this.onTempContentDidChange
);
model.onDidChange(()=>this.updateCurrent());
model.onDispose(()=>this.models.delete(key));
this.models.set(key,model);
}
}
for(consturioftoDelete){
constmodel=this.models.get(uri);
if(model){
model.dispose();
}
}
this.updateCurrent();
},500);

privateasyncgetTempLaunchJsonContent(): Promise<
(TheiaDebugConfigurationModel.JsonContent&{uri: URI})|URI|undefined
>{
constsketch=awaitthis.sketchesServiceClient.currentSketch();
if(!CurrentSketch.isValid(sketch)){
returnundefined;
}
consturi=awaitthis.sketchesService.getIdeTempFolderUri(sketch);
consttempFolderUri=newURI(uri);
awaitthis.fileService.createFolder(tempFolderUri);
try{
consturi=tempFolderUri.resolve('launch.json');
const{ value }=awaitthis.fileService.read(uri);
constconfigurations=DebugConfigurationModel.parse(JSON.parse(value));
return{ uri, configurations,compounds: []};
}catch(err){
if(
errinstanceofFileOperationError&&
err.fileOperationResult===FileOperationResult.FILE_NOT_FOUND
){
returntempFolderUri;
}
console.error(
'Could not load debug configuration from IDE2 temp folder.',
err
);
throwerr;
}
}
}