Chainlink对接Cosmos区块链

区块链预言机（Oracle）是一种第三方去中心化数据服务，可以为智能合约和区块链提供链外数据。预言机在封闭、确定性的区块链系统与现实世界之间搭建了一座桥梁。

区块链开发教程链接：以太坊 | 比特币 | EOS | Tendermint | Hyperledger Fabric | Omni/USDT | Ripple | Tron

区块链预言机的主要问题是，它不是区块链共识机制的组成部分，因此没有区块链的公共基础设施提供的基本安全保证。Chainlink是目前的行业标准，提供了一个鲁棒的解决方案。

Cosmos是构建多资产的、PoS共识的自定义区块链的一个出色的开源框架。每个Cosmos程序都运行在PoS共识引擎Tendermint Core之上。

自定义区块链意味着Cosmos没有采用以太坊那样的虚拟机区块链范式，即使用状态机运行智能合约，虽然你也可以利用Ethermint让自定义区块链支持智能合约。

Chainlink目前广泛地用于以太坊智能合约，整个过程大致如下：

你的智能合约与预言机合约智能合约进行交易，该合约会触发一个事件
链下的chainlink节点通过订阅预言机事件就可以在交易时得到通知。
当合约事件被记录下来时，它会执行一些链下的操作，并调用预言机合约函数并传入所执行工作的结果。
最后，预言机合约会调用你的合约上的回调方法并传入收到的链下数据。

从这个描述中，我们可以清楚地看到，智能合约是整个过程中的关键。你的智能合约不与任何链下API 或资源通信 - 仅与另一个智能合约交互。

那么，基于cosmos的自定义区块链，在没有智能合约的情况下，如何实现预言机呢？老实说我不确定。我知道的唯一类似的项目，是Kava区块链在其系统中集成了Chainlink价格预言机。他们使用一个可以发布链上价格数据的预言机白名单。当Kava平台用户想要价格数据时，他们可以查询保存的所有价格数据或预言机发布的所有价格的中间价。

据我所知，Chainlink也在尝试建立一个模块，完成类似的功能。

在我不得不考虑这个问题的一小段时间里，我想出了两个解决方案。我相信有更好的方法来解决这个技术问题，所以请随时使本文的评论部分成为集思广益的创意中心。

1、解决方案 1

一种解决方案是，预言机运营商在自定义区块链上创建一个钱包。然后，它使用 WebSocket来监听涉及该地址的交易。当它记录到此类交易时，就执行一些链下操作，一旦完成，就将交易发送到上一笔交易的来源地址。

它将允许按需启动预言机请求，预言机将能够执行任何工作——而不仅仅是发布价格数据。

目前，这可以利用Chainlink预言机完成。预言机运营商可以在区块链上注册钱包，并使用外部启动器和外部适配器提供服务。

2、解决方案 2

第二个更可靠的选择是在Cosmos上创建一个预言机区块链，这将作为Chainlink节点和Cosmos 生态系统之间的通信点。它将Chainlink的所有 API 暴露在用Cosmos构建的每一个区块链中。我们甚至可以在预言机区块链中构建安全机制，以验证链外数据的完整性。

听起来对Cosmos生态系统来说这是一件非常有价值的事情，那么应该怎么实现？

预言机区块链使用前面提出的第一个解决方案，这意味着预言机将使用WebSockets订阅来自其他Cosmos 区块链上来自预言机区块链上的交易事件。这些事件包含的信息，允许预言机节点确定它必须执行什么工作。成功执行后，从预言机区块链向客户端区块链提交一个交易。

最近推出的链间通信协议（IBC）使上述方案变得可行。简言之，IBC是一个允许Cosmos区块链之间端到端、可靠和经过验证的通信的协议。任何Cosmos区块链都能够执行与预言机区块链通信的协议。

显然，我不会在本文中实施这第二个解决方案，因为它需要大量的规划、架构和编程，并且会让你失去继续读下去的兴趣。但是，从长远来看，我确实计划将此成为现实，因此，如果你有兴趣，请留意我的更新或与我保持联系。

我们将在以下段落中实施第一个解决方案：创建一个Cosmos区块链，并使用Chainlink从互联网上获取随机报价。

