Lima operaitons

dipdup-io · Nov 29, 2022 · 48b2245 · 48b2245
1 parent a8abdee
commit 48b2245
Show file tree

Hide file tree

Showing 6 changed files with 90 additions and 2 deletions.
diff --git a/node/consts.go b/node/consts.go
@@ -34,6 +34,8 @@ const (
 	KindEvent                      = "event"
 	KindVdfRevelation              = "vdf_revelation"
 	KindIncreasePaidStorage        = "Increase_paid_storage"
+	KindUpdateConsensusKey         = "update_consensus_key"
+	KindDrainDelegate              = "drain_delegate"
 )
 
 const (

diff --git a/node/operations.go b/node/operations.go
@@ -15,7 +15,8 @@ type OperationConstraint interface {
 		RegisterGlobalConstant | DoublePreendorsementEvidence | SetDepositsLimit |
 		Preendorsement | Event | VdfRevelation | TxRollupCommit | TxRollupOrigination |
 		TxRollupDispatchTickets | TxRollupFinalizeCommitment | TxRollupRejection |
-		TxRollupRemoveCommitment | TxRollupSubmitBatch
+		TxRollupRemoveCommitment | TxRollupSubmitBatch | UpdateConsensusKey |
+		DrainDelegate
 }
 
 // OperationGroup -
@@ -93,6 +94,10 @@ func (op *Operation) UnmarshalJSON(data []byte) error {
 		err = parseOperation[TxRollupRemoveCommitment](data, op)
 	case KindTxRollupSubmitBatch:
 		err = parseOperation[TxRollupSubmitBatch](data, op)
+	case KindUpdateConsensusKey:
+		err = parseOperation[UpdateConsensusKey](data, op)
+	case KindDrainDelegate:
+		err = parseOperation[DrainDelegate](data, op)
 
 	}
 	return err
@@ -625,3 +630,24 @@ type TxRollupSubmitBatch struct {
 	Content      string                    `json:"content"`
 	Metadata     *ManagerOperationMetadata `json:"metadata,omitempty"`
 }
+
+// UpdateConsensusKey -
+type UpdateConsensusKey struct {
+	Kind         string                    `json:"kind"`
+	Source       string                    `json:"source"`
+	Fee          string                    `json:"fee"`
+	Counter      string                    `json:"counter"`
+	GasLimit     string                    `json:"gas_limit"`
+	StorageLimit string                    `json:"storage_limit"`
+	Pk           string                    `json:"pk"`
+	Metadata     *ManagerOperationMetadata `json:"metadata,omitempty"`
+}
+
+// DrainDelegate -
+type DrainDelegate struct {
+	Kind         string                    `json:"kind"`
+	ConsensusKey string                    `json:"consensus_key"`
+	Delegate     string                    `json:"delegate"`
+	Destination  string                    `json:"destination"`
+	Metadata     *ManagerOperationMetadata `json:"metadata,omitempty"`
+}
diff --git a/tzkt/api/operations.go b/tzkt/api/operations.go
@@ -203,3 +203,15 @@ func (tzkt *API) GetIncreasePaidStorage(ctx context.Context, filters map[string]
 	err = tzkt.json(ctx, "/v1/operations/increase_paid_storage", filters, false, &operations)
 	return
 }
+
+// GetUpdateConsensusKey -
+func (tzkt *API) GetUpdateConsensusKey(ctx context.Context, filters map[string]string) (operations []data.UpdateConsensusKey, err error) {
+	err = tzkt.json(ctx, "/v1/operations/update_consensus_key", filters, false, &operations)
+	return
+}
+
+// GetDrainDelegates -
+func (tzkt *API) GetDrainDelegates(ctx context.Context, filters map[string]string) (operations []data.DrainDelegate, err error) {
+	err = tzkt.json(ctx, "/v1/operations/drain_delegate", filters, false, &operations)
+	return
+}
diff --git a/tzkt/data/consts.go b/tzkt/data/consts.go
@@ -32,6 +32,8 @@ const (
 	KindEndorsingReward          = "endorsing_reward"
 	KindVdfRevelation            = "vdf_revelation"
 	KindIncreasePaidStorage      = "increase_paid_storage"
+	KindUpdateConsensusKey       = "update_consensus_key"
+	KindDrainDelegate            = "drain_delegate"
 )
 
 // urls

diff --git a/tzkt/data/operations.go b/tzkt/data/operations.go
@@ -14,7 +14,8 @@ type OperationConstraint interface {
 		Ballot | Proposal | Activation | TransferTicket | TxRollupCommit | TxRollupDispatchTicket |
 		TxRollupFinalizeCommitment | TxRollupOrigination | TxRollupRejection | TxRollupRemoveCommitment |
 		TxRollupReturnBond | TxRollupSubmitBatch | NonceRevelation | DoubleBaking | DoubleEndorsing | SetDepositsLimit |
-		Baking | RevelationPenalty | EndorsingReward | VdfRevelation | IncreasePaidStorage
+		Baking | RevelationPenalty | EndorsingReward | VdfRevelation | IncreasePaidStorage | DrainDelegate |
+		UpdateConsensusKey
 }
 
 // Operation -
@@ -660,3 +661,40 @@ type IncreasePaidStorage struct {
 	Contract     Account         `json:"contract"`
 	Amount       decimal.Decimal `json:"amount"`
 }
+
+// UpdateConsensusKey -
+type UpdateConsensusKey struct {
+	Type            string    `json:"type"`
+	ID              uint64    `json:"id"`
+	Level           uint64    `json:"level"`
+	Timestamp       time.Time `json:"timestamp"`
+	Block           string    `json:"block"`
+	Hash            string    `json:"hash"`
+	Sender          Account   `json:"sender"`
+	Counter         uint64    `json:"counter"`
+	GasLimit        uint64    `json:"gasLimit"`
+	GasUsed         uint64    `json:"gasUsed"`
+	StorageLimit    uint64    `json:"storageLimit"`
+	BakerFee        uint64    `json:"bakerFee"`
+	Status          string    `json:"status"`
+	ActivationCycle uint64    `json:"activationCycle"`
+	PublicKey       string    `json:"publicKey"`
+	PublicKeyHash   string    `json:"publicKeyHash"`
+	Errors          []Error   `json:"errors,omitempty"`
+	Quote           *Quote    `json:"quote,omitempty"`
+}
+
+// DrainDelegate -
+type DrainDelegate struct {
+	Type      string    `json:"type"`
+	ID        uint64    `json:"id"`
+	Level     uint64    `json:"level"`
+	Timestamp time.Time `json:"timestamp"`
+	Block     string    `json:"block"`
+	Hash      string    `json:"hash"`
+	Delegate  Account   `json:"delegate"`
+	Target    Account   `json:"target"`
+	Amount    uint64    `json:"amount"`
+	Fee       uint64    `json:"fee"`
+	Quote     *Quote    `json:"quote,omitempty"`
+}
diff --git a/tzkt/events/tzkt.go b/tzkt/events/tzkt.go
@@ -312,6 +312,14 @@ func parseOperations(data []byte) (any, error) {
 			result = append(result, &tzktData.Baking{})
 		case tzktData.KindDoublePreendorsing:
 			result = append(result, &tzktData.DoublePreendorsing{})
+		case tzktData.KindIncreasePaidStorage:
+			result = append(result, &tzktData.IncreasePaidStorage{})
+		case tzktData.KindVdfRevelation:
+			result = append(result, &tzktData.VdfRevelation{})
+		case tzktData.KindUpdateConsensusKey:
+			result = append(result, &tzktData.UpdateConsensusKey{})
+		case tzktData.KindDrainDelegate:
+			result = append(result, &tzktData.DrainDelegate{})
 		default:
 			result = append(result, make(map[string]interface{}))
 		}