reconcile

type CatalogStore interface {
	ListActiveItemKeysByChannelKey(ctx context.Context, channelKey string) ([]string, error)
	ListActiveItemKeysByCatalogFilter(ctx context.Context, groupNames []string, searchQuery string, searchRegex bool) ([]string, error)
}

type ChannelsService interface {
	List(ctx context.Context) ([]channels.Channel, error)
	ListSources(ctx context.Context, channelID int64, enabledOnly bool) ([]channels.Source, error)
	AddSource(ctx context.Context, channelID int64, itemKey string, allowCrossChannel bool) (channels.Source, error)
	// SyncDynamicSources must treat matchedItemKeys as read-only input.
	SyncDynamicSources(ctx context.Context, channelID int64, matchedItemKeys []string) (channels.DynamicSourceSyncResult, error)
	SyncDynamicChannelBlocks(ctx context.Context) (channels.DynamicChannelSyncResult, error)
	RefreshDynamicGeneratedGuideNames(ctx context.Context) (int, error)
}

type Result struct {
	ChannelsTotal            int `json:"channels_total"`
	ChannelsProcessed        int `json:"channels_processed"`
	ChannelsSkipped          int `json:"channels_skipped"`
	SourcesAdded             int `json:"sources_added"`
	SourcesAlreadySeen       int `json:"sources_existing"`
	DynamicBlocksProcessed   int `json:"dynamic_blocks_processed"`
	DynamicBlocksEnabled     int `json:"dynamic_blocks_enabled"`
	DynamicChannelsAdded     int `json:"dynamic_channels_added"`
	DynamicChannelsUpdated   int `json:"dynamic_channels_updated"`
	DynamicChannelsRetained  int `json:"dynamic_channels_retained"`
	DynamicChannelsRemoved   int `json:"dynamic_channels_removed"`
	DynamicChannelsTruncated int `json:"dynamic_channels_truncated"`
	DynamicChannelsProcessed int `json:"dynamic_channels_processed"`
	DynamicSourcesAdded      int `json:"dynamic_sources_added"`
	DynamicSourcesRemoved    int `json:"dynamic_sources_removed"`
	DynamicGuideNamesUpdated int `json:"dynamic_guide_names_updated"`
}

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