proto

type AgentServiceClient interface {
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
	Send(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*SendResponse, error)
	Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (AgentService_ListenClient, error)
}

type AgentServiceServer interface {
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
	Send(context.Context, *SendRequest) (*SendResponse, error)
	Listen(*ListenRequest, AgentService_ListenServer) error
}

type AgentService_ListenClient interface {
	Recv() (*ListenResponse, error)
	grpc.ClientStream
}

type AgentService_ListenServer interface {
	Send(*ListenResponse) error
	grpc.ServerStream
}

type ExecuteRequest struct {
	AgentName string
	Input     *Message

	// Session context (optional)
	SessionID      string          // Session ID to use
	IncludeHistory bool            // Whether to include conversation history
	SessionContext *SessionContext // Full session context if needed
}

type ExecuteResponse struct {
	Output *Message

	// Session updates (if session was used)
	SessionUpdate *SessionUpdate
}

type ListenRequest struct {
	AgentName string
}

type ListenResponse struct {
	Message *Message
}

type Message struct {
	Id        string
	Type      string
	Payload   string
	Timestamp string
	Metadata  map[string]interface{}
}

type SendRequest struct {
	Target  string
	Message *Message
}

type SendResponse struct {
	Success bool
}

type SessionContext struct {
	ID        string
	UserID    string
	AgentName string
	History   []*Message // Conversation history
}

type SessionEntry struct {
	ID        string
	ParentID  string
	Timestamp int64
	Type      string
	Data      []byte
}

type SessionUpdate struct {
	NewEntries   []*SessionEntry
	MessageCount int32
}

type UnimplementedAgentServiceServer struct{}