测试已完成的 chainlink oracle 请求 ethers/hardhat 的最佳实践是什么?
What is best practice for for testing fulfilled chainlink oracle requests ethers/hardhat?
我在 rinkeby 上使用带以太币的 hardhat 来测试向本地 chainlink 节点发出获取请求的智能合约。我可以在节点仪表板上观察到请求已完成。
我正在努力编写等待确认第二个履行交易的测试。
我在 SmartContractKit/chainlink repo tests
中看到类似的测试
it("logs the data given to it by the oracle", async () => {
const tx = await oc.connect(roles.oracleNode).fulfillOracleRequest(...convertFufillParams(request, response));
const receipt = await tx.wait();
assert.equal(2, receipt?.logs?.length);
const log = receipt?.logs?.[1];
assert.equal(log?.topics[2], response);
});
我完全看不出这会等待完成的交易。在consumer.sol这个函数调用中有一个事件RequestFulfilled,也就是emit,但是这个测试好像没有在监听。
我发现的另一个示例 ocean protocol request test 通过创建请求 ID 的映射、访问器和测试轮询中的 while 循环来实现此目的,直到找到请求 ID。
it("create a request and send to Chainlink", async () => {
let tx = await ocean.createRequest(jobId, url, path, times);
request = h.decodeRunRequest(tx.receipt.rawLogs[3]);
console.log("request has been sent. request id :=" + request.id)
let data = 0
let timer = 0
while(data == 0){
data = await ocean.getRequestResult(request.id)
if(data != 0) {
console.log("Request is fulfilled. data := " + data)
}
wait(1000)
timer = timer + 1
console.log("waiting for " + timer + " second")
}
});
这是有道理的,我知道它是如何工作的。但是,当我认为必须有更优化的方法时,我想避免创建映射和访问器。
您想查看 hardhat-starter-kit 以查看使用 Chainlink/oracle API 响应的示例。
对于单元测试,您只想 mock 来自 Chainlink 节点的 API 响应。
对于集成测试(例如,在测试网上),您需要为 return 添加一些等待参数。在示例 hardhat-starter-kit 中,它只等待 x 秒,但您也可以编写测试代码来侦听事件以了解 oracle 何时响应。这确实使用事件来获取 requestId,但是,您实际上不必自己创建事件,因为 Chainlink 核心代码已经有了这个。
it('Should successfully make an external API request and get a result', async () => {
const transaction = await apiConsumer.requestVolumeData()
const tx_receipt = await transaction.wait()
const requestId = tx_receipt.events[0].topics[1]
//wait 30 secs for oracle to callback
await new Promise(resolve => setTimeout(resolve, 30000))
//Now check the result
const result = await apiConsumer.volume()
console.log("API Consumer Volume: ", new web3.utils.BN(result._hex).toString())
expect(new web3.utils.BN(result._hex)).to.be.a.bignumber.that.is.greaterThan(new web3.utils.BN(0))
})
我在 rinkeby 上使用带以太币的 hardhat 来测试向本地 chainlink 节点发出获取请求的智能合约。我可以在节点仪表板上观察到请求已完成。
我正在努力编写等待确认第二个履行交易的测试。
我在 SmartContractKit/chainlink repo tests
中看到类似的测试 it("logs the data given to it by the oracle", async () => {
const tx = await oc.connect(roles.oracleNode).fulfillOracleRequest(...convertFufillParams(request, response));
const receipt = await tx.wait();
assert.equal(2, receipt?.logs?.length);
const log = receipt?.logs?.[1];
assert.equal(log?.topics[2], response);
});
我完全看不出这会等待完成的交易。在consumer.sol这个函数调用中有一个事件RequestFulfilled,也就是emit,但是这个测试好像没有在监听。
我发现的另一个示例 ocean protocol request test 通过创建请求 ID 的映射、访问器和测试轮询中的 while 循环来实现此目的,直到找到请求 ID。
it("create a request and send to Chainlink", async () => {
let tx = await ocean.createRequest(jobId, url, path, times);
request = h.decodeRunRequest(tx.receipt.rawLogs[3]);
console.log("request has been sent. request id :=" + request.id)
let data = 0
let timer = 0
while(data == 0){
data = await ocean.getRequestResult(request.id)
if(data != 0) {
console.log("Request is fulfilled. data := " + data)
}
wait(1000)
timer = timer + 1
console.log("waiting for " + timer + " second")
}
});
这是有道理的,我知道它是如何工作的。但是,当我认为必须有更优化的方法时,我想避免创建映射和访问器。
您想查看 hardhat-starter-kit 以查看使用 Chainlink/oracle API 响应的示例。
对于单元测试,您只想 mock 来自 Chainlink 节点的 API 响应。
对于集成测试(例如,在测试网上),您需要为 return 添加一些等待参数。在示例 hardhat-starter-kit 中,它只等待 x 秒,但您也可以编写测试代码来侦听事件以了解 oracle 何时响应。这确实使用事件来获取 requestId,但是,您实际上不必自己创建事件,因为 Chainlink 核心代码已经有了这个。
it('Should successfully make an external API request and get a result', async () => {
const transaction = await apiConsumer.requestVolumeData()
const tx_receipt = await transaction.wait()
const requestId = tx_receipt.events[0].topics[1]
//wait 30 secs for oracle to callback
await new Promise(resolve => setTimeout(resolve, 30000))
//Now check the result
const result = await apiConsumer.volume()
console.log("API Consumer Volume: ", new web3.utils.BN(result._hex).toString())
expect(new web3.utils.BN(result._hex)).to.be.a.bignumber.that.is.greaterThan(new web3.utils.BN(0))
})