feat: bootstrap ask config on first use

This commit is contained in:
Erik Kotsiuba
2026-04-29 02:36:29 +02:00
parent 18120e8801
commit 2bf85b3f6f
4 changed files with 126 additions and 19 deletions
+41 -2
View File
@@ -28,9 +28,15 @@ export class AskConfigStore {
private notice?: AskConfigNotice;
private readonly listeners = new Set<(config: AskConfig) => void>();
private readonly configPath: string;
private readonly legacyConfigPath?: string;
constructor(configPath = getAskConfigPath()) {
constructor(
configPath = getAskConfigPath(),
legacyConfigPath = getLegacyAskConfigPath()
) {
this.configPath = configPath;
this.legacyConfigPath =
legacyConfigPath === configPath ? undefined : legacyConfigPath;
}
subscribe(onChange: (config: AskConfig) => void): () => void {
@@ -80,12 +86,15 @@ export class AskConfigStore {
}
private async loadFromDisk(): Promise<AskConfigLoadResult> {
await this.migrateLegacyConfigIfNeeded();
let content: string;
try {
content = await readFile(this.configPath, "utf-8");
} catch (error) {
if (isMissingFileError(error)) {
return { config: normalizeAskConfig(DEFAULT_ASK_CONFIG) };
const config = normalizeAskConfig(DEFAULT_ASK_CONFIG);
await this.save(config);
return { config };
}
throw error;
}
@@ -137,6 +146,20 @@ export class AskConfigStore {
},
};
}
private async migrateLegacyConfigIfNeeded(): Promise<void> {
if (!this.legacyConfigPath) {
return;
}
if (await pathExists(this.configPath)) {
return;
}
if (!(await pathExists(this.legacyConfigPath))) {
return;
}
await mkdir(dirname(this.configPath), { recursive: true });
await rename(this.legacyConfigPath, this.configPath);
}
}
let askConfigStore: AskConfigStore | undefined;
@@ -147,6 +170,10 @@ export function getAskConfigStore(): AskConfigStore {
}
export function getAskConfigPath(): string {
return join(getAgentDir(), "eko24ive-pi-ask.json");
}
export function getLegacyAskConfigPath(): string {
return join(getAgentDir(), "extensions", "eko24ive-pi-ask.json");
}
@@ -155,6 +182,18 @@ function createBackupPath(path: string, date: Date): string {
return path.replace(JSON_EXTENSION_PATTERN, `.${timestamp}.bak.json`);
}
async function pathExists(path: string): Promise<boolean> {
try {
await readFile(path, "utf-8");
return true;
} catch (error) {
if (isMissingFileError(error)) {
return false;
}
throw error;
}
}
function isMissingFileError(error: unknown): boolean {
return (
!!error &&