使用Either处理调用链错误向上传递的方案探讨

一、错误类型耦合冗长的解决思路 #

1. 封装层级化联合错误类型 #

不要让仓库接口直接返回TaskEither<DataSourceError | ParseError | TodoNotFoundError, T>这类冗长的平级联合类型，而是定义带类型标记的层级化错误：

// 仓库层统一错误类型
type RepositoryError = 
  | { type: 'DataSourceError', cause: DataSourceError }
  | { type: 'ParseError', cause: ParseError }
  | { type: 'TodoNotFoundError', todoId: string }

仓库统一返回TaskEither<RepositoryError, T>，上层调用时只需处理这个顶层类型，不用关心底层具体错误细节，同时通过type标记和附加信息保留错误的可追溯性。

2. 用fp-ts组合器封装错误转换逻辑 #

借助mapLeft、chain等组合器，将底层错误自动包装为上层错误，避免在业务代码中重复处理错误类型转换：

// 数据源层：返回数据源专属错误
const fetchRawTodo = (id: string): TaskEither<DataSourceError, RawTodo> => { /* ... */ }

// 仓库层：将底层错误包装为仓库统一错误
const getTodo = (id: string): TaskEither<RepositoryError, Todo> => 
  fetchRawTodo(id)
    .mapLeft(err => ({ type: 'DataSourceError', cause: err }))
    .chain(rawTodo => 
      parseRawTodo(rawTodo).mapLeft(parseErr => ({ type: 'ParseError', cause: parseErr }))
    )

这样仓库的错误处理逻辑被内聚封装，上层代码无需感知底层错误的具体类型。

3. 全局统一应用错误类型（中小型应用适用） #

如果应用规模不大，可以定义一个全局AppError类型，整合所有服务/仓库的错误类型：

type AppError = 
  | RepositoryError
  | AuthError
  | ValidationError
  // 其他服务的错误类型

所有业务函数统一返回TaskEither<AppError, T>，控制器调用多个服务时，只需处理AppError这一种错误类型，大幅简化类型定义。

二、混合try/catch与Either的可行性分析 #

完全可行，但要明确分工边界：

• Either处理可预见业务错误：比如资源不存在、数据解析失败、数据源连接异常这类能提前定义的错误，用Either显式处理，让错误类型成为函数签名的一部分，提升代码的可读性和可维护性。
• try/catch处理不可预见运行时异常：比如第三方库抛出的未捕获异常、Node.js系统级错误（如文件权限不足、内存溢出），可以在控制器或Express全局错误中间件中用try/catch捕获，统一转换为AppError或直接返回HTTP错误响应。

注意：使用TaskEither时，要确保所有异步操作都被包裹，避免异步代码抛出未捕获异常。对于可能抛异常的第三方异步函数，用tryCatch转换为TaskEither：

import { tryCatch } from 'fp-ts/TaskEither'

// 第三方可能抛异常的异步函数
const riskyThirdPartyCall = (id: string): Promise<Data> => { /* ... */ }

// 转换为安全的TaskEither
const safeThirdPartyCall = (id: string): TaskEither<UnknownError, Data> => 
  tryCatch(
    () => riskyThirdPartyCall(id),
    err => ({ type: 'UnknownError', message: err instanceof Error ? err.message : 'Unknown error' })
  )

三、Express层的错误适配示例 #

在Express路由处理器中，用fold方法将TaskEither的结果转换为HTTP响应：

import { fold } from 'fp-ts/Either'
import { pipe } from 'fp-ts/function'

router.get('/todos/:id', async (req, res) => {
  const taskResult = getTodo(req.params.id)
  const result = await taskResult()
  
  pipe(
    result,
    fold(
      (err) => {
        switch(err.type) {
          case 'TodoNotFoundError':
            return res.status(404).json({ message: `Todo ${err.todoId} not found` })
          case 'DataSourceError':
            return res.status(500).json({ message: 'Database access failed' })
          default:
            return res.status(500).json({ message: 'Internal server error' })
        }
      },
      (todo) => res.status(200).json(todo)
    )
  )
})

内容的提问来源于stack exchange，提问作者leepowell