src/login-cache.ts

@@ -38,13 +38,9 @@ type CacheLogin = {
 
 export type CacheStore<T = Cache> = {
   name: string;
-  /**
-   * 缓存数据
-   * @important 需要先调用init
-   */
   cacheData: CacheLogin;
   /**
-   * 实际操作的cache, 需要先调用init
+   * 实际操作的cache
    */
   cache: T;
 

src/login-node-cache.ts

@@ -1,21 +1,15 @@
-import { Cache } from './login-cache.ts';
+import { Cache, LoginCacheStore, LoginCacheStoreOpts } from './login-cache.ts';
 import { homedir } from 'node:os';
 import { join, dirname } from 'node:path';
 import fs from 'node:fs';
 import { readFileSync, writeFileSync, accessSync } from 'node:fs';
 import { readFile, writeFile, unlink, mkdir } from 'node:fs/promises';
-export const fileExists = async (
-  filePath: string,
-  { createIfNotExists = true, isFile = true, isDir = false }: { createIfNotExists?: boolean; isFile?: boolean; isDir?: boolean } = {},
-) => {
+export const fileExists = async (filePath: string, createIfNotExists = false) => {
   try {
     accessSync(filePath, fs.constants.F_OK);
     return true;
   } catch (error) {
-    if (createIfNotExists && isDir) {
-      await mkdir(filePath, { recursive: true });
-      return true;
-    } else if (createIfNotExists && isFile) {
+    if (createIfNotExists) {
       await mkdir(dirname(filePath), { recursive: true });
       return false;
     }
@@ -31,9 +25,6 @@ export const readConfigFile = (filePath: string) => {
     return {};
   }
 };
-export const writeConfigFile = (filePath: string, data: any) => {
-  writeFileSync(filePath, JSON.stringify(data, null, 2));
-};
 export const getHostName = () => {
   const configDir = join(homedir(), '.config', 'envision');
   const configFile = join(configDir, 'config.json');
@@ -50,13 +41,14 @@ export class StorageNode implements Storage {
     const configDir = join(homedir(), '.config', 'envision');
     const hostname = getHostName();
     this.filePath = join(configDir, 'config', `${hostname}-storage.json`);
-    fileExists(this.filePath, { isFile: true });
+    fileExists(this.filePath, true);
   }
   async loadCache() {
     const filePath = this.filePath;
     try {
-      const data = await readConfigFile(filePath);
-      this.cacheData = data;
+      const data = await readFile(filePath, 'utf-8');
+      const jsonData = JSON.parse(data);
+      this.cacheData = jsonData;
     } catch (error) {
       this.cacheData = {};
       await writeFile(filePath, JSON.stringify(this.cacheData, null, 2));
@@ -89,23 +81,24 @@ export class LoginNodeCache implements Cache {
 
   constructor(filepath?: string) {
     this.filepath = filepath || join(homedir(), '.config', 'envision', 'config', `${getHostName()}-login.json`);
-    fileExists(this.filepath, { isFile: true });
+    fileExists(this.filepath, true);
   }
   async get(_key: string) {
+    const data = readFileSync(this.filepath, 'utf-8');
     try {
-      const filePath = this.filepath;
-      const data = readConfigFile(filePath);
-      return data;
+      const jsonData = JSON.parse(data);
+      return jsonData;
     } catch (error) {
       console.log('get error', error);
-      return {};
+      return null;
     }
   }
   async set(_key: string, value: any) {
+    const data = readFileSync(this.filepath, 'utf-8');
     try {
-      const data = readConfigFile(this.filepath);
-      const newData = { ...data, ...value };
-      writeConfigFile(this.filepath, newData);
+      const jsonData = JSON.parse(data);
+      const newData = { ...jsonData, ...value };
+      writeFileSync(this.filepath, JSON.stringify(newData, null, 2));
     } catch (error) {
       console.log('set error', error);
     }
@@ -121,7 +114,7 @@ export class LoginNodeCache implements Cache {
     } catch (error) {
       console.log('loadCache error', error);
       const defaultData = { loginUsers: [] };
-      writeConfigFile(filePath, defaultData);
+      await writeFile(filePath, JSON.stringify(defaultData, null, 2));
       return defaultData;
     }
   }