contract

type ChainCore interface {
	// GetAccountAddress get addresses associated with account name
	GetAccountAddresses(accountName string) ([]string, error)
	// VerifyContractPermission verify permission of calling contract
	VerifyContractPermission(initiator string, authRequire []string, contractName, methodName string) (bool, error)
	// VerifyContractOwnerPermission verify contract ownership permisson
	VerifyContractOwnerPermission(contractName string, authRequire []string) error
	// QueryTransaction query confirmed tx
	QueryTransaction(txid []byte) (*pb.Transaction, error)
	// QueryBlock query block
	QueryBlock(blockid []byte) (ledger.BlockHandle, error)
}

type Context interface {
	Invoke(method string, args map[string][]byte) (*Response, error)
	ResourceUsed() Limits
	Release() error
}

type ContextConfig struct {
	State StateSandbox

	Initiator   string
	AuthRequire []string

	Caller string

	Module       string
	ContractName string

	ResourceLimits Limits

	// Whether contract can be initialized
	CanInitialize bool

	// The amount transfer to contract
	TransferAmount string

	// Contract being called
	// set by bridge to check recursive contract call
	ContractSet map[string]bool

	// ContractCodeFromCache control whether fetch contract code from XMCache
	ContractCodeFromCache bool
}

type ContractConfig struct {
	EnableDebugLog bool
	EnableUpgrade  bool
	LogDriver      logs.Logger

	Native  NativeConfig
	Wasm    WasmConfig
	Xkernel XkernelConfig
	EVM     EVMConfig
}

type ContractEventState interface {
	AddEvent(events ...*protos.ContractEvent)
}

type CrossQueryState interface {
}

type EVMConfig struct {
	Enable bool
	Driver string
}

type Iterator interface {
	Key() []byte
	Value() []byte
	Next() bool
	Error() error
	// Iterator 必须在使用完毕后关闭
	Close()
}

type KContext interface {
	// 交易相关数据
	Args() map[string][]byte
	Initiator() string
	Caller() string
	AuthRequire() []string

	// 状态修改接口
	StateSandbox

	AddResourceUsed(delta Limits)
	ResourceLimit() Limits

	Call(module, contract, method string, args map[string][]byte) (*Response, error)

	// 合约异步事件调用
	EmitAsyncTask(event string, args interface{}) error
}

type KernMethod func(ctx KContext) (*Response, error)

type KernRegistry interface {
	RegisterKernMethod(contract, method string, handler KernMethod)
	UnregisterKernMethod(ctract, method string)
	// RegisterShortcut 用于contractName缺失的时候选择哪个合约名字和合约方法来执行对应的kernel合约
	RegisterShortcut(oldmethod, contract, method string)
	GetKernMethod(contract, method string) (KernMethod, error)
}

type Limits struct {
	Cpu    int64
	Memory int64
	Disk   int64
	XFee   int64
}

type LogConfig struct {
	Module         string `yaml:"module,omitempty"`
	Filepath       string `yaml:"filepath,omitempty"`
	Filename       string `yaml:"filename,omitempty"`
	Fmt            string `yaml:"fmt,omitempty"`
	Console        bool   `yaml:"console,omitempty"`
	Level          string `yaml:"level,omitempty"`
	Async          bool   `yaml:"async,omitempty"`
	RotateInterval int    `yaml:"rotateinterval,omitempty"`
	RotateBackups  int    `yaml:"rotatebackups,omitempty"`
}

type Manager interface {
	NewContext(cfg *ContextConfig) (Context, error)
	NewStateSandbox(cfg *SandboxConfig) (StateSandbox, error)
	GetKernRegistry() KernRegistry
}

type ManagerConfig struct {
	Basedir  string
	BCName   string
	EnvConf  *xconfig.EnvConf
	Core     ChainCore
	XMReader ledger.XMReader

	Config *ContractConfig // used by testing
}

type NativeConfig struct {
	Driver string
	// Timeout (in seconds) to stop native code process
	StopTimeout int
	Docker      NativeDockerConfig
	Enable      bool
}

type NativeDockerConfig struct {
	Enable    bool
	ImageName string
	Cpus      float32
	Memory    string
}

type NewManagerFunc func(cfg *ManagerConfig) (Manager, error)

type RWSet struct {
	RSet []*ledger.VersionedData
	WSet []*ledger.PureData
}

type Response struct {
	// Status 用于反映合约的运行结果的错误码
	Status int `json:"status"`
	// Message 用于携带一些有用的debug信息
	Message string `json:"message"`
	// Data 字段用于存储合约执行的结果
	Body []byte `json:"body"`
}

type SandboxConfig struct {
	XMReader   ledger.XMReader
	UTXOReader UtxoReader
}

type State interface {
	XMState
	UTXOState
	CrossQueryState
	ContractEventState
}

type StateSandbox interface {
	State
	// Flush将缓存的UTXO，CrossQuery等内存状态写入到读写集
	// 没有调用Flush只能得到KV数据的读写集
	Flush() error
	RWSet() *RWSet
	UTXORWSet() *UTXORWSet
}

type UTXORWSet struct {
	Rset []*protos.TxInput
	WSet []*protos.TxOutput
}

type UTXOState interface {
	Transfer(from string, to string, amount *big.Int) error
}

type UtxoReader interface {
	SelectUtxo(string, *big.Int, bool, bool) ([]*protos.TxInput, [][]byte, *big.Int, error)
}

type WasmConfig struct {
	Enable bool
	Driver string
	XVM    XVMConfig
}

type XMState interface {
	Get(bucket string, key []byte) ([]byte, error)
	//扫描一个bucket中所有的kv, 调用者可以设置key区间[startKey, endKey)
	Select(bucket string, startKey []byte, endKey []byte) (Iterator, error)
	Put(bucket string, key, value []byte) error
	Del(bucket string, key []byte) error
}

type XVMConfig struct {
	// From 0 to 3
	// The higher the number, the faster the program runs,
	// but the compilation speed will be slower
	OptLevel int `yaml:"optlevel"`
}

type XkernelConfig struct {
	Enable bool
	Driver string

	Registry KernRegistry
}