event support

tzkt/data/general.go

@@ -160,3 +160,14 @@ type Statistics struct {
 	TotalVested       uint64    `json:"totalVested"`
 	Quote             *Quote    `json:"quote,omitempty"`
 }
+
+type Event struct {
+	Id            int         `json:"id"`
+	Level         int         `json:"level"`
+	Timestamp     time.Time   `json:"timestamp"`
+	Contract      Address     `json:"contract"`
+	CodeHash      int         `json:"codeHash"`
+	Tag           string      `json:"tag"`
+	Payload       interface{} `json:"payload,omitempty"`
+	TransactionId int64       `json:"transactionId"`
+}

tzkt/events/consts.go

@@ -19,6 +19,7 @@ const (
 	ChannelBigMap     = "bigmaps"
 	ChannelAccounts   = "accounts"
 	ChannelTransfers  = "transfers"
+	ChannelEvents     = "events"
 )
 
 // Big map tags

tzkt/events/tzkt.go

@@ -9,7 +9,7 @@ import (
 
 	"github.com/dipdup-net/go-lib/tzkt/events/signalr"
 
-	tzktData "github.com/dipdup-net/go-lib/tzkt/data"
+	tzktData "github.com/art-technologies/go-lib/tzkt/data"
 	"github.com/pkg/errors"
 	"github.com/rs/zerolog"
 	"github.com/rs/zerolog/log"
@@ -255,6 +255,10 @@ func parseData(channel string, data []byte) (any, error) {
 		var transfer []tzktData.Transfer
 		err := json.Unmarshal(data, &transfer)
 		return transfer, err
+	case ChannelEvents:
+		var events []tzktData.Event
+		err := json.Unmarshal(data, &events)
+		return events, err
 	default:
 		return nil, errors.Errorf("unknown channel: %s", channel)
 	}