projectintegrations

type ActiveSyncRunStore interface {
	GetActiveSyncRun(context.Context, string, Provider) (SyncRun, error)
}

type AsyncPollRunner interface {
	SubmitProviderPoll(context.Context, string, Provider, SyncKind) (SyncRun, error)
}

type ConfluencePlanInput struct {
	ProjectID string
	Config    config.ConfluenceIntegration
	State     SyncState
	Kind      SyncKind
}

type ConfluencePoller interface {
	PollConfluence(context.Context, Credentials, ConfluenceQueryPlan) (PollResult, error)
}

type ConfluenceProgressPoller interface {
	PollConfluenceWithProgress(context.Context, Credentials, ConfluenceQueryPlan, PollProgressFunc) (PollResult, error)
}

type ConfluenceQueryPlan struct {
	ProjectID           string
	Provider            Provider
	Kind                SyncKind
	SpaceKeys           []string
	CQL                 string
	PageSize            int
	MaxResults          int
	IncrementalInterval time.Duration
	OverlapWindow       time.Duration
	Since               time.Time
	BodyRepresentation  string
	IncludeBody         bool
	IncludeComments     bool
	IncludeLabels       bool
	IncludeProperties   bool
}

type CredentialResolver struct {
	LookupEnv func(string) (string, bool)
	ReadFile  func(string) ([]byte, error)
}

type Credentials struct {
	Email    string
	APIToken string
}

type ErrorCategory string

type IntegrationToolError struct {
	Code        string          `json:"code"`
	Reason      ToolErrorReason `json:"reason"`
	ProjectID   string          `json:"project_id,omitempty"`
	Provider    Provider        `json:"provider,omitempty"`
	Key         string          `json:"key,omitempty"`
	Remediation []string        `json:"remediation,omitempty"`
}

type ItemCountStore interface {
	CountItems(context.Context, string, Provider) (int, error)
}

type ItemListOptions struct {
	ItemType  string
	PageSize  int
	PageToken string
	Sort      string
}

type ItemListResult struct {
	ProjectID       string
	Provider        Provider
	Items           []ItemMetadata
	NextPageToken   string
	Sort            string
	SampleTruncated bool
}

type ItemListStore interface {
	ListItemsPage(context.Context, string, Provider, ItemListOptions) (ItemListResult, error)
}

type ItemMetadata struct {
	ProjectID       string
	Provider        Provider
	ItemID          string
	ItemKey         string
	ItemIDHash      string
	ItemKeyHash     string
	ItemType        string
	ItemStatus      string
	ItemUpdatedAt   time.Time
	ContentSHA256   string
	ProviderVersion string
	ProviderETag    string
	FirstSeenAt     time.Time
	LastSeenAt      time.Time
	LastRunID       string
	Changed         bool
}

type ItemMetadataInput struct {
	ProjectID       string
	Provider        Provider
	ItemID          string
	ItemKey         string
	ItemType        string
	ItemStatus      string
	ItemUpdatedAt   time.Time
	ProviderVersion string
	ProviderETag    string
	FirstSeenAt     time.Time
	LastSeenAt      time.Time
	LastRunID       string
}

type JiraPlanInput struct {
	ProjectID string
	Config    config.JiraIntegration
	State     SyncState
	Kind      SyncKind
}

type JiraPoller interface {
	PollJira(context.Context, Credentials, JiraQueryPlan) (PollResult, error)
}

type JiraProgressPoller interface {
	PollJiraWithProgress(context.Context, Credentials, JiraQueryPlan, PollProgressFunc) (PollResult, error)
}

type JiraQueryPlan struct {
	ProjectID           string
	Provider            Provider
	Kind                SyncKind
	ProjectKeys         []string
	JQL                 string
	Fields              []string
	PageSize            int
	MaxResults          int
	IncrementalInterval time.Duration
	OverlapWindow       time.Duration
	Since               time.Time
	IncludeRichFields   bool
	IncludeComments     bool
}

