eventbus

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

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 ContentSavedEvent struct {
	ID         string
	Collection string
	Content    string
	Metadata   map[string]string
	Source     string // "knowledge" or "memory"
}

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 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 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
	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
}