lily

type FullBlock struct {
	Header       *types.BlockHeader
	BlsMessages  []*types.Message
	SecpMessages []*types.SignedMessage
}

type FullTipSet struct {
	Blocks []*FullBlock
	TipSet *types.TipSet

	HasMessages bool
	HasState    bool
	HasReceipts bool
}

type LilyAPI interface {
	AuthVerify(ctx context.Context, token string) ([]auth.Permission, error)

	LilyIndex(ctx context.Context, cfg *LilyIndexConfig) (interface{}, error)
	LilyWatch(ctx context.Context, cfg *LilyWatchConfig) (*schedule.JobSubmitResult, error)
	LilyWalk(ctx context.Context, cfg *LilyWalkConfig) (*schedule.JobSubmitResult, error)
	LilySurvey(ctx context.Context, cfg *LilySurveyConfig) (*schedule.JobSubmitResult, error)

	LilyIndexNotify(ctx context.Context, cfg *LilyIndexNotifyConfig) (interface{}, error)
	LilyWatchNotify(ctx context.Context, cfg *LilyWatchNotifyConfig) (*schedule.JobSubmitResult, error)
	LilyWalkNotify(ctx context.Context, cfg *LilyWalkNotifyConfig) (*schedule.JobSubmitResult, error)

	LilyJobStart(ctx context.Context, ID schedule.JobID) error
	LilyJobStop(ctx context.Context, ID schedule.JobID) error
	LilyJobWait(ctx context.Context, ID schedule.JobID) (*schedule.JobListResult, error)
	LilyJobList(ctx context.Context) ([]schedule.JobListResult, error)

	LilyGapFind(ctx context.Context, cfg *LilyGapFindConfig) (*schedule.JobSubmitResult, error)
	LilyGapFill(ctx context.Context, cfg *LilyGapFillConfig) (*schedule.JobSubmitResult, error)
	LilyGapFillNotify(ctx context.Context, cfg *LilyGapFillNotifyConfig) (*schedule.JobSubmitResult, error)

	// SyncState returns the current status of the chain sync system.
	SyncState(context.Context) (*api.SyncState, error) //perm:read

	ChainHead(context.Context) (*types.TipSet, error)                                                            //perm:read
	ChainGetBlock(context.Context, cid.Cid) (*types.BlockHeader, error)                                          //perm:read
	ChainReadObj(context.Context, cid.Cid) ([]byte, error)                                                       //perm:read
	ChainStatObj(context.Context, cid.Cid, cid.Cid) (api.ObjStat, error)                                         //perm:read
	ChainGetTipSet(context.Context, types.TipSetKey) (*types.TipSet, error)                                      //perm:read
	ChainGetTipSetByHeight(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)              //perm:read
	ChainGetTipSetAfterHeight(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)           //perm:read
	ChainGetBlockMessages(context.Context, cid.Cid) (*api.BlockMessages, error)                                  //perm:read
	ChainGetParentReceipts(context.Context, cid.Cid) ([]*types.MessageReceipt, error)                            //perm:read
	ChainGetParentMessages(context.Context, cid.Cid) ([]api.Message, error)                                      //perm:read
	ChainSetHead(context.Context, types.TipSetKey) error                                                         //perm:read
	ChainGetGenesis(context.Context) (*types.TipSet, error)                                                      //perm:read
	ChainPrune(ctx context.Context, opts api.PruneOpts) error                                                    //perm:read
	ChainHotGC(ctx context.Context, opts api.HotGCOpts) error                                                    //perm:read
	EthGetBlockByHash(ctx context.Context, blkHash ethtypes.EthHash, fullTxInfo bool) (ethtypes.EthBlock, error) //perm:read
	EthGetTransactionReceipt(ctx context.Context, txHash ethtypes.EthHash) (*api.EthTxReceipt, error)            //perm:read
	ChainGetMessagesInTipset(ctx context.Context, tsk types.TipSetKey) ([]api.Message, error)                    //perm:read
	EthGetTransactionByHash(ctx context.Context, txHash *ethtypes.EthHash) (*ethtypes.EthTx, error)              //perm:read
	StateListActors(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)                         //perm:read
	GetActorEventsRaw(ctx context.Context, filter *types.ActorEventFilter) ([]*types.ActorEvent, error)          //perm:read

	// SyncIncomingBlocks returns a channel streaming incoming, potentially not
	// yet synced block headers.
	SyncIncomingBlocks(ctx context.Context) (<-chan *types.BlockHeader, error) //perm:read

	// trigger graceful shutdown
	Shutdown(context.Context) error

	// LogList returns a list of loggers
	LogList(context.Context) ([]string, error)                       //perm:write
	LogSetLevel(context.Context, string, string) error               //perm:write
	LogSetLevelRegex(ctx context.Context, regex, level string) error //perm:write

	// ID returns peerID of libp2p node backing this API
	ID(context.Context) (peer.ID, error) //perm:read
	NetAutoNatStatus(ctx context.Context) (i api.NatInfo, err error)
	NetPeers(context.Context) ([]peer.AddrInfo, error)
	NetAddrsListen(context.Context) (peer.AddrInfo, error)
	NetPubsubScores(context.Context) ([]api.PubsubScore, error)
	NetAgentVersion(ctx context.Context, p peer.ID) (string, error)
	NetPeerInfo(context.Context, peer.ID) (*api.ExtendedPeerInfo, error)
	NetConnect(context.Context, peer.AddrInfo) error
	NetDisconnect(context.Context, peer.ID) error

	StartTipSetWorker(ctx context.Context, cfg *LilyTipSetWorkerConfig) (*schedule.JobSubmitResult, error)

	FindOldestState(ctx context.Context, limit int64) ([]*StateReport, error)
	StateCompute(ctx context.Context, tsk types.TipSetKey) (interface{}, error)
}

