bot

type Action struct {
	Kind   string `json:"kind"`
	Reason string `json:"reason"`
}

type Analysis struct {
	NextAction         map[string]Action `json:"next_action"`
	WorkflowState      string            `json:"workflow_state"`
	Size               string            `json:"size"`
	Tags               []string          `json:"tags"`
	Checks             Checks            `json:"checks"`
	UnresolvedComments int               `json:"unresolved_comments"`
	ReadyToMerge       bool              `json:"ready_to_merge"`
	Approved           bool              `json:"approved"`
	MergeConflict      bool              `json:"merge_conflict"`
}

type CheckResponse struct {
	PullRequest PRInfo   `json:"pull_request"`
	Analysis    Analysis `json:"analysis"`
}

type Checks struct {
	Pending int `json:"pending"`
	Passing int `json:"passing"`
	Failing int `json:"failing"`
	Waiting int `json:"waiting"`
}

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

type ConfigManager interface {
	LoadConfig(ctx context.Context, org string) error
	ReloadConfig(ctx context.Context, org string) error
	Config(org string) (*config.DiscordConfig, bool)
	ChannelsForRepo(org, repo string) []string
	ChannelType(org, channel string) string
	DiscordUserID(org, githubUsername string) string
	ReminderDMDelay(org, channel string) int
	When(org, channel string) string
	GuildID(org string) string
	SetGitHubClient(org string, client any)
}

type Coordinator struct {
	UserMapper UserMapper
	// contains filtered or unexported fields
}

type CoordinatorConfig struct {
	Discord    DiscordClient
	Config     ConfigManager
	Store      StateStore
	Turn       TurnClient
	UserMapper UserMapper
	Searcher   PRSearcher
	Logger     *slog.Logger
	Org        string
}

type DiscordClient interface {
	// Text channel operations
	PostMessage(ctx context.Context, channelID, text string) (messageID string, err error)
	UpdateMessage(ctx context.Context, channelID, messageID, text string) error

	// Forum channel operations
	PostForumThread(ctx context.Context, forumID, title, content string) (threadID, messageID string, err error)
	UpdateForumPost(ctx context.Context, threadID, messageID, newTitle, newContent string) error
	ArchiveThread(ctx context.Context, threadID string) error

	// Direct message operations
	SendDM(ctx context.Context, userID, text string) (channelID, messageID string, err error)
	UpdateDM(ctx context.Context, channelID, messageID, newText string) error

	// Lookup operations
	ResolveChannelID(ctx context.Context, channelName string) string
	LookupUserByUsername(ctx context.Context, username string) string
	IsBotInChannel(ctx context.Context, channelID string) bool
	IsUserInGuild(ctx context.Context, userID string) bool
	IsUserActive(ctx context.Context, userID string) bool
	IsForumChannel(ctx context.Context, channelID string) bool

	// Guild info
	GuildID() string

	// Search operations (for cross-instance race prevention)
	FindForumThread(ctx context.Context, forumID, prURL string) (threadID, messageID string, found bool)
	FindChannelMessage(ctx context.Context, channelID, prURL string) (messageID string, found bool)
	FindDMForPR(ctx context.Context, userID, prURL string) (channelID, messageID string, found bool)
	MessageContent(ctx context.Context, channelID, messageID string) (string, error)
}

type PRInfo struct {
	Title     string   `json:"title"`
	Author    string   `json:"author"`
	State     string   `json:"state"`
	UpdatedAt string   `json:"updated_at"`
	Commits   []string `json:"commits,omitempty"`
	Assignees []string `json:"assignees,omitempty"`
	Draft     bool     `json:"draft"`
	Merged    bool     `json:"merged"`
	Closed    bool     `json:"closed"`
}

type PRSearchResult struct {
	UpdatedAt time.Time
	URL       string
	Owner     string
	Repo      string
	Number    int
}

type PRSearcher interface {
	// ListOpenPRs returns open PRs for an org updated within the given hours.
	ListOpenPRs(ctx context.Context, org string, updatedWithinHours int) ([]PRSearchResult, error)
	// ListClosedPRs returns recently closed/merged PRs for catching terminal states.
	ListClosedPRs(ctx context.Context, org string, closedWithinHours int) ([]PRSearchResult, error)
}

type PRURLInfo struct {
	Owner  string
	Repo   string
	Number int
}

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

type SprinklerConfig struct {
	Logger        *slog.Logger
	OnEvent       func(SprinklerEvent)
	OnConnect     func()
	OnDisconnect  func(error)
	ServerURL     string
	TokenProvider TokenProvider
	Organization  string
}

type SprinklerEvent struct {
	Timestamp  time.Time      `json:"timestamp"`
	Raw        map[string]any `json:"-"` // Raw message for additional fields
	Type       string         `json:"type"`
	URL        string         `json:"url"`
	DeliveryID string         `json:"delivery_id"`
	CommitSHA  string         `json:"commit_sha,omitempty"`
}

type StateStore interface {
	Thread(ctx context.Context, owner, repo string, number int, channelID string) (state.ThreadInfo, bool)
	SaveThread(ctx context.Context, owner, repo string, number int, channelID string, info state.ThreadInfo) error
	ClaimThread(ctx context.Context, owner, repo string, number int, channelID string, ttl time.Duration) bool
	DMInfo(ctx context.Context, userID, prURL string) (state.DMInfo, bool)
	SaveDMInfo(ctx context.Context, userID, prURL string, info state.DMInfo) error
	ClaimDM(ctx context.Context, userID, prURL string, ttl time.Duration) bool
	ListDMUsers(ctx context.Context, prURL string) []string // Returns all user IDs who received DMs for this PR
	WasProcessed(ctx context.Context, eventKey string) bool
	MarkProcessed(ctx context.Context, eventKey string, ttl time.Duration) error
	QueuePendingDM(ctx context.Context, dm *state.PendingDM) error
	PendingDMs(ctx context.Context, before time.Time) ([]*state.PendingDM, error)
	RemovePendingDM(ctx context.Context, id string) error
	DailyReportInfo(ctx context.Context, userID string) (state.DailyReportInfo, bool)
	SaveDailyReportInfo(ctx context.Context, userID string, info state.DailyReportInfo) error
	Cleanup(ctx context.Context) error
}

type TokenProvider interface {
	InstallationToken(ctx context.Context) (string, error)
}

type TurnClient interface {
	Check(ctx context.Context, prURL, username string, updatedAt time.Time) (*CheckResponse, error)
}

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

type UserMapper interface {
	DiscordID(ctx context.Context, githubUsername string) string
	Mention(ctx context.Context, githubUsername string) string
}