subgraph

type Base struct {
	Intrinsics
	*Definition

	ID  string // QmHELLOWORLD as fetched when necessary
	Log *zap.Logger
}

type BlockRef interface {
	ID() string
	Number() uint64
	Timestamp() time.Time
}

type DDL interface {
	InitiateSchema(handleStatement func(statement string) error) error
	CreateTables(handleStatement func(table string, statement string) error) error
	CreateIndexes(handleStatement func(table string, statement string) error) error
	DropIndexes(handleStatement func(table string, statement string) error) error
}

type Definition struct {
	PackageName string

	HighestParallelStep int

	StartBlock    uint64
	IncludeFilter string
	Entities      *graphnode.Registry
	DDL           DDL
	Manifest      string
	GraphQLSchema string
	Abis          map[string]string

	New       func(Base) Subgraph
	MergeFunc func(step int, current, next graphnode.Entity) graphnode.Entity
}

type Intrinsics interface {
	Save(entity graphnode.Entity) error
	Load(entity graphnode.Entity) error
	LoadAllDistinct(model graphnode.Entity, blockNum uint64) ([]graphnode.Entity, error)
	Remove(entity graphnode.Entity) error

	// Block returns the current block being processed by your subgraph handler.
	Block() BlockRef

	/// Reproc
	Step() int
	StepBelow(step int) bool
	StepAbove(step int) bool

	/// JSON-RPC
	RPC(calls []*RPCCall) ([]*RPCResponse, error)
}

type RPCCall struct {
	ToAddr          string
	MethodSignature string // ex: "name() (string)"
}

type RPCResponse struct {
	Decoded       []interface{}
	Raw           string
	DecodingError error
	CallError     error // always deterministic
}

type Subgraph interface {
	Init() error

	LoadDynamicDataSources(blockNum uint64) error

	LogStatus()
}