如何在 FP-TS 中链接依赖的 TaskEither 操作

Question

我是 FP-TS 的新手，仍然不太明白如何使用TaskEither. 我正在尝试异步读取文件，然后使用 yaml-parse-promise 解析结果字符串。

==编辑==

我使用文件的完整内容更新了代码以提供更多上下文，并应用了 MnZrK 提供的一些建议。抱歉，我对 FP-TS 还很陌生，并且仍在努力使类型匹配。

现在我的错误在于该行map(printConfig)：

Argument of type '<E>(fa: TaskEither<E, AppConfig>) => TaskEither<E, AppConfig>' is not assignable to parameter of type '(a: TaskEither<unknown, AppConfig>) => Either<unknown, Task<any>>'.
  Type 'TaskEither<unknown, AppConfig>' is not assignable to type 'Either<unknown, Task<any>>'.
    Type 'TaskEither<unknown, AppConfig>' is missing the following properties from type 'Right<Task<any>>': _tag, rightts(2345)

[我通过使用 TaskEither 中的 getOrElse 解决了这个问题，而不是来自 Either 库]

==编辑结束==

我已使用 IOEither 成功执行此操作，作为此项目的同步操作： https: //github.com/anotherhale/fp-ts_sync-example。

我还查看了这里的示例代码： https ://gcanti.github.io/fp-ts/recipes/async.html

完整代码在这里： https: //github.com/anotherhale/fp-ts_async-example

import { pipe } from 'fp-ts/lib/pipeable'
import { TaskEither, tryCatch, chain, map, getOrElse } from "fp-ts/lib/TaskEither";
import * as T from 'fp-ts/lib/Task';
import { promises as fsPromises } from 'fs';
const yamlPromise = require('js-yaml-promise');

// const path = require('path');
export interface AppConfig {
  service: {
    interface: string
    port: number
  };
}

function readFileAsyncAsTaskEither(path: string): TaskEither<unknown, string> {
  return tryCatch(() => fsPromises.readFile(path, 'utf8'), e => e)
}

function readYamlAsTaskEither(content: string): TaskEither<unknown, AppConfig> {
  return tryCatch(() => yamlPromise.safeLoad(content), e => e)
}

// function getConf(filePath:string){
//   return pipe(
//       readFileAsyncAsTaskEither(filePath)()).then(
//           file=>pipe(file,foldE(
//               e=>left(e),
//               r=>right(readYamlAsTaskEither(r)().then(yaml=>
//                   pipe(yaml,foldE(
//                       e=>left(e),
//                       c=>right(c)
//                   ))
//               ).catch(e=>left(e)))
//           ))
//       ).catch(e=>left(e))
// }

function getConf(filePath: string): TaskEither<unknown, AppConfig> {
  return pipe(
    readFileAsyncAsTaskEither(filePath),
    chain(readYamlAsTaskEither)
  )
}

function printConfig(config: AppConfig): AppConfig {
  console.log("AppConfig is: ", config);
  return config;
}

async function main(filePath: string): Promise<void> {
  const program: T.Task<void> = pipe(
    getConf(filePath),
    map(printConfig),
    getOrElse(e => {
      return T.of(undefined);
    })
  );

  await program();
}

main('./app-config.yaml')

结果输出是： { _tag: 'Right', right: Promise { <pending> } }

但我想要生成的 AppConfig： { service: { interface: '127.0.0.1', port: 9090 } }

Answer 1

所有这些e=>left(e)都是.catch(e=>left(e))不必要的。你的第二种方法更惯用。

// convert nodejs-callback-style function to function returning TaskEither
const readFile = taskify(fs.readFile);
// I don't think there is `taskify` alternative for Promise-returning functions but you can write it yourself quite easily
const readYamlAsTaskEither = r => tryCatch(() => readYaml(r), e => e);

function getConf(filePath: string): TaskEither<unknown, AppConfig> {
  return pipe(
    readFile(path.resolve(filePath)),
    chain(readYamlAsTaskEither)
  );
}

现在你的getConf回报TaskEither<unknown, AppConfig>实际上是一个() => Promise<Either<unknown, AppConfig>>. 如果您有比 更具体的错误类型unknown，请改用它。

为了“解压”实际值，您需要有一些主要入口点函数，您可以在其中使用map或组合您需要对配置执行的其他操作chain（即将其打印到控制台），然后应用一些错误处理来摆脱Either部分并最终得到Task（这实际上只是懒惰() => Promise）：

import * as T from 'fp-ts/lib/Task';

function printConfig(config: AppConfig): AppConfig {
  console.log("AppConfig is", config);
  return config;
}

function doSomethingElseWithYourConfig(config: AppConfig): TaskEither<unknown, void> {
  // ...
}

async function main(filePath: string): Promise<void> {
  const program: T.Task<void> = pipe(
    getConf(filePath),
    map(printConfig),
    chain(doSomethingElseWithYourConfig),
    // getting rid of `Either` by using `getOrElse` or `fold`
    getOrElse(e => {
      // error handling (putting it to the console, sending to sentry.io, whatever is needed for you app)
      // ...
      return T.of(undefined);
    })
  );

  await program();
}