tools

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

type AgentAPI interface {
	ID() string
	PublicKey() string
	Discover(ctx context.Context, capabilities []string) ([]*discovery.DiscoverResult, error)
	Send(ctx context.Context, env *envelope.Envelope) error
	SendRequest(ctx context.Context, env *envelope.Envelope, timeout time.Duration) (*envelope.Envelope, error)
	Broadcast(ctx context.Context, env *envelope.Envelope, destinations []string) map[string]error
	AddContact(agentID string)
	RemoveContact(agentID string)
	BlockAgent(agentID string)
	ListContacts() []security.TrustEntry
}

type AgentProfile struct {
	ID                string    `json:"id"`
	Name              string    `json:"name"`
	Description       string    `json:"description,omitempty"`
	Version           string    `json:"version,omitempty"`
	PublicKey         string    `json:"public_key,omitempty"`
	Capabilities      []string  `json:"capabilities,omitempty"`
	Protocols         []string  `json:"protocols,omitempty"`
	Status            string    `json:"status"`
	Tags              []string  `json:"tags,omitempty"`
	Verified          bool      `json:"verified"`
	Trusted           bool      `json:"trusted"`
	ReputationScore   float64   `json:"reputation_score"`
	ReputationEvents  int64     `json:"reputation_events"`
	PlaygroundEnabled bool      `json:"playground_enabled"`
	TotalCalls        int64     `json:"total_calls"`
	EndpointURL       string    `json:"endpoint_url,omitempty"`
	RegisteredAt      time.Time `json:"registered_at"`
	Categories        []string  `json:"categories,omitempty"`
}

type BroadcastDestResult struct {
	Destination string `json:"destination"`
	Success     bool   `json:"success"`
	Error       string `json:"error,omitempty"`
}

type BroadcastInput struct {
	Destinations []string `json:"destinations"`
	Payload      string   `json:"payload"`
	Protocol     string   `json:"protocol,omitempty"`
}

type BroadcastOutput struct {
	Results []BroadcastDestResult `json:"results"`
}

type CheckReputationInput struct {
	AgentID string `json:"agent_id"`
	Limit   int    `json:"limit,omitempty"`
}

type ContactEntry struct {
	PublicKey string `json:"public_key"`
	Level     int    `json:"level"`
	LevelName string `json:"level_name"`
	FirstSeen string `json:"first_seen"`
	LastSeen  string `json:"last_seen,omitempty"`
	Alias     string `json:"alias,omitempty"`
}

type ContactInput struct {
	AgentID string `json:"agent_id"`
}

type DirectoryRequest struct {
	Capability string `json:"capability,omitempty"`
	Search     string `json:"search,omitempty"`
	PageSize   int    `json:"page_size,omitempty"`
}

type DirectoryResponse struct {
	Agents     []AgentProfile `json:"agents"`
	TotalCount int            `json:"total_count"`
}

type DiscoverAgentResult struct {
	ID        string `json:"id"`
	Name      string `json:"name"`
	PublicKey string `json:"public_key"`
}

type DiscoverInput struct {
	Capabilities []string `json:"capabilities"`
}

type GetProfileInput struct {
	AgentID string `json:"agent_id"`
}

type GetTaskInput struct {
	TraceID string `json:"trace_id"`
}

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

type InvokeInput struct {
	AgentID   string            `json:"agent_id"`
	Message   string            `json:"message"`
	Protocol  string            `json:"protocol,omitempty"`
	Metadata  map[string]string `json:"metadata,omitempty"`
	SessionID string            `json:"session_id,omitempty"`
}

type InvokeOutput struct {
	ID         string `json:"id"`
	AgentID    string `json:"agent_id"`
	Response   string `json:"response"`
	Protocol   string `json:"protocol"`
	DurationMs int64  `json:"duration_ms"`
	SessionID  string `json:"session_id,omitempty"`
}

type ListContactsOutput struct {
	Contacts []ContactEntry `json:"contacts"`
}

type ListTasksOutput struct {
	Tasks []TaskInfo `json:"tasks"`
}

type Options struct {
	// Agent is the local agent instance (required for P2P tools).
	Agent AgentAPI

	// TaskAPI provides optional task tracking capabilities.
	TaskAPI TaskAPI

	// APIClient is used for server-dependent tools (invoke, profile, reputation).
	// If nil, those tools will return errors when called.
	APIClient *APIClient

	// Disabled lists tool names to exclude from AvailableTools and reject in Handle.
	Disabled []string
}

type ReputationEvent struct {
	ID         int64     `json:"id"`
	AgentID    string    `json:"agent_id"`
	EventType  string    `json:"event_type"`
	Weight     float64   `json:"weight"`
	ScoreAfter float64   `json:"score_after"`
	Metadata   string    `json:"metadata,omitempty"`
	CreatedAt  time.Time `json:"created_at"`
}

type ReputationResult struct {
	Events []ReputationEvent `json:"events"`
}

type Result struct {
	Success bool            `json:"success"`
	Data    json.RawMessage `json:"data,omitempty"`
	Error   string          `json:"error,omitempty"`
}

type SendMessageInput struct {
	Destination string `json:"destination"`
	Payload     string `json:"payload"`
	Protocol    string `json:"protocol,omitempty"`
	MessageType string `json:"message_type,omitempty"`
}

type SendMessageOutput struct {
	MessageID string `json:"message_id"`
}

type SendRequestInput struct {
	Destination string `json:"destination"`
	Payload     string `json:"payload"`
	Protocol    string `json:"protocol,omitempty"`
	TimeoutSecs int    `json:"timeout_secs,omitempty"`
}

type SendRequestOutput struct {
	ResponsePayload string `json:"response_payload"`
	Source          string `json:"source"`
	TraceID         string `json:"trace_id"`
}

type TaskAPI interface {
	GetTask(traceID string) (*TaskInfo, bool)
	ListTasks() []*TaskInfo
}

type TaskInfo struct {
	ID        string `json:"id"`
	TraceID   string `json:"trace_id"`
	AgentID   string `json:"agent_id"`
	State     string `json:"state"`
	CreatedAt string `json:"created_at"`
	UpdatedAt string `json:"updated_at"`
}