cherryFacade

type ActorPath struct {
	NodeID  string
	ActorID string
	ChildID string
}

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

type IActor interface {
	App() IApplication
	ActorID() string
	Path() *ActorPath
	Call(targetPath, funcName string, arg any) int32
	CallWait(targetPath, funcName string, arg, reply any) int32
	CallType(nodeType, actorID, funcName string, arg any) int32
	PostRemote(m *Message)
	PostLocal(m *Message)
	LastAt() int64
	Exit()
}

type IActorChild interface {
	Create(id string, handler IActorHandler) (IActor, error)    // 创建子Actor
	Get(id string) (IActor, bool)                               // 获取子Actor
	Remove(id string)                                           // 称除子Actor
	Each(fn func(i IActor))                                     // 遍历所有子Actor
	Call(childID, funcName string, arg any)                     // 调用当前子actor的函数
	CallWait(targetPath, funcName string, arg, reply any) int32 // 调用当前子actor的函数并等待返回
}

type IActorHandler interface {
	AliasID() string                          // actorID
	OnInit()                                  // 当Actor启动前触发该函数
	OnStop()                                  // 当Actor停止前触发该函数
	OnLocalReceived(m *Message) (bool, bool)  // 当Actor接收local消息时触发该函数
	OnRemoteReceived(m *Message) (bool, bool) // 当Actor接收remote消息时执行的函数
	OnFindChild(m *Message) (IActor, bool)    // 当actor查找子Actor时触发该函数
}

type IActorSystem interface {
	GetIActor(id string) (IActor, bool)
	CreateActor(id string, handler IActorHandler) (IActor, error)
	PostRemote(m *Message) bool
	PostLocal(m *Message) bool
	PostEvent(data IEventData)
	Call(source, target, funcName string, arg any) int32
	CallWait(source, target, funcName string, arg, reply any) int32
	CallType(nodeType, actorID, funcName string, arg any) int32
	SetLocalInvoke(invoke InvokeFunc)
	SetRemoteInvoke(invoke InvokeFunc)
	SetCallTimeout(d time.Duration)
	SetArrivalTimeout(t int64)
	SetExecutionTimeout(t int64)
}

type IApplication interface {
	INode
	Running() bool                     // 是否运行中
	DieChan() chan bool                // die chan
	IsFrontend() bool                  // 是否为前端节点
	Register(components ...IComponent) // 注册组件
	Find(name string) IComponent       // 根据name获取组件对象
	Remove(name string) IComponent     // 根据name移除组件对象
	All() []IComponent                 // 获取所有组件列表
	OnShutdown(fn ...func())           // 关闭前执行的函数
	Startup()                          // 启动应用实例
	Shutdown()                         // 关闭应用实例
	Serializer() ISerializer           // 序列化
	Discovery() IDiscovery             // 发现服务
	Cluster() ICluster                 // 集群服务
	ActorSystem() IActorSystem         // actor系统
}

type ICluster interface {
	Mode() string                                                                        // cluster implement mode
	PublishLocal(nodeID string, msg *Message) error                                      // publish local message
	PublishRemote(nodeID string, msg *Message) error                                     // publish remote message
	PublishRemoteType(nodeType string, msg *Message) error                               // publish remote message by node type
	RequestRemote(nodeID string, msg *Message, timeout ...time.Duration) ([]byte, int32) // request remote message
}

type IClusterComponent interface {
	IComponent
	ICluster
}

type IComponent interface {
	Name() string
	App() IApplication
	IComponentLifecycle
}

type IComponentLifecycle interface {
	Set(app IApplication)
	Init()
	OnAfterInit()
	OnBeforeStop()
	OnStop()
}

type IConnector interface {
	IComponent
	Start()                     // 启动连接器
	Stop()                      // 停止连接器
	OnConnect(fn OnConnectFunc) // 建立新连接时触发的函数
}

type IDiscovery interface {
	Mode() string                                                 //
	Map() map[string]IMember                                      // get member list
	ListByType(nodeType string, filterNodeID ...string) []IMember // get member list by node type
	Random(nodeType string) (IMember, bool)                       // random member by node type
	GetType(nodeID string) (nodeType string, err error)           // get node type by node id
	GetMember(nodeID string) (member IMember, found bool)         // get member
	AddMember(member IMember)                                     // add member
	RemoveMember(nodeID string)                                   // remove member
	OnAddMember(listener MemberListener)                          // add member listener
	OnRemoveMember(listener MemberListener)                       // remove member listener
}

type IDiscoveryComponent interface {
	IComponent
	IDiscovery
}

type IEventData interface {
	Name() string    // 事件名
	UniqueID() int64 // 唯一id
}

type IMember interface {
	GetNodeID() string
	GetNodeType() string
	GetAddress() string
	GetSettings() map[string]string
}

type INetParser interface {
	Load(application IApplication)
	AddConnector(connector IConnector)
	Connectors() []IConnector
}

type INode interface {
	NodeID() string        // 节点id(全局唯一)
	NodeType() string      // 节点类型
	Address() string       // 对外网络监听地址(前端节点用)
	RpcAddress() string    // rpc监听地址(未用)
	Settings() ProfileJSON // 节点配置参数
	Enabled() bool         // 是否启用
}

type ISerializer interface {
	Marshal(interface{}) ([]byte, error) // 编码
	Unmarshal([]byte, interface{}) error // 解码
	Name() string                        // 序列化类型的名称
}

type InvokeFunc func(app IApplication, fi *creflect.FuncInfo, m *Message)

type MemberListener func(member IMember) // member add/remove listener

type Message struct {
	BuildTime int64       // message build time(ms)
	Source    string      // source actor path
	Target    string      // target actor path (node.actor or node.actor.child)
	FuncName  string      // target function name
	Args      interface{} // payload: same-node=decoded object, cross-node=[]byte (pending decode)

	// --- Local only (client->Actor, set by parser) ---
	Session *cproto.Session // client session

	// --- Remote only (Actor->Actor, set by System.Call/CallWait/CallType) ---
	ReqID      string           // NATS request ID (cross-node request-reply)
	Reply      string           // NATS reply subject (non-empty if from cross-node)
	ChanResult chan interface{} // same-node CallWait sync channel
	// contains filtered or unexported fields
}

type OnConnectFunc func(conn net.Conn)

type ProfileJSON interface {
	jsoniter.Any
	GetConfig(path ...interface{}) ProfileJSON
	GetString(path interface{}, defaultVal ...string) string
	GetBool(path interface{}, defaultVal ...bool) bool
	GetInt(path interface{}, defaultVal ...int) int
	GetInt32(path interface{}, defaultVal ...int32) int32
	GetInt64(path interface{}, defaultVal ...int64) int64
	GetDuration(path interface{}, defaultVal ...time.Duration) time.Duration
	Unmarshal(ptrVal interface{}) error
}

type SID = string // session unique id

type UID = int64 // user unique id