1
Fork 0

Rename resolvers/photo.go to media.go

This commit is contained in:
viktorstrate 2020-07-10 18:52:18 +02:00
parent cacfb5edde
commit b510e14ecd
1 changed files with 8 additions and 11 deletions

View File

@ -3,10 +3,9 @@ package resolvers
import ( import (
"context" "context"
"database/sql" "database/sql"
"errors"
"log"
"strings" "strings"
"github.com/pkg/errors"
api "github.com/viktorstrate/photoview/api/graphql" api "github.com/viktorstrate/photoview/api/graphql"
"github.com/viktorstrate/photoview/api/graphql/auth" "github.com/viktorstrate/photoview/api/graphql/auth"
"github.com/viktorstrate/photoview/api/graphql/models" "github.com/viktorstrate/photoview/api/graphql/models"
@ -55,7 +54,7 @@ func (r *queryResolver) Media(ctx context.Context, id int) (*models.Media, error
media, err := models.NewMediaFromRow(row) media, err := models.NewMediaFromRow(row)
if err != nil { if err != nil {
return nil, err return nil, errors.Wrap(err, "could not get media by media_id and user_id from database")
} }
return media, nil return media, nil
@ -72,7 +71,7 @@ func (r *Resolver) Media() api.MediaResolver {
func (r *mediaResolver) Shares(ctx context.Context, obj *models.Media) ([]*models.ShareToken, error) { func (r *mediaResolver) Shares(ctx context.Context, obj *models.Media) ([]*models.ShareToken, error) {
rows, err := r.Database.Query("SELECT * FROM share_token WHERE media_id = ?", obj.MediaID) rows, err := r.Database.Query("SELECT * FROM share_token WHERE media_id = ?", obj.MediaID)
if err != nil { if err != nil {
return nil, err return nil, errors.Wrapf(err, "get shares for media (%s)", obj.Path)
} }
return models.NewShareTokensFromRows(rows) return models.NewShareTokensFromRows(rows)
@ -82,7 +81,7 @@ func (r *mediaResolver) Downloads(ctx context.Context, obj *models.Media) ([]*mo
rows, err := r.Database.Query("SELECT * FROM media_url WHERE media_id = ?", obj.MediaID) rows, err := r.Database.Query("SELECT * FROM media_url WHERE media_id = ?", obj.MediaID)
if err != nil { if err != nil {
return nil, err return nil, errors.Wrapf(err, "get downloads for media (%s)", obj.Path)
} }
mediaUrls, err := models.NewMediaURLFromRows(rows) mediaUrls, err := models.NewMediaURLFromRows(rows)
@ -133,8 +132,7 @@ func (r *mediaResolver) HighRes(ctx context.Context, obj *models.Media) (*models
url, err := models.NewMediaURLFromRow(row) url, err := models.NewMediaURLFromRow(row)
if err != nil { if err != nil {
log.Printf("Error: Could not query highres: %s\n", err) return nil, errors.Wrapf(err, "could not query high-res (%s)", obj.Path)
return nil, err
} }
return url, nil return url, nil
@ -145,8 +143,7 @@ func (r *mediaResolver) Thumbnail(ctx context.Context, obj *models.Media) (*mode
url, err := models.NewMediaURLFromRow(row) url, err := models.NewMediaURLFromRow(row)
if err != nil { if err != nil {
log.Printf("Error: Could not query thumbnail: %s\n", err) return nil, errors.Wrapf(err, "could not query thumbnail (%s)", obj.Path)
return nil, err
} }
return url, nil return url, nil
@ -165,7 +162,7 @@ func (r *mediaResolver) Exif(ctx context.Context, obj *models.Media) (*models.Me
if err == sql.ErrNoRows { if err == sql.ErrNoRows {
return nil, nil return nil, nil
} else { } else {
return nil, err return nil, errors.Wrapf(err, "could not get exif of media from database")
} }
} }
@ -185,7 +182,7 @@ func (r *mutationResolver) FavoriteMedia(ctx context.Context, mediaID int, favor
_, err = r.Database.Exec("UPDATE media SET favorite = ? WHERE media_id = ?", favorite, media.MediaID) _, err = r.Database.Exec("UPDATE media SET favorite = ? WHERE media_id = ?", favorite, media.MediaID)
if err != nil { if err != nil {
return nil, err return nil, errors.Wrap(err, "failed to update media favorite on database")
} }
media.Favorite = favorite media.Favorite = favorite