analytics

type Action struct {
	At         time.Time `json:"at"`
	Kind       string    `json:"kind"`
	Repository string    `json:"repository"`
	PR         int       `json:"pr"`
}

type Actions struct {
	Path string
	Now  func() time.Time
	// contains filtered or unexported fields
}

type BaumWeek struct {
	Reviews         int  `json:"reviews"`
	FixesPushed     int  `json:"fixes_pushed"`
	ThreadsResolved int  `json:"threads_resolved"`
	Merges          *int `json:"merges"`
	BranchUpdates   *int `json:"branch_updates"`
	CheckReruns     *int `json:"check_reruns"`
	Decisions       *int `json:"decisions"`
}

type BaumWeeks struct {
	This     BaumWeek `json:"this"`
	Previous BaumWeek `json:"previous"`
}

type BaumWork struct {
	Available    bool `json:"available"`
	Reviews      int  `json:"reviews"`
	GroupReviews int  `json:"group_reviews"`
	// ReviewsCompleted counts the reviews and group reviews that finished.
	ReviewsCompleted int `json:"reviews_completed"`
	Fixes            int `json:"fixes"`
	// Questions counts questions asked of a review's agent (jobs.KindChat).
	Questions int `json:"questions"`
	// DetailsRetries counts retries of a saved review's failed section
	// details (jobs.KindDetails), which are not reviews; one that stood down
	// counts nowhere else.
	DetailsRetries  int           `json:"details_retries"`
	Automatic       int           `json:"automatic"`
	Completed       int           `json:"completed"`
	Failed          int           `json:"failed"`
	Cancelled       int           `json:"cancelled"`
	Active          int           `json:"active"`
	Tokens          int           `json:"tokens"`
	Cost            Cost          `json:"cost"`
	Failures        []ReasonCount `json:"failures"`
	FixesPushed     int           `json:"fixes_pushed"`
	FixesFailed     int           `json:"fixes_failed"`
	ThreadsResolved int           `json:"threads_resolved"`
	ThreadsReplied  int           `json:"threads_replied"`
	// Merges, BranchUpdates and CheckReruns are nil without the ledger.
	Merges        *int `json:"merges"`
	BranchUpdates *int `json:"branch_updates"`
	CheckReruns   *int `json:"check_reruns"`
	// Decisions is decision capture's model calls, nil without its ledger.
	Decisions *DecisionCapture `json:"decisions"`
	// Weeks is the last seven days' figures against the seven before; nil
	// in a week's own figures.
	Weeks *BaumWeeks `json:"weeks,omitempty"`
}

type Clones interface {
	List(ctx context.Context) ([]repos.Clone, error)
}

type CommitShare struct {
	// Available is false when no clone in scope could be read; Reasons say
	// why, and also name clones left out of an available share.
	Available bool     `json:"available"`
	Reasons   []string `json:"reasons"`
	Commits   int      `json:"commits"`
	// Agent counts the commits linked to an agent; each commit once, under
	// its strongest evidence: a session that recorded creating it, then an
	// Entire checkpoint, then a co-author trailer.
	Agent      int               `json:"agent_commits"`
	BySession  int               `json:"by_session"`
	ByCheck    int               `json:"by_checkpoint"`
	ByTrailer  int               `json:"by_trailer"`
	Share      *float64          `json:"share"`
	Repository []RepositoryShare `json:"by_repository"`
}

type Cost struct {
	USD        *float64 `json:"usd"`
	Incomplete bool     `json:"incomplete"`
	Reasons    []string `json:"reasons"`
}

type Day struct {
	Date   string              `json:"date"`
	Agents map[string]DayAgent `json:"agents"`
	Models map[string]DayAgent `json:"models"`
}

type DayAgent struct {
	Sessions      int   `json:"sessions"`
	ActiveSeconds int64 `json:"active_seconds"`
}

