common_type

type APICore interface {
	Fetch(*HttpRequest) *HttpResponse
}

type Ability interface {
	Call(kind string, req []byte) ([]byte, PluginError)
}

type AbilityRequest struct {
	ID   string `json:"id"`
	Type string `json:"type"`
	Func string `json:"func"`
	Args []byte `json:"args"`
}

type AbilityResponse struct {
	Data []byte      `json:"data"`
	Err  PluginError `json:"err"`
}

type AsyncInvokeCallbackParams func(PluginError)

type ColumnDesc struct {
	Index int64
	Name  string
	Type  string
}

type DBCallBack func([]*RawData, []*ColumnDesc, PluginError)

type EventPublisher interface {
	Subscribe(condition []string) PluginError                                       // 不支持通配符, ex: project.task.create
	SubscribeWithFilter(condition []string, filter map[string][]string) PluginError // 支持过滤条件, ex: filter: project_uuid_in:[""]
	Unsubscribe(condition []string) PluginError                                     // 支持通配符
}

type HeaderVal struct {
	Val []string
}

type HostBootInfo struct {
	ID      string
	Name    string
	Version string
}

type HostBootStatus int

type HostInfo struct {
	ID               string
	Name             string
	Version          string
	MinSystemVersion string
	Language         string
	LanguageVersion  string
	RunningPlugins   map[string]IInstanceDescription
	SupportPlugins   map[string]IInstanceDescription
}

type HostStatus int

type HttpContext struct {
	Params   map[string]string
	Request  *HttpRequest
	Response *HttpResponse
}

type HttpRequest struct {
	Method   string
	QueryMap map[string]string
	Url      string
	Path     string
	Headers  map[string][]string
	Body     []byte
	Root     bool
}

type HttpResponse struct {
	Err        PluginError
	Headers    map[string][]string
	Body       []byte
	StatusCode int
}

type IHost interface {
	//Store()
	GetInfo() HostInfo
	GetStatus() HostStatus
}

type IHostBoot interface {
	GetInfo() HostBootInfo
	GetStatus() HostBootStatus
}

type IInstanceDescription interface {
	PluginDescription() IPluginDescriptor
	InstanceID() string
}

type IPlugin interface {
	// 程序实现
	Assign(pid IInstanceDescription, resources IResources) PluginError
	GetPluginDescription() IInstanceDescription

	// 业务动作
	Enable(LifeCycleRequest) PluginError
	Disable(LifeCycleRequest) PluginError
	Install(LifeCycleRequest) PluginError
	UnInstall(LifeCycleRequest) PluginError
	Upgrade(IVersion, LifeCycleRequest) PluginError
	CheckState() PluginError
	CheckCompatibility() PluginError

	// 事件相关
	OnEvent(eventType string, payload []byte) PluginError

	// 配置修改
	OnConfigChange(configKey string, originValue, newValue []string) PluginError

	// 外部请求
	OnExternalHttpRequest(request *HttpRequest) *HttpResponse
}

type IPluginDescriptor interface {
	ApplicationID() string
	Name() string
	Language() string
	LanguageVersion() IVersion
	ApplicationVersion() IVersion
	HostVersion() IVersion
	MinSystemVersion() IVersion
}

type IResources interface {
	GetLogger() PluginLogger
	GetWorkspace() Workspace
	GetLocalDB() LocalDB
	GetEventPublisher() EventPublisher
	GetSysDB() SysDB
	GetAPICore() APICore
	GetOutDoor() Network
	GetAbility() Ability
}

type IVersion interface {
	Major() int
	Minor() int
	Revision() int
	VersionString() string
	Relationship(IVersion) VersionTime
}

type LifeCycleRequest struct {
	Headers map[string]*HeaderVal
}

type LocalDB interface {
	Select(sql string) ([]*RawData, []*ColumnDesc, PluginError)
	AsyncSelect(sql string, callback DBCallBack)
	// Unmarshal eg:
	//	type User struct {
	//		UUID string `orm:"uuid"`
	//		Name string `orm:"name"`
	//	}
	//	users := make([]*User, 0)
	//	err = Unmarshal(rawData, colDesc, &users)
	Unmarshal(rawData []*RawData, columnDesc []*ColumnDesc, v interface{}) PluginError
	Exec(sql string) PluginError
	ImportSQL(sqlFilePath string) PluginError
}

type MockHost struct {
	Info   HostInfo
	Status HostStatus
}

type MockHostBoot struct {
	Info   HostBootInfo
	Status HostBootStatus
}

type MockInstanceDesc struct {
	PluginInstanceID string
	PluginDescriptor *MockPluginDescriptor
}

type MockPluginDescriptor struct {
	AppID      string
	PluginName string
	Lang       string
	LangVer    string
	AppVer     string
	HostVer    string
	MinSysVer  string
}

type Network interface {
	Fetch(*HttpRequest) *HttpResponse

	AsyncFetch(*HttpRequest, NetworkCallBack)
}

type NetworkCallBack func(*HttpResponse, PluginError)

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

type PluginError interface {
	Code() int
	Error() string
	Msg() string
}

type PluginFactory interface {
	GetPlugin() IPlugin
}

type PluginLogger interface {
	Trace(string)
	Info(string)
	Warn(string)
	Error(string)
}

type RawData struct {
	Cell [][]byte
}

type SysDB interface {
	Select(db, sql string) ([]*RawData, []*ColumnDesc, PluginError)
	AsyncSelect(db, sql string, callback DBCallBack)
	Exec(db, sql string) PluginError
	// Unmarshal eg:
	//	type User struct {
	//		UUID string `orm:"uuid"`
	//		Name string `orm:"name"`
	//	}
	//	users := make([]*User, 0)
	//	err = Unmarshal(rawData, colDesc, &users)
	Unmarshal(rawData []*RawData, columnDesc []*ColumnDesc, v interface{}) PluginError
}

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

type VersionTime int

type Workspace interface {
	CreateFile(string) PluginError
	MakeDir(string) PluginError
	Rename(string, string) PluginError
	Remove(string) PluginError
	IsExist(string) (bool, PluginError)
	IsDir(string) (bool, PluginError)
	Copy(string, string) PluginError
	Read(string) ([]byte, PluginError)
	ReadLines(string, int32, int32) ([]byte, PluginError)
	WriteBytes(string, []byte) PluginError
	AppendBytes(string, []byte) PluginError
	WriteStrings(string, []string) PluginError
	AppendStrings(string, []string) PluginError
	Zip(string, []string) PluginError
	UnZip(string, string) PluginError
	Gz(string) PluginError
	UnGz(string, string) PluginError
	Hash(string) ([]byte, PluginError)
	List(string) ([]string, PluginError)

	AsyncCopy(string, string, AsyncInvokeCallbackParams)
	AsyncZip(string, []string, AsyncInvokeCallbackParams)
	AsyncUnZip(string, string, AsyncInvokeCallbackParams)
	AsyncGz(string, AsyncInvokeCallbackParams)
	AsyncUnGz(string, string, AsyncInvokeCallbackParams)
}