Add fingerprint resolver (#4287)

* Refactor into internal/api/models.go
* Add file fingerprint resolver
This commit is contained in:
DingDongSoLong4
2023-11-20 04:09:12 +02:00
committed by GitHub
parent a0f33e3dab
commit 049a1b15c3
8 changed files with 118 additions and 38 deletions

View File

@@ -14,6 +14,7 @@ resolver:
struct_tag: gqlgen struct_tag: gqlgen
autobind: autobind:
- github.com/stashapp/stash/internal/api
- github.com/stashapp/stash/pkg/models - github.com/stashapp/stash/pkg/models
- github.com/stashapp/stash/pkg/plugin - github.com/stashapp/stash/pkg/plugin
- github.com/stashapp/stash/pkg/scraper - github.com/stashapp/stash/pkg/scraper
@@ -41,30 +42,13 @@ models:
fields: fields:
title: title:
resolver: true resolver: true
# override models, from internal/api/models.go
BaseFile:
model: github.com/stashapp/stash/internal/api.BaseFile
GalleryFile:
model: github.com/stashapp/stash/internal/api.GalleryFile
fields:
# override fingerprint field
fingerprints:
fieldName: FingerprintSlice
VideoFile: VideoFile:
fields: fields:
# override fingerprint field
fingerprints:
fieldName: FingerprintSlice
# override float fields - #1572 # override float fields - #1572
duration: duration:
fieldName: DurationFinite fieldName: DurationFinite
frame_rate: frame_rate:
fieldName: FrameRateFinite fieldName: FrameRateFinite
ImageFile:
fields:
# override fingerprint field
fingerprints:
fieldName: FingerprintSlice
# autobind on config causes generation issues # autobind on config causes generation issues
BlobsStorageType: BlobsStorageType:
model: github.com/stashapp/stash/internal/manager/config.BlobsStorageType model: github.com/stashapp/stash/internal/manager/config.BlobsStorageType

View File

@@ -27,6 +27,7 @@ interface BaseFile {
mod_time: Time! mod_time: Time!
size: Int64! size: Int64!
fingerprint(type: String!): String
fingerprints: [Fingerprint!]! fingerprints: [Fingerprint!]!
created_at: Time! created_at: Time!
@@ -44,6 +45,7 @@ type VideoFile implements BaseFile {
mod_time: Time! mod_time: Time!
size: Int64! size: Int64!
fingerprint(type: String!): String
fingerprints: [Fingerprint!]! fingerprints: [Fingerprint!]!
format: String! format: String!
@@ -70,6 +72,7 @@ type ImageFile implements BaseFile {
mod_time: Time! mod_time: Time!
size: Int64! size: Int64!
fingerprint(type: String!): String
fingerprints: [Fingerprint!]! fingerprints: [Fingerprint!]!
width: Int! width: Int!
@@ -92,6 +95,7 @@ type GalleryFile implements BaseFile {
mod_time: Time! mod_time: Time!
size: Int64! size: Int64!
fingerprint(type: String!): String
fingerprints: [Fingerprint!]! fingerprints: [Fingerprint!]!
created_at: Time! created_at: Time!

View File

@@ -1,11 +1,64 @@
package api package api
import ( import (
"fmt"
"github.com/stashapp/stash/pkg/models" "github.com/stashapp/stash/pkg/models"
) )
type BaseFile interface{} type BaseFile interface {
IsBaseFile()
}
type VisualFile interface {
IsVisualFile()
}
func convertVisualFile(f models.File) (VisualFile, error) {
switch f := f.(type) {
case VisualFile:
return f, nil
case *models.VideoFile:
return &VideoFile{VideoFile: f}, nil
case *models.ImageFile:
return &ImageFile{ImageFile: f}, nil
default:
return nil, fmt.Errorf("file %s is not a visual file", f.Base().Path)
}
}
type GalleryFile struct { type GalleryFile struct {
*models.BaseFile *models.BaseFile
} }
func (GalleryFile) IsBaseFile() {}
func (GalleryFile) IsVisualFile() {}
func (f *GalleryFile) Fingerprints() []models.Fingerprint {
return f.BaseFile.Fingerprints
}
type VideoFile struct {
*models.VideoFile
}
func (VideoFile) IsBaseFile() {}
func (VideoFile) IsVisualFile() {}
func (f *VideoFile) Fingerprints() []models.Fingerprint {
return f.VideoFile.Fingerprints
}
type ImageFile struct {
*models.ImageFile
}
func (ImageFile) IsBaseFile() {}
func (ImageFile) IsVisualFile() {}
func (f *ImageFile) Fingerprints() []models.Fingerprint {
return f.ImageFile.Fingerprints
}

View File

@@ -81,6 +81,15 @@ func (r *Resolver) Subscription() SubscriptionResolver {
func (r *Resolver) Tag() TagResolver { func (r *Resolver) Tag() TagResolver {
return &tagResolver{r} return &tagResolver{r}
} }
func (r *Resolver) GalleryFile() GalleryFileResolver {
return &galleryFileResolver{r}
}
func (r *Resolver) VideoFile() VideoFileResolver {
return &videoFileResolver{r}
}
func (r *Resolver) ImageFile() ImageFileResolver {
return &imageFileResolver{r}
}
func (r *Resolver) SavedFilter() SavedFilterResolver { func (r *Resolver) SavedFilter() SavedFilterResolver {
return &savedFilterResolver{r} return &savedFilterResolver{r}
} }
@@ -104,6 +113,9 @@ type imageResolver struct{ *Resolver }
type studioResolver struct{ *Resolver } type studioResolver struct{ *Resolver }
type movieResolver struct{ *Resolver } type movieResolver struct{ *Resolver }
type tagResolver struct{ *Resolver } type tagResolver struct{ *Resolver }
type galleryFileResolver struct{ *Resolver }
type videoFileResolver struct{ *Resolver }
type imageFileResolver struct{ *Resolver }
type savedFilterResolver struct{ *Resolver } type savedFilterResolver struct{ *Resolver }
type pluginResolver struct{ *Resolver } type pluginResolver struct{ *Resolver }
type configResultResolver struct{ *Resolver } type configResultResolver struct{ *Resolver }

View File

@@ -0,0 +1,30 @@
package api
import "context"
func (r *galleryFileResolver) Fingerprint(ctx context.Context, obj *GalleryFile, type_ string) (*string, error) {
fp := obj.BaseFile.Fingerprints.For(type_)
if fp != nil {
v := fp.Value()
return &v, nil
}
return nil, nil
}
func (r *imageFileResolver) Fingerprint(ctx context.Context, obj *ImageFile, type_ string) (*string, error) {
fp := obj.ImageFile.Fingerprints.For(type_)
if fp != nil {
v := fp.Value()
return &v, nil
}
return nil, nil
}
func (r *videoFileResolver) Fingerprint(ctx context.Context, obj *VideoFile, type_ string) (*string, error) {
fp := obj.VideoFile.Fingerprints.For(type_)
if fp != nil {
v := fp.Value()
return &v, nil
}
return nil, nil
}

View File

@@ -2,21 +2,12 @@ package api
import ( import (
"context" "context"
"fmt"
"github.com/stashapp/stash/internal/api/loaders" "github.com/stashapp/stash/internal/api/loaders"
"github.com/stashapp/stash/internal/api/urlbuilders" "github.com/stashapp/stash/internal/api/urlbuilders"
"github.com/stashapp/stash/pkg/models" "github.com/stashapp/stash/pkg/models"
) )
func convertVisualFile(f models.File) (models.VisualFile, error) {
vf, ok := f.(models.VisualFile)
if !ok {
return nil, fmt.Errorf("file %s is not a visual file", f.Base().Path)
}
return vf, nil
}
func (r *imageResolver) getFiles(ctx context.Context, obj *models.Image) ([]models.File, error) { func (r *imageResolver) getFiles(ctx context.Context, obj *models.Image) ([]models.File, error) {
fileIDs, err := loaders.From(ctx).ImageFiles.Load(obj.ID) fileIDs, err := loaders.From(ctx).ImageFiles.Load(obj.ID)
if err != nil { if err != nil {
@@ -32,13 +23,13 @@ func (r *imageResolver) Title(ctx context.Context, obj *models.Image) (*string,
return &ret, nil return &ret, nil
} }
func (r *imageResolver) VisualFiles(ctx context.Context, obj *models.Image) ([]models.VisualFile, error) { func (r *imageResolver) VisualFiles(ctx context.Context, obj *models.Image) ([]VisualFile, error) {
files, err := r.getFiles(ctx, obj) files, err := r.getFiles(ctx, obj)
if err != nil { if err != nil {
return nil, err return nil, err
} }
ret := make([]models.VisualFile, len(files)) ret := make([]VisualFile, len(files))
for i, f := range files { for i, f := range files {
ret[i], err = convertVisualFile(f) ret[i], err = convertVisualFile(f)
if err != nil { if err != nil {
@@ -57,13 +48,13 @@ func (r *imageResolver) Date(ctx context.Context, obj *models.Image) (*string, e
return nil, nil return nil, nil
} }
func (r *imageResolver) Files(ctx context.Context, obj *models.Image) ([]*models.ImageFile, error) { func (r *imageResolver) Files(ctx context.Context, obj *models.Image) ([]*ImageFile, error) {
files, err := r.getFiles(ctx, obj) files, err := r.getFiles(ctx, obj)
if err != nil { if err != nil {
return nil, err return nil, err
} }
var ret []*models.ImageFile var ret []*ImageFile
for _, f := range files { for _, f := range files {
// filter out non-image files // filter out non-image files
@@ -72,7 +63,9 @@ func (r *imageResolver) Files(ctx context.Context, obj *models.Image) ([]*models
continue continue
} }
ret = append(ret, imageFile) ret = append(ret, &ImageFile{
ImageFile: imageFile,
})
} }
return ret, nil return ret, nil

View File

@@ -73,13 +73,21 @@ func (r *sceneResolver) Date(ctx context.Context, obj *models.Scene) (*string, e
return nil, nil return nil, nil
} }
func (r *sceneResolver) Files(ctx context.Context, obj *models.Scene) ([]*models.VideoFile, error) { func (r *sceneResolver) Files(ctx context.Context, obj *models.Scene) ([]*VideoFile, error) {
files, err := r.getFiles(ctx, obj) files, err := r.getFiles(ctx, obj)
if err != nil { if err != nil {
return nil, err return nil, err
} }
return files, nil ret := make([]*VideoFile, len(files))
for i, f := range files {
ret[i] = &VideoFile{
VideoFile: f,
}
}
return ret, nil
} }
func (r *sceneResolver) Rating(ctx context.Context, obj *models.Scene) (*int, error) { func (r *sceneResolver) Rating(ctx context.Context, obj *models.Scene) (*int, error) {

View File

@@ -133,10 +133,6 @@ type BaseFile struct {
UpdatedAt time.Time `json:"updated_at"` UpdatedAt time.Time `json:"updated_at"`
} }
func (f *BaseFile) FingerprintSlice() []Fingerprint {
return f.Fingerprints
}
// SetFingerprints sets the fingerprints of the file. // SetFingerprints sets the fingerprints of the file.
// If a fingerprint of the same type already exists, it is overwritten. // If a fingerprint of the same type already exists, it is overwritten.
func (f *BaseFile) SetFingerprints(fp Fingerprints) { func (f *BaseFile) SetFingerprints(fp Fingerprints) {