type DecisionCapture struct {
	Attempts  int `json:"attempts"`
	Succeeded int `json:"succeeded"`
	Failed    int `json:"failed"`
	// Abandoned calls were cut short by the daemon stopping.
	Abandoned int `json:"abandoned"`
	// Cost sums the known costs of settled calls; any without one makes it
	// incomplete, and none known leaves it unknown.
	Cost     Cost          `json:"cost"`
	Failures []ReasonCount `json:"failures"`
}

type Delivery struct {
	Search PullRequestSearcher
	Now    func() time.Time
	// Paused is when the host's GitHub rate limit lets requests resume, as
	// the background refresh knows it; nil means unknown. Limited records a
	// rate limit a search hit, so the refresh waits it out too.
	Paused  func(host string) time.Time
	Limited func(host string, until time.Time)
	// contains filtered or unexported fields
}

type DeliveryReport struct {
	Status       string     `json:"status"`
	Reasons      []string   `json:"reasons"`
	FetchedAt    *time.Time `json:"fetched_at"`
	Repositories int        `json:"repositories"`
	// Opened and the figures below cover pull requests that are not drafts;
	// Drafts counts the drafts opened in the window.
	Opened                   int      `json:"opened"`
	Merged                   int      `json:"merged"`
	Drafts                   int      `json:"drafts"`
	MedianMergeSeconds       *float64 `json:"median_merge_seconds"`
	Reviewed                 int      `json:"reviewed"`
	MedianFirstReviewSeconds *float64 `json:"median_first_review_seconds"`
	ConflictOrFailing        int      `json:"conflict_or_failing"`
	ConflictOrFailingShare   *float64 `json:"conflict_or_failing_share"`
}

type Entry struct {
	// Key changes whenever one of the tree's files does (sizes and
	// modification times, or a digest of generated content).
	Key        string `json:"key"`
	Source     string `json:"source"`
	SessionID  string `json:"session_id"`
	Clone      string `json:"clone"`
	Repository string `json:"repository"`
	// Branch is the top-level session's branch, as the agent recorded it.
	Branch     string     `json:"branch,omitempty"`
	ModifiedAt time.Time  `json:"modified_at"`
	StartedAt  *time.Time `json:"started_at,omitempty"`
	EndedAt    *time.Time `json:"ended_at,omitempty"`
	// Generation marks one of baum's own runs, which is kept only so it is
	// not read again: it never counts as the person's agent work.
	Generation bool `json:"generation,omitempty"`
	// ActiveSeconds is nil for a session without a transcript (metadata
	// only): its activity is unknown, not zero. Hours holds the same seconds
	// by the unix hour they fell in.
	ActiveSeconds *int64          `json:"active_seconds,omitempty"`
	Hours         map[int64]int64 `json:"hours,omitempty"`
	Prompts       int             `json:"prompts"`
	ToolCalls     int             `json:"tool_calls"`
	FailedTools   int             `json:"failed_tool_calls"`
	Subagents     int             `json:"subagents,omitempty"`
	ModelCalls    int             `json:"model_calls"`
	Usage         []Usage         `json:"usage,omitempty"`
	// TokensUnknown says some of the session's model calls reported no
	// usage, or none was recorded at all, so its token sums are a floor.
	TokensUnknown bool `json:"tokens_unknown,omitempty"`
	// Commits are the commits the session recorded creating, as the agent
	// printed them (possibly abbreviated).
	Commits []string `json:"commits,omitempty"`
}

type Filters struct {
	Repository string `json:"repository"`
	Agent      string `json:"agent"`
}

type FlowCounts struct {
	Opened       int       `json:"opened"`
	OpenedMerged int       `json:"opened_merged"`
	Merged       int       `json:"merged"`
	MergeSeconds []float64 `json:"merge_seconds"`
}

type FlowDay struct {
	Date string     `json:"date"`
	Mine FlowCounts `json:"mine"`
	Team FlowCounts `json:"team"`
}

type FlowReport struct {
	// Available is false without the decision store the feature log keeps.
	Available bool `json:"available"`
	// Yours is false when the person's GitHub login is not known, so their
	// own pull requests cannot be told from the team's.
	Yours bool `json:"yours"`
	// Unlisted names the repositories in scope the feature log has not
	// listed: those with decisions off, or no clone.
	Unlisted []string `json:"unlisted"`
	// Unread names those whose pull requests could not be read.
	Unread []string  `json:"unread"`
	Days   []FlowDay `json:"days"`
}

