sensors

type CoreF func(config config.Config, plugin *Plugin) (Sensor, error)

type Notifier interface {
	// notify order status changed
	Notify(receiver *Watcher, order *Order) error
}

type NotifierF func(config config.Config) (Notifier, error)

type NotifierFunc func(receiver *Watcher, order *Order) error

type Option func(plugin *Plugin)

type Order struct {
	ID           string    `xorm:"pk"`
	TX           string    `xorm:"unique"`
	PendingBlock int64     `xorm:""`
	CommitBlock  int64     `xorm:""`
	ConfirmBlock int64     `xorm:""`
	Status       Status    `xorm:"index"`
	CreateTime   time.Time `xorm:"created"`
	PendingTime  time.Time `xorm:""`
	CommitTime   time.Time `xorm:""`
	ConfirmTime  time.Time `xorm:""`
	From         string    `xorm:"index"`
	To           string    `xorm:"index"`
	Value        string    `xorm:"default('0x0')"`
	Code         string    `xorm:""`
	GasLimits    string    `xorm:""`
	GasPrice     string    `xorm:""`
}

type OrderCacher interface {
	Cache([]*Order)                                                             // load unconfirmed  orders
	Mint(tx string, block int64, time time.Time) (*Order, bool)                 // mint cached order with tx string
	Confirm(block int64, time time.Time) (timeout []*Order, confirmed []*Order) // confirm orders
	Pending() (*Order, bool)                                                    // pending order number
	Pend(order *Order)
}

type OrderCacherF func(config config.Config) (OrderCacher, error)

type OrderStorage interface {
	Save(order *Order) error
	Update(order *Order) error
	Unconfirmed() ([]*Order, error)
}

type OrderStorageF func(config config.Config) (OrderStorage, error)

type Plugin struct {
	slf4go.Logger
	NotifierCreator NotifierF

	OrderStorageCreator OrderStorageF
	OrderCacherCreator  OrderCacherF
	// contains filtered or unexported fields
}

type Sensor interface {
	// create a new watcher with config
	New(watcher *Watcher) (id string, err error)
	// delete watcher by watcher key
	Delete(key string) (err error)
	// list the register watcher
	List(page orm.Page) ([]*Watcher, int64, error)
}

type Status string

type Watcher struct {
	ID      string `xorm:"pk"`                    // watcher id
	Name    string `xorm:"index"`                 // watcher name
	Key     string `xorm:"unique"`                // watcher unique key provider by notifier
	Address string `xorm:"unique(address_erc20)"` // watched address
	ERC20   bool   `xorm:"unique(address_erc20)"` // true if the target address is a erc20 contract address
}