组合根

设计模式 / 整洁架构模式
image

//a port method with no body names the class that left
//it out: JavaScript has no interfaces, so a port here
//is a base class and extends says who serves it
function notWritten(owner, method) {
    throw new Error(owner.constructor.name + "." + method);
}

//entity
class Order {
    #total;

    constructor(id, total) {
        this.id = id;
        this.#total = total;
    }

    payable() {
        let cut = this.#total >= 200 ? this.#total / 10 : 0;
        return this.#total - Math.trunc(cut);
    }
}

//gateway
class Catalog {
    price(sku) {
        notWritten(this, "price");
    }
}

//repository
class Orders {
    save(order) {
        notWritten(this, "save");
    }

    count() {
        notWritten(this, "count");
    }
}

//output port
class Report {
    say(text) {
        notWritten(this, "say");
    }
}

//use case: asks for its parts, never builds them
class PlaceOrder {
    #catalog;
    #orders;
    #report;
    #nextId = 1001;

    constructor(catalog, orders, report) {
        this.#catalog = catalog;
        this.#orders = orders;
        this.#report = report;
    }

    place(items) {
        let total = 0;
        for (let [sku, count] of items) {
            let price = this.#catalog.price(sku);
            if (price === undefined) {
                this.#report.say("no " + sku);
                return;
            }
            total += price * count;
        }
        let order = new Order(this.#nextId++, total);
        this.#orders.save(order);
        this.#report.say("order " + order.id +
            " for " + order.payable());
    }
}

//adapters
class MemoryCatalog extends Catalog {
    #prices = new Map([["pen", 30], ["lamp", 190]]);

    price(sku) {
        return this.#prices.get(sku);
    }
}

class MemoryOrders extends Orders {
    #rows = new Map();

    save(order) {
        this.#rows.set(order.id, order);
    }

    count() {
        return this.#rows.size;
    }
}

class ConsoleReport extends Report {
    say(text) {
        console.log(text);
    }
}

class SilentReport extends Report {
    say(text) {
    }
}

//composition root: the only place that sees every layer
//at once, and the only place where new stands next to an
//adapter. No container is needed; a function is the root
function build(report) {
    let orders = new MemoryOrders();
    return {
        useCase: new PlaceOrder(
            new MemoryCatalog(), orders, report),
        orders: orders
    };
}

function loud() {
    return build(new ConsoleReport());
}

function quiet() {
    return build(new SilentReport());
}

//client code
let app = loud();
app.useCase.place(new Map([["pen", 2], ["lamp", 1]]));
app.useCase.place(new Map([["chair", 1]]));

//a second root builds the same use case differently, and
//neither of them ever named a class inside the use case
let night = quiet();
night.useCase.place(new Map([["lamp", 1]]));
console.log("night saved " + night.orders.count());
console.log("loud saved " + app.orders.count());
//printed: order 1001 for 225
//         no chair
//         night saved 1
//         loud saved 1


A composition root is the only place where the layers are connected and the adapters are built; the rest of the application only asks for its parts.
Read more

问题。用例需要一个价格目录、一个订单存储,以及一种报告结果的途径。如果用例自己创建这些部件,它就会指明外层的适配器,并依赖于它们。测试也无法为它提供别的部件。如果程序的每个部分都自行构建自己的部件,就没有人能看清应用程序是如何连接起来的。

思路。组合根是唯一一个连接各层、构建适配器的地方。适配器是实现端口的外层代码,而端口是内层声明的接口。用例只通过端口索取自己的部件,从不自己构建它们。组合根同时了解每一层,这正是它的职责。其余所有代码都遵守依赖规则:内层代码从不了解外层代码。这不需要任何框架或容器:组合根就是程序启动处的普通代码。

如何阅读示例。用例索取三个端口:一个查询价格的网关、一个保存订单的仓库,以及一个用于报告的输出端口。外层为它们提供了适配器:内存中的目录和存储,一个会打印的报告,还有一个什么也不说的报告。示例把应用程序构建了两次。第一次构建中,报告会打印:客户端代码下了订单 1001,应付 225,又下了一个含未知商品的订单。第二次构建使用静默的报告,因此它的订单什么也不打印。只有已保存订单的数量表明它们确实被保存了。两次构建中的用例完全相同。

何时使用。每个应用程序都有一个组合根,位于它的启动处;测试可以有自己的小型组合根,使用假的适配器。没有端口的短脚本不需要组合根。

常见错误。在用例内部创建适配器,哪怕只有一次。这样用例就依赖于外层,组合根也不再能展示应用程序是如何连接起来的。