type Hour struct {
	Hour          int   `json:"hour"`
	ActiveSeconds int64 `json:"active_seconds"`
}

type Index struct {
	Path   string
	Clones Clones
	Stores Stores
	Log    *slog.Logger
	Now    func() time.Time
	// contains filtered or unexported fields
}

type Merger interface {
	MergeOptions(ctx context.Context, repository github.Repository, number int) (github.MergeOptions, error)
	MergePullRequest(ctx context.Context, repository github.Repository, number int, method, expectedHead string) error
}

type ModelRow struct {
	Model    string `json:"model"`
	Agent    string `json:"agent"`
	Sessions int    `json:"sessions"`
	Calls    int64  `json:"calls"`
	Tokens   int64  `json:"tokens"`
	Cost     Cost   `json:"cost"`
}

type Options struct {
	Repositories []string `json:"repositories"`
	Agents       []string `json:"agents"`
}

type PlanPoint struct {
	At          time.Time `json:"at"`
	UsedPercent float64   `json:"used_percent"`
}

type PlanSeries struct {
	Provider string      `json:"provider"`
	Window   string      `json:"window"`
	Points   []PlanPoint `json:"points"`
	Peak     float64     `json:"peak"`
	// LimitHits counts the times the window reached 100%.
	LimitHits int `json:"limit_hits"`
}

type PlanUsageReport struct {
	Available bool         `json:"available"`
	Series    []PlanSeries `json:"series"`
}

type Progress struct {
	Done     int  `json:"done"`
	Total    int  `json:"total"`
	Complete bool `json:"complete"`
}

type PullRequestSearcher interface {
	AuthoredPullRequests(ctx context.Context, repository github.Repository, since time.Time) ([]github.AuthoredPullRequest, error)
}

type Query struct {
	Days       int
	Repository string
	Agent      string
}

type ReasonCount struct {
	Reason string `json:"reason"`
	Count  int    `json:"count"`
}

type Registry interface {
	List(ctx context.Context) ([]repos.Clone, error)
	Repositories(ctx context.Context) ([]repos.Repository, error)
}

type Report struct {
	Window    Window          `json:"window"`
	Filters   Filters         `json:"filters"`
	Options   Options         `json:"options"`
	Indexing  Progress        `json:"indexing"`
	Summary   Summary         `json:"summary"`
	Daily     []Day           `json:"daily"`
	Hours     []Hour          `json:"hours"`
	ByAgent   []Row           `json:"by_agent"`
	ByModel   []ModelRow      `json:"by_model"`
	ByRepo    []Row           `json:"by_repository"`
	Longest   []SessionRow    `json:"longest"`
	Commits   CommitShare     `json:"commits"`
	Baum      BaumWork        `json:"baum"`
	Delivery  DeliveryReport  `json:"delivery"`
	PlanUsage PlanUsageReport `json:"plan_usage"`
	Flow      FlowReport      `json:"flow"`
}

type RepositoryShare struct {
	Repository string   `json:"repository"`
	Commits    int      `json:"commits"`
	Agent      int      `json:"agent_commits"`
	Share      *float64 `json:"share"`
}

type Row struct {
	Key             string   `json:"key"`
	Sessions        int      `json:"sessions"`
	Prompts         int      `json:"prompts"`
	ToolCalls       int      `json:"tool_calls"`
	FailedToolCalls int      `json:"failed_tool_calls"`
	FailedRate      *float64 `json:"failed_rate"`
	ActiveSeconds   *int64   `json:"active_seconds"`
	// Tokens is nil when no session reported any; TokensIncomplete when
	// some did not.
	Tokens           *int64 `json:"tokens"`
	TokensIncomplete bool   `json:"tokens_incomplete"`
	Cost             Cost   `json:"cost"`
}