为了保持这篇文章的合理长度，我们将代码编写的尽可能简洁。不过还是有相当多的步骤和代码需要我们完成。我知道这很复杂，但这将是值得的。

我们必须：

在Cosmos上创建一个简单但有效的区块链，能够存储并检索随机报价。虽然除了作为示例外，它不是很有用。
创建Chainlink外部启动器，该启动器将监听区块链上的交易并触发预言机。
创建Chainlink外部适配器，该适配器将从公共 API 中获取随机报价并将其发布回我们的区块链。

现在是时候卷起袖子，戴上安全帽去上班了！

3、创建区块链

我实现了一个最小功能的区块链，用于预言机报价请求和报价创建。下面，我将展示如何从头开始的基本知识，但不会解释如何构建整个示例应用程序，因为这不是本文的重点。

如果你想直接上手代码，可以点击此处查看 GitHub仓库：

让我们开始创建Cosmos区块链。最简单的方法是使用starport工具，你可以GitHub安装。

打开终端运行：

1	starport app github.com/lajosdeme/linktest

上述命令将创建一个名为”linktest”的cosmos应用程序。你可以进入linktest文件夹并运行starport serve以生成和运行这个区块链。运行结果类似下面这样：

这个区块链目前还没有太多功能。基本上，它所做的就是运行 Tendermint 共识引擎，并提供最小功能，在地址之间交易。我们下面就要实现业务逻辑了。

从上面的终端输出，可以看到，我们可以在端口26657与tendermint互动。共识引擎会发出不同的事件，我们可以通过 WebSocket 订阅它们。让我们用命令行和postman说明一下这其中的工作原理，然后我们可以继续实现Chainlink外部启动器。

打开Postman，然后单击File ->New -> WebSocket请求。在顶部输入ws://localhost:25657并单击Connect。现在，让我们订阅所有交易事件。在消息字段中粘贴以下信息，然后单击Send：

{“jsonrpc”: “2.0”,“method”: “subscribe”,“id”: 0,“params”: {“query”:”tm.event = ‘Tx’”}
}

就是这样。我们用WebSocket连接共识引擎。现在是时候利用一个交易来测试一切正常。以下是我们需要的命令：

1	linktestd tx bank send <SENDER_ADDRESS> <RECIPIENT_ADDRESS> <AMOUNT>

例如，对于我来说，带入实际参数后是这样：

linktestd tx bank send \cosmos1fztn5xte9c0gqfhjrf5a8vuqz9d2p6wf90ez72 \cosmos1f0g0m92f6s405vww6n0kgjwcqfxyf8fjnzyuff \10token

让我们回到Postman那里，在那里我们可以看到交易已被记录。我们的外部发起人将做同样的事情，并触发预言机节点的工作。

4、创建Chainlink外部启动器

外部启动器是使Chainlink节点与区块链无关的秘密武器，即任何区块链都可用。

外部发起人允许根据某些外部条件在节点中启动作业。创建和添加外部启动器到Chainlink节点的能力实现了跨链兼容性。 - Chainlink文档

虽然您可以按照代码执行，但如果你也希望能够运行并测试代码，则应在本地或云中设置Chainlink节点。要设置本地节点，请按照此教程执行。一旦你有了自己的节点，打开.env文件，并确保它包括以下内容，以便禁用以太坊并启用外部启动器：

1
2
3

ETH_CHAIN_ID=0
ETH_DISABLED=true
FEATURE_EXTERNAL_INITIATORS=true

现在是时候登录到节点的管理员设置，以便添加发起人：

1	chainlink admin login

现在可以注册它：

1	chainlink initiators create linktest http://localhost:6688/jobs

这将创建一个名为linktest并使用默认端点访问Chainlink节点作业的启动器。输出将是这样的：

复制并保存这些值，因为我们下面还需要它们。

现在使用命令chainlink node start启动你的Chainlink节点，并前往浏览器http://localhost:6688。登录并选择顶部导航栏中的”Bridges”。然后单击”New Bridge”，输入名称（我的是link-ea）和URL（http://localhost:3000）。可以暂时将最低付款和确认数设置为0。最后单击”Create Bridge”。

