types

type Context interface {
	Name() string

	GetImports() ImportsHandler
	SetImports(ImportsHandler)

	GetExports() Exports

	GetInstance() Instance
	SetInstance(Instance)

	OnCreated(Instance)
	OnDestroy(Instance)
}

type DefaultImportsAsyncCall struct{}

type DefaultImportsChainOperation struct{}

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

type DefaultImportsEventType struct {
}

type DefaultImportsKVStore struct{}

type DefaultImportsMQTT struct{}

type DefaultImportsMetrics struct{}

type DefaultImportsResource struct {
}

type DefaultImportsSQL struct{}

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

type Exports interface {
	// OnEventReceived pass data to wasm to handle event
	// entry wasm entry
	// typ event type
	// data payload
	OnEventReceived(entry string, typ string, data []byte) (interface{}, uint64, error)
}

type Function interface {
	Call(args ...any) (any, error)
	Params() []string
	Results() []string
}

type ImportsAsyncCall interface {
	// AsyncAPICall call async api
	AsyncAPICall(req []byte) ([]byte, error)
}

type ImportsChainOperation interface {
	// SendTX send tx by chain id and data, returns tx hash and error
	SendTX(chainID uint32, data []byte) (string, error)
	// SendTXWithOperator
	SendTXWithOperator(chainID uint32, data []byte) (string, error)
	// CallContract call contract by chain id and data, returns call result
	CallContract(chainID uint32, data []byte) ([]byte, error)
}

type ImportsContext interface {
	Entry(contextID string) bool
	Leave(contextID string) bool
	ContextID() string
}

type ImportsEventType interface {
	// GetEventType get event type by resource id
	GetEventType(rid uint32) (string, bool)
	// SetEventType set event type by resource id
	SetEventType(rid uint32, typ string) error
	// RemoveEventType remove event type by resource id
	RemoveEventType(rid uint32)
}

type ImportsHandler interface {
	ImportsSystem
	ImportsContext
	ImportsResource
	ImportsEventType
	ImportsKVStore
	ImportsSQL
	ImportsChainOperation
	ImportsMQTT
	ImportsMetrics
	ImportsAsyncCall
}

type ImportsKVStore interface {
	// GetKVData read value by key from kv store
	GetKVData(key string) ([]byte, error)
	// SetKVData set value by key to kv store
	SetKVData(key string, data []byte) error
}

type ImportsMQTT interface {
	// PubMQTT publish mqtt message
	PubMQTT(topic string, message []byte) error
}

type ImportsMetrics interface {
	// SubmitMetrics submit metrics
	SubmitMetrics(data []byte) error
}

type ImportsResource interface {
	// GetResourceData get resource data by resource id
	GetResourceData(rid uint32) ([]byte, bool)
	// SetResourceData set resource data by resource id
	SetResourceData(rid uint32, data []byte) error
	// RemoveResourceData remove resource data by resource id
	RemoveResourceData(rid uint32)
}

type ImportsSQL interface {
	// ExecSQL exec sql query
	ExecSQL(q string) error
	// QuerySQL query data
	QuerySQL(q string) ([]byte, error)
}

type ImportsSystem interface {
	// Log host log
	Log(level consts.LogLevel, msg string)
	// LogInternal
	LogInternal(level consts.LogLevel, msg string, args ...any)
	// FlushLog
	FlushLog()
	// Env get env var by key
	Env(key string) (string, bool)
	// Abort
	Abort(msg, filename string, line, col int32)
	// Trace is reserved for imported func env.trace() which is auto-generated by assembly-script
	Trace(msg string, trace string)
	// Seed is reserved for imported func env.seed() which is auto-generated by assembly-script
	Seed() float64
}

type Instance interface {
	ID() string
	// RegisterImports
	RegisterImports(name string) error

	// Start starts wasm instance
	Start() error
	// Stop stops wasm instance
	Stop()
	// Started returns if instance is started
	Started() bool

	// GetModule get current wasm module
	GetModule() Module
	// GetExportsFunc returns the exported func of the wasm instance by name
	GetExportsFunc(name string) (Function, error)
	// GetExportsMem returns the exported memory of the wasm instance
	GetExportsMem(name string) ([]byte, error)

	// GetByte returns the wasm byte from the specified addr
	GetByte(addr int32) (byte, error)
	// PutByte set a wasm byte to specified addr
	PutByte(addr int32, v byte) error
	// GetUint32 returns the u32 value from the specified addr
	GetUint32(addr int32) (uint32, error)
	// PutUint32 sets u32 value to the specified addr
	PutUint32(addr int32, v uint32) error
	// GetMemory returns wasm memory
	GetMemory(addr int32, size int32) ([]byte, error)
	// PutMemory
	PutMemory(addr int32, size int32, data []byte) error
	// Malloc allocates size of memory from wasm default memory
	Malloc(size int32) (int32, error)

	// GetUserdata get user-defined data
	GetUserdata() any
	// SetUserdata set user-define data into wasm instance
	SetUserdata(any)
	// Lock gets the exclusive ownership of the wasm instance and sets userdata
	Lock(any)
	// Unlock releases the exclusive ownership of the wasm instance and unref userdata
	Unlock()

	// Acquire increases the refer count of wasm instance
	Acquire() bool
	// Release decreases the refer count of wasm instance
	Release()

	// Call wasm function with name and args, returns wasm return value, fuel consumed, and error
	Call(string, ...interface{}) (interface{}, uint64, error)

	HandleError(error)
}

type Module interface {
	// Init was invoked when creating a wasm module
	Init()
	// NewInstance instantiates a wasm vm instance
	NewInstance() Instance
	// GetABINameList returns the abi name list exported from wasm module
	GetABINameList() []string
}

type VM interface {
	ID() string
	// Name the name of the wasm vm
	Name() string
	// Init was invoked when creating a new wasm vm
	Init()
	// NewModule compile user code into a wasm module
	NewModule(code []byte) (Module, error)
	// Close to prevent from memory leaking
	Close() error
}