type Service struct {
	Registry Registry
	Index    *Index
	Jobs     func() []jobs.Job
	Actions  *Actions
	Plans    *planusage.History
	Delivery *Delivery
	// Captures reads decision capture's ledger from since on; nil without
	// decision capture.
	Captures func(ctx context.Context, since time.Time) ([]decisionlog.LedgerEntry, error)
	// Pulls reads the feature log's pull requests of a repository opened or
	// merged from since on, and whether it listed the repository; nil
	// without the decision store. Login is the person's GitHub login.
	Pulls func(ctx context.Context, repository string, since time.Time) ([]decisionlog.FlowPull, bool, error)
	Login func(ctx context.Context) string
	// Location is the zone days and hours are counted in; nil is local.
	Location *time.Location
	Now      func() time.Time
	// contains filtered or unexported fields
}

type SessionRow struct {
	Agent           string     `json:"agent"`
	Repository      string     `json:"repository"`
	Branch          string     `json:"branch"`
	StartedAt       *time.Time `json:"started_at"`
	EndedAt         *time.Time `json:"ended_at"`
	ActiveSeconds   *int64     `json:"active_seconds"`
	Prompts         int        `json:"prompts"`
	ToolCalls       int        `json:"tool_calls"`
	FailedToolCalls int        `json:"failed_tool_calls"`
	Subagents       int        `json:"subagents"`
	Tokens          *int64     `json:"tokens"`
	Cost            Cost       `json:"cost"`
}

type Stores struct {
	ClaudeProjectsDir string
	CodexSessionsDir  string
	CursorStorePaths  []string
}

type Summary struct {
	Sessions int `json:"sessions"`
	// ActiveSeconds is nil when no session in the window recorded its
	// activity; ActiveIncomplete when some did not.
	ActiveSeconds    *int64   `json:"active_seconds"`
	ActiveIncomplete bool     `json:"active_incomplete"`
	Prompts          int      `json:"prompts"`
	Subagents        int      `json:"subagents"`
	Cost             Cost     `json:"cost"`
	AgentShare       *float64 `json:"agent_share"`
}

type Updater interface {
	UpdateOptions(ctx context.Context, repository github.Repository, number int) (prupdate.UpdateOptions, error)
	UpdateBranch(ctx context.Context, repository github.Repository, number int, expectedHead string) error
	RerunOptions(ctx context.Context, repository github.Repository, number int) (prupdate.RerunOptions, error)
	RerunFailedChecks(ctx context.Context, repository github.Repository, number int, expectedHead string) (prupdate.RerunResult, error)
	ReviewThreads(ctx context.Context, repository github.Repository, number, unresolved int) (prupdate.Threads, error)
	ResolveThread(ctx context.Context, repository github.Repository, number int, id string) error
	FailingChecks(ctx context.Context, repository github.Repository, number int, head string) (prupdate.Checks, error)
	RerunJob(ctx context.Context, repository github.Repository, number int, expectedHead string, job int64) error
	AllChecks(ctx context.Context, repository github.Repository, number int, head string) (prupdate.CheckList, error)
	Conflicts(ctx context.Context, repository github.Repository, number int) (prupdate.ConflictFiles, error)
	Description(ctx context.Context, repository github.Repository, number int) (prupdate.Description, error)
}

type Usage struct {
	Model        string `json:"model"`
	Speed        string `json:"speed,omitempty"`
	Single       bool   `json:"single,omitempty"`
	Band         int    `json:"band,omitempty"`
	Calls        int64  `json:"calls"`
	Input        int64  `json:"input"`
	Output       int64  `json:"output"`
	CacheRead    int64  `json:"cache_read"`
	CacheWrite   int64  `json:"cache_write"`
	CacheWrite1h int64  `json:"cache_write_1h,omitempty"`
	MinPrompt    int64  `json:"min_prompt"`
	MaxPrompt    int64  `json:"max_prompt"`
}

type Window struct {
	Days  int       `json:"days"`
	Start time.Time `json:"start"`
	End   time.Time `json:"end"`
}