外部适配器通过创建桥类型添加到Chainlink节点中。桥定义了外部适配器的任务名称和网址。当收到不是核心适配器之一的任务类型时，节点将搜索带有该名称的桥类型，将桥用于外部适配器。 - Chainlink文档

现在前往顶部栏中的”Jobs”，选择”New Job”，并将此粘贴到”Job Spec”中：

{“name”: “LINK-EA”,“initiators”: [{“type”: “external”,“params”: {“name”: “linktest”,“body”: {“endpoint”: “random”}}}],“tasks”: [{“type”: “link-ea”}]
}

这告诉Chainlink，我们希望运行的工作，由名为linktest的外部发起人触发，并且应该调用link-ea桥。创建作业后，如果打开它，你将看到名称下的 ID。我们还需要那个ID。

我们要做的最后一件事就是为我们的外部适配器在本地建立一个Postgres数据库。如果你不知道如何做到这一点，可以查阅Chainlink节点教程中的相关解释。

现在，我们可以创建实际的外部启动器。这只是一个简单的WebSocket服务器，你可以在任何编程语言中构建它，但我会在Go中构建它，因为我真的很喜欢该语言。

首先，创建一个名为”external-initiator”的项目，并在项目根源中定义一个.env文件。现在，我们需要将保存的值添加到改文件中：

EI_DATABASEURL=<external initiator postgres db url>
EI_CHAINLINKURL=localhost:6688
EI_IC_ACCESSKEY=<ACCESSKEY saved above>
EI_IC_SECRET=<SECRET saved above>
EI_CI_ACCESSKEY=<OUTGOINGTOKEN saved above>
EI_CI_SECRET=<OUTGOINGSECRET saved above>
JOB_ID=<Chainlink Job ID>

现在让我们来看看WebSocket客户端的代码：

package mainimport ("encoding/json""log""os""github.com/gorilla/websocket"
)type WebSocket struct {Endpoint string
}type wsConn struct {connection *websocket.Connopen       bool
}func (ws WebSocket) Connect() wsConn {c, _, err := websocket.DefaultDialer.Dial(ws.Endpoint, nil)if err != nil {log.Fatal("Error dialing: ", err)}con := wsConn{connection: c,open:       true,}return con
}func (con wsConn) Subscribe(message string) {defer con.connection.Close()interrupt := make(chan os.Signal, 1)done := make(chan struct{})err := con.connection.WriteMessage(websocket.TextMessage, []byte(message))if err != nil {con.open = falselog.Fatal("Error subscibing to tx: ", err)}go func() {defer close(done)for {_, message, err := con.connection.ReadMessage()if err != nil {log.Println("Read error: ", err)}var txRes TxResultjson.Unmarshal([]byte(message), &txRes)var requesterAddr, event stringtxRes.convert(&requesterAddr, &event)if event == "RequestQuote" {startJob(requesterAddr)}}}()for {select {case <-done:returncase <-interrupt:log.Println("Interrupting")err := con.connection.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, ""))con.open = falseif err != nil {log.Println("Close error:", err)return}return}}
}

这为外部发起人执行了大部分工作。还有其他一些文件，所以你应该看看仓库代码，以建立整体概念。

在这里，我们有一个WebSocket结构，它保存访问端接点，还有一个wsConn结构，代表连接。

我们在WebSocket上定义了一个Connect方法，其作用是建立一个连接。

我们在wsConn上定义了subscribe方法，用来订阅交易事件。当它记录到一个事件时，会获取到请求者的地址并检查事件类型是否为RequestQuote。我们只需要这种类型的事件。然后，它调用startJob方法，这将触发Chainlink 预言机的工作。

现在我们有了一个功能正常的区块链，并且正顺利地将预言机连接到它。伟大的工作！让我们继续！

5、创建Chainlink外部适配器

外部适配器是能够用我们的预言机调用任何外部API 的关键。我们将在 JavaScript 中构建适配器，因为一方面，这几乎是标准方法（尽管你可以同样轻松地使用 Go 或 Python）。另一方面，以后我们将希望能够签署和广播交易到我们的区块链，Cosmos可以为我们自动生成所需的JavaScript代码。

外部适配器是Chainlink如何实现自定义计算和专业 API 的简单集成。外部适配器是Chainlink节点的核心通过其API与简单的JSON规范进行通信的服务。 – Chainlink文档

