domain

type AllDMInfo struct {
	ChannelID     int64
	ChannelName   string
	User1Username string // removed User1ID, User2ID — not needed
	User2Username string
}

type BackupStore interface {
	Store
	ImportMessage(channelID int64, identityID string, body string, threadID *int64, mentionIdentityIDs []string, createdAt time.Time) (int64, error)
	IsEmpty() (bool, error)
	WipeAll() error
}

type Channel struct {
	ID        int64
	Name      string
	Public    bool
	Type      string // "channel" or "dm"
	CreatedAt time.Time
}

type ChannelStore interface {
	CreateChannel(name string, public bool, memberIDs []string, channelType string) (int64, error)
	GetChannelByID(id int64) (*Channel, error)
	GetChannelByName(name string) (*Channel, error)
	ListChannelsForUser(identityID string) ([]ChannelWithMembership, error)
	ListAllChannelsWithMembership(identityID string) ([]ChannelWithMembership, error)
	AddChannelMember(channelID int64, identityID string) error
	ChannelMemberUsernames(channelID int64) ([]string, error)
	IsChannelMember(channelID int64, identityID string) (bool, error)
	GetServiceMemberUsernames(channelID int64) ([]string, error)
	ListDMsForUser(identityID string) ([]DMInfo, error)
	ListAllDMs() ([]AllDMInfo, error)
	OpenDM(identityID string, otherIdentityID string, otherUsername string) (string, bool, error)
}

type ChannelWithMembership struct {
	Channel
	Member bool
}

type DMInfo struct {
	ChannelID     int64
	ChannelName   string
	OtherUsername string // removed OtherUserID — not needed
}

type Event struct {
	Type    string
	Payload any
}

type EventBus interface {
	Publish(event Event)
	Subscribe(eventTypes ...string) Subscription
}

type Identity struct {
	ID          string // Internal stable UUID (never changes after creation)
	AuthID      string // Passport-provided UUID (may change if user is recreated)
	Username    string
	DisplayName string
	Type        string // "user", "agent", "service"
	Role        string
	CreatedAt   time.Time
}

type IdentityStore interface {
	UpsertIdentity(authID, username, displayName, identityType, role string) (*Identity, error)
	GetIdentityByID(id string) (*Identity, error)
	GetIdentityByUsername(username string) (*Identity, error)
	ListIdentities() ([]Identity, error)
}

type IdentityWebhook struct {
	ID         string
	IdentityID string
	URL        string
	Active     bool
}

type MentionGroup struct {
	ID        int64     `json:"id"`
	Slug      string    `json:"slug"`
	CreatedBy string    `json:"created_by,omitempty"`
	Members   []string  `json:"members,omitempty"`
	CreatedAt time.Time `json:"created_at,omitempty"`
}

type MentionGroupStore interface {
	CreateMentionGroup(slug string, createdByID string) (int64, error)
	DeleteMentionGroup(id int64) error
	GetMentionGroup(slug string) (*MentionGroup, error)
	ListMentionGroups() ([]MentionGroup, error)
	AddMentionGroupMember(groupID int64, identityID string) error
	RemoveMentionGroupMember(groupID int64, identityID string) error
	GetMentionGroupMembers(groupID int64) ([]string, error)
	ExpandMentionGroups(slugs []string) (map[string][]string, error)
}

type Message struct {
	ID         int64
	ChannelID  int64
	IdentityID string // was UserID int64
	From       string
	Body       string
	ThreadID   *int64
	Mentions   []string
	Metadata   *string // JSON string, nullable
	CreatedAt  time.Time
}

type MessageEvent struct {
	ChannelName string
	ChannelType string // "channel" or "dm"
	From        string
	Body        string
	MessageID   int64
	SentAt      time.Time
	Mentions    []string
	ThreadID    *int64
	Metadata    *string // JSON string, opaque
}

type MessageStore interface {
	SendMessage(channelID int64, identityID string, body string, threadID *int64, mentionIdentityIDs []string, metadata *string) (int64, error)
	GetMessages(channelID int64, before *int64, after *int64, limit int, threadID *int64) ([]Message, error)
	GetUnreadMessages(identityID string, channelID *int64, mentionsOnly bool, threadID *int64) ([]Message, error)
	GetUnreadCounts(identityID string) ([]UnreadCount, error)
	MarkRead(identityID string, channelID int64, messageID *int64) error
}

type Role struct {
	Name    string
	BuiltIn bool
}

type RoleStore interface {
	CreateRole(name string) error
	DeleteRole(name string) error
	ListRoles() ([]Role, error)
	GrantPermission(role, permission string) error
	RevokePermission(role, permission string) error
	GetRolePermissions(role string) ([]string, error)
	GetUserPermissions(username string) ([]string, error)
	HasPermission(username, permission string) (bool, error)
	SetUserRole(username, role string) error
	SetUserType(username, userType string) error
}

type SettingsStore interface {
	GetSetting(key string) (string, error)
	SetSetting(key, value string) error
	ListSettings() (map[string]string, error)
}

type Store interface {
	IdentityStore
	ChannelStore
	MessageStore
	RoleStore
	MentionGroupStore
	SettingsStore
	WebhookStore
	Close() error
}

type Subscription interface {
	Events() <-chan Event
	Close()
}

type UnreadCount struct {
	ChannelID    int64
	Channel      string
	UnreadCount  int
	MentionCount int
	Type         string
}

type WebhookStore interface {
	RegisterWebhook(identityID, url string) (string, error)
	UnregisterWebhook(identityID, webhookID string) error
	GetActiveWebhooksForIdentity(identityID string) ([]IdentityWebhook, error)
	// GetWebhooksForChannel returns active webhooks for all service members of a channel.
	GetWebhooksForChannel(channelID int64) ([]IdentityWebhook, error)
}