# NXTP(二) Router

By [Walker](https://paragraph.com/@walker-4) · 2022-07-19

---

说明:nxtp包含有不同模块,大部分采用ts语言编写,因为本人对ts语言并不太了解,只是大概看了看代码大致结构和主要功能(不太能完全读懂所有ts细节,可能有错误之处,敬请谅解)

路由器是什么
======

路由器Connext网络中的,一个在后台的自动化的参与者，主要负责提供交易流动性和促进跨链互换。

  

路由器基本功能
=======

监听用户跨链交易交换请求。

提交拍卖投标以满足用户交换请求。

监视所有链上的TransactionManager合约事件，以获取TransactionPrepared事件，其中路由器匹配配置的路由器的签名地址，sendingChainId匹配事件链。

在接收链上使用amount = amount - calculatedFees调用prepare，其中calculatedFees是AMM-based 互换率、固定的0.05%费用和用户支付的gas组合。

监控所有跨链的TransactionManager合约事件，以获取transactionfulfillment事件，其中路由器与配置的路由器的签署人地址匹配，receivingChainId与事件链匹配

使用从transactionfulfillment事件发出的签名在发送链上调用fulfillment。

  

路由器架构图
======

![](https://storage.googleapis.com/papyrus_images/798bb6200a39462c40d10c04dde44a4804313a2d087664c105723327041beb08.png)

上图清晰的反应了:Router功能模块,以及和其相互关联的各个组件

  

路由主要功能主要是围绕下面代码展开:

    export const makeRouter = async () => {
      const requestContext = createRequestContext("makeRouter");
      const methodContext = createMethodContext(makeRouter.name);
      try {
        // set up external, config based services
        const chainData = await getChainData();
        if (!chainData) {
          throw new Error("Could not get chain data");
        }
        context.chainData = chainData;
        context.config = await getConfig();
        context.wallet = context.config.mnemonic
          ? Wallet.fromMnemonic(context.config.mnemonic)
          : new Web3Signer(context.config.web3SignerUrl!);
        context.signerAddress = await context.wallet.getAddress();
        context.isRouterContract = context.config.routerContractAddress ? true : false;
        context.routerAddress = context.config.routerContractAddress || context.signerAddress;
        context.messaging = await initMessaging({
          signer: context.wallet,
          authUrl: context.config.authUrl,
          natsUrl: context.config.natsUrl,
          logger: context.logger,
        });
        // TODO: txserviceconfig log level
        context.txService = new TransactionService(
          context.logger.child({ module: "TransactionService" }, context.config.logLevel),
          context.config.chainConfig as any,
          context.wallet,
        );
        // 创建cache,主要是存储bid订单信息,内部有增加、删除、确认bid等功能函数
        context.cache = createRouterCache();
        
        // adapters
        //通过subgraph,获取链上数据
        context.contractReader = subgraphContractReader();
        //直接通过中继获取链上(合约TransactionManager)事件信息
        context.contractWriter = contractWriter();
        context.chainAssetSwapPoolMap = await getSwapPoolMap({
          txService: context.txService,
          isRouterContract: context.isRouterContract,
          swapPools: context.config.swapPools,
          routerAddress: context.routerAddress,
        });
        // bindings
        if (!context.config.diagnosticMode) {
        //代码里获取getActiveTransactions交易
          await bindContractReader();
        } else {
          logger.warn("Running router in diagnostic mode");
        }
        if (!context.config.cleanUpMode) {
        //订阅从messaging几类消息,拍卖,状态信息,metatx请求获取订阅消息
          await bindMessaging();
        } else {
          logger.warn("Running router in cleanup mode");
        }
        if (context.config.priceCacheMode) {
        //从链上获取资产价格存储在cachedPriceMap(根据chainid和assetId组合作为key去存储)
          await bindPrices();
        } else {
          logger.warn("Running router not in price cache mode");
        }
        //
        await bindFastify();
        await bindMetrics();
        logger.info("Router ready!");
      } catch (e) {
        console.error("Error starting router :(", e);
        process.exit();
      }
    };
    

  

subgraphContractReader() 这里读取很多函数,有些函数比较简单如获取资产余额等(getAssetBalances和getExpressiveAssetBalances区别是后者表现了某类资产详细信息

如供应量、锁定量等),主要有如下函数有getActiveTransactions,getTransactionForChain.

getActiveTransactions, 根据发送链交易检查接受链上交易看相互是否匹配,不同情况,需做不同处理,看起来是做了不同的状态标示便于后续处理

getTransactionForChain,在指定链上检索具有给定transactionId-user组合的交易(交易状态、中继费用、投标情况等信息)。

  

contractWriter() 监听TransactionManager合约三个事件,TransactionPrepared,TransactionCancelled,LiquidityRemoved(后续ts事件处理操作没太看明白)

bindContractReader()->getActiveTransactions()->handleActiveTransactions() 依次调用

handleActiveTransactions(transactions); 根据各交易状态继续处理,经过一系列校验,然后两类交易ReceiverFulfilled会继续fufill,,SenderPrepared会继续prepare,最后通过txservice发送交易到链上,其余状态会执行cancel取消交易,各种状态如下:

![](https://storage.googleapis.com/papyrus_images/ef63458d176ba2bfc2fe3c86ac3852a9e8ba89f50aec1541c014fb59e9d77d84.png)

 bindFastify()内部有一系列处理流动性功能相关服务,可增加、删除、移动路由器资产流动性等功能,还有处理active交易(内部调用了contractReader.getActiveTransactions()->handleActiveTransactions(activeTxs))

很高兴能和你交流技术、人生等各种话题:

twitter:[https://twitter.com/tylz\_cai](https://twitter.com/tylz_cai)

---

*Originally published on [Walker](https://paragraph.com/@walker-4/nxtp-router)*