bridge_core

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

type Block interface {
	GetHash() common.Hash
	GetHeight() uint64
	GetTransactions() []Transaction
	GetLogs() []Log
	GetTimestamp() uint64
}

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

type Config struct {
	Listeners       map[string]*LsConfig `json:"listeners"`
	SlackUrl        string               `json:"slackUrl"`
	ScanUrl         string               `json:"scanUrl"`
	NumberOfWorkers int                  `json:"numberOfWorkers"`
	MaxQueueSize    int                  `json:"maxQueueSize"`
	MaxRetry        int32                `json:"maxRetry"`
	BackOff         int32                `json:"backoff"`
	DB              *stores.Database     `json:"database"`

	// this field is used for testing purpose
	Testing bool
}

type Controller struct {
	HandlerABIs map[string]*abi.ABI

	Pool *Pool
	// contains filtered or unexported fields
}

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

type Handler struct {
	// Contract Name that will be used to get ABI
	Contract string `json:"contract"`

	// Name is method/event name
	Name string `json:"name"`

	// ContractAddress is used in callback case
	ContractAddress string `json:"contractAddress"`

	// Listener who triggers callback event
	Listener string `json:"listener"`

	ABI *abi.ABI `json:"-"`

	// HandleMethod is used when processing listened job, do nothing if it is empty
	HandleMethod string `json:"handleMethod"`
}

type Job struct {
	ID         int32
	Type       int
	Message    []interface{}
	RetryCount int32
	NextTry    int32
	MaxTry     int32
	BackOff    int32
	Listener   Listener
}

type JobHandler interface {
	GetID() int32
	GetType() int
	GetRetryCount() int
	GetNextTry() int64
	GetMaxTry() int
	GetData() []byte
	GetValue() *big.Int
	GetBackOff() int

	Process() ([]byte, error)
	Hash() common.Hash

	IncreaseRetryCount()
	UpdateNextTry(int64)

	GetListener() Listener
	GetSubscriptionName() string
	GetTransaction() Transaction

	FromChainID() *big.Int

	Save() error
	Update(string) error

	CreatedAt() time.Time
	String() string
}

type Listener interface {
	GetName() string
	GetStore() stores.MainStore
	Config() *LsConfig

	Period() time.Duration
	GetSafeBlockRange() uint64
	GetPreventOmissionRange() uint64
	GetCurrentBlock() Block
	GetLatestBlock() (Block, error)
	GetLatestBlockHeight() (uint64, error)
	GetBlock(height uint64) (Block, error)
	GetBlockWithLogs(height uint64) (Block, error)
	GetChainID() (*big.Int, error)
	GetReceipt(common.Hash) (*types.Receipt, error)
	Context() context.Context

	GetSubscriptions() map[string]*Subscribe

	UpdateCurrentBlock(block Block) error

	SaveCurrentBlockToDB() error
	SaveTransactionsToDB(txs []Transaction) error

	GetListenHandleJob(subscriptionName string, tx Transaction, eventId string, data []byte) JobHandler
	SendCallbackJobs(listeners map[string]Listener, subscriptionName string, tx Transaction, inputData []byte)

	NewJobFromDB(job *models.Job) (JobHandler, error)

	Start()
	Close()

	IsDisabled() bool
	SetInitHeight(uint64)
	GetInitHeight() uint64

	GetEthClient() utils.EthClient

	GetTasks() []TaskHandler
	GetTask(index int) TaskHandler
	AddTask(handler TaskHandler)

	IsUpTodate() bool
	SetPrepareJobChan(chan JobHandler)

	GetValidatorSign() utils.ISign

	AddListeners(map[string]Listener)

	// GetListener returns listener by name
	GetListener(string) Listener
}

type Log interface {
	GetContractAddress() string
	GetTopics() []string
	GetData() []byte
	GetIndex() uint
	GetTxIndex() uint
	GetTransactionHash() string
}

type LsConfig struct {
	ChainId              string            `json:"chainId"`
	Name                 string            `json:"name"`
	RpcUrl               string            `json:"rpcUrl"`
	SlackUrl             string            `json:"slackUrl"`
	ScanUrl              string            `json:"scanUrl"`
	LoadInterval         time.Duration     `json:"blockTime"`
	SafeBlockRange       uint64            `json:"safeBlockRange"`
	PreventOmissionRange uint64            `json:"preventOmissionRange"`
	FromHeight           uint64            `json:"fromHeight"`
	DomainSeparators     map[uint64]string `json:"domainSeparators"`
	Decimals             map[uint64]uint64 `json:"decimals"`
	TaskInterval         time.Duration     `json:"taskInterval"`
	Disabled             bool              `json:"disabled"`

	// TODO: apply more ways to get privatekey. such as: PLAINTEXT, KMS, etc.
	Secret                 *Secret               `json:"secret"`
	Subscriptions          map[string]*Subscribe `json:"subscriptions"`
	TransactionCheckPeriod time.Duration         `json:"transactionCheckPeriod"`
	Contracts              map[string]string     `json:"contracts"`
	ProcessWithinBlocks    uint64                `json:"processWithinBlocks"`

	MaxTasksQuery int `json:"maxTasksQuery"`
	MinTasksQuery int `json:"minTasksQuery"`

	// GetLogsBatchSize is used at batch size when calling processBatchLogs
	GetLogsBatchSize int `json:"getLogsBatchSize"`

	// MaxProcessingTasks is used to specify max processing tasks allowed while processing tasks
	// if number of tasks reaches this number, it waits until this number decrease
	MaxProcessingTasks int `json:"maxProcessingTasks"`
}

type Pool struct {
	Workers []Worker

	// message backoff
	MaxRetry int32
	BackOff  int32

	// Queue holds a list of worker
	Queue chan chan JobHandler

	// JobChan receives new job
	JobChan        chan JobHandler
	RetryJobChan   chan JobHandler
	FailedJobChan  chan JobHandler
	PrepareJobChan chan JobHandler

	MaxQueueSize int
	// contains filtered or unexported fields
}

type Receipt interface {
	GetTransaction() Transaction
	GetStatus() bool
	GetLogs() []Log
}

type Secret struct {
	Validator *utils.SignMethodConfig `json:"validator"`
}

type Stats struct {
	PendingQueue int
	Queue        int
}

type Subscribe struct {
	From string `json:"from"`
	To   string `json:"to"`

	// Type can be either TxEvent or LogEvent
	Type int `json:"type"`

	Handler   *Handler          `json:"handler"`
	CallBacks map[string]string `json:"callbacks"`
}

type TaskHandler interface {
	Start()
	Close()
	GetListener() Listener
	SetLimitQuery(limit int)
}

type Transaction interface {
	GetHash() common.Hash
	GetFromAddress() string
	GetToAddress() string
	GetData() []byte
	GetValue() *big.Int
}

type Worker interface {
	Context() context.Context
	Close()
	ProcessJob(job JobHandler) error
	IsClose() bool
	Channel() chan JobHandler
	PoolChannel() chan<- JobHandler
	WorkersQueue() chan chan JobHandler
}