type LilyAPIStruct struct {
	// authentication
	// TODO: avoid importing CommonStruct, split out into separate lily structs
	v0api.CommonStruct

	Internal struct {
		Store func() adt.Store `perm:"read"`

		LilyIndex  func(ctx context.Context, config *LilyIndexConfig) (interface{}, error)     `perm:"read"`
		LilyWatch  func(context.Context, *LilyWatchConfig) (*schedule.JobSubmitResult, error)  `perm:"read"`
		LilyWalk   func(context.Context, *LilyWalkConfig) (*schedule.JobSubmitResult, error)   `perm:"read"`
		LilySurvey func(context.Context, *LilySurveyConfig) (*schedule.JobSubmitResult, error) `perm:"read"`

		LilyIndexNotify   func(ctx context.Context, config *LilyIndexNotifyConfig) (interface{}, error)                 `perm:"read"`
		LilyWatchNotify   func(ctx context.Context, config *LilyWatchNotifyConfig) (*schedule.JobSubmitResult, error)   `perm:"read"`
		LilyWalkNotify    func(ctx context.Context, config *LilyWalkNotifyConfig) (*schedule.JobSubmitResult, error)    `perm:"read"`
		LilyGapFillNotify func(ctx context.Context, config *LilyGapFillNotifyConfig) (*schedule.JobSubmitResult, error) `perm:"read"`

		LilyJobStart func(ctx context.Context, ID schedule.JobID) error                            `perm:"read"`
		LilyJobStop  func(ctx context.Context, ID schedule.JobID) error                            `perm:"read"`
		LilyJobWait  func(ctx context.Context, ID schedule.JobID) (*schedule.JobListResult, error) `perm:"read"`
		LilyJobList  func(ctx context.Context) ([]schedule.JobListResult, error)                   `perm:"read"`

		LilyGapFind func(ctx context.Context, cfg *LilyGapFindConfig) (*schedule.JobSubmitResult, error) `perm:"read"`
		LilyGapFill func(ctx context.Context, cfg *LilyGapFillConfig) (*schedule.JobSubmitResult, error) `perm:"read"`

		Shutdown func(context.Context) error `perm:"read"`

		SyncState func(ctx context.Context) (*api.SyncState, error) `perm:"read"`

		ChainHead                 func(context.Context) (*types.TipSet, error)                                                    `perm:"read"`
		ChainGetBlock             func(context.Context, cid.Cid) (*types.BlockHeader, error)                                      `perm:"read"`
		ChainReadObj              func(context.Context, cid.Cid) ([]byte, error)                                                  `perm:"read"`
		ChainStatObj              func(context.Context, cid.Cid, cid.Cid) (api.ObjStat, error)                                    `perm:"read"`
		ChainGetTipSet            func(context.Context, types.TipSetKey) (*types.TipSet, error)                                   `perm:"read"`
		ChainGetTipSetByHeight    func(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)                   `perm:"read"`
		ChainGetBlockMessages     func(context.Context, cid.Cid) (*api.BlockMessages, error)                                      `perm:"read"`
		ChainGetParentReceipts    func(context.Context, cid.Cid) ([]*types.MessageReceipt, error)                                 `perm:"read"`
		ChainGetParentMessages    func(context.Context, cid.Cid) ([]api.Message, error)                                           `perm:"read"`
		ChainGetTipSetAfterHeight func(context.Context, abi.ChainEpoch, types.TipSetKey) (*types.TipSet, error)                   `perm:"read"`
		ChainSetHead              func(context.Context, types.TipSetKey) error                                                    `perm:"read"`
		ChainGetGenesis           func(context.Context) (*types.TipSet, error)                                                    `perm:"read"`
		ChainPrune                func(ctx context.Context, opts api.PruneOpts) error                                             `perm:"read"`
		ChainHotGC                func(ctx context.Context, opts api.HotGCOpts) error                                             `perm:"read"`
		EthGetBlockByHash         func(ctx context.Context, blkHash ethtypes.EthHash, fullTxInfo bool) (ethtypes.EthBlock, error) `perm:"read"`
		EthGetTransactionReceipt  func(ctx context.Context, txHash ethtypes.EthHash) (*api.EthTxReceipt, error)                   `perm:"read"`
		ChainGetMessagesInTipset  func(ctx context.Context, tsk types.TipSetKey) ([]api.Message, error)                           `perm:"read"`
		EthGetTransactionByHash   func(ctx context.Context, txHash *ethtypes.EthHash) (*ethtypes.EthTx, error)                    `perm:"read"`
		StateListActors           func(ctx context.Context, tsk types.TipSetKey) ([]address.Address, error)                       `perm:"read"`
		GetActorEventsRaw         func(ctx context.Context, filter *types.ActorEventFilter) ([]*types.ActorEvent, error)          `perm:"read"`

		// SyncIncomingBlocks returns a channel streaming incoming, potentially not
		// yet synced block headers.
		SyncIncomingBlocks func(ctx context.Context) (<-chan *types.BlockHeader, error) `perm:"read"`

		LogList          func(context.Context) ([]string, error)     `perm:"read"`
		LogSetLevel      func(context.Context, string, string) error `perm:"read"`
		LogSetLevelRegex func(context.Context, string, string) error `perm:"read"`

		ID               func(context.Context) (peer.ID, error)                        `perm:"read"`
		NetAutoNatStatus func(context.Context) (api.NatInfo, error)                    `perm:"read"`
		NetPeers         func(context.Context) ([]peer.AddrInfo, error)                `perm:"read"`
		NetAddrsListen   func(context.Context) (peer.AddrInfo, error)                  `perm:"read"`
		NetPubsubScores  func(context.Context) ([]api.PubsubScore, error)              `perm:"read"`
		NetAgentVersion  func(context.Context, peer.ID) (string, error)                `perm:"read"`
		NetPeerInfo      func(context.Context, peer.ID) (*api.ExtendedPeerInfo, error) `perm:"read"`
		NetConnect       func(context.Context, peer.AddrInfo) error                    `perm:"read"`
		NetDisconnect    func(context.Context, peer.ID) error                          `perm:"read"`

		StartTipSetWorker func(ctx context.Context, cfg *LilyTipSetWorkerConfig) (*schedule.JobSubmitResult, error) `perm:"read"`

		FindOldestState func(ctx context.Context, limit int64) ([]*StateReport, error)      `perm:"read"`
		StateCompute    func(ctx context.Context, tsk types.TipSetKey) (interface{}, error) `perm:"read"`
	}
}

