schema

type Config struct {
	RedisUrl string `json:"redisUrl" yaml:"redisUrl"`
	Keyfile  string `json:"keyfile" yaml:"keyfile"`
	OptType  string `json:"optType" yaml:"optType"`
}

type DownloadResult struct {
	Nonce      int64
	Assignment *goarSchema.BundleItem
	Message    *goarSchema.BundleItem
}

type GraphQLEdge struct {
	Cursor string      `json:"cursor"`
	Node   GraphQLNode `json:"node"`
}

type GraphQLNode struct {
	ID   string       `json:"id"`
	Tags []GraphQLTag `json:"tags"`
}

type GraphQLPageInfo struct {
	HasNextPage bool `json:"hasNextPage"`
}

type GraphQLResp struct {
	Transactions GraphQLTransactions `json:"transactions"`
}

type GraphQLTag struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type GraphQLTransactions struct {
	PageInfo GraphQLPageInfo `json:"pageInfo"`
	Edges    []GraphQLEdge   `json:"edges"`
}

type IDB interface {
	AddPending(txid string) error
	MoveToUploading() (int64, error)
	EndUpload() error

	IsUploadedBatch(txids []string) (map[string]bool, error)
	GetUploading() ([]string, error)
	SetBundledIn(bundledInID string) error
	GetBundledIn() (string, error)
}

type INode interface {
	// DB
	GetMessage(msgid string) (msg *goarSchema.BundleItem, err error)
	GetMessageByNonce(pid string, nonce int64) (msg *goarSchema.BundleItem, err error)

	GetAssignByMessage(msgid string) (assign *goarSchema.BundleItem, err error)
	GetAssignByNonce(pid string, nonce int64) (assign *goarSchema.BundleItem, err error)
}

type IOperator interface {
	// Upload a transaction in BundleItem form; a BundleItem may nest multiple BundleItems.
	// The outermost BundleItem is submitted to the network as the atomic Transaction.
	// The outermost BundleItem's txID is used as parentTxID when downloading.
	Upload(items []goarSchema.BundleItem) (txid string, err error)

	// Download a transaction
	// return BundleItem format
	Download(itemID string) (*goarSchema.BundleItem, error)

	// Download multiple transactions
	Downloads(itemIDs []string) ([]*goarSchema.BundleItem, error)

	// Execute a GraphQL query.
	GraphQL(query string) ([]byte, error)

	// Check if a transaction upload success
	CheckTransaction(txid string) (bool, error)
}