/
event.go
377 lines (358 loc) · 11.6 KB
/
event.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
// Copyright Fuzamei Corp. 2018 All Rights Reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
package types
// event
const (
EventTx = 1
EventGetBlocks = 2
EventBlocks = 3
EventGetBlockHeight = 4
EventReplyBlockHeight = 5
EventQueryTx = 6
EventTransactionDetail = 7
EventReply = 8
EventTxBroadcast = 9
EventPeerInfo = 10
EventTxList = 11
EventReplyTxList = 12
EventAddBlock = 13
EventBlockBroadcast = 14
EventFetchBlocks = 15
EventAddBlocks = 16
EventTxHashList = 17
EventTxHashListReply = 18
EventGetHeaders = 19
EventHeaders = 20
EventGetMempoolSize = 21
EventMempoolSize = 22
EventStoreGet = 23
EventStoreSet = 24
EventStoreGetReply = 25
EventStoreSetReply = 26
EventReceipts = 27
EventExecTxList = 28
EventPeerList = 29
EventGetLastHeader = 30
EventHeader = 31
EventAddBlockDetail = 32
EventGetMempool = 33
EventGetTransactionByAddr = 34
EventGetTransactionByHash = 35
EventReplyTxInfo = 36
EventWalletAccountList = 38
EventWalletAccount = 40
EventWalletExecutor = 42
EventStoreDel = 47
EventReplyHashes = 49
EventTransactionDetails = 53
EventBroadcastAddBlock = 54
EventGetBlockOverview = 55
EventGetAddrOverview = 56
EventReplyBlockOverview = 57
EventReplyAddrOverview = 58
EventGetBlockHash = 59
EventBlockHash = 60
EventGetLastMempool = 61
EventMinerStart = 63
EventMinerStop = 64
EventWalletTickets = 65
EventStoreMemSet = 66
EventStoreRollback = 67
EventStoreCommit = 68
EventCheckBlock = 69
//seed
EventReplyGenSeed = 71
EventReplyGetSeed = 74
EventDelBlock = 75
//local store
EventLocalGet = 76
EventLocalReplyValue = 77
EventLocalList = 78
EventLocalSet = 79
EventCheckTx = 81
EventReceiptCheckTx = 82
EventReplyQuery = 84
EventSubscribePush = 85
EventFetchBlockHeaders = 86
EventAddBlockHeaders = 87
EventReplyWalletStatus = 89
EventGetLastBlock = 90
EventBlock = 91
EventGetTicketCount = 92
EventReplyGetTicketCount = 93
EventReplyPrivkey = 95
EventIsSync = 96
EventReplyIsSync = 97
EventCloseTickets = 98
EventGetAddrTxs = 99
EventReplyAddrTxs = 100
EventIsNtpClockSync = 101
EventReplyIsNtpClockSync = 102
EventDelTxList = 103
EventStoreGetTotalCoins = 104
EventGetTotalCoinsReply = 105
EventQueryTotalFee = 106
EventReplySignRawTx = 108
EventSyncBlock = 109
EventGetNetInfo = 110
EventReplyNetInfo = 111
EventReplyFatalFailure = 114
EventBindMiner = 115
EventReplyBindMiner = 116
EventDecodeRawTx = 117
EventReplyDecodeRawTx = 118
EventGetLastBlockSequence = 119
EventReplyLastBlockSequence = 120
EventGetBlockSequences = 121
EventReplyBlockSequences = 122
EventGetBlockByHashes = 123
EventReplyBlockDetailsBySeqs = 124
EventDelParaChainBlockDetail = 125
EventAddParaChainBlockDetail = 126
EventGetSeqByHash = 127
EventLocalPrefixCount = 128
EventStoreList = 130
EventStoreListReply = 131
EventListPushes = 132
EventGetPushLastNum = 133
EventGetBlockBySeq = 134
EventLocalBegin = 135
EventLocalCommit = 136
EventLocalRollback = 137
EventLocalNew = 138
EventLocalClose = 139
//mempool
EventGetProperFee = 140
EventReplyProperFee = 141
EventReExecBlock = 142
EventTxListByHash = 143
//exec
EventBlockChainQuery = 212
EventConsensusQuery = 213
EventUpgrade = 214
// BlockChain 接收的事件
EventGetLastBlockMainSequence = 300
EventReplyLastBlockMainSequence = 301
EventGetMainSeqByHash = 302
EventReplyMainSeqByHash = 303
//其他模块读写blockchain db事件
EventSetValueByKey = 304
EventGetValueByKey = 305
//通过平行链title获取平行链的交易
EventGetParaTxByTitle = 306
EventReplyParaTxByTitle = 307
//获取拥有此title交易的区块高度
EventGetHeightByTitle = 308
EventReplyHeightByTitle = 309
//通过区块高度列表+title获取平行链交易
EventGetParaTxByTitleAndHeight = 310
//比较当前区块和新广播的区块最优区块
EventCmpBestBlock = 311
EventReplySubscribePush = 312
// 通知其它节点进行数据归档存储
EventNotifyStoreChunk = 313
// 获取chunkBlock数据
EventGetChunkBlock = 314
// 添加addChunkBlock
EventAddChunkBlock = 315
// 获取chunkBody数据
EventGetChunkBlockBody = 316
// 获取ChunkRecord
EventGetChunkRecord = 317
// 添加ChunkRecord
EventAddChunkRecord = 318
//p2p 其他接收事件
EventSubTopic = 350
EventPubTopicMsg = 351
EventFetchTopics = 352
EventRemoveTopic = 353
EventReceiveSubData = 355
EventNetProtocols = 356
//检测mempool是否存在该交易
EventCheckTxsExist = 357
//delete para blocks
EventDeleteParaBlocks = 358
//添加延时交易
EventAddDelayTx = 359
//添加节点到黑名单
EventAddBlacklist = 360
//删除节点中的黑名单
EventDelBlacklist = 361
//获取黑名单列表
EventShowBlacklist = 362
// 连接指定的节点
EventDialPeer = 363
//断开指定的节点
EventClosePeer = 364
EventPushBlock = 365
EventPushBlockHeader = 366
EventPushTxReceipt = 367
EventPushTxResult = 368
EventPushEVM = 369
)
var eventName = map[int]string{
1: "EventTx",
2: "EventGetBlocks",
3: "EventBlocks",
4: "EventGetBlockHeight",
5: "EventReplyBlockHeight",
6: "EventQueryTx",
7: "EventTransactionDetail",
8: "EventReply",
9: "EventTxBroadcast",
10: "EventPeerInfo",
11: "EventTxList",
12: "EventReplyTxList",
13: "EventAddBlock",
14: "EventBlockBroadcast",
15: "EventFetchBlocks",
16: "EventAddBlocks",
17: "EventTxHashList",
18: "EventTxHashListReply",
19: "EventGetHeaders",
20: "EventHeaders",
21: "EventGetMempoolSize",
22: "EventMempoolSize",
23: "EventStoreGet",
24: "EventStoreSet",
25: "EventStoreGetReply",
26: "EventStoreSetReply",
27: "EventReceipts",
28: "EventExecTxList",
29: "EventPeerList",
30: "EventGetLastHeader",
31: "EventHeader",
32: "EventAddBlockDetail",
33: "EventGetMempool",
34: "EventGetTransactionByAddr",
35: "EventGetTransactionByHash",
36: "EventReplyTxInfo",
38: "EventWalletAccountList",
40: "EventWalletAccount",
42: "EventWalletExecutor",
47: "EventStoreDel",
49: "EventReplyHashes",
53: "EventTransactionDetails",
54: "EventBroadcastAddBlock",
55: "EventGetBlockOverview",
56: "EventGetAddrOverview",
57: "EventReplyBlockOverview",
58: "EventReplyAddrOverview",
59: "EventGetBlockHash",
60: "EventBlockHash",
61: "EventGetLastMempool",
63: "EventMinerStart",
64: "EventMinerStop",
65: "EventWalletTickets",
66: "EventStoreMemSet",
67: "EventStoreRollback",
68: "EventStoreCommit",
69: "EventCheckBlock",
71: "EventReplyGenSeed",
74: "EventReplyGetSeed",
75: "EventDelBlock",
76: "EventLocalGet",
77: "EventLocalReplyValue",
78: "EventLocalList",
79: "EventLocalSet",
81: "EventCheckTx",
82: "EventReceiptCheckTx",
84: "EventReplyQuery",
85: "EventSubscribePush",
86: "EventFetchBlockHeaders",
87: "EventAddBlockHeaders",
89: "EventReplyWalletStatus",
90: "EventGetLastBlock",
91: "EventBlock",
92: "EventGetTicketCount",
93: "EventReplyGetTicketCount",
95: "EventReplyPrivkey",
96: "EventIsSync",
97: "EventReplyIsSync",
98: "EventCloseTickets",
99: "EventGetAddrTxs",
100: "EventReplyAddrTxs",
101: "EventIsNtpClockSync",
102: "EventReplyIsNtpClockSync",
103: "EventDelTxList",
104: "EventStoreGetTotalCoins",
105: "EventGetTotalCoinsReply",
106: "EventQueryTotalFee",
108: "EventReplySignRawTx",
109: "EventSyncBlock",
110: "EventGetNetInfo",
111: "EventReplyNetInfo",
114: "EventReplyFatalFailure",
115: "EventBindMiner",
116: "EventReplyBindMiner",
117: "EventDecodeRawTx",
118: "EventReplyDecodeRawTx",
119: "EventGetLastBlockSequence",
120: "EventReplyLastBlockSequence",
121: "EventGetBlockSequences",
122: "EventReplyBlockSequences",
123: "EventGetBlockByHashes",
124: "EventReplyBlockDetailsBySeqs",
125: "EventDelParaChainBlockDetail",
126: "EventAddParaChainBlockDetail",
127: "EventGetSeqByHash",
128: "EventLocalPrefixCount",
//todo: 这个可能后面会删除
EventStoreList: "EventStoreList",
EventStoreListReply: "EventStoreListReply",
EventListPushes: "EventListPushes",
EventGetPushLastNum: "EventGetPushLastNum",
// Token
EventBlockChainQuery: "EventBlockChainQuery",
EventConsensusQuery: "EventConsensusQuery",
EventGetBlockBySeq: "EventGetBlockBySeq",
EventLocalBegin: "EventLocalBegin",
EventLocalCommit: "EventLocalCommit",
EventLocalRollback: "EventLocalRollback",
EventLocalNew: "EventLocalNew",
EventLocalClose: "EventLocalClose",
//mempool
EventGetProperFee: "EventGetProperFee",
EventReplyProperFee: "EventReplyProperFee",
EventTxListByHash: "EventTxListByHash",
// block chain
EventGetLastBlockMainSequence: "EventGetLastBlockMainSequence",
EventReplyLastBlockMainSequence: "EventReplyLastBlockMainSequence",
EventGetMainSeqByHash: "EventGetMainSeqByHash",
EventReplyMainSeqByHash: "EventReplyMainSeqByHash",
EventSetValueByKey: "EventSetValueByKey",
EventGetValueByKey: "EventGetValueByKey",
EventGetParaTxByTitle: "EventGetParaTxByTitle",
EventReplyParaTxByTitle: "EventReplyParaTxByTitle",
EventGetHeightByTitle: "EventGetHeightByTitle",
EventReplyHeightByTitle: "EventReplyHeightByTitle",
EventGetParaTxByTitleAndHeight: "EventGetParaTxByTitleAndHeight",
EventCmpBestBlock: "EventCmpBestBlock",
EventUpgrade: "EventUpgrade",
EventReplySubscribePush: "EventReplySubscribePush",
EventNotifyStoreChunk: "EventNotifyStoreChunk",
EventGetChunkBlock: "EventGetChunkBlock",
EventAddChunkBlock: "EventAddChunkBlock",
EventGetChunkBlockBody: "EventGetChunkBlockBody",
EventGetChunkRecord: "EventGetChunkRecord",
EventAddChunkRecord: "EventAddChunkRecord",
EventSubTopic: "EventSubTopic",
EventPubTopicMsg: "EventPubTopicMsg",
EventFetchTopics: "EventFetchTopics",
EventRemoveTopic: "EventRemoveTopic",
EventReceiveSubData: "EventReceiveSubData",
EventNetProtocols: "EventNetProtocols",
EventCheckTxsExist: "EventCheckTxsExist",
EventDeleteParaBlocks: "EventDeleteParaBlocks",
EventAddBlacklist: "EventAddBlacklist",
EventDelBlacklist: "EventDelBlacklist",
EventShowBlacklist: "EventShowBlacklist",
EventDialPeer: "EventDialPeer",
EventClosePeer: "EventClosePeer",
EventPushEVM: "EventPushEVM",
EventPushBlock: "EventPushBlock",
EventPushBlockHeader: "EventPushBlockHeader",
EventPushTxReceipt: "EventPushTxReceipt",
EventPushTxResult: "EventPushTxResult",
}