events

type ACLMembershipChanged struct {
	Base
	Pubkey    []byte // The affected pubkey
	PrevLevel string // Previous access level
	NewLevel  string // New access level
	Reason    string // Reason for the change
}

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

type ClusterMembershipChanged struct {
	Base
	Event  *event.E // The kind 39108 event
	Action string   // "join" or "leave"
}

type ConnectionClosed struct {
	Base
	ConnectionID    string        // Unique connection identifier
	Duration        time.Duration // How long the connection was open
	EventsReceived  int           // Number of events received
	EventsPublished int           // Number of events published
}

type ConnectionOpened struct {
	Base
	ConnectionID string // Unique connection identifier
	RemoteAddr   string // Client IP:port
}

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

type DispatcherConfig struct {
	// AsyncBufferSize is the buffer size for async event delivery.
	// Default: 1000
	AsyncBufferSize int
}

type DispatcherStats struct {
	EventsPublished int64
	EventsDropped   int64
	SubscriberCount int
	QueueSize       int
	QueueCapacity   int
}

type DomainEvent interface {
	// OccurredAt returns when the event occurred.
	OccurredAt() time.Time
	// EventType returns a string identifier for the event type.
	EventType() string
}

type EventDeleted struct {
	Base
	EventID   []byte // The deleted event ID
	DeletedBy []byte // Pubkey that requested deletion
	Serial    uint64 // The serial of the deleted event
}

type EventSaved struct {
	Base
	Event   *event.E // The saved event
	Serial  uint64   // The assigned serial number
	IsAdmin bool     // Whether the author is an admin
	IsOwner bool     // Whether the author is an owner
}

type FollowListUpdated struct {
	Base
	AdminPubkey    []byte   // The admin whose follow list changed
	AddedFollows   [][]byte // Pubkeys that were added
	RemovedFollows [][]byte // Pubkeys that were removed
}

type MemberJoined struct {
	Base
	Pubkey     []byte // The new member's pubkey
	InviteCode string // The invite code used (if any)
}

type MemberLeft struct {
	Base
	Pubkey []byte // The departed member's pubkey
}

type PolicyConfigUpdated struct {
	Base
	UpdatedBy []byte                 // Pubkey that made the update
	Changes   map[string]interface{} // Changed configuration keys
}

type PolicyFollowsUpdated struct {
	Base
	AdminPubkey []byte   // The admin whose follows were processed
	FollowCount int      // Number of follows in the updated list
	Follows     [][]byte // The follow pubkeys (may be nil for large lists)
}

type RelayGroupConfigChanged struct {
	Base
	Event *event.E // The kind 39105 event
}

type Subscriber interface {
	// Handle processes the given domain event.
	Handle(event DomainEvent)
	// Supports returns true if this subscriber handles the given event type.
	Supports(eventType string) bool
}

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

type SubscriptionClosed struct {
	Base
	SubscriptionID string // The subscription ID
	ConnectionID   string // The connection this subscription belonged to
	EventsMatched  int    // Number of events that matched this subscription
}

type SubscriptionCreated struct {
	Base
	SubscriptionID string // The subscription ID from REQ
	ConnectionID   string // The connection this subscription belongs to
	FilterCount    int    // Number of filters in the subscription
}

type SyncSerialUpdated struct {
	Base
	Serial uint64 // The new serial number
}

type UserAuthenticated struct {
	Base
	Pubkey       []byte // The authenticated pubkey
	AccessLevel  string // The granted access level
	IsFirstTime  bool   // Whether this is a first-time user
	ConnectionID string // The connection ID
}