Merge pull request #82 from Cerebellum-Network/feature/pass-block-to-…

…events-listener

Pass block hash and number to events listener

blockchain/client.go

@@ -13,7 +13,7 @@ import (
 	"github.com/cerebellum-network/cere-ddc-sdk-go/blockchain/pallets"
 )
 
-type EventsListener func(*pallets.Events)
+type EventsListener func(events *pallets.Events, blockNumber types.BlockNumber, blockHash types.Hash)
 
 type Client struct {
 	*gsrpc.SubstrateAPI
@@ -77,6 +77,12 @@ func (c *Client) StartEventsListening() (func(), <-chan error, error) {
 			case <-done:
 				return
 			case set := <-sub.Chan():
+				header, err := c.RPC.Chain.GetHeader(set.Block)
+				if err != nil {
+					c.errsListening <- fmt.Errorf("get header: %w", err)
+					continue
+				}
+
 				for _, change := range set.Changes {
 					if !codec.Eq(change.StorageKey, key) || !change.HasStorageData {
 						continue
@@ -86,10 +92,11 @@ func (c *Client) StartEventsListening() (func(), <-chan error, error) {
 					err = types.EventRecordsRaw(change.StorageData).DecodeEventRecords(meta, events)
 					if err != nil {
 						c.errsListening <- fmt.Errorf("events decoder: %w", err)
+						continue
 					}
 
 					for _, callback := range c.eventsListeners {
-						go callback(events)
+						go callback(events, header.Number, set.Block)
 					}
 				}
 			}