type LocalItemListInput struct {
	ProjectID string
	Provider  Provider
	ItemType  string
	PageSize  int
	PageToken string
	Sort      string
}

type LocalReadInput struct {
	ProjectID     string
	Provider      Provider
	ItemIDOrKey   string
	MaxChunkBytes int
	MaxChunks     int
	ChunkOffset   int
}

type LocalSearchInput struct {
	ProjectID       string
	Provider        Provider
	Query           string
	MaxResults      int
	MaxSnippetBytes int
	CaseSensitive   bool
}

type Planner struct {
	Jira       func(JiraPlanInput) (JiraQueryPlan, error)
	Confluence func(ConfluencePlanInput) (ConfluenceQueryPlan, error)
}

type PollItem struct {
	ID              string
	Key             string
	Type            string
	Status          string
	UpdatedAt       time.Time
	ProviderVersion string
	ProviderETag    string
}

type PollProgress struct {
	ItemsSeen int
}

type PollProgressFunc func(context.Context, PollProgress) error

type PollResult struct {
	Items       []PollItem
	RichContent []RichContentPayload
	Cursor      string
}

type PollRunResult struct {
	Run   SyncRun
	State SyncState
}

type PollRunner interface {
	RunProviderPoll(context.Context, string, Provider, SyncKind) (PollRunResult, error)
}

type ProjectIntegrationCounts struct {
	ProjectID string
	Counts    []ProviderItemCount
}

type Provider string

type ProviderCoverage struct {
	LocalItemCount       int  `json:"local_item_count"`
	LocalItemCountKnown  bool `json:"local_item_count_known"`
	SourcePersisted      bool `json:"source_persisted"`
	SourceAllowlistCount int  `json:"source_allowlist_count"`
}

type ProviderError struct {
	Provider   string
	Operation  string
	Category   ErrorCategory
	StatusCode int
	RetryAfter time.Duration
}

type ProviderItemCount struct {
	ProjectID string
	Provider  Provider
	Count     int
}

type ProviderPollAccepted struct {
	ProjectID string
	Provider  Provider
	Accepted  bool
	Run       SyncRunStatusView
}

type ProviderPollStatus struct {
	ProjectID string
	Provider  Provider
	Run       SyncRunStatusView
	SyncState SyncStateStatus
}

type ProviderSchedule struct {
	ProjectID           string
	Provider            Provider
	InitialFullSync     string
	IncrementalInterval time.Duration
	EmptyPollSleep      time.Duration
	MaxIdleSleep        time.Duration
}

type ProviderStatus struct {
	ProjectID            string
	Provider             Provider
	Configured           bool
	Enabled              bool
	AuthMode             string
	CredentialSource     string
	AllowlistKind        string
	AllowlistCount       int
	IngestionEnabled     bool
	InitialFullSync      string
	IncrementalInterval  time.Duration
	EmptyPollSleep       time.Duration
	MaxIdleSleep         time.Duration
	OverlapWindow        time.Duration
	InitialPageSize      int
	IncrementalPageSize  int
	MaxResults           int
	SourcePersisted      bool
	SourceAllowlistCount int
	SyncState            *SyncStateStatus
	LastRun              *SyncRunStatusView
	Coverage             ProviderCoverage   `json:"coverage"`
	SyncStateSplit       *SyncStateStatus   `json:"sync_state,omitempty"`
	LastRunSplit         *SyncRunStatusView `json:"last_run,omitempty"`
	ActiveRun            *SyncRunStatusView `json:"active_run,omitempty"`
}

type ProviderSummary struct {
	ProjectID         string
	Provider          Provider
	Configured        bool
	Enabled           bool
	AuthMode          string
	CredentialSource  string
	AllowlistKind     string
	AllowlistCount    int
	IngestionEnabled  bool
	IncrementalPeriod time.Duration
}

