zoukankan      html  css  js  c++  java
  • [Functional Programming] Free monad application

    Let's say we have a command line application:

    const { Task } = require("../../libs/types");
    const { save, all } = require("../../libs/db");
    const { last } = require("ramda");
    
    const AuthorTable = "Authors";
    const Author = (name) => ({ name });
    const PostTable = "Posts";
    const Post = (title, body) => ({ title, body });
    
    const readline = require("readline").createInterface({
      input: process.stdin,
      output: process.stdout,
    });
    
    const formatPost = (post) => `${post.title}:
    ${post.body}`;
    const print = (s) =>
      Task((rej, res) => {
        res(console.log(s));
      });
    
    const getInput = (q) =>
      Task((rej, res) => readline.question(q, (i) => res(i.trim())));
    
    const menu = () =>
      getInput("where do you want to go today? (createAuthor, write, latest)").map(
        (route) => router[route]
      );
    
    const createAuthor = () =>
      getInput("Name? ")
        .map((name) => Author(name))
        .chain((author) => save(AuthorTable, author))
        .map(() => menu);
    
    const latest = () =>
      all(PostTable)
        .map((posts) => last(posts))
        .map(formatPost)
        .chain(print)
        .map(() => menu);
    
    const write = () =>
      getInput("Title: ")
        .chain((title) => getInput("Body: ").map((body) => Post({ title, body })))
        .chain((post) => save(PostTable, post))
        .map(() => latest);
    
    const start = () =>
      all(AuthorTable).map((authors) => (authors.length ? menu : createAuthor));
    
    const router = { menu, createAuthor, latest, write };
    
    const runApp = (f) => f().fork(console.error, runApp);
    
    runApp(start);

    All the actions are in 'Task' data type. such as 'getInput', 'print' dealing with console and stdout/stdin.

    Those actions is not easy to test. 

    Free monad can help in those cases. We can mock those actions as data type, then we are able to test those data type. In the end, we just interpret into real functions.

    const { Task } = require("../../libs/types");
    const { save, all } = require("../../libs/db");
    const { last } = require("ramda");
    const { liftF } = require("../../libs/free");
    const { taggedSum } = require("daggy");
    
    const AuthorTable = "Authors";
    const Author = (name) => ({ name });
    const PostTable = "Posts";
    const Post = (title, body) => ({ title, body });
    
    /** real actions */
    const readline = require("readline").createInterface({
      input: process.stdin,
      output: process.stdout,
    });
    const formatPost = (post) => `${post.title}
    ${post.body}`;
    const writeOutput = (s) =>
      Task((rej, res) => {
        console.log(s);
        res(s);
      });
    const getInput = (q) =>
      Task((rej, res) => readline.question(q, (i) => res(i.trim())));
    
    /** Mock data type */
    const Console = taggedSum("Console", { Question: ["q"], Print: ["s"] });
    const Db = taggedSum("Db", {
      Save: ["table", "record"],
      All: ["table", "query"],
    });
    
    /**Lift into free monads */
    const print = (s) => liftF(Console.Print(s));
    const question = (s) => liftF(Console.Question(s));
    const dbAll = (table, query) => liftF(Db.All(table, query));
    const dbSave = (table, record) => liftF(Db.Save(table, record));
    
    /**App logics */
    const menu = () =>
      question("where do you want to go today? (createAuthor, write, latest)").map(
        (route) => router[route]
      );
    
    const createAuthor = () =>
      question("Name? ")
        .map((name) => Author(name))
        .chain((author) => dbSave(AuthorTable, author))
        .map(() => menu);
    
    const latest = () =>
      dbAll(PostTable)
        .map((posts) => last(posts))
        .map(formatPost)
        .chain(print)
        .map(() => menu);
    
    const write = () =>
      question("Title: ")
        .chain((title) => question("Body: ").map((body) => Post(title, body)))
        .chain((post) => dbSave(PostTable, post))
        .map(() => latest);
    
    const start = () =>
      dbAll(AuthorTable).map((authors) => (authors.length ? menu : createAuthor));
    
    const router = { menu, createAuthor, latest, write };
    
    /** interpret */
    const dbToTask = (x) =>
      x.cata({
        Save: save,
        All: all,
      });
    const consoleToTask = (x) =>
      x.cata({
        Question: getInput,
        Print: writeOutput,
      });
    const interpret = (x) => (x.table ? dbToTask(x) : consoleToTask(x));
    
    const runApp = (f) =>
      f().foldMap(interpret, Task.of).fork(console.error, runApp);
    
    runApp(start);
  • 相关阅读:
    自动化运维工具Ansible实战Playbooks剧本使用
    Mysql5.6.x版本半同步主从复制的开启方法
    mysql数据库的一些基本概念
    mysql之视图
    mysql之索引
    机器学习笔记09-----决策树与随机森林1---决策树概述
    机器学习笔记08-----回归2
    Anaconda 利用conda安装第3方包
    机器学习笔记07-----回归1
    使用navicat导出数据库字典
  • 原文地址:https://www.cnblogs.com/Answer1215/p/13262743.html
Copyright © 2011-2022 走看看