Merge branch 'main' into 2.0.0

Author: Rel1cx

package.json

@@ -51,6 +51,8 @@
     "update:website": "tsx ./scripts/update-website.ts"
   },
   "devDependencies": {
+    "@effect/platform": "^0.90.6",
+    "@effect/platform-node": "^0.96.0",
     "@eslint/config-inspector": "^1.2.0",
     "@eslint/markdown": "^7.1.0",
     "@local/configs": "workspace:*",
@@ -69,6 +71,7 @@
     "cspell": "^9.2.0",
     "dedent": "^1.6.0",
     "dprint": "^0.50.1",
+    "effect": "^3.17.8",
     "esbuild": "^0.25.9",
     "eslint": "^9.33.0",
     "eslint-config-flat-gitignore": "^2.1.0",

pnpm-lock.yaml

@@ -0,0 +1,16 @@
+import * as FileSystem from "@effect/platform/FileSystem";
+import * as Arr from "effect/Array";
+import * as Effect from "effect/Effect";
+import * as Fn from "effect/Function";
+import { not, or } from "effect/Predicate";
+import * as Str from "effect/String";
+
+export const ignores = Fn.pipe(
+  FileSystem.FileSystem,
+  Effect.flatMap((fs) => fs.readFileString(".gitignore", "utf8")),
+  Effect.map(Str.split("\n")),
+  Effect.map(Arr.map(Str.trim)),
+  Effect.map(Arr.filter(not(or(Str.startsWith("#"), Str.startsWith("!"))))),
+  Effect.map(Arr.map(Str.replace(/^\//, ""))),
+  Effect.map(Arr.filter(Str.isNonEmpty)),
+);

scripts/effects/ignores.ts

@@ -0,0 +1,11 @@
+import * as FileSystem from "@effect/platform/FileSystem";
+import * as Effect from "effect/Effect";
+import * as Fn from "effect/Function";
+import * as Str from "effect/String";
+
+export const version = Fn.pipe(
+  FileSystem.FileSystem,
+  Effect.flatMap((fs) => fs.readFileString("VERSION", "utf8")),
+  Effect.map(Str.trim),
+  Effect.map(Str.replace(/^v/, "")),
+);

scripts/effects/version.ts

@@ -1,42 +1,52 @@
-import fs from "node:fs";
-
+import * as NodeFileSystem from "@effect/platform-node/NodeFileSystem";
+import * as NodeRuntime from "@effect/platform-node/NodeRuntime";
+import * as FileSystem from "@effect/platform/FileSystem";
 import ansis from "ansis";
+import * as Effect from "effect/Effect";
 import { isMatching, match, P } from "ts-pattern";
 
-import { glob } from "./lib/glob";
-import { ignores } from "./lib/ignores";
-import { version } from "./lib/version";
+import { ignores } from "./effects/ignores";
+import { version } from "./effects/version";
+import { glob } from "./utils/glob";
 
 const GLOB_PACKAGE_JSON = [
   "package.json",
   "packages/*/package.json",
   "packages/*/*/package.json",
 ];
 
-async function update(path: string) {
-  const packageJson = JSON.parse(fs.readFileSync(path, "utf8"));
-  if (!isMatching({ version: P.string }, packageJson)) {
-    throw new Error(`Invalid package.json at ${path}`);
-  }
-  const newVersion = version;
-  const oldVersion = match(packageJson)
-    .with({ version: P.select(P.string) }, (v) => v)
-    .otherwise(() => "0.0.0");
-  if (oldVersion === newVersion) {
-    console.info(ansis.greenBright(`Skipping ${path} as it's already on version ${newVersion}`));
-    return;
-  }
-  const packageJsonUpdated = {
-    ...packageJson,
-    version: newVersion,
-  };
-  fs.writeFileSync(path, `${JSON.stringify(packageJsonUpdated, null, 2)}\n`);
-  console.info(ansis.green(`Updated ${path} to version ${packageJsonUpdated.version}`));
+function update(path: string) {
+  return Effect.gen(function*() {
+    const fs = yield* FileSystem.FileSystem;
+    const packageJsonText = yield* fs.readFileString(path, "utf8");
+    const packageJson = JSON.parse(packageJsonText);
+    if (!isMatching({ version: P.string }, packageJson)) {
+      yield* Effect.fail(new Error(`Invalid package.json at ${path}: invalid or missing version field`));
+    }
+    const newVersion = yield* version;
+    const oldVersion = match(packageJson)
+      .with({ version: P.select(P.string) }, (v) => v)
+      .otherwise(() => "0.0.0");
+    if (oldVersion === newVersion) {
+      yield* Effect.log(ansis.greenBright(`Skipping ${path} as it's already on version ${newVersion}`));
+      return false;
+    }
+    const packageJsonUpdated = {
+      ...packageJson,
+      version: newVersion,
+    };
+    yield* fs.writeFileString(path, `${JSON.stringify(packageJsonUpdated, null, 2)}\n`);
+    yield* Effect.log(`Updated ${path} to version ${packageJsonUpdated.version}`);
+    return true;
+  });
 }
 
-async function main() {
-  const tasks = glob(GLOB_PACKAGE_JSON, ignores);
-  await Promise.all(tasks.map((path) => update(path)));
-}
+const program = Effect.gen(function*() {
+  const ignorePatterns = yield* ignores;
+  return yield* Effect.all(glob(GLOB_PACKAGE_JSON, ignorePatterns).map(update), { concurrency: 8 });
+});
 
-await main();
+program.pipe(
+  Effect.provide(NodeFileSystem.layer),
+  NodeRuntime.runMain,
+);

scripts/lib/ignores.ts

@@ -1,7 +1,7 @@
 import fs from "node:fs/promises";
 import path from "node:path";
 
-import { glob } from "./lib/glob";
+import { glob } from "./utils/glob";
 
 /**
  * Build script for processing and copying documentation to the website

scripts/lib/version.ts

@@ -1,14 +1,20 @@
-import ansis from "ansis";
-import { x } from "tinyexec";
+import { Command, CommandExecutor } from "@effect/platform";
+import { NodeCommandExecutor, NodeFileSystem, NodeRuntime } from "@effect/platform-node";
+import { Effect } from "effect";
 
-const { stdout } = await x("git", ["diff", "HEAD@{1}", "--stat", "--", "./pnpm-lock.yaml"]);
+const command = Command.make("git", "diff", "HEAD@{1}", "--stat", "--", "./pnpm-lock.yaml");
+const program = Effect.gen(function*() {
+  const executor = yield* CommandExecutor.CommandExecutor;
+  const output = yield* executor.lines(command);
+  if (output.length === 0) {
+    return;
+  }
+  yield* Effect.logWarning("Detected changes in pnpm-lock.yaml!");
+  yield* Effect.logWarning("Please run `pnpm install --fix-lockfile && pnpm dedupe` to update local dependencies.");
+});
 
-if (stdout.split("\n").length > 0) {
-  console.info("");
-  console.info(ansis.yellow("Detected changes in pnpm-lock.yaml!"));
-  console.info(
-    ansis.yellowBright(
-      "Please run `pnpm install --fix-lockfile && pnpm dedupe` to update local dependencies.",
-    ),
-  );
-}
+program.pipe(
+  Effect.provide(NodeCommandExecutor.layer),
+  Effect.provide(NodeFileSystem.layer),
+  NodeRuntime.runMain,
+);