mirror of
https://github.com/navidrome/navidrome.git
synced 2026-08-01 07:21:17 +00:00
3158451b8d
* refactor(req): drop redundant error return from Strings
The error from Strings carried no information beyond emptiness — it fired
exactly when the param was absent — and nearly every caller discarded it with
a blank identifier. Strings now just returns the values (empty when absent),
making the common optional-list reads one clean expression.
The few required-param callers (scrobble, createShare) check for emptiness and
return the same Subsonic error code 10 as before; their e2e tests now pin that
code. Ints and Times keep their contracts by synthesizing ErrMissingParam
themselves, so selectedMusicFolderIds is untouched. The jellyfin parseFields
helper is inlined away, since ParseFields(p.Strings("fields")...) now
compiles directly.
* docs(req): clarify Strings returns nil when param is absent
121 lines
3.0 KiB
Go
121 lines
3.0 KiB
Go
package subsonic
|
|
|
|
import (
|
|
"net/http"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/deluan/rest"
|
|
"github.com/navidrome/navidrome/model"
|
|
"github.com/navidrome/navidrome/server/public"
|
|
"github.com/navidrome/navidrome/server/subsonic/responses"
|
|
"github.com/navidrome/navidrome/utils/req"
|
|
"github.com/navidrome/navidrome/utils/slice"
|
|
)
|
|
|
|
func (api *Router) GetShares(r *http.Request) (*responses.Subsonic, error) {
|
|
repo := api.share.NewRepository(r.Context()).(model.ShareRepository)
|
|
shares, err := repo.GetAll(model.QueryOptions{Sort: "created_at desc"})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
response := newResponse()
|
|
response.Shares = &responses.Shares{}
|
|
for _, share := range shares {
|
|
response.Shares.Share = append(response.Shares.Share, api.buildShare(r, share))
|
|
}
|
|
return response, nil
|
|
}
|
|
|
|
func (api *Router) buildShare(r *http.Request, share model.Share) responses.Share {
|
|
resp := responses.Share{
|
|
ID: share.ID,
|
|
Url: public.ShareURL(r, share.ID),
|
|
Description: share.Description,
|
|
Username: share.Username,
|
|
Created: share.CreatedAt,
|
|
Expires: share.ExpiresAt,
|
|
LastVisited: share.LastVisitedAt,
|
|
VisitCount: int32(share.VisitCount),
|
|
}
|
|
if resp.Description == "" {
|
|
resp.Description = share.Contents
|
|
}
|
|
if len(share.Albums) > 0 {
|
|
resp.Entry = slice.MapWithArg(share.Albums, r.Context(), childFromAlbum)
|
|
} else {
|
|
resp.Entry = slice.MapWithArg(share.Tracks, r.Context(), childFromMediaFile)
|
|
}
|
|
return resp
|
|
}
|
|
|
|
func (api *Router) CreateShare(r *http.Request) (*responses.Subsonic, error) {
|
|
p := req.Params(r)
|
|
ids := p.Strings("id")
|
|
if len(ids) == 0 {
|
|
return nil, newError(responses.ErrorMissingParameter, "missing parameter: 'id'")
|
|
}
|
|
|
|
description, _ := p.String("description")
|
|
repo := api.share.NewRepository(r.Context())
|
|
share := &model.Share{
|
|
Description: description,
|
|
ExpiresAt: new(p.TimeOr("expires", time.Time{})),
|
|
ResourceIDs: strings.Join(ids, ","),
|
|
}
|
|
|
|
id, err := repo.(rest.Persistable).Save(share)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
share, err = repo.(model.ShareRepository).Get(id)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
response := newResponse()
|
|
response.Shares = &responses.Shares{Share: []responses.Share{api.buildShare(r, *share)}}
|
|
return response, nil
|
|
}
|
|
|
|
func (api *Router) UpdateShare(r *http.Request) (*responses.Subsonic, error) {
|
|
p := req.Params(r)
|
|
id, err := p.String("id")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
description, _ := p.String("description")
|
|
repo := api.share.NewRepository(r.Context())
|
|
share := &model.Share{
|
|
ID: id,
|
|
Description: description,
|
|
ExpiresAt: new(p.TimeOr("expires", time.Time{})),
|
|
}
|
|
|
|
err = repo.(rest.Persistable).Update(id, share)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return newResponse(), nil
|
|
}
|
|
|
|
func (api *Router) DeleteShare(r *http.Request) (*responses.Subsonic, error) {
|
|
p := req.Params(r)
|
|
id, err := p.String("id")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
repo := api.share.NewRepository(r.Context())
|
|
err = repo.(rest.Persistable).Delete(id)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return newResponse(), nil
|
|
}
|