services

type AnalysisService interface {
	Inquire(ctx context.Context, query string, limit int, opts InquireOptions) (*InquireResult, error)
	StoreAnalysis(ctx context.Context, collectionID uuid.UUID, a *models.Analysis) error
	LoadAnalysis(ctx context.Context, collectionID uuid.UUID) (*models.Analysis, error)
	QueryCategory(ctx context.Context, collectionID uuid.UUID, category string, limit int) ([]*models.Result, error)
	Search(ctx context.Context, collectionID uuid.UUID, query string, limit int) (*models.Analysis, error)
	GetWorks(ctx context.Context, collectionID uuid.UUID, ids []string) ([]*models.Work, []string, error)
}

type Collection struct {
	ID          uuid.UUID `json:"id"`
	QueryHash   [32]byte  `json:"query_hash"`
	Query       string    `json:"query"`
	ResultLimit int       `json:"result_limit"`
	Parameters  []byte    `json:"parameters,omitempty"`
	Name        *string   `json:"name,omitempty"`
	WorkCount   int       `json:"work_count"`
	CreatedAt   time.Time `json:"created_at"`
	UpdatedAt   time.Time `json:"updated_at"`
}

type CollectionService interface {
	FindByHash(ctx context.Context, hash [32]byte) (*Collection, error)
	FindByID(ctx context.Context, id uuid.UUID) (*Collection, error)
	FindByName(ctx context.Context, name string) (*Collection, error)
	Resolve(ctx context.Context, target string) (*Collection, error)
	List(ctx context.Context) ([]*Collection, error)
	Create(ctx context.Context, col *Collection) error
	UpdateName(ctx context.Context, id uuid.UUID, name *string) error
	Delete(ctx context.Context, id uuid.UUID) error
}

type InquireOptions struct {
	Force bool
	Name  string
}

type InquireResult struct {
	Collection *Collection
	IsNew      bool
	// SeedCount is the number of works OpenAlex returned for the query. It is
	// only set when the collection was newly fetched.
	SeedCount int
}

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

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