chore: init

src/file.ts

@@ -0,0 +1,98 @@
+import dayjs from 'dayjs';
+import _ from 'lodash';
+import fs from 'node:fs/promises';
+import url from 'node:url';
+import path from 'node:path';
+import { SubscriptionConfig } from './types';
+import { refreshUrls, uploadFile } from './upload_qiniu';
+
+export const relativePath = (p: string) => {
+  return url.fileURLToPath(new URL(p, import.meta.url));
+};
+
+export const writeConfig = async (fp: string, config: SubscriptionConfig) => {
+  const filePath = relativePath(fp);
+  const newConfig: SubscriptionConfig = { ...config };
+  const oldConfig: SubscriptionConfig = JSON.parse(
+    await fs.readFile(filePath, 'utf-8').catch(() => `{}`),
+  );
+
+  newConfig.version = oldConfig.version ?? 0;
+  if (_.isEqual(newConfig, oldConfig)) {
+    return;
+  }
+  newConfig.version++;
+
+  // check duplicated key
+  newConfig.apps?.forEach((app) => {
+    const keys = new Set<number>();
+    app.groups?.forEach((g) => {
+      if (keys.has(g.key)) {
+        console.error({
+          configName: newConfig.name,
+          appId: app.id,
+          groupName: g.name,
+          groupKey: g.key,
+        });
+        throw new Error(`invalid duplicated group key`);
+      }
+      keys.add(g.key);
+    });
+  });
+
+  const sortKeys: (keyof SubscriptionConfig)[] = [
+    `name`,
+    `version`,
+    `author`,
+    'supportUrl',
+    `updateUrl`,
+    `apps`,
+  ];
+  const newKeys = Object.keys(newConfig) as (keyof SubscriptionConfig)[];
+  if (newKeys.some((s) => !sortKeys.includes(s))) {
+    console.log({
+      sortKeys,
+      newKeys,
+    });
+    throw new Error(`sortKeys miss some new key`);
+  }
+  // keep json key sort by map
+  const map = new Map<string, unknown>();
+  sortKeys.forEach((k) => {
+    if (newConfig[k] === undefined) return;
+    map.set(k, newConfig[k]);
+  });
+  const buffer = Buffer.from(
+    JSON.stringify(Object.fromEntries(map.entries()), void 0, 2),
+    'utf-8',
+  );
+  await fs.writeFile(filePath, buffer);
+  const { key, hash } = await uploadFile(filePath);
+  await refreshUrls(key);
+  console.log(
+    [
+      dayjs().format(`HH:mm:ss`),
+      (buffer.length / 1024).toFixed(3) + `KB`,
+      newConfig.version,
+      key,
+      hash,
+    ].join(` `),
+  );
+};
+
+export async function* walk(dirPath: string) {
+  const pathnames = (await fs.readdir(dirPath)).map((s) =>
+    path.join(dirPath, s),
+  );
+  while (pathnames.length > 0) {
+    const pathname = pathnames.pop()!;
+    const state = await fs.lstat(pathname);
+    if (state.isFile()) {
+      yield pathname;
+    } else if (state.isDirectory()) {
+      pathnames.push(
+        ...(await fs.readdir(pathname)).map((s) => path.join(pathname, s)),
+      );
+    }
+  }
+}