eventbus

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

type AlertEvent struct {
	Type       string // "policy_block_rate", "recovery_retries", "circuit_breaker"; "config_drift" is planned
	Severity   string // "warning", "critical"
	Message    string
	Details    map[string]interface{}
	SessionKey string
	Timestamp  time.Time
}

type BudgetAlertEvent struct {
	TaskID    string
	Threshold float64 // the threshold percentage that was crossed (e.g. 0.5, 0.8)
}

type BudgetExhaustedEvent struct {
	TaskID     string
	TotalSpent *big.Int
}

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

type ChannelMessageReceivedEvent struct {
	Channel    string // "telegram", "discord", "slack"
	SessionKey string // e.g., "telegram:123:456"
	SenderName string // username or display name
	SenderID   string // platform user ID
	Text       string // message content
	Timestamp  time.Time
	Metadata   map[string]string // platform-specific extras (ThreadTS, GuildID, etc.)
}

type ChannelMessageSentEvent struct {
	Channel      string // "telegram", "discord", "slack"
	SessionKey   string
	ResponseText string
	Timestamp    time.Time
}

type ContentSavedEvent struct {
	ID         string
	Collection string
	Content    string
	Metadata   map[string]string
	Source     string // "knowledge" or "memory"
	IsNew      bool   // true for first-time creation, false for updates
	NeedsGraph bool   // true when graph triple extraction should also run
	Version    int    // Knowledge version; 0 for non-versioned collections
}

type ContextInjectedEvent struct {
	TurnID           string // from session.TurnIDFromContext; "" if not in turn runner
	SessionKey       string
	Query            string // raw user query (processor must not log this — PII)
	Items            []ContextInjectedItem
	KnowledgeTokens  int
	RAGTokens        int
	MemoryTokens     int
	RunSummaryTokens int
	TotalTokens      int
	Timestamp        time.Time
}

type ContextInjectedItem struct {
	Layer         string // human-readable layer name (from ContextLayer.String())
	Key           string
	Score         float64 // normalized: higher = better
	Source        string  // search source: "fts5", "like"
	Category      string
	TokenEstimate int
}

type EscrowCreatedEvent struct {
	EscrowID string
	PayerDID string
	PayeeDID string
	Amount   *big.Int
}

type EscrowDanglingEvent struct {
	EscrowID     string
	BuyerDID     string
	SellerDID    string
	Amount       string // string representation of *big.Int
	PendingSince time.Time
	Action       string // "expired", "refunded"
}

type EscrowMilestoneEvent struct {
	EscrowID    string
	MilestoneID string
	Index       int
}

type EscrowOnChainDepositEvent struct {
	EscrowID string
	DealID   string
	Buyer    string
	Amount   *big.Int
	TxHash   string
}

type EscrowOnChainDisputeEvent struct {
	EscrowID  string
	DealID    string
	Initiator string
	TxHash    string
}

type EscrowOnChainRefundEvent struct {
	EscrowID string
	DealID   string
	Buyer    string
	Amount   *big.Int
	TxHash   string
}

type EscrowOnChainReleaseEvent struct {
	EscrowID string
	DealID   string
	Seller   string
	Amount   *big.Int
	TxHash   string
}

type EscrowOnChainResolvedEvent struct {
	EscrowID    string
	DealID      string
	SellerFavor bool
	Amount      *big.Int
	TxHash      string
}

type EscrowOnChainWorkEvent struct {
	EscrowID string
	DealID   string
	Seller   string
	WorkHash string
	TxHash   string
}

type EscrowReleasedEvent struct {
	EscrowID string
	Amount   *big.Int
}

type EscrowReorgDetectedEvent struct {
	PreviousBlock uint64
	NewBlock      uint64
	Depth         uint64
	ExceedsDepth  bool // reorg deeper than confirmationDepth
}

type Event interface {
	EventName() string
}

type GitDivergenceInfo struct {
	MemberDID string
	HeadHash  string
}

type HandlerFunc func(event Event)

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

type NegotiationCompletedEvent struct {
	SessionID    string
	InitiatorDID string
	ResponderDID string
	AgreedPrice  *big.Int
}

type NegotiationFailedEvent struct {
	SessionID string
	Reason    string // "rejected", "expired", "cancelled"
}

type NegotiationStartedEvent struct {
	SessionID    string
	InitiatorDID string
	ResponderDID string
	ToolName     string
}

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

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

type PolicyDecisionEvent struct {
	Command    string
	Unwrapped  string
	Verdict    string // "allow", "observe", "block"
	Reason     string // machine-readable reason code
	Message    string
	SessionKey string
	AgentName  string
}

type ReputationChangedEvent struct {
	PeerDID  string
	NewScore float64
}

type SandboxDecisionEvent struct {
	SessionKey string
	Source     string // "exec" | "skill" | "mcp"
	Command    string // user-facing command, skill name, or MCP server name
	Decision   string // "applied" | "skipped" | "rejected" | "excluded"
	Backend    string // "bwrap" | "seatbelt" | "noop" | ""
	Reason     string // empty for "applied", populated otherwise
	Pattern    string // populated for "excluded" only
	Timestamp  time.Time
}

type SchemaExchangeEvent struct {
	PeerDID    string // remote peer DID
	Direction  string // "export" or "import"
	TypeCount  int    // number of types exchanged
	PredCount  int    // number of predicates exchanged
	ImportMode string // import mode used (empty for export)
}

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 TeamBudgetWarningEvent struct {
	TeamID    string
	Threshold float64
	Spent     float64
	Budget    float64
}

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 TeamGracefulShutdownEvent struct {
	TeamID         string
	Reason         string
	BundlesCreated int
	MembersSettled 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 TeamMemberUnhealthyEvent struct {
	TeamID      string
	MemberDID   string
	MemberName  string
	MissedPings int
	LastSeenAt  time.Time
}

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 TokenUsageEvent struct {
	Provider     string
	Model        string
	SessionKey   string
	AgentName    string
	InputTokens  int64
	OutputTokens int64
	TotalTokens  int64
	CacheTokens  int64
}

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
	SubjectType string
	ObjectType  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
}

type WorkspaceArchivedEvent struct {
	WorkspaceID string
	ArchivedAt  time.Time
}

type WorkspaceCommitReceivedEvent struct {
	WorkspaceID string
	CommitHash  string
	SenderDID   string
	Message     string
	ReceivedAt  time.Time
}

type WorkspaceCreatedEvent struct {
	WorkspaceID string
	Name        string
	Goal        string
	CreatorDID  string
	CreatedAt   time.Time
}

type WorkspaceGitDivergenceEvent struct {
	WorkspaceID  string
	MajorityHead string
	Divergent    []GitDivergenceInfo
	DetectedAt   time.Time
}

type WorkspaceMemberJoinedEvent struct {
	WorkspaceID string
	MemberDID   string
	JoinedAt    time.Time
}

type WorkspaceMemberLeftEvent struct {
	WorkspaceID string
	MemberDID   string
	LeftAt      time.Time
}

type WorkspaceMessagePostedEvent struct {
	WorkspaceID string
	MessageID   string
	MessageType string
	SenderDID   string
	PostedAt    time.Time
}