feat: move import folders out of original function, optimize logs

This commit is contained in:
reito
2024-11-13 11:32:30 +08:00
parent fb6fac8803
commit 1e749ec793

View File

@@ -326,11 +326,10 @@ export class DatabaseUI extends DisposableObject {
} }
private async chooseDatabaseFolder( private async chooseDatabaseFolder(
subFolder: boolean,
progress: ProgressCallback, progress: ProgressCallback,
): Promise<void> { ): Promise<void> {
try { try {
await this.chooseAndSetDatabase(true, subFolder, progress); await this.chooseAndSetDatabase(true, progress);
} catch (e) { } catch (e) {
void showAndLogExceptionWithTelemetry( void showAndLogExceptionWithTelemetry(
this.app.logger, this.app.logger,
@@ -345,7 +344,7 @@ export class DatabaseUI extends DisposableObject {
private async handleChooseDatabaseFolder(): Promise<void> { private async handleChooseDatabaseFolder(): Promise<void> {
return withProgress( return withProgress(
async (progress) => { async (progress) => {
await this.chooseDatabaseFolder(false, progress); await this.chooseDatabaseFolder(progress);
}, },
{ {
title: "Adding database from folder", title: "Adding database from folder",
@@ -356,7 +355,7 @@ export class DatabaseUI extends DisposableObject {
private async handleChooseDatabaseFolderFromPalette(): Promise<void> { private async handleChooseDatabaseFolderFromPalette(): Promise<void> {
return withProgress( return withProgress(
async (progress) => { async (progress) => {
await this.chooseDatabaseFolder(false, progress); await this.chooseDatabaseFolder(progress);
}, },
{ {
title: "Choose a Database from a Folder", title: "Choose a Database from a Folder",
@@ -367,7 +366,7 @@ export class DatabaseUI extends DisposableObject {
private async handleChooseMultipleDatabaseFolderFromPalette(): Promise<void> { private async handleChooseMultipleDatabaseFolderFromPalette(): Promise<void> {
return withProgress( return withProgress(
async (progress) => { async (progress) => {
await this.chooseDatabaseFolder(true, progress); await this.chooseDatabasesParentFolder(progress);
}, },
{ {
title: "Choose a Folder contains all Database Folders", title: "Choose a Folder contains all Database Folders",
@@ -510,7 +509,7 @@ export class DatabaseUI extends DisposableObject {
progress: ProgressCallback, progress: ProgressCallback,
): Promise<void> { ): Promise<void> {
try { try {
await this.chooseAndSetDatabase(false, false, progress); await this.chooseAndSetDatabase(false, progress);
} catch (e: unknown) { } catch (e: unknown) {
void showAndLogExceptionWithTelemetry( void showAndLogExceptionWithTelemetry(
this.app.logger, this.app.logger,
@@ -978,7 +977,6 @@ export class DatabaseUI extends DisposableObject {
*/ */
private async chooseAndSetDatabase( private async chooseAndSetDatabase(
byFolder: boolean, byFolder: boolean,
subFolder: boolean,
progress: ProgressCallback, progress: ProgressCallback,
): Promise<DatabaseItem[] | DatabaseItem | undefined> { ): Promise<DatabaseItem[] | DatabaseItem | undefined> {
const uri = await chooseDatabaseDir(byFolder); const uri = await chooseDatabaseDir(byFolder);
@@ -986,60 +984,72 @@ export class DatabaseUI extends DisposableObject {
return undefined; return undefined;
} }
if (subFolder) { if (byFolder && !uri.fsPath.endsWith("testproj")) {
if (!byFolder) { const fixedUri = await this.fixDbUri(uri);
return undefined; // we are selecting a database folder
} return await this.databaseManager.openDatabase(fixedUri, {
type: "folder",
});
} else {
// we are selecting a database archive or a testproj.
// Unzip archives (if an archive) and copy into a workspace-controlled area
// before importing.
return await this.databaseFetcher.importLocalDatabase(
uri.toString(true),
progress,
);
}
}
const databases: DatabaseItem[] = []; /**
const failures: string[] = []; * Ask the user for a parent directory that contains all databases.
const entries = await workspace.fs.readDirectory(uri); * Returns all valid databases, or `undefined` if the operation was canceled.
for (const entry of entries) { */
if (entry[1] === FileType.Directory) { private async chooseDatabasesParentFolder(
try { progress: ProgressCallback,
const fixedUri = await this.fixDbUri(Uri.joinPath(uri, entry[0])); ): Promise<DatabaseItem[] | undefined> {
const database = await this.databaseManager.openDatabase(fixedUri, { const uri = await chooseDatabaseDir(true);
type: "folder", if (!uri) {
}); return undefined;
databases.push(database); }
} catch (e) {
failures.push(entry[0]); const databases: DatabaseItem[] = [];
} const failures: string[] = [];
const entries = await workspace.fs.readDirectory(uri);
for (const [index, entry] of entries.entries()) {
progress({
step: index + 1,
maxStep: entries.length,
message: `Importing ${entry[0]}`,
});
if (entry[1] === FileType.Directory) {
try {
const fixedUri = await this.fixDbUri(Uri.joinPath(uri, entry[0]));
const database = await this.databaseManager.openDatabase(fixedUri, {
type: "folder",
});
databases.push(database);
} catch (e) {
failures.push(entry[0]);
} }
} }
if (failures.length) {
void showAndLogErrorMessage(
this.app.logger,
`Failed to import ${failures.length} database(s) (${failures.join(
", ",
)}), successfully imported ${databases.length} database(s).`,
);
} else {
void showAndLogInformationMessage(
this.app.logger,
`Successfully imported ${databases.length} database(s).`,
);
}
return databases;
} else {
if (byFolder && !uri.fsPath.endsWith("testproj")) {
const fixedUri = await this.fixDbUri(uri);
// we are selecting a database folder
return await this.databaseManager.openDatabase(fixedUri, {
type: "folder",
});
} else {
// we are selecting a database archive or a testproj.
// Unzip archives (if an archive) and copy into a workspace-controlled area
// before importing.
return await this.databaseFetcher.importLocalDatabase(
uri.toString(true),
progress,
);
}
} }
if (failures.length) {
void showAndLogErrorMessage(
this.app.logger,
`Failed to import ${failures.length} database(s), successfully imported ${databases.length} database(s).`,
{ fullMessage: `Failed imports: \n${failures.join("\n")}` },
);
} else {
void showAndLogInformationMessage(
this.app.logger,
`Successfully imported ${databases.length} database(s).`,
);
}
return databases;
} }
/** /**