cfacade

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
	LastAt() int64
	Invoke(ctx *RequestContext, methodID uint32, payload any) *InvokeResult
	Notify(ctx *RequestContext, methodID uint32, payload any) *InvokeResult
	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
}

type IActorHandler interface {
	AliasID() string                       // actorID
	OnInit()                               // 当Actor启动前触发该函数
	OnStop()                               // 当Actor停止前触发该函数
	OnFindChild(m *Message) (IActor, bool) // 当actor查找子Actor时触发该函数
}

type IActorSystem interface {
	GetIActor(id string) (IActor, bool)
	CreateActor(id string, handler IActorHandler) (IActor, error)
	Invoke(ctx *RequestContext, methodID uint32, payload any) *InvokeResult
	InvokeNode(ctx *RequestContext, nodeID string, methodID uint32, payload any) *InvokeResult
	InvokeTarget(ctx *RequestContext, target string, methodID uint32, payload any) *InvokeResult
	Notify(ctx *RequestContext, methodID uint32, payload any) *InvokeResult
	NotifyNode(ctx *RequestContext, nodeID string, methodID uint32, payload any) *InvokeResult
	NotifyTarget(ctx *RequestContext, target string, methodID uint32, payload any) *InvokeResult
	SetCallTimeout(d time.Duration)
	SetExecutionTimeout(t int64)
}

type IApplication interface {
	INode
	Running() bool                     // 是否运行中
	DieChan() chan bool                // die chan
	Register(components ...IComponent) // 注册组件
	Find(name string) IComponent       // 根据name获取组件对象
	Remove(name string) IComponent     // 根据name移除组件对象
	All() []IComponent                 // 获取所有组件列表
	OnShutdown(fn ...func())           // 关闭前执行的函数
	Startup()                          // 启动应用实例
	Shutdown()                         // 关闭应用实例
	BodyCodecs() IBodyCodecRegistry    // 协议体编解码器注册表
	Discovery() IDiscovery             // 发现服务
	Cluster() ICluster                 // 集群服务
	ActorSystem() IActorSystem         // actor系统
	Methods() IMethodTable             // actor方法表
}

type IBodyCodec interface {
	ISerializer
	ID() int32
}

type IBodyCodecRegistry interface {
	Register(codec IBodyCodec) error
	Lookup(id int32) (IBodyCodec, bool)
	Marshal(id int32, value any) ([]byte, error)
	Unmarshal(id int32, data []byte, value any) error
	Default() int32
	SetDefault(id int32) error
}

type ICluster interface {
	Init()                                                                                                        // 初始化
	Publish(nodeID string, message *cproto.ClusterMessage) error                                                  // 发布远程消息
	Request(nodeID string, message *cproto.ClusterMessage, timeout time.Duration) (*cproto.ClusterMessage, error) // 请求远程消息
	Stop()                                                                                                        // 停止
}

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 {
	Load(app IApplication)
	Name() string                                                 // 发现服务名称
	Map() map[string]IMember                                      // 获取成员列表
	ListByType(nodeType string, filterNodeID ...string) []IMember // 根据节点类型获取列表
	Random(nodeType string) (IMember, bool)                       // 根据节点类型随机一个
	GetType(nodeID string) (nodeType string, err error)           // 根据节点id获取类型
	GetMember(nodeID string) (member IMember, found bool)         // 获取成员
	AddMember(member IMember)                                     // 添加成员
	RemoveMember(nodeID string)                                   // 移除成员
	OnAddMember(listener MemberListener)                          // 添加成员监听函数
	OnRemoveMember(listener MemberListener)                       // 移除成员监听函数
	Stop()
}

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

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

type IMethodTable interface {
	Register(methodID uint32, target string, msgType cproto.MsgType) error
	UnregisterTarget(target string)
	MsgType(methodID uint32) (cproto.MsgType, bool)
	// Target returns the top-level Actor registered for a MethodID.
	Target(methodID uint32) (string, bool)
	// Dispatch resolves the top-level Actor exclusively by MethodID.
	Dispatch(ctx *RequestContext, methodID uint32, body []byte, msgType cproto.MsgType) *InvokeResult
}

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

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

type InvokeResult struct {
	Payload any
	Code    int32
	Message string
}

type MemberListener func(member IMember) // MemberListener 成员增、删监听函数

type Message struct {
	MethodID uint32 // 请求调用的方法id
	Target   string // 目标actor path

	Context          *RequestContext    // 请求上下文
	Payload          any                // 请求的参数
	ChanInvokeResult chan *InvokeResult // 请求结果通道
	Cancel           context.CancelFunc // 释放 Actor 持有的通知上下文
	// contains filtered or unexported fields
}

type OnConnectFunc func(conn net.Conn)

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

type RequestContext struct {
	context.Context

	RequestID uint32
	Transport TransportType
	Codec     int32

	Session  *cproto.Session
	Metadata map[string][]byte
}

type SID = string // session unique id

type TransportType uint8

type TypedInvoke func(ctx *RequestContext, payload any) *InvokeResult

type UID = int64 // user unique id