1 files changed, 5 insertions, 101 deletions

diff --git a/packages/main/src/services/ConfigPersistenceService.ts b/packages/main/src/services/ConfigPersistenceService.ts
index b2109f6..b3ad162 100644
--- a/packages/main/src/services/ConfigPersistenceService.ts
+++ b/packages/main/src/services/ConfigPersistenceService.ts
@@ -17,112 +17,16 @@
  *
  * SPDX-License-Identifier: AGPL-3.0-only
  */
-import { watch } from 'fs';
-import { readFile, stat, writeFile } from 'fs/promises';
-import JSON5 from 'json5';
-import throttle from 'lodash-es/throttle';
-import { join } from 'path';
 
 import type { ConfigSnapshotOut } from  '../stores/Config';
-import { Disposer, getLogger } from '../utils';
-
-const log = getLogger('configPersistence');
+import { Disposer } from '../utils';
 
 export type ReadConfigResult = { found: true; data: unknown; } | { found: false; };
 
-export class ConfigPersistenceService {
-  private readonly configFilePath: string;
-
-  private writingConfig = false;
-
-  private timeLastWritten: Date | null = null;
-
-  constructor(
-    private readonly userDataDir: string,
-    private readonly configFileName: string = 'config.json5',
-  ) {
-    this.configFileName = configFileName;
-    this.configFilePath = join(this.userDataDir, this.configFileName);
-  }
-
-  async readConfig(): Promise<ReadConfigResult> {
-    let configStr;
-    try {
-      configStr = await readFile(this.configFilePath, 'utf8');
-    } catch (err) {
-      if ((err as NodeJS.ErrnoException).code === 'ENOENT') {
-        log.debug('Config file', this.configFilePath, 'was not found');
-        return { found: false };
-      }
-      throw err;
-    }
-    log.info('Read config file', this.configFilePath);
-    return {
-      found: true,
-      data: JSON5.parse(configStr),
-    };
-  }
-
-  async writeConfig(configSnapshot: ConfigSnapshotOut): Promise<void> {
-    const configJson = JSON5.stringify(configSnapshot, {
-      space: 2,
-    });
-    this.writingConfig = true;
-    try {
-      await writeFile(this.configFilePath, configJson, 'utf8');
-      const { mtime } = await stat(this.configFilePath);
-      log.trace('Config file', this.configFilePath, 'last written at', mtime);
-      this.timeLastWritten = mtime;
-    } finally {
-      this.writingConfig = false;
-    }
-    log.info('Wrote config file', this.configFilePath);
-  }
-
-  watchConfig(callback: () => Promise<void>, throttleMs: number): Disposer {
-    log.debug('Installing watcher for', this.userDataDir);
-
-    const configChanged = throttle(async () => {
-      let mtime: Date;
-      try {
-        const stats = await stat(this.configFilePath);
-        mtime = stats.mtime;
-        log.trace('Config file last modified at', mtime);
-      } catch (err) {
-        if ((err as NodeJS.ErrnoException).code === 'ENOENT') {
-          log.debug('Config file', this.configFilePath, 'was deleted after being changed');
-          return;
-        }
-        throw err;
-      }
-      if (!this.writingConfig
-        && (this.timeLastWritten === null || mtime > this.timeLastWritten)) {
-        log.debug(
-          'Found a config file modified at',
-          mtime,
-          'whish is newer than last written',
-          this.timeLastWritten,
-        );
-        return callback();
-      }
-    }, throttleMs);
-
-    const watcher = watch(this.userDataDir, {
-      persistent: false,
-    });
+export interface ConfigPersistenceService {
+  readConfig(): Promise<ReadConfigResult>;
 
-    watcher.on('change', (eventType, filename) => {
-      if (eventType === 'change'
-        && (filename === this.configFileName || filename === null)) {
-        configChanged()?.catch((err) => {
-          console.log('Unhandled error while listening for config changes', err);
-        });
-      }
-    });
+  writeConfig(configSnapshot: ConfigSnapshotOut): Promise<void>;
 
-    return () => {
-      log.trace('Removing watcher for', this.configFilePath);
-      watcher.close();
-    };
-  }
+  watchConfig(callback: () => Promise<void>, throttleMs: number): Disposer;
 }