【问题标题】:Rewriting a small function wrapped with a logger using fp-ts使用 fp-ts 重写一个用记录器包装的小函数
【发布时间】:2019-05-06 21:55:02
【问题描述】:

我想尝试使用 fp-ts 重写我的代码的某些部分,并考虑重构以下方法:

export const createApiServer = () => {
    logger.info("Starting World Server API");

    const apiServer = express()
        // 3rd party middleware
        .use(helmet())
        .use(bodyParser.json())
        .use(cors())
        // Root route
        .get("/", (_, result) => result.sendStatus(httpStatusCodes.OK))
        // 404 - Not Found
        .use((_, result) => result.sendStatus(httpStatusCodes.NOT_FOUND))
        // 500 - Internal Server Error
        .use(errorLoggerMiddleware)
        .use(errorResponseMiddleware);

    logger.verbose(`Initialized World Server API in ${process.uptime().toFixed(3)} seconds`);

    return apiServer;
};

在阅读了IO 类型的副作用后,我尝试如下使用它:

const info = (message: string) => new IO(() => log.info(message));
const verbose = (message: string) => new IO(() => log.verbose(message));

const setupApiServer = () =>
    new IO(() =>
        express()
            .use(helmet())
            .use(bodyParser.json())
            .use(cors())
            .get("/", (_, result) => result.sendStatus(httpStatusCodes.OK))
            .use((_, result) => result.sendStatus(httpStatusCodes.NOT_FOUND))
            .use(errorLoggerMiddleware)
            .use(errorResponseMiddleware)
    );

export const createApiServer = () =>
    info("Starting World Server API")
        .chain(setupApiServer)
        .chain((apiServer) =>
            verbose(`Initialized World Server API in ${process.uptime().toFixed(3)} seconds`)
                .map(() => apiServer)
        )
        .run();

在最后一个链调用中随意使用map方法来管道通过apiServer对象只是为了在接收它和进一步发送它之间登录,感觉很奇怪。我想知道这是否正确或是否有任何不同的模式。

【问题讨论】:

  • 你找到这个问题的答案了吗?
  • @DmytroFilipenko 不幸的是,我完全放弃了它。

标签: typescript fp-ts


【解决方案1】:

您可以使用chainFirst

使用chainFirst,您可以重构它

import { pipe } from "fp-ts/lib/pipeable";
import * as IO from "fp-ts/lib/IO";

declare const log: (m: string) => IO.IO<void>
declare const a: IO.IO<number>

pipe(
  a,
  IO.chain((a) => pipe(log(`Got ${a}`), IO.map(() => a)))
)

进入这个

pipe(
  a,
  IO.chainFirst((a) => log(`Got ${a}`))
)

【讨论】:

  • 这是正确答案。 Chain首先允许您使用计算结果,然后返回相同的计算。这是记录然后返回值的完美方式,就好像您根本没有登录一样。
猜你喜欢
  • 2014-05-30
  • 2020-04-18
  • 1970-01-01
  • 1970-01-01
  • 2014-11-03
  • 1970-01-01
  • 2021-05-10
  • 2013-05-23
  • 2021-08-07
相关资源
最近更新 更多