chore: 🤖 暂存一下

packages/api/package.json

@@ -15,7 +15,6 @@
     "@acme/curd": "^0.1.0",
     "@acme/db": "^0.1.0",
     "@acme/eagle": "^0.1.0",
-    "@acme/folder": "^0.1.0",
     "@trpc/client": "^10.23.0",
     "@trpc/server": "^10.23.0",
     "superjson": "^1.12.3",

packages/support/eagle/index.ts

@@ -1,31 +1,54 @@
-import * as fs from "fs";
 import { join } from "path";
-import * as fg from "fast-glob";
+import chokidar from "chokidar";
+import * as fs from "fs-extra";
 
+import curd from "@acme/curd";
 import { type Library } from "@acme/db";
 
 import { handleFolder } from "./folder";
-import { handleImage } from "./image";
-import { type LibraryMetadata } from "./types";
-
-export type EagleEmitOption = { type: "folder" | "image"; current: number; count: number; failCount?: number };
-export type EagleEmit = (option: EagleEmitOption) => void;
+import { type EmitOption, type LibraryMetadata } from "./types";
 
 interface Props {
   library: Library;
-  emit?: EagleEmit;
+  emit?: (option: EmitOption) => void;
   onError?: (err: unknown) => void;
 }
 
+/**
+ * 是否第一次监听，第一次监听无需记录，直接添加
+ */
+export const isFirst = async (library: Library) => {
+  const libs = await curd.library.get({ library: library.id });
+  const lib = libs && libs[0];
+  if (lib && lib._count.images > 0) {
+    return false;
+  }
+
+  return true;
+};
+
 export const start = async ({ library, emit, onError }: Props) => {
   try {
-    const base = JSON.parse(fs.readFileSync(`${library.dir}/metadata.json`, "utf-8")) as LibraryMetadata;
-    const images = fg.sync(join(library.dir, "images", "**", "metadata.json").replace(/\\/g, "/"));
-
+    // handle folder
+    const base = fs.readJSONSync(join(library.dir, "metadata.json")) as LibraryMetadata;
     await handleFolder(base.folders, library, emit);
 
-    await handleImage({ images, library, emit, onError });
+    const first = await isFirst(library);
+
+    chokidar.watch(library.dir).on(join(library.dir, "images", "**", "metadata.json"), (path) => {
+      if (first) {
+      }
+    });
   } catch (e) {
     onError?.(e);
   }
+
+  // try {
+  //   const base = JSON.parse(fs.readFileSync(`${library.dir}/metadata.json`, "utf-8")) as LibraryMetadata;
+  //   const images = fg.sync(join(library.dir, "images", "**", "metadata.json").replace(/\\/g, "/"));
+  //   await handleFolder(base.folders, library, emit);
+  //   await handleImage({ images, library, emit, onError });
+  // } catch (e) {
+  //   onError?.(e);
+  // }
 };

packages/support/eagle/package.json

@@ -13,8 +13,10 @@
     "@acme/constant": "^0.1.0",
     "@acme/curd": "^0.1.0",
     "@acme/db": "^0.1.0",
+    "chokidar": "^3.5.3",
     "chroma-js": "^2.4.2",
-    "fast-glob": "^3.2.12"
+    "fast-glob": "^3.2.12",
+    "fs-extra": "^11.1.1"
   },
   "devDependencies": {
     "@acme/eslint-config": "^0.1.0",

packages/support/eagle/src/image.ts

@@ -0,0 +1,18 @@
+import * as fs from "fs-extra";
+
+import curd from "@acme/curd";
+import { type Library } from "@acme/db";
+
+import { type EmitOption, type Metadata } from "../types";
+
+export const createImage = (path: string, library: Library, emit: (option: EmitOption) => void) => {
+  try {
+    const metadata = fs.readJSONSync(path) as Metadata;
+
+    // curd.image.add({
+
+    // })
+  } catch (e) {
+    throw e;
+  }
+};

packages/support/eagle/tsconfig.json

@@ -1,4 +1,4 @@
 {
   "extends": "../../../tsconfig.json",
-  "include": ["*.ts", "test", "../../../global.d.ts"]
+  "include": ["*.ts", "test", "src", "../../../global.d.ts"]
 }

packages/support/eagle/types.ts

@@ -2,6 +2,8 @@ import { CONSTANT, type Constant } from "@acme/constant";
 
 export const SUPPORT_EXT = CONSTANT.EXT;
 
+export type EmitOption = { type: Constant["app"]; current: number; count: number; failCount?: number };
+
 export interface Metadata {
   id: string;
   name: string;