mirror of
https://github.com/microsoft/vscode.git
synced 2026-04-20 00:04:14 +08:00
01fcf004a6
* Use electron net directly in shared process * add built file * introduce shared electron-node layer * remove electron-utility layer * fix (overlook): move back cli files to node
74 lines
3.6 KiB
TypeScript
74 lines
3.6 KiB
TypeScript
/*---------------------------------------------------------------------------------------------
|
|
* Copyright (c) Microsoft Corporation. All rights reserved.
|
|
* Licensed under the MIT License. See License.txt in the project root for license information.
|
|
*--------------------------------------------------------------------------------------------*/
|
|
|
|
import { RunOnceScheduler } from '../../../../base/common/async.js';
|
|
import { onUnexpectedError } from '../../../../base/common/errors.js';
|
|
import { Disposable } from '../../../../base/common/lifecycle.js';
|
|
import { join } from '../../../../base/common/path.js';
|
|
import { Promises } from '../../../../base/node/pfs.js';
|
|
import { INativeEnvironmentService } from '../../../../platform/environment/common/environment.js';
|
|
import { ILogService } from '../../../../platform/log/common/log.js';
|
|
import { StorageClient } from '../../../../platform/storage/common/storageIpc.js';
|
|
import { EXTENSION_DEVELOPMENT_EMPTY_WINDOW_WORKSPACE } from '../../../../platform/workspace/common/workspace.js';
|
|
import { NON_EMPTY_WORKSPACE_ID_LENGTH } from '../../../../platform/workspaces/node/workspaces.js';
|
|
import { INativeHostService } from '../../../../platform/native/common/native.js';
|
|
import { IMainProcessService } from '../../../../platform/ipc/common/mainProcessService.js';
|
|
import { Schemas } from '../../../../base/common/network.js';
|
|
|
|
export class UnusedWorkspaceStorageDataCleaner extends Disposable {
|
|
|
|
constructor(
|
|
@INativeEnvironmentService private readonly environmentService: INativeEnvironmentService,
|
|
@ILogService private readonly logService: ILogService,
|
|
@INativeHostService private readonly nativeHostService: INativeHostService,
|
|
@IMainProcessService private readonly mainProcessService: IMainProcessService
|
|
) {
|
|
super();
|
|
|
|
const scheduler = this._register(new RunOnceScheduler(() => {
|
|
this.cleanUpStorage();
|
|
}, 30 * 1000 /* after 30s */));
|
|
scheduler.schedule();
|
|
}
|
|
|
|
private async cleanUpStorage(): Promise<void> {
|
|
this.logService.trace('[storage cleanup]: Starting to clean up workspace storage folders for unused empty workspaces.');
|
|
|
|
try {
|
|
const workspaceStorageHome = this.environmentService.workspaceStorageHome.with({ scheme: Schemas.file }).fsPath;
|
|
const workspaceStorageFolders = await Promises.readdir(workspaceStorageHome);
|
|
const storageClient = new StorageClient(this.mainProcessService.getChannel('storage'));
|
|
|
|
await Promise.all(workspaceStorageFolders.map(async workspaceStorageFolder => {
|
|
const workspaceStoragePath = join(workspaceStorageHome, workspaceStorageFolder);
|
|
|
|
if (workspaceStorageFolder.length === NON_EMPTY_WORKSPACE_ID_LENGTH) {
|
|
return; // keep workspace storage for folders/workspaces that can be accessed still
|
|
}
|
|
|
|
if (workspaceStorageFolder === EXTENSION_DEVELOPMENT_EMPTY_WINDOW_WORKSPACE.id) {
|
|
return; // keep workspace storage for empty extension development workspaces
|
|
}
|
|
|
|
const windows = await this.nativeHostService.getWindows({ includeAuxiliaryWindows: false });
|
|
if (windows.some(window => window.workspace?.id === workspaceStorageFolder)) {
|
|
return; // keep workspace storage for empty workspaces opened as window
|
|
}
|
|
|
|
const isStorageUsed = await storageClient.isUsed(workspaceStoragePath);
|
|
if (isStorageUsed) {
|
|
return; // keep workspace storage for empty workspaces that are in use
|
|
}
|
|
|
|
this.logService.trace(`[storage cleanup]: Deleting workspace storage folder ${workspaceStorageFolder} as it seems to be an unused empty workspace.`);
|
|
|
|
await Promises.rm(workspaceStoragePath);
|
|
}));
|
|
} catch (error) {
|
|
onUnexpectedError(error);
|
|
}
|
|
}
|
|
}
|