third-party-mirrors/navidrome
1
0
Fork 0
mirror of https://github.com/navidrome/navidrome.git synced 2025-05-16 18:16:40 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix(server): use tx immediate for some playlist endpoints

Browse Source 
Signed-off-by: Deluan <deluan@navidrome.org>
This commit is contained in:
Deluan 2025-02-26 21:36:29 -05:00
parent a5741050df
commit 3e29edd6c6
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/nativeapi/playlists.go
View File

@ -100,7 +100,7 @@ func deleteFromPlaylist(ds model.DataStore) http.HandlerFunc {
p := req.Params(r) p := req.Params(r)
playlistId, _ := p.String(":playlistId") playlistId, _ := p.String(":playlistId")
ids, _ := p.Strings("id") ids, _ := p.Strings("id")
err := ds.WithTx(func(tx model.DataStore) error { err := ds.WithTxImmediate(func(tx model.DataStore) error {
tracksRepo := tx.Playlist(r.Context()).Tracks(playlistId, true) tracksRepo := tx.Playlist(r.Context()).Tracks(playlistId, true)
return tracksRepo.Delete(ids...) return tracksRepo.Delete(ids...)
}) })

2
server/subsonic/playlists.go
View File

@ -58,7 +58,7 @@ func (api *Router) getPlaylist(ctx context.Context, id string) (*responses.Subso
} }
func (api *Router) create(ctx context.Context, playlistId, name string, ids []string) (string, error) { func (api *Router) create(ctx context.Context, playlistId, name string, ids []string) (string, error) {
err := api.ds.WithTx(func(tx model.DataStore) error { err := api.ds.WithTxImmediate(func(tx model.DataStore) error {
owner := getUser(ctx) owner := getUser(ctx)
var pls *model.Playlist var pls *model.Playlist
var err error var err error