core

type BaseDevice interface {
	Mine(wg *sync.WaitGroup)
	Update()
	InitDevice()
	Status(wg *sync.WaitGroup)
	GetIsValid() bool
	SetIsValid(valid bool)
	GetMinerId() int
	GetAverageHashRate() float64
	GetName() string
	GetStart() uint64
	SetPool(pool bool)
	SetNewWork(w BaseWork)
	SetForceUpdate(force bool)
	Release()
	GetMinerType() string
	SubmitShare(substr chan string)
	StopTask()
	GetIsRunning() bool
}

type BaseWork interface {
	Get() bool
	Submit(h *types.BlockHeader, gbtID string) (string, int, error)
	PoolGet() bool
	PoolSubmit(subm string) error
}

type Device struct {
	Cfg              *common.GlobalConfig //must init
	DeviceName       string
	HasNewWork       bool
	ForceStop        bool
	AllDiffOneShares uint64
	AverageHashRate  float64
	MinerId          uint32
	NonceStep        uint64
	NonceStart       uint64
	LocalItemSize    int
	NonceOut         []byte
	Started          int64
	GlobalItemSize   int
	CurrentWorkID    uint64
	Quit             context.Context //must init
	sync.Mutex
	Wg           sync.WaitGroup
	Pool         bool        //must init
	IsValid      bool        //is valid
	SubmitData   chan string //must
	NewWork      chan BaseWork
	Err          error
	MiningType   string
	UartPath     string
	StopTaskChan chan bool
	IsRunning    bool
}

type MinerRobot struct {
	Cfg              *common.GlobalConfig //config
	ValidShares      uint64
	PendingShares    uint64
	StaleShares      uint64
	InvalidShares    uint64
	AllDiffOneShares uint64
	Wg               *sync.WaitGroup
	Started          uint32
	Quit             context.Context
	Work             *Work
	ClDevices        []string
	Rpc              *common.RpcClient
	Pool             bool
	SubmitStr        chan string
	UseDevices       []string
}

type Robot interface {
	Run(ctx context.Context) // uses device to calulate the nonce
	ListenWork()             //listen the solo or pool work
	SubmitWork()             //submit the work
}

type Stratum struct {
	sync.Mutex
	Cfg           *common.GlobalConfig
	Conn          net.Conn
	Reader        *bufio.Reader
	ID            uint64
	Started       uint32
	Timeout       uint32
	ValidShares   uint64
	InvalidShares uint64
	StaleShares   uint64
	SubmitIDs     []uint64
	SubID         uint64
	AuthID        uint64
	PowType       pow.PowType
	Quit          context.Context
}

type StratumMsg struct {
	Method string `json:"method"`
	// Need to make generic.
	Params []string    `json:"params"`
	ID     interface{} `json:"id"`
}

type Work struct {
	Cfg   *common.GlobalConfig
	Rpc   *common.RpcClient
	Clean bool
	sync.Mutex
	Quit        context.Context
	Started     uint32
	GetWorkTime int64
	LastSub     string //last submit string
}