type LilyGapFillConfig struct {
	JobConfig LilyJobConfig

	To   int64
	From int64
}

type LilyGapFillNotifyConfig struct {
	GapFillConfig LilyGapFillConfig

	Queue string
}

type LilyGapFindConfig struct {
	JobConfig LilyJobConfig

	To   int64
	From int64
}

type LilyIndexConfig struct {
	JobConfig LilyJobConfig

	TipSet types.TipSetKey
}

type LilyIndexNotifyConfig struct {
	IndexConfig LilyIndexConfig

	Queue string
}

type LilyJobConfig struct {
	// Name is the name of the job.
	Name string
	// Tasks are executed by the job.
	Tasks []string
	// Window after which if an execution of the job is not complete it will be canceled.
	Window time.Duration
	// RestartOnFailure when true will restart the job if it encounters an error.
	RestartOnFailure bool
	// RestartOnCompletion when true will restart the job when it completes.
	RestartOnCompletion bool
	// RestartOnCompletion when true will restart the job when it completes.
	StopOnError bool
	// RestartDelay configures how long to wait before restarting the job.
	RestartDelay time.Duration
	// Storage is the name of the storage system the job will use, may be empty.
	Storage string
}

type LilyNodeAPI struct {
	fx.In `ignore-unexported:"true"`

	net.NetAPI
	full.ChainAPI
	full.StateAPI
	full.SyncAPI
	full.EthModuleAPI
	full.ActorEventAPI
	common.CommonAPI
	Events    *events.Events
	Scheduler *schedule.Scheduler

	ExecMonitor stmgr.ExecMonitor
	CacheConfig *util.CacheConfig

	StorageCatalog *storage.Catalog
	QueueCatalog   *distributed.Catalog
	// contains filtered or unexported fields
}

type LilySurveyConfig struct {
	JobConfig LilyJobConfig

	Interval time.Duration
}

type LilyTipSetWorkerConfig struct {
	JobConfig LilyJobConfig

	// Queue is the name of the queueing system the worker will consume work from.
	Queue string
}

type LilyWalkConfig struct {
	JobConfig LilyJobConfig

	From     int64
	To       int64
	Interval int
}

type LilyWalkNotifyConfig struct {
	WalkConfig LilyWalkConfig

	Queue string
}

type LilyWatchConfig struct {
	JobConfig LilyJobConfig

	BufferSize int // number of tipsets to buffer from notifier service
	Confidence int
	Workers    int // number of indexing jobs that can run in parallel
	Interval   int
}

type LilyWatchNotifyConfig struct {
	JobConfig LilyJobConfig

	BufferSize int // number of tipsets to buffer from notifier service
	Confidence int
	Queue      string
}

type LogQueryHook struct{}

type StateReport struct {
	Height      int64
	TipSet      *types.TipSet
	HasMessages bool
	HasReceipts bool
	HasState    bool
}