type RichContentArtifact struct {
	ID            string
	ProjectID     string
	Provider      Provider
	ItemID        string
	ItemKey       string
	ItemType      string
	FieldCount    int
	ChunkCount    int
	ContentSHA256 string
	UpdatedAt     time.Time
}

type RichContentChunk struct {
	ID        string
	ProjectID string
	Provider  Provider
	ItemID    string
	ItemKey   string
	ItemType  string
	FieldName string
	Label     string
	Index     int
	ByteStart int
	ByteEnd   int
	Text      string
	UpdatedAt time.Time
}

type RichContentChunkView struct {
	ID            string
	ArtifactID    string
	ProjectID     string
	Provider      Provider
	ItemID        string
	ItemKey       string
	ItemType      string
	FieldName     string
	Label         string
	Index         int
	ByteStart     int
	ByteEnd       int
	Text          string
	TextTruncated bool
	UpdatedAt     time.Time
}

type RichContentField struct {
	Name  string
	Label string
	Text  string
}

type RichContentGraphResult struct {
	ArtifactID    string
	ChunksWritten int
	ContentSHA256 string
	Changed       bool
}

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

type RichContentItem struct {
	ProjectID string
	Provider  Provider
	ItemID    string
	ItemKey   string
	ItemType  string
	UpdatedAt time.Time
	Fields    []RichContentField
}

type RichContentOptions struct {
	MaxItemTextBytes int
	MaxChunkBytes    int
}

type RichContentPayload struct {
	Item   RichContentItem
	Chunks []RichContentChunk
}

type RichContentReadOptions struct {
	MaxChunkBytes int
	MaxChunks     int
	ChunkOffset   int
}

type RichContentReadResult struct {
	Artifact        RichContentArtifact    `json:"artifact"`
	Chunks          []RichContentChunkView `json:"chunks"`
	ChunksTruncated bool                   `json:"chunks_truncated"`
	NextChunkOffset int                    `json:"next_chunk_offset,omitempty"`
}

type RichContentReader interface {
	GetRichContentItem(context.Context, string, Provider, string, RichContentReadOptions) (RichContentReadResult, error)
	SearchRichContent(context.Context, string, RichContentSearchOptions) ([]RichContentSearchResult, error)
}

type RichContentSearchOptions struct {
	Provider        Provider
	Query           string
	MaxResults      int
	MaxSnippetBytes int
	CaseSensitive   bool
}

type RichContentSearchResult struct {
	Artifact         RichContentArtifact
	Chunk            RichContentChunkView
	Snippet          string
	SnippetTruncated bool
	ByteStart        int
	ByteEnd          int
}

type RichContentStore interface {
	PutRichContentItem(context.Context, RichContentItem, []RichContentChunk) (RichContentGraphResult, error)
}

type RichContentTitleReader interface {
	ListRichContentTitles(context.Context, string, Provider, []string) (map[string]string, error)
}

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

type RunnerBatchItemStore interface {
	UpsertItems(context.Context, []ItemMetadataInput) ([]ItemMetadata, error)
}

type RunnerOptions struct {
	Projects           []config.Project
	Store              RunnerStore
	RichContentStore   RichContentStore
	CredentialResolver CredentialResolver
	JiraClient         JiraPoller
	ConfluenceClient   ConfluencePoller
	Planner            Planner
	Now                func() time.Time
	NewRunID           func() string
}

type RunnerStore interface {
	UpsertSource(context.Context, SourceMetadataInput) (SourceMetadata, error)
	CreateSyncRun(context.Context, SyncRun) error
	UpdateSyncRun(context.Context, SyncRun) error
	GetSyncState(context.Context, string, Provider) (SyncState, error)
	UpdateSyncState(context.Context, SyncStateInput) (SyncState, error)
	UpsertItem(context.Context, ItemMetadataInput) (ItemMetadata, error)
}

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

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

type SchedulerDiagnostics struct {
	Started                bool
	ScheduledProviderCount int
	ActivePollCount        int
	ActivePolls            map[string]int
}

