NestJS：按请求（子域）进行数据库连接（TypeORM）

我正在尝试通过Nest / TypeORM构建SAAS产品，并且需要按子域配置/更改数据库连接。

customer1.domain.com => connect to customer1 database
customer2.domain.com => connect to customer2 database
x.domain.com => connect to x database

我怎样才能做到这一点 ？使用拦截器或请求上下文（或Zone.js）？

我不知道如何开始。有人已经这样做了吗？

WIP：我目前在做什么：

将所有连接设置添加到ormconfig文件中

在所有路由上创建中间件以将子域注入res.locals（实例名称）并创建/警告typeorm连接

import { Injectable, NestMiddleware, MiddlewareFunction } from '@nestjs/common';
import { getConnection, createConnection } from "typeorm";

@Injectable()
export class DatabaseMiddleware implements NestMiddleware {
    resolve(): MiddlewareFunction {
      return async (req, res, next) => {
          const instance = req.headers.host.split('.')[0]
          res.locals.instance = instance

          try {
              getConnection(instance)
          } catch (error) {
              await createConnection(instance)
          }

          next();
      };
    }
}

在Controller中：从@Response获取实例名称并将其传递给我的服务

@Controller('/catalog/categories')
export class CategoryController {
    constructor(private categoryService: CategoryService) {}

    @Get()
    async getList(@Query() query: SearchCategoryDto, @Response() response): Promise {
      return response.send(
        await this.categoryService.findAll(response.locals.instance, query)
      )
    }

在Service中：获取给定实例的TypeORM Manager，并通过存储库查询数据库

@Injectable()
export class CategoryService {
  // constructor(
  //   @InjectRepository(Category) private readonly categoryRepository: Repository
  // ) {}

  async getRepository(instance: string): Promise> {
      return (await getManager(instance)).getRepository(Category)
  }

  async findAll(instance: string, dto: SearchCategoryDto): Promise {
    let queryBuilder = (await this.getRepository(instance)).createQueryBuilder('category')

    if (dto.name) {
        queryBuilder.andWhere("category.name like :name", { name: `%${dto.name}%` })
    }

    return await queryBuilder.getMany();
  }

似乎可行，但我不确定几乎所有内容：

连接池（我可以在ConnectionManager中创建多少个连接？）

传递子域到response.locals ...不好的做法？

可读性/理解力/添加大量其他代码...

副作用：恐怕在几个子域之间共享连接

副作用：性能

处理response.send（）+ Promise + await（s）+在任何地方传递子域都不是一件令人愉快的事情...

有没有一种方法可以直接将子域加入我的服务？

有没有一种方法可以将正确的子域连接/存储库直接添加到我的服务中并将其注入到我的控制器中？