mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-09-21 07:24:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

updates

Browse Source
This commit is contained in:
Aleksandr Bezobchuk
2022-06-17 15:59:26 -04:00
parent 30ca882a1f
commit 655c00e5ba
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
state/indexer/sink/pubsub/pubsub.go
+3 -2
View File
@@ -80,6 +80,7 @@ func NewEventSink(projectID, topic, chainID string) (*EventSink, error) {
func (es *EventSink) IndexBlock(h types.EventDataNewBlockHeader) error {
buf := new(bytes.Buffer)
blockHeightStr := strconv.Itoa(int(h.Header.Height))
// publish BeginBlock Events
if err := jsonpbMarshaller.Marshal(buf, &h.ResultBeginBlock); err != nil {
@@ -93,7 +94,7 @@ func (es *EventSink) IndexBlock(h types.EventDataNewBlockHeader) error {
Attributes: map[string]string{
MsgType: MsgTypeBeginBlock,
AttrKeyChainID: es.chainID,
AttrKeyBlockHeight: strconv.Itoa(int(h.Header.Height)),
AttrKeyBlockHeight: blockHeightStr,
},
},
)
@@ -117,7 +118,7 @@ func (es *EventSink) IndexBlock(h types.EventDataNewBlockHeader) error {
Attributes: map[string]string{
MsgType: MsgTypeEndBlock,
AttrKeyChainID: es.chainID,
AttrKeyBlockHeight: strconv.Itoa(int(h.Header.Height)),
AttrKeyBlockHeight: blockHeightStr,
},
},
)