type SchedulerOptions struct {
	Sleep  func(context.Context, time.Duration) error
	Logger *slog.Logger
}

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

type ServiceOptions struct {
	Runner      PollRunner
	RichContent RichContentReader
}

type SourceMetadata struct {
	ProjectID           string
	Provider            Provider
	SiteURLHash         string
	CloudIDHash         string
	AllowlistHash       string
	AllowlistCount      int
	AuthMode            string
	IngestionEnabled    bool
	InitialFullSync     string
	IncrementalInterval time.Duration
	EmptyPollSleep      time.Duration
	MaxIdleSleep        time.Duration
	OverlapWindow       time.Duration
	InitialPageSize     int
	IncrementalPageSize int
	MaxResults          int
	UpdatedAt           time.Time
}

type SourceMetadataInput struct {
	ProjectID           string
	Provider            Provider
	SiteURL             string
	CloudID             string
	Allowlist           []string
	AuthMode            string
	IngestionEnabled    bool
	InitialFullSync     string
	IncrementalInterval time.Duration
	EmptyPollSleep      time.Duration
	MaxIdleSleep        time.Duration
	OverlapWindow       time.Duration
	InitialPageSize     int
	IncrementalPageSize int
	MaxResults          int
	UpdatedAt           time.Time
}

type Store interface {
	UpsertSource(context.Context, SourceMetadataInput) (SourceMetadata, error)
	ListSources(context.Context, string) ([]SourceMetadata, error)
	GetSyncState(context.Context, string, Provider) (SyncState, error)
	GetSyncRun(context.Context, string, Provider, string) (SyncRun, error)
}

type SyncKind string

type SyncRun struct {
	ID                   string
	ProjectID            string
	Provider             Provider
	Kind                 SyncKind
	Status               SyncRunStatus
	ItemsSeen            int
	ItemsUpserted        int
	ItemsChanged         int
	ItemsUnchanged       int
	RichContentChanged   int
	RichContentUnchanged int
	EmptyPoll            bool
	IdleSleep            time.Duration
	ErrorCategory        string
	StartedAt            time.Time
	FinishedAt           time.Time
}

type SyncRunStatus string

type SyncRunStatusView struct {
	ID                   string
	Kind                 SyncKind
	Status               SyncRunStatus
	ItemsSeen            int
	ItemsUpserted        int
	ItemsChanged         int
	ItemsUnchanged       int
	RichContentChanged   int
	RichContentUnchanged int
	EmptyPoll            bool
	IdleSleep            time.Duration
	ErrorCategory        string
	StartedAt            time.Time
	FinishedAt           time.Time
}

type SyncState struct {
	ProjectID             string
	Provider              Provider
	LastRunID             string
	LastSuccessfulRunID   string
	LastSuccessAt         time.Time
	LastFullSyncAt        time.Time
	LastIncrementalSyncAt time.Time
	LastEmptyPollAt       time.Time
	EmptyPollCount        int
	CurrentIdleSleep      time.Duration
	Cursor                string
	CursorHash            string
	UpdatedAt             time.Time
}

type SyncStateInput struct {
	ProjectID             string
	Provider              Provider
	LastRunID             string
	LastSuccessfulRunID   string
	LastSuccessAt         time.Time
	LastFullSyncAt        time.Time
	LastIncrementalSyncAt time.Time
	LastEmptyPollAt       time.Time
	EmptyPollCount        int
	CurrentIdleSleep      time.Duration
	Cursor                string
	UpdatedAt             time.Time
}

type SyncStateStatus struct {
	LastRunID             string
	LastSuccessfulRunID   string
	LastSuccessAt         time.Time
	LastFullSyncAt        time.Time
	LastIncrementalSyncAt time.Time
	LastEmptyPollAt       time.Time
	EmptyPollCount        int
	CurrentIdleSleep      time.Duration
	CursorHashPresent     bool
	UpdatedAt             time.Time
}

type ToolErrorReason string