在Moonbeam上使用The Graph¶
概览¶
索引协议可以更有效地组织信息，便于应用程序访问及使用。例如，Google就是通过索引整个互联网的信息，快速为搜索者提供所需信息。
The Graph是一个去中心化、开源的索引协议，可以为以太坊等网络查询信息进行服务。简而言之，The Graph提供了一种更有效的、储存智能合约发出的事件消息数据的方式，让其他项目或DApp都可以便捷地利用这些数据。
此外，开发人员还可以创建相应的API（称为Subgraph）。用户或其他开发人员可以用Subgraph来查询与一系列智能合约相关的数据，数据将通过标准化GraphQL API进行获取。您可以访问此文档了解更多关于The Graph协议的信息。
因为Moonbeam支持以太坊跟踪模块，The Graph可以索引Moonbeam上的区块链数据。本教程将介绍如何在Moonbase Alpha上为彩票合约创建简单的subgraph。本教程也可以在Moonbeam和Moonriver网络上使用。
此处提供的信息仅供参考，由第三方提供。 Moonbeam文档网站(https://docs.moonbeam.network/)上列出和描述的任何项目与Moonbeam立场无关。
快速开始¶
如果您已经熟悉使用The Graph，并且想很快开始在Moonbeam上面开发，您可以在Subgraph manifest (subgraph.yaml)中配置以下网络：
dataSources:
network: moonbeam
dataSources:
network: moonriver
dataSources:
network: mbase
dataSources:
network: mbase
查看先决条件¶
在Moonbase Alpha上使用The Graph有两种方式：
- 在Moonbase Alpha上运行Graph节点，并将Subgraph指向这一节点。具体操作步骤请见此教程（也可适用于Moonbeam和Moonriver）
- 通过Graph Explorer网站将您的Subgraph指向The Graph API。为此，您需要创建账户，并获取访问代币
彩票合约¶
我们将使用一个简单的彩票合约作为示例。您可以通过MoonLotto Repo找到其Solidity文档。
合约玩家可以通过这个合约为自己购买彩票，也可以送给另外一位用户。一个小时后，如果参与者达到了十位，并且下一位玩家进入后，就会触发某一函数决定中奖者。所有储存在合约中的资金将发送到中奖者的地址上，然后游戏进入下一轮。
该合约的主要函数有：
- joinLottery —— 没有输入值。进入本轮抽奖的函数，发送到合约的值（代币数量）需要与彩票价格相等
- giftTicket —— 一个输入值：彩票接收者的地址。与
joinLottery函数相似，但彩票持有者可以和彩票购买者为不同的地址 - enterLottery —— 一个输入值：彩票持有者的地址。为内部函数，处理彩票逻辑。一个小时后，若参与者达到十人或更多，即调用
pickWinner函数 - pickWinner —— 没有输入值。为内部函数，通过伪随机数发生器（仅作演示用途）选择中奖者。该函数负责处理资金转移和重新设定下一轮彩票变量的逻辑
彩票合约事件¶
The Graph使用彩票合约发出的事件消息进行数据索引。彩票合约仅发出两种事件消息：
- PlayerJoined —— 在
enterLottery函数内，提供最后一个加入玩家相关的信息，例如玩家地址、本轮轮次、彩票是否已经送出，以及本轮的奖金数额等 - LotteryResult —在
pickWinner函数内，提供进行中轮次抽奖的相关信息，例如中奖者地址、本轮轮次、中奖者持有的奖券是否为赠予、彩票奖金数额大小以及抽奖时间戳等
创建Subgraph¶
本章节将介绍创建Subgraph的流程。彩票Subgraph的GitHub代码库有您所需的所有信息。此外，代码库还包含了该彩票合约以及Hardhat配置文件和部署脚本。如果您想了解更多关于配置文件和使用Hardhat部署智能合约，可以查看Hardhat集成教程。
第一步，克隆代码库并安装附带程序：
git clone https://github.com/PureStake/moonlotto-subgraph \
&& cd moonlotto-subgraph && yarn
运行以下代码为The Graph创建TypeScript类型：
npx graph codegen --output-dir src/types/
注意事项
创建类型需要您在subgraph.yaml文档中指定ABI文档。在本示例的代码库中已经存在该文档，但在一般操作过程中，这是在编译好合约之后才获得的。
codegen命令也可使用yarn codegen执行。
在本示例中，合约的部署地址为0x44ddD2EC5BE2A7f3e4A465C21600bE8df644093f。Moonloto代码库中的README.md文档也有合约编译与部署的必要步骤指引。
Subgraph核心架构¶
一般而言，Subgraph定义了The Graph将从区块链上索引的数据以及其存储方式。Subgraph一般含有以下文档：
- subgraph.yaml —— 包含着Subgraph manifest文件的YAML文档，也就是与Subgraph索引的智能合约相关的信息
- schema.graphql —— GraphQL schema文档，定义正在创建的Subgraph的数据储存及其架构。通过GraphQL interface definition schema){target=_blank}编写。
- AssemblyScript mappings —— TypeScript中的代码（接下来编译为AssemblyScript，用于将合约中的事件数据翻译成schema中定义的实体
创建Subgraph需要对文档进行修改，文档的修改没有特定顺序。
Schema.graphql¶
在对schema.graphql进行修改之前，需要先列明要从合约事件中抽取的数据。需要根据DApp本身的要求对schema进行定义。本示例中虽然没有与彩票相关的DApp，但我们定义了四个实体：
- Round —— 一轮彩票抽奖活动。它将储存以下索引：轮次、发出奖金、轮次开始的时间戳、中奖者、结果出炉的时间以及参与彩票（从
Ticket实体中获取）等相关信息 - Player —— 参加了至少一轮的玩家。它将存储玩家地址和所有参与彩票（从
Ticket实体中获取）的相关信息 - Ticket —— 指的是参与一轮彩票抽奖活动的奖券。它将存储以下相关信息：奖券是否为赠予、持有者地址、奖券生效的轮次，以及奖券是否为最终中奖等
简而言之，schema.graphql函数的显示应与以下代码段相似：
type Round @entity {
id: ID!
index: BigInt!
prize: BigInt!
timestampInit: BigInt!
timestampEnd: BigInt
tickets: [Ticket!] @derivedFrom(field: "round")
}
type Player @entity {
id: ID!
address: Bytes!
tickets: [Ticket!] @derivedFrom(field: "player")
}
type Ticket @entity {
id: ID!
isGifted: Boolean!
player: Player!
round: Round!
isWinner: Boolean!
}
Subgraph清单文件¶
subgraph.yaml文档（或Subgraph的清单文件）包含与所索引智能合约相关的信息，其中包括映射所需的数据。数据将由Graph节点储存，应用程序可请求获取。
subgraph.yaml文档中一些重要参数有：
- repository —— subgraph的Github代码库
- schema/file ——
schema.graphql文档的位置 - dataSources/name —— Subgraph的名称
- network —— 网络名称。对于所有在Moonbase Alpha上部署的Subgraph，这一值必须设置为
mbase。Moonbeam和 Moonriver可分别使用moonbeam和moonriver标签 - dataSources/source/address —— 利息合约地址
- dataSources/source/abi —— 合约界面在以
codegen命令创建的types文件夹中储存的位置 - dataSources/source/startBlock —— 索引开始的第一个区块。在理想的情况下，这个数值和合约创建区块接近。在Moonscan上提供合约地址即可获取这一信息。在本示例中，合约的创建区块为
132605 - dataSources/mapping/file —— 映射文档的位置
- dataSources/mapping/entities —— 在
schema.graphql文档中实体的定义 - dataSources/abis/name —— 合约界面在
types/dataSources/name文档中的储存位置 - dataSources/abis/file —— 带有合约ABI的
.json文档的储存位置 - dataSources/eventHandlers —— 不定义任何数值，但在这一章节指的是The Graph即将索引的所有事件
- dataSources/eventHandlers/event —— 即将被合约跟踪的事件的结构。需要提供事件名称及其变量类型
- dataSources/eventHandlers/handler —— 处理事件数据的
mapping.ts文档中的函数名称
简而言之，subgraph.yaml函数的显示应与以下代码段相似：
specVersion: 0.0.4
description: Moonbeam lottery subgraph tutorial
repository: https://github.com/PureStake/moonlotto-subgraph
schema:
file: ./schema.graphql
dataSources:
- kind: ethereum/contract
name: MoonLotto
network: mbase
source:
address: '0x44ddD2EC5BE2A7f3e4A465C21600bE8df644093f'
abi: MoonLotto
startBlock: 132605
mapping:
kind: ethereum/events
apiVersion: 0.0.6
language: wasm/assemblyscript
file: ./src/mapping.ts
entities:
- Player
- Round
- Ticket
- Winner
abis:
- name: MoonLotto
file: ./artifacts/contracts/MoonLotto.sol/MoonLotto.json
eventHandlers:
- event: PlayerJoined(uint256,address,uint256,bool,uint256)
handler: handlePlayerJoined
- event: LotteryResult(uint256,address,uint256,bool,uint256,uint256)
handler: handleLotteryResult
映射¶
映射文档是将区块链数据转换为在schema文档中定义的实体。subgraph.yaml文档中的每一个事件处理函数都需要在映射中有一个后续函数。
彩票合约示例中所用的映射文档可以在Moonlotto Github Repository中找到。
一般而言，处理函数的工作流程是：加载事件数据，检查是否已存在，以最优方式排列数据，并进行保存。例如， PlayerJoined事件的处理函数如下：
export function handlePlayerJoined(event: PlayerJoined): void {
// ID for the round:
// round number
let roundId = event.params.round.toString();
// try to load Round from a previous player
let round = Round.load(roundId);
// if round doesn't exists, it's the first player in the round -> create round
if (round == null) {
round = new Round(roundId);
round.timestampInit = event.block.timestamp;
}
round.index = event.params.round;
round.prize = event.params.prizeAmount;
round.save();
// ID for the player:
// issuer address
let playerId = event.params.player.toHex();
// try to load Player from previous rounds
let player = Player.load(playerId);
// if player doesn't exists, create it
if (player == null) {
player = new Player(playerId);
}
player.address = event.params.player;
player.save();
// ID for the ticket (round - player_address - ticket_index_round):
// `${round_number}-${player_address}-${ticket_index_per_round}`
let nextTicketIndex = event.params.ticketIndex.toString();
let ticketId = `${roundId}-${playerId}-${nextTicketIndex}`;
let ticket = new Ticket(ticketId);
ticket.round = roundId;
ticket.player = playerId;
ticket.isGifted = event.params.isGifted;
ticket.isWinner = false;
ticket.save();
}
部署Subgraph¶
部署Subgraph有几种方式。本教程会介绍使用托管式服务部署，及使用本地节点部署。
使用托管式服务¶
如果您准备使用The Graph API（托管式服务），您需要进行以下步骤：
- 首先您需要有Github账户，创建Graph Explorer账户
- 进入主面板，并输入访问代币
- 在Graph Explorer网页点击Add Subgraph按钮，创建Subgraph。输入Subgraph名称。
然后在命令行中添加access token和部署Subgraph
npx graph auth --product hosted-service <access-token>
npx graph deploy --product hosted-service <username>/<subgraph-name>
注意事项
以上步骤均可在此链接中找到。
使用本地Graph节点¶
如果您使用的是本地Graph节点，可以通过执行以下代码创建Subgraph：
npx graph create <username>/<subgraph-name> --node <graph-node>
在以上代码中：
- username —— 即将创建的Subgraph相关的用户名
- subgraphName —— Subgraph名称
- graph-node —— 使用托管式服务的URL；一般而言，本地Graph节点是
http://127.0.0.1:8020
一旦创建完成后即可运行以下命令，用与此前相同的参数进行Subgraph部署：
npx graph deploy <username>/<subgraphName> \
--ipfs <ipfs-url> \
--node <graph-node> \
--access-token <access-token>
在以上命令中：
- username —— 创建Subgraph时所使用的用户名
- subraphName —— 创建Subgraph时所定义的Subgraph名称
- ipfs-url —— IPFS 的URL；如果使用的是The Graph API，可以使用
https://api.thegraph.com/ipfs/地址。如果运行的是本地Graph节点，默认值为http://localhost:5001 - graph-node —— 所使用的托管式服务的URL；如果使用的是The Graph API，可以使用
https://api.thegraph.com/deploy/。如果运行的是本地Graph节点，默认值为http://localhost:8020 - access-token —— 使用The Graph API的访问代币；如果使用的是本地Graph节点，那么这一参数为非必要参数
上述命令的日志应与以下内容相似：
现在各种DApp均可使用Subgraph终端获取由The Graph协议索引的数据。
| Created: April 28, 2021