sub

type CompletedUBD struct {
	Validator sdk.ValAddress
	Delegator sdk.AccAddress
	Amount    sdk.Coin
}

type EventStore struct {
	// store for stake topic
	StakeData *StakeData
	// store for slash topic
	SlashData map[string][]SlashData
	// store for cross chain transfer topic
	CrossTransferData []pubsub.CrossTransferEvent
	// store for mirror topic
	MirrorData []bridge.MirrorEvent
}

type SlashData struct {
	Validator              sdk.ValAddress
	InfractionType         byte
	InfractionHeight       int64
	JailUtil               time.Time
	SlashAmount            int64
	ToFeePool              int64
	Submitter              sdk.AccAddress
	SubmitterReward        int64
	ValidatorsCompensation map[string]int64
}

type StakeData struct {
	// stash for stake topic
	Distribution         map[string][]stake.DistributionData             // ChainId -> []DistributionData
	CompletedUBDs        map[string][]CompletedUBD                       // ChainId -> []CompletedUBD
	CompletedREDs        map[string][]types.DVVTriplet                   // ChainId -> []DVVTriplet
	Validators           map[string]stake.Validator                      // operator(string) -> validator
	RemovedValidators    map[string][]sdk.ValAddress                     // ChainId -> []sdk.ValAddress
	Delegations          map[string]map[string]stake.Delegation          // ChainId -> delegator+validator -> Delegation
	RemovedDelegations   map[string][]types.DVPair                       // ChainId -> []DVPair
	UnbondingDelegations map[string]map[string]stake.UnbondingDelegation // ChainId -> delegator+validator -> UBD
	ReDelegations        map[string]map[string]stake.Redelegation        // ChainId -> delegator+srcValidator+dstValidator -> RED
	DelegateEvents       map[string][]stake.DelegateEvent                // ChainId -> delegate event
	UndelegateEvents     map[string][]stake.UndelegateEvent              // ChainId -> undelegate event
	RedelegateEvents     map[string][]stake.RedelegateEvent              // ChainId -> redelegate event
	ElectedValidators    map[string][]stake.Validator                    // ChainId -> elected validators
}

type ToPublishEvent struct {
	Height         int64
	Timestamp      time.Time
	IsBreatheBlock bool
	EventData      *EventStore
}

type TxDeliverEvent struct{}

type TxDeliverFailEvent struct {
	TxDeliverEvent
}

type TxDeliverSuccEvent struct {
	TxDeliverEvent
}