首先创建一个文件夹link-ea并执行npm init。我们将使用一些包，因此让我们安装：

@chainlink/external-adapter：用于创建外部启动器的辅助包。
@cosmjs/proto-signing和@cosmjs/stargate：这两个将帮助我们与Cosmos区块链互动。
express和dotenv：这两个包和layda gaga一样出名。他们将帮助处理网络和环境变量。

还记得我告诉过你保存第一次运行区块链时生成的地址的助记词吗？现在我们需要其中之一。创建一个.env文件，并复制MNEMONIC和ORACLE_ADDRESS。如果你没有保存它，只需使用starport serve --reset-once生成新的帐户。

现在是时候生成与区块链交互的代码了。在区块链文件夹中运行以下命令：

1	starport serve --rebuild-proto-once

在此之后，你应该会看到./vue/src/store路径上名为generated的文件夹。这包含生成的代码。我们只需要其中一些文件，也必须做一些轻微的修改，以便能够在我们的应用程序中正常工作。完整代码可以查看这里

一旦我们有了这个，就可以设置签署和广播交易的API：

const {DirectSecp256k1HdWallet} = require('@cosmjs/proto-signing')
const {assertIsBroadcastTxSuccess} = require('@cosmjs/stargate')const {MsgCreateQuote} = require('../cosmos/tx')
const { txClient } = require('../cosmos/client')require('dotenv').config()class LinkAPI {constructor() {this.main = {//Create, sign and broadcast a quote txsignAndBroadcast: async (oracle, requester, quote) => {const wallet = await DirectSecp256k1HdWallet.fromMnemonic(process.env.MNEMONIC);const client = await txClient(wallet)const msg = MsgCreateQuote.fromJSON({creator: oracle,requester: requester,oracle: oracle,text: quote})const msgAny = client.msgCreateQuote(msg)const result = await client.signAndBroadcast([msgAny])assertIsBroadcastTxSuccess(result)console.log("Result: ", result)}}}
}
module.exports = LinkAPI

在上面，我们需要一些东西：

DirectSecp256k1HdWallet将利用助记词生成一个钱包
assertIsBroadcastTxSuccess将帮助我们验证已签署和广播的交易。
MsgCreateQuote是为我们生成的一个对象。它提供了创建和编码自定义事务消息的接口和方法。
txClient将用于签署和广播交易。

我们创建一个具有具有singAndBroadcast方法和main属性的API类。我们的 API 目前仅包含此功能，但此设计可方便将来更新它。

signAndBroadcast方法包括预言机地址、请求报价的帐户地址和报价文本。它利用我们的助记词（存储在文件中）创建一个钱包，并使用该钱包创建交易客户端（txClient）。然后，我们使用我们之前引入的MsgCreateQuote对象的fromJSON方法，并传入到txClient创建消息的方法。之后我们调用signAndBroadcast广播消息，并用assertIsBroadcastTxSuccess来检查一切是否顺利。

除此之外，我们有两个重要的文件（我不会在这里粘贴他们的代码）。一个被称为index.js，它定义了一个createRequest函数，将验证来自我们的外部发起人的API请求的主体，并生成第三方API请求。

另一个是app.js，它负责启动我们的服务器然后调用createRequest。

6、把一切放在一起

我们基本完成了！现在是时候看看是否做的每件事都是正确的。让我们逐一启动所有的流程：

chainlink node start：运行链链接节点。
starport serve：运行宇宙区块链。
在外部启动器文件夹中运行go build，然后运行external-initiator
node app.js启动外部适配器。

现在向预言机体提交报价请求：

1
2
3

linktestd tx linktest request-quote \cosmos1g7gw9jet6czu2m854v0ce3n3us8g8wyjkmdm3n \--from alice

用你自己的预言机地址替换cosmos1g...行，并从任何你喜欢的帐户发送。在这里，我使用默认情况下创建的帐户之一作为请求者，另一个用作预言机。

现在，您应该观察每个终端窗口中的日志，看到各自流程正在开展的工作。

当一切都完成后，你可以使用linktest q linktest list-quote查询报价。你应该看到你的预言机发布在链上的第一个随机报价。

原文链接：Connect a Chainlink Oracle to a Cosmos Blockchain