identify

Documentation

Index

• Variables
• type FieldOptions
• type FieldStrategy
  • func (e FieldStrategy) IsValid() bool
  • func (e FieldStrategy) MarshalGQL(w io.Writer)
  • func (e FieldStrategy) String() string
  • func (e *FieldStrategy) UnmarshalGQL(v interface{}) error
• type MetadataOptions
• type MultipleMatchesFoundError
  • func (e *MultipleMatchesFoundError) Error() string
• type Options
• type PerformerCreator
• type SceneCoverGetter
• type SceneIdentifier
  • func (t *SceneIdentifier) Identify(ctx context.Context, scene *models.Scene) error
• type SceneReaderUpdater
• type SceneScraper
• type SceneUpdatePostHookExecutor
• type ScraperSource
• type Source

Variables

var AllFieldStrategy = []FieldStrategy{
	FieldStrategyIgnore,
	FieldStrategyMerge,
	FieldStrategyOverwrite,
}

var (
	ErrSkipSingleNamePerformer = errors.New("a performer was skipped because they only had a single name and no disambiguation")
)

Types

type FieldOptions

type FieldOptions struct {
	Field    string        `json:"field"`
	Strategy FieldStrategy `json:"strategy"`
	// creates missing objects if needed - only applicable for performers, tags and studios
	CreateMissing *bool `json:"createMissing"`
}

type FieldStrategy

type FieldStrategy string

const (
	// Never sets the field value
	FieldStrategyIgnore FieldStrategy = "IGNORE"
	// For multi-value fields, merge with existing.
	// For single-value fields, ignore if already set
	FieldStrategyMerge FieldStrategy = "MERGE"
	// Always replaces the value if a value is found.
	//   For multi-value fields, any existing values are removed and replaced with the
	//   scraped values.
	FieldStrategyOverwrite FieldStrategy = "OVERWRITE"
)

func (FieldStrategy) IsValid

func (e FieldStrategy) IsValid() bool

func (FieldStrategy) MarshalGQL

func (e FieldStrategy) MarshalGQL(w io.Writer)

func (FieldStrategy) String

func (e FieldStrategy) String() string

func (*FieldStrategy) UnmarshalGQL

func (e *FieldStrategy) UnmarshalGQL(v interface{}) error

type MetadataOptions

type MetadataOptions struct {
	// any fields missing from here are defaulted to MERGE and createMissing false
	FieldOptions []*FieldOptions `json:"fieldOptions"`
	// defaults to true if not provided
	SetCoverImage *bool `json:"setCoverImage"`
	SetOrganized  *bool `json:"setOrganized"`
	// defaults to true if not provided
	IncludeMalePerformers *bool `json:"includeMalePerformers"`
	// defaults to true if not provided
	SkipMultipleMatches *bool `json:"skipMultipleMatches"`
	// ID of tag to tag skipped multiple matches with
	SkipMultipleMatchTag *string `json:"skipMultipleMatchTag"`
	// defaults to true if not provided
	SkipSingleNamePerformers *bool `json:"skipSingleNamePerformers"`
	// ID of tag to tag skipped single name performers with
	SkipSingleNamePerformerTag *string `json:"skipSingleNamePerformerTag"`
}

type MultipleMatchesFoundError

type MultipleMatchesFoundError struct {
	Source ScraperSource
}

func (*MultipleMatchesFoundError) Error

func (e *MultipleMatchesFoundError) Error() string

type Options

type Options struct {
	// An ordered list of sources to identify items with. Only the first source that finds a match is used.
	Sources []*Source `json:"sources"`
	// Options defined here override the configured defaults
	Options *MetadataOptions `json:"options"`
	// scene ids to identify
	SceneIDs []string `json:"sceneIDs"`
	// paths of scenes to identify - ignored if scene ids are set
	Paths []string `json:"paths"`
}

type PerformerCreator

type PerformerCreator interface {
	models.PerformerCreator
	UpdateImage(ctx context.Context, performerID int, image []byte) error
}

type SceneCoverGetter

type SceneCoverGetter interface {
	GetCover(ctx context.Context, sceneID int) ([]byte, error)
}

type SceneIdentifier

type SceneIdentifier struct {
	TxnManager         txn.Manager
	SceneReaderUpdater SceneReaderUpdater
	StudioReaderWriter models.StudioReaderWriter
	PerformerCreator   PerformerCreator
	TagFinderCreator   models.TagFinderCreator

	DefaultOptions              *MetadataOptions
	Sources                     []ScraperSource
	SceneUpdatePostHookExecutor SceneUpdatePostHookExecutor
}

func (*SceneIdentifier) Identify

func (t *SceneIdentifier) Identify(ctx context.Context, scene *models.Scene) error

type SceneReaderUpdater

type SceneReaderUpdater interface {
	SceneCoverGetter
	models.SceneUpdater
	models.PerformerIDLoader
	models.TagIDLoader
	models.StashIDLoader
	models.URLLoader
}

type SceneScraper

type SceneScraper interface {
	ScrapeScenes(ctx context.Context, sceneID int) ([]*scraper.ScrapedScene, error)
}

type SceneUpdatePostHookExecutor

type SceneUpdatePostHookExecutor interface {
	ExecuteSceneUpdatePostHooks(ctx context.Context, input models.SceneUpdateInput, inputFields []string)
}

type ScraperSource

type ScraperSource struct {
	Name       string
	Options    *MetadataOptions
	Scraper    SceneScraper
	RemoteSite string
}

type Source

type Source struct {
	Source *scraper.Source `json:"source"`
	// Options defined for a source override the defaults
	Options *MetadataOptions `json:"options"`
}