core

type ArbCore interface {
	ArbCoreLookup
	ArbCoreInbox
	LogsCursor
	StartThread() bool
	StopThread()
	MachineIdle() bool
}

type ArbCoreInbox interface {
	DeliverMessages(messages []inbox.InboxMessage, previousInboxAcc common.Hash, lastBlockComplete bool, reorgHeight *big.Int) bool
	MessagesStatus() (MessageStatus, error)
}

type ArbCoreLookup interface {
	ArbOutputLookup

	GetInboxAcc(index *big.Int) (common.Hash, error)
	GetInboxAccPair(index1 *big.Int, index2 *big.Int) (common.Hash, common.Hash, error)

	MachineMessagesRead() *big.Int

	// GetExecutionCursor returns a cursor containing the machine after executing totalGasUsed
	// from the original machine
	GetExecutionCursor(totalGasUsed *big.Int) (ExecutionCursor, error)

	// Advance executes as much as it can without going over maxGas or
	// optionally until it reaches or goes over maxGas
	AdvanceExecutionCursor(executionCursor ExecutionCursor, maxGas *big.Int, goOverGas bool) error

	// TakeMachine takes ownership of machine such that ExecutionCursor will
	// no longer be able to advance.
	TakeMachine(executionCursor ExecutionCursor) (machine.Machine, error)
}

type ArbOutputLookup interface {
	GetLogCount() (*big.Int, error)
	GetLogs(startIndex, count *big.Int) ([]value.Value, error)

	GetSendCount() (*big.Int, error)
	GetSends(startIndex, count *big.Int) ([][]byte, error)

	GetMessageCount() (*big.Int, error)
	GetMessages(startIndex, count *big.Int) ([]inbox.InboxMessage, error)

	GetMachineForSideload(uint64) (machine.Machine, error)
}

type Assertion struct {
	Before *ExecutionState
	After  *ExecutionState
}

type BigIntList []*big.Int

type Bisection struct {
	ChallengedSegment *ChallengeSegment
	Cuts              []Cut
}

type ChallengeKind uint8

type ChallengeSegment struct {
	Start  *big.Int
	Length *big.Int
}

type Cut interface {
	Equals(other Cut) bool
	CutHash() [32]byte
}

type ExecutionCursor interface {
	Clone() ExecutionCursor
	MachineHash() (common.Hash, error)
	TotalMessagesRead() *big.Int
	InboxAcc() common.Hash
	SendAcc() common.Hash
	LogAcc() common.Hash
	TotalGasConsumed() *big.Int
	TotalSteps() *big.Int
	TotalSendCount() *big.Int
	TotalLogCount() *big.Int
}

type ExecutionState struct {
	MachineHash       common.Hash
	InboxAcc          common.Hash
	TotalMessagesRead *big.Int
	TotalGasConsumed  *big.Int
	TotalSendCount    *big.Int
	TotalLogCount     *big.Int
	SendAcc           common.Hash
	LogAcc            common.Hash
}

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

type InMemoryOutputLookup struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type LogConsumer interface {
	AddLogs(initialIndex *big.Int, avmLogs []value.Value) error
	DeleteLogs(avmLogs []value.Value) error
}

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

type LogsCursor interface {
	LogsCursorRequest(cursorIndex *big.Int, count *big.Int) error
	LogsCursorGetLogs(cursorIndex *big.Int) (*big.Int, []value.Value, []value.Value, error)
	LogsCursorCheckError(cursorIndex *big.Int) error
	LogsCursorConfirmReceived(cursorIndex *big.Int) (bool, error)
	LogsCursorPosition(cursorIndex *big.Int) (*big.Int, error)
}

type MessageStatus uint8

type NodeID *big.Int

type NodeInfo struct {
	NodeNum       NodeID
	BlockProposed *common.BlockId
	Assertion     *Assertion
	InboxMaxCount *big.Int
	NodeHash      common.Hash
	AfterInboxAcc [32]byte
}

type NodeState struct {
	ProposedBlock *big.Int
	InboxMaxCount *big.Int
	*ExecutionState
}

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