context

type Conf struct {
	CosmosRpcAddr        string `json:"cosmos_rpc_addr"`
	CosmosWallet         string `json:"cosmos_wallet"`
	CosmosWalletPwd      string `json:"cosmos_wallet_pwd"`
	CosmosStartHeight    int64  `json:"cosmos_start_height"`
	CosmosListenInterval int    `json:"cosmos_listen_interval"`
	CosmosChainId        string `json:"cosmos_chain_id"`
	CosmosGasPrice       string `json:"cosmos_gas_price"`
	CosmosGas            uint64 `json:"cosmos_gas"`

	PolyRpcAddr        string `json:"poly_rpc_addr"`
	PolyWallet         string `json:"poly_wallet"`
	PolyWalletPwd      string `json:"poly_wallet_pwd"`
	PolyStartHeight    uint32 `json:"poly_start_height"`
	PolyListenInterval int    `json:"poly_listen_interval"`
	PolyToCosmosKey    string `json:"poly_to_cosmos_key"`

	SideChainId    uint64 `json:"side_chain_id"`
	DBPath         string `json:"db_path"`
	ConfirmTimeout int    `json:"confirm_timeout"`

	LogLevel int `json:"log_level"`
}

type CosmosInfo struct {
	// type 1 means header and tx; type 2 means only header;
	Type InfoType

	// to update height of chain
	Height int64

	// tx part
	Tx *CosmosTx

	// header part
	Hdrs []*cosmos.CosmosHeader
}

type CosmosSeq struct {
	// contains filtered or unexported fields
}

type CosmosStatus struct {
	Txs             *sync.Map // TODO: record a start time to test if it's not confirm for a long time, that could be tx lost
	Wg              *sync.WaitGroup
	IsBlocked       bool
	PolyEpochHeight uint32
}

type CosmosTx struct {
	Tx          *rpctypes.ResultTx
	ProofHeight int64
	Proof       []byte
	PVal        []byte
}

type Ctx struct {
	// configuration
	Conf *Conf

	// To transfer cross chain tx from listening to relaying
	ToCosmos chan *PolyInfo
	ToPoly   chan *CosmosInfo

	// Cosmos
	CMRpcCli *rpchttp.HTTP
	CMPrivk  tcrypto.PrivKey
	CMAcc    ctypes.AccAddress
	CMSeq    *CosmosSeq
	CMAccNum uint64
	CMFees   ctypes.Coins
	CMGas    uint64
	CMCdc    *codec.Codec

	// Poly chain
	Poly    *poly_go_sdk.PolySdk
	PolyAcc *poly_go_sdk.Account

	// DB
	Db *db.Database

	// status for relayed tx
	CMStatus   *CosmosStatus
	PolyStatus *PolyStatus
}

type InfoType int

type PolyInfo struct {
	// type 0 means only tx; type 2 means header and tx; type 1 means only header;
	Type InfoType

	// to update height of Poly on COSMOS
	Height uint32

	// tx part
	Tx *PolyTx

	// header part
	Hdr *types.Header

	// proof of header which is not during current epoch
	HeaderProof string

	// any header in current epoch can be trust anchor
	EpochAnchor string
}

type PolyStatus struct {
	Txs               *sync.Map
	Wg                *sync.WaitGroup
	IsBlocked         bool
	CosmosEpochHeight int64
}

type PolyTx struct {
	Height      uint32
	Proof       string
	TxHash      string
	IsEpoch     bool
	CCID        []byte
	FromChainId uint64
}