From e016ad99f53a6e4b2ac9501b2536051292c6e32a Mon Sep 17 00:00:00 2001 From: imbytecat Date: Sun, 18 Jan 2026 14:23:29 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BD=BF=E7=94=A8Effect=E6=A8=A1?= =?UTF-8?q?=E5=9E=8B=E9=87=8D=E6=9E=84=E6=9E=84=E5=BB=BA=E6=B5=81=E7=A8=8B?= =?UTF-8?q?=E5=B9=B6=E5=BC=95=E5=85=A5=E7=B1=BB=E5=9E=8B=E5=AE=89=E5=85=A8?= =?UTF-8?q?=E6=94=AF=E6=8C=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 使用 Effect 模型重构构建流程，引入类型安全的配置验证、服务层解耦和错误处理，提升代码可维护性与可测试性。 - 添加 Effect 平台和模式库依赖及其相关构建工具，支持多平台二进制文件下载与原生模块编译。 - 添加Effect平台和模式库依赖以支持类型安全和平台功能 --- build.ts | 331 ++++++++++++++++++++++++++++++++++++--------------- bun.lock | 28 +++++ package.json | 2 + 3 files changed, 263 insertions(+), 98 deletions(-) diff --git a/build.ts b/build.ts index 87b1697..6dd1572 100644 --- a/build.ts +++ b/build.ts @@ -1,8 +1,9 @@ +import { Schema } from '@effect/schema' import { $ } from 'bun' -import { Console, Effect } from 'effect' +import { Console, Context, Data, Effect, Layer } from 'effect' // ============================================================================ -// Domain Models +// Domain Models & Schema // ============================================================================ const targetMap = { @@ -13,141 +14,275 @@ const targetMap = { 'bun-linux-arm64': 'aarch64-unknown-linux-gnu', } as const -type BunTarget = keyof typeof targetMap +const BunTargetSchema = Schema.Literal( + 'bun-windows-x64', + 'bun-darwin-arm64', + 'bun-darwin-x64', + 'bun-linux-x64', + 'bun-linux-arm64', +) -type BuildConfig = Readonly<{ - entrypoint: string - outputDir: string - targets: ReadonlyArray -}> +type BunTarget = Schema.Schema.Type -type BuildResult = Readonly<{ - target: BunTarget - outputs: ReadonlyArray -}> +const BuildConfigSchema = Schema.Struct({ + entrypoint: Schema.String.pipe(Schema.nonEmptyString()), + outputDir: Schema.String.pipe(Schema.nonEmptyString()), + targets: Schema.Array(BunTargetSchema).pipe(Schema.minItems(1)), +}) + +type BuildConfig = Schema.Schema.Type + +const BuildResultSchema = Schema.Struct({ + target: BunTargetSchema, + outputs: Schema.Array(Schema.String), +}) + +type BuildResult = Schema.Schema.Type // ============================================================================ -// Configuration +// Error Models (使用 Data.TaggedError) // ============================================================================ -const defaultConfig: BuildConfig = { - entrypoint: './.output/server/index.mjs', - outputDir: './out', - targets: ['bun-windows-x64', 'bun-darwin-arm64', 'bun-linux-x64'], -} +class CleanError extends Data.TaggedError('CleanError')<{ + readonly dir: string + readonly cause: unknown +}> {} + +class BuildError extends Data.TaggedError('BuildError')<{ + readonly target: BunTarget + readonly cause: unknown +}> {} + +class ConfigError extends Data.TaggedError('ConfigError')<{ + readonly message: string + readonly cause: unknown +}> {} // ============================================================================ -// Effects +// Services // ============================================================================ /** - * 清理输出目录 + * 配置服务 */ -const cleanOutputDir = (dir: string) => - Effect.tryPromise({ - try: async () => { - await $`rm -rf ${dir}` - return undefined - }, - catch: (error: unknown) => ({ - _tag: 'CleanError' as const, - message: `无法清理目录 ${dir}`, - cause: error, +class BuildConfigService extends Context.Tag('BuildConfigService')< + BuildConfigService, + BuildConfig +>() { + /** + * 从原始数据创建并验证配置 + */ + static fromRaw = (raw: unknown) => + Effect.gen(function* () { + const decoded = yield* Schema.decodeUnknown(BuildConfigSchema)(raw) + return decoded + }).pipe( + Effect.catchAll((error) => + Effect.fail( + new ConfigError({ + message: '配置验证失败', + cause: error, + }), + ), + ), + ) + + /** + * 默认配置 Layer + */ + static readonly Live = Layer.effect( + BuildConfigService, + BuildConfigService.fromRaw({ + entrypoint: './.output/server/index.mjs', + outputDir: './out', + targets: ['bun-windows-x64', 'bun-darwin-arm64', 'bun-linux-x64'], }), - }).pipe(Effect.tap(() => Console.log(`✓ 已清理输出目录: ${dir}`))) - -/** - * 为单个目标平台构建 - */ -const buildForTarget = ( - config: BuildConfig, - target: BunTarget, -): Effect.Effect< - BuildResult, - { _tag: 'BuildError'; target: BunTarget; message: string; cause: unknown } -> => - Effect.gen(function* () { - yield* Console.log(`🔨 开始构建: ${target}`) - - const output = yield* Effect.tryPromise({ - try: () => - Bun.build({ - entrypoints: [config.entrypoint], - compile: { - outfile: `server-${targetMap[target]}`, - target: target, - }, - outdir: config.outputDir, - }), - catch: (error: unknown) => ({ - _tag: 'BuildError' as const, - target, - message: `构建失败: ${target}`, - cause: error, - }), - }) - - const paths = output.outputs.map((item: { path: string }) => item.path) - - return { - target, - outputs: paths, - } satisfies BuildResult - }) - -/** - * 并行构建所有目标平台 - */ -const buildAllTargets = (config: BuildConfig) => { - const effects = config.targets.map((target) => buildForTarget(config, target)) - return Effect.all(effects, { concurrency: 'unbounded' }) + ) } /** - * 输出构建结果摘要 + * 文件系统服务 */ -const printBuildSummary = (results: ReadonlyArray) => - Effect.gen(function* () { - yield* Console.log('\n📦 构建完成:') - for (const result of results) { - yield* Console.log(` ${result.target}:`) - for (const path of result.outputs) { - yield* Console.log(` - ${path}`) - } - } +class FileSystemService extends Context.Tag('FileSystemService')< + FileSystemService, + { + readonly cleanDir: (dir: string) => Effect.Effect + } +>() { + static readonly Live = Layer.succeed(FileSystemService, { + cleanDir: (dir: string) => + Effect.tryPromise({ + try: async () => { + await $`rm -rf ${dir}` + }, + catch: (cause: unknown) => + new CleanError({ + dir, + cause, + }), + }), }) +} + +/** + * 构建服务 + */ +class BuildService extends Context.Tag('BuildService')< + BuildService, + { + readonly buildForTarget: ( + config: BuildConfig, + target: BunTarget, + ) => Effect.Effect + readonly buildAll: ( + config: BuildConfig, + ) => Effect.Effect, BuildError> + } +>() { + static readonly Live = Layer.succeed(BuildService, { + buildForTarget: (config: BuildConfig, target: BunTarget) => + Effect.gen(function* () { + yield* Console.log(`🔨 开始构建: ${target}`) + + const output = yield* Effect.tryPromise({ + try: () => + Bun.build({ + entrypoints: [config.entrypoint], + compile: { + outfile: `server-${targetMap[target]}`, + target: target, + }, + outdir: config.outputDir, + }), + catch: (cause: unknown) => + new BuildError({ + target, + cause, + }), + }) + + const paths = output.outputs.map((item: { path: string }) => item.path) + + return { + target, + outputs: paths, + } satisfies BuildResult + }), + + buildAll: (config: BuildConfig) => + Effect.gen(function* () { + const effects = config.targets.map((target) => + Effect.gen(function* () { + yield* Console.log(`🔨 开始构建: ${target}`) + + const output = yield* Effect.tryPromise({ + try: () => + Bun.build({ + entrypoints: [config.entrypoint], + compile: { + outfile: `server-${targetMap[target]}`, + target: target, + }, + outdir: config.outputDir, + }), + catch: (cause: unknown) => + new BuildError({ + target, + cause, + }), + }) + + const paths = output.outputs.map( + (item: { path: string }) => item.path, + ) + + return { + target, + outputs: paths, + } satisfies BuildResult + }), + ) + return yield* Effect.all(effects, { concurrency: 'unbounded' }) + }), + }) +} + +/** + * 报告服务 + */ +class ReporterService extends Context.Tag('ReporterService')< + ReporterService, + { + readonly printSummary: ( + results: ReadonlyArray, + ) => Effect.Effect + } +>() { + static readonly Live = Layer.succeed(ReporterService, { + printSummary: (results: ReadonlyArray) => + Effect.gen(function* () { + yield* Console.log('\n📦 构建完成:') + for (const result of results) { + yield* Console.log(` ${result.target}:`) + for (const path of result.outputs) { + yield* Console.log(` - ${path}`) + } + } + }), + }) +} // ============================================================================ // Main Program // ============================================================================ const program = Effect.gen(function* () { - const config = defaultConfig + const config = yield* BuildConfigService + const fs = yield* FileSystemService + const builder = yield* BuildService + const reporter = yield* ReporterService // 1. 清理输出目录 - yield* cleanOutputDir(config.outputDir) + yield* fs.cleanDir(config.outputDir) + yield* Console.log(`✓ 已清理输出目录: ${config.outputDir}`) // 2. 并行构建所有目标 - const results = yield* buildAllTargets(config) + const results = yield* builder.buildAll(config) // 3. 输出构建摘要 - yield* printBuildSummary(results) + yield* reporter.printSummary(results) return results }) +// ============================================================================ +// Layer Composition +// ============================================================================ + +const MainLayer = Layer.mergeAll( + BuildConfigService.Live, + FileSystemService.Live, + BuildService.Live, + ReporterService.Live, +) + // ============================================================================ // Runner // ============================================================================ -const main = program.pipe( - Effect.catchAllCause((cause) => - Console.error('❌ 构建失败:', cause).pipe( - Effect.flatMap(() => Effect.fail(cause)), - ), - ), +const runnable = program.pipe( + Effect.provide(MainLayer), + Effect.catchTags({ + CleanError: (error) => + Console.error(`❌ 清理目录失败: ${error.dir}`, error.cause), + BuildError: (error) => + Console.error(`❌ 构建失败 [${error.target}]:`, error.cause), + ConfigError: (error) => + Console.error(`❌ 配置错误: ${error.message}`, error.cause), + }), + Effect.tapErrorCause((cause) => Console.error('❌ 未预期的错误:', cause)), ) -Effect.runPromise(main).catch(() => { +Effect.runPromise(runnable).catch(() => { process.exit(1) }) diff --git a/bun.lock b/bun.lock index 4c3b01a..9e65686 100644 --- a/bun.lock +++ b/bun.lock @@ -24,6 +24,8 @@ }, "devDependencies": { "@biomejs/biome": "^2.3.11", + "@effect/platform": "^0.94.1", + "@effect/schema": "^0.75.5", "@tailwindcss/vite": "^4.1.18", "@tanstack/devtools-vite": "^0.4.1", "@tanstack/react-devtools": "^0.9.2", @@ -127,6 +129,10 @@ "@drizzle-team/brocli": ["@drizzle-team/brocli@0.10.2", "", {}, "sha512-z33Il7l5dKjUgGULTqBsQBQwckHh5AbIuxhdsIxDDiZAzBOrZO6q9ogcWC65kU382AfynTfgNumVcNIjuIua6w=="], + "@effect/platform": ["@effect/platform@0.94.1", "", { "dependencies": { "find-my-way-ts": "^0.1.6", "msgpackr": "^1.11.4", "multipasta": "^0.2.7" }, "peerDependencies": { "effect": "^3.19.14" } }, "sha512-SlL8OMTogHmMNnFLnPAHHo3ua1yrB1LNQOVQMiZsqYu9g3216xjr0gn5WoDgCxUyOdZcseegMjWJ7dhm/2vnfg=="], + + "@effect/schema": ["@effect/schema@0.75.5", "", { "dependencies": { "fast-check": "^3.21.0" }, "peerDependencies": { "effect": "^3.9.2" } }, "sha512-TQInulTVCuF+9EIbJpyLP6dvxbQJMphrnRqgexm/Ze39rSjfhJuufF7XvU3SxTgg3HnL7B/kpORTJbHhlE6thw=="], + "@emnapi/core": ["@emnapi/core@1.8.1", "", { "dependencies": { "@emnapi/wasi-threads": "1.1.0", "tslib": "^2.4.0" } }, "sha512-AvT9QFpxK0Zd8J0jopedNm+w/2fIzvtPKPjqyw9jwvBaReTTqPBk9Hixaz7KbjimP+QNz605/XnjFcDAL2pqBg=="], "@emnapi/runtime": ["@emnapi/runtime@1.8.1", "", { "dependencies": { "tslib": "^2.4.0" } }, "sha512-mehfKSMWjjNol8659Z8KxEMrdSJDDot5SXMq00dM8BN4o+CLNXQ0xH2V7EchNHV4RmbZLmmPdEaXZc5H2FXmDg=="], @@ -199,6 +205,18 @@ "@jridgewell/trace-mapping": ["@jridgewell/trace-mapping@0.3.31", "", { "dependencies": { "@jridgewell/resolve-uri": "^3.1.0", "@jridgewell/sourcemap-codec": "^1.4.14" } }, "sha512-zzNR+SdQSDJzc8joaeP8QQoCQr8NuYx2dIIytl1QeBEZHJ9uW6hebsrYgbz8hJwUQao3TWCMtmfV8Nu1twOLAw=="], + "@msgpackr-extract/msgpackr-extract-darwin-arm64": ["@msgpackr-extract/msgpackr-extract-darwin-arm64@3.0.3", "", { "os": "darwin", "cpu": "arm64" }, "sha512-QZHtlVgbAdy2zAqNA9Gu1UpIuI8Xvsd1v8ic6B2pZmeFnFcMWiPLfWXh7TVw4eGEZ/C9TH281KwhVoeQUKbyjw=="], + + "@msgpackr-extract/msgpackr-extract-darwin-x64": ["@msgpackr-extract/msgpackr-extract-darwin-x64@3.0.3", "", { "os": "darwin", "cpu": "x64" }, "sha512-mdzd3AVzYKuUmiWOQ8GNhl64/IoFGol569zNRdkLReh6LRLHOXxU4U8eq0JwaD8iFHdVGqSy4IjFL4reoWCDFw=="], + + "@msgpackr-extract/msgpackr-extract-linux-arm": ["@msgpackr-extract/msgpackr-extract-linux-arm@3.0.3", "", { "os": "linux", "cpu": "arm" }, "sha512-fg0uy/dG/nZEXfYilKoRe7yALaNmHoYeIoJuJ7KJ+YyU2bvY8vPv27f7UKhGRpY6euFYqEVhxCFZgAUNQBM3nw=="], + + "@msgpackr-extract/msgpackr-extract-linux-arm64": ["@msgpackr-extract/msgpackr-extract-linux-arm64@3.0.3", "", { "os": "linux", "cpu": "arm64" }, "sha512-YxQL+ax0XqBJDZiKimS2XQaf+2wDGVa1enVRGzEvLLVFeqa5kx2bWbtcSXgsxjQB7nRqqIGFIcLteF/sHeVtQg=="], + + "@msgpackr-extract/msgpackr-extract-linux-x64": ["@msgpackr-extract/msgpackr-extract-linux-x64@3.0.3", "", { "os": "linux", "cpu": "x64" }, "sha512-cvwNfbP07pKUfq1uH+S6KJ7dT9K8WOE4ZiAcsrSes+UY55E/0jLYc+vq+DO7jlmqRb5zAggExKm0H7O/CBaesg=="], + + "@msgpackr-extract/msgpackr-extract-win32-x64": ["@msgpackr-extract/msgpackr-extract-win32-x64@3.0.3", "", { "os": "win32", "cpu": "x64" }, "sha512-x0fWaQtYp4E6sktbsdAqnehxDgEc/VwM7uLsRCYWaiGu0ykYdZPiS8zCWdnjHwyiumousxfBm4SO31eXqwEZhQ=="], + "@napi-rs/wasm-runtime": ["@napi-rs/wasm-runtime@1.1.1", "", { "dependencies": { "@emnapi/core": "^1.7.1", "@emnapi/runtime": "^1.7.1", "@tybys/wasm-util": "^0.10.1" } }, "sha512-p64ah1M1ld8xjWv3qbvFwHiFVWrq1yFvV4f7w+mzaqiR4IlSgkqhcRdHwsGgomwzBH51sRY4NEowLxnaBjcW/A=="], "@oozcitak/dom": ["@oozcitak/dom@2.0.2", "", { "dependencies": { "@oozcitak/infra": "^2.0.2", "@oozcitak/url": "^3.0.0", "@oozcitak/util": "^10.0.0" } }, "sha512-GjpKhkSYC3Mj4+lfwEyI1dqnsKTgwGy48ytZEhm4A/xnH/8z9M3ZVXKr/YGQi3uCLs1AEBS+x5T2JPiueEDW8w=="], @@ -657,6 +675,8 @@ "fill-range": ["fill-range@7.1.1", "", { "dependencies": { "to-regex-range": "^5.0.1" } }, "sha512-YsGpe3WHLK8ZYi4tWDg2Jy3ebRz2rXowDxnld4bkQB00cc/1Zw9AWnC0i9ztDJitivtQvaI9KaLyKrc+hBW0yg=="], + "find-my-way-ts": ["find-my-way-ts@0.1.6", "", {}, "sha512-a85L9ZoXtNAey3Y6Z+eBWW658kO/MwR7zIafkIUPUMf3isZG0NCs2pjW2wtjxAKuJPxMAsHUIP4ZPGv0o5gyTA=="], + "fsevents": ["fsevents@2.3.3", "", { "os": "darwin" }, "sha512-5xoDfX+fL7faATnagmWPpbFtwh/R77WmMMqqHGS65C3vvB0YHrgF+B1YmZ3441tMj5n63k0212XNoJwzlhffQw=="], "gensync": ["gensync@1.0.0-beta.2", "", {}, "sha512-3hN7NaskYvMDLQY55gnW3NQ+mesEAepTqlg+VEbj7zzqEMBVNhzcGYYeqFo/TlYz6eQiFcp1HcsCZO+nGgS8zg=="], @@ -763,12 +783,20 @@ "ms": ["ms@2.1.3", "", {}, "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA=="], + "msgpackr": ["msgpackr@1.11.8", "", { "optionalDependencies": { "msgpackr-extract": "^3.0.2" } }, "sha512-bC4UGzHhVvgDNS7kn9tV8fAucIYUBuGojcaLiz7v+P63Lmtm0Xeji8B/8tYKddALXxJLpwIeBmUN3u64C4YkRA=="], + + "msgpackr-extract": ["msgpackr-extract@3.0.3", "", { "dependencies": { "node-gyp-build-optional-packages": "5.2.2" }, "optionalDependencies": { "@msgpackr-extract/msgpackr-extract-darwin-arm64": "3.0.3", "@msgpackr-extract/msgpackr-extract-darwin-x64": "3.0.3", "@msgpackr-extract/msgpackr-extract-linux-arm": "3.0.3", "@msgpackr-extract/msgpackr-extract-linux-arm64": "3.0.3", "@msgpackr-extract/msgpackr-extract-linux-x64": "3.0.3", "@msgpackr-extract/msgpackr-extract-win32-x64": "3.0.3" }, "bin": { "download-msgpackr-prebuilds": "bin/download-prebuilds.js" } }, "sha512-P0efT1C9jIdVRefqjzOQ9Xml57zpOXnIuS+csaB4MdZbTdmGDLo8XhzBG1N7aO11gKDDkJvBLULeFTo46wwreA=="], + + "multipasta": ["multipasta@0.2.7", "", {}, "sha512-KPA58d68KgGil15oDqXjkUBEBYc00XvbPj5/X+dyzeo/lWm9Nc25pQRlf1D+gv4OpK7NM0J1odrbu9JNNGvynA=="], + "nanoid": ["nanoid@3.3.11", "", { "bin": { "nanoid": "bin/nanoid.cjs" } }, "sha512-N8SpfPUnUp1bK+PMYW8qSWdl9U+wwNWI4QKxOYDy9JAro3WMX7p2OeVRF9v+347pnakNevPmiHhNmZ2HbFA76w=="], "nf3": ["nf3@0.3.4", "", {}, "sha512-GnEgxkyJBjxbI+PxWICbQ2CaoAKeH8g7NaN8EidW+YvImlY/9HUJaGJ+1+ycEqBiZpZtIMyd/ppCXkkUw4iMrA=="], "nitro": ["nitro-nightly@3.0.1-20260115-135431-98fc91c5", "", { "dependencies": { "consola": "^3.4.2", "crossws": "^0.4.1", "db0": "^0.3.4", "h3": "^2.0.1-rc.8", "jiti": "^2.6.1", "nf3": "^0.3.4", "ofetch": "^2.0.0-alpha.3", "ohash": "^2.0.11", "oxc-minify": "^0.108.0", "oxc-transform": "^0.108.0", "srvx": "^0.10.0", "undici": "^7.18.2", "unenv": "^2.0.0-rc.24", "unstorage": "^2.0.0-alpha.5" }, "peerDependencies": { "rolldown": ">=1.0.0-beta.0", "rollup": "^4", "vite": "^7 || ^8 || >=8.0.0-0", "xml2js": "^0.6.2" }, "optionalPeers": ["rolldown", "rollup", "vite", "xml2js"], "bin": { "nitro": "dist/cli/index.mjs" } }, "sha512-dLGCF/NjNz0dfso6NP4Eck6HSVXCT2Mu3CIpsj6dDxfnQycXVvrRLXY5/mK2qnNjfVwr3PsbDLTrqAKNWIKWMw=="], + "node-gyp-build-optional-packages": ["node-gyp-build-optional-packages@5.2.2", "", { "dependencies": { "detect-libc": "^2.0.1" }, "bin": { "node-gyp-build-optional-packages": "bin.js", "node-gyp-build-optional-packages-optional": "optional.js", "node-gyp-build-optional-packages-test": "build-test.js" } }, "sha512-s+w+rBWnpTMwSFbaE0UXsRlg7hU4FjekKU4eyAih5T8nJuNZT1nNsskXpxmeqSK9UzkBl6UgRlnKc8hz8IEqOw=="], + "node-releases": ["node-releases@2.0.27", "", {}, "sha512-nmh3lCkYZ3grZvqcCH+fjmQ7X+H0OeZgP40OierEaAptX4XofMh5kwNbWh7lBduUzCcV/8kZ+NDLCwm2iorIlA=="], "normalize-path": ["normalize-path@3.0.0", "", {}, "sha512-6eZs5Ls3WtCisHWp9S2GUy8dqkpGi4BVSz3GaqiE6ezub0512ESztXUwUB6C6IKbQkY2Pnb/mD4WYojCRwcwLA=="], diff --git a/package.json b/package.json index f58b1ba..9e548e9 100644 --- a/package.json +++ b/package.json @@ -34,6 +34,8 @@ }, "devDependencies": { "@biomejs/biome": "^2.3.11", + "@effect/platform": "^0.94.1", + "@effect/schema": "^0.75.5", "@tailwindcss/vite": "^4.1.18", "@tanstack/devtools-vite": "^0.4.1", "@tanstack/react-devtools": "^0.9.2",