eventbus

type AgentDiscoveredEvent struct {
	DID          string
	Name         string
	Capabilities []string
}

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

type ContentSavedEvent struct {
	ID         string
	Collection string
	Content    string
	Metadata   map[string]string
	Source     string // "knowledge" or "memory"
}

type Event interface {
	EventName() string
}

type HandlerFunc func(event Event)

type MemoryGraphEvent struct {
	Triples    []Triple
	SessionKey string
	Type       string // "observation" or "reflection"
}

type PaymentNegotiatedEvent struct {
	TeamID   string
	AgentDID string
	Mode     string
	Price    float64
}

type PaymentSettledEvent struct {
	TeamID   string
	AgentDID string
	Amount   float64
	TxHash   string
}

type ReputationChangedEvent struct {
	PeerDID  string
	NewScore float64
}

type TaskCompletedEvent struct {
	TeamID     string
	TaskID     string
	AgentDID   string
	Success    bool
	DurationMs int64
}

type TaskDelegatedEvent struct {
	TeamID   string
	TaskID   string
	AgentDID string
}

type TaskFailedEvent struct {
	TeamID   string
	TaskID   string
	AgentDID string
	Error    string
}

type TeamConflictDetectedEvent struct {
	TeamID   string
	ToolName string
	Members  int
}

type TeamDisbandedEvent struct {
	TeamID string
	Reason string
}

type TeamFormedEvent struct {
	TeamID    string
	Name      string
	Goal      string
	LeaderDID string
	Members   int
}

type TeamHealthCheckEvent struct {
	TeamID  string
	Healthy int
	Total   int
}

type TeamLeaderChangedEvent struct {
	TeamID       string
	OldLeaderDID string
	NewLeaderDID string
}

type TeamMemberJoinedEvent struct {
	TeamID    string
	MemberDID string
	Role      string
}

type TeamMemberLeftEvent struct {
	TeamID    string
	MemberDID string
	Reason    string
}

type TeamPaymentAgreedEvent struct {
	TeamID    string
	MemberDID string
	Mode      string
	Price     string
}

type TeamTaskCompletedEvent struct {
	TeamID     string
	ToolName   string
	Successful int
	Failed     int
	Duration   time.Duration
}

type TeamTaskDelegatedEvent struct {
	TeamID   string
	ToolName string
	Workers  int
}

type ToolExecutionPaidEvent struct {
	PeerDID      string
	ToolName     string
	Auth         interface{} // *eip3009.Authorization (interface to avoid import cycle)
	SettlementID string      // non-empty for post-pay deferred entries
}

type Triple struct {
	Subject   string
	Predicate string
	Object    string
	Metadata  map[string]string
}

type TriplesExtractedEvent struct {
	Triples []Triple
	Source  string // e.g. "learning", "analysis", "librarian"
}

type TrustUpdatedEvent struct {
	AgentDID string
	OldScore float64
	NewScore float64
}

type TurnCompletedEvent struct {
	SessionKey string
}