yonlu
7cde7cc7b8
- Column accessor shows '0' instead of empty string for unplayed tracks - recordPlay emits TrackMetadataChanged event after updating DB - Frontend library store invalidates on that event, refreshing play counts
71 lines
1.4 KiB
Go
71 lines
1.4 KiB
Go
package queue
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/wailsapp/wails/v2/pkg/runtime"
|
|
|
|
"yellowjacket/backend/events"
|
|
)
|
|
|
|
// recordPlay inserts a play_history row and updates the denormalized
|
|
// play_count / last_played columns on audio_files. Called from
|
|
// OnPlaybackFinished for the track that just finished.
|
|
//
|
|
// SAFETY: Uses ExecContext with parameterized queries only.
|
|
// Must be called without q.mu held — it acquires the DB connection
|
|
// which is single-writer (MaxOpenConns 1).
|
|
func (q *Queue) recordPlay(audioFileID int64) {
|
|
if audioFileID <= 0 {
|
|
return
|
|
}
|
|
|
|
now := time.Now().UTC().Format(time.DateTime)
|
|
|
|
// Insert play_history row.
|
|
_, err := q.db.ExecContext(
|
|
`INSERT INTO play_history (audio_file_id, played_at)
|
|
VALUES (?, ?)`,
|
|
audioFileID, now,
|
|
)
|
|
if err != nil {
|
|
q.logger.Error(
|
|
"failed to insert play history",
|
|
"audioFileId", audioFileID,
|
|
"error", err,
|
|
)
|
|
|
|
return
|
|
}
|
|
|
|
// Update denormalized columns on audio_files.
|
|
_, err = q.db.ExecContext(
|
|
`UPDATE audio_files
|
|
SET play_count = play_count + 1,
|
|
last_played = ?
|
|
WHERE id = ?`,
|
|
now, audioFileID,
|
|
)
|
|
if err != nil {
|
|
q.logger.Error(
|
|
"failed to update play count",
|
|
"audioFileId", audioFileID,
|
|
"error", err,
|
|
)
|
|
|
|
return
|
|
}
|
|
|
|
q.logger.Info(
|
|
"Play recorded",
|
|
"audioFileId", audioFileID,
|
|
)
|
|
|
|
// Notify frontend so the track list refreshes play count.
|
|
if q.ctx != nil {
|
|
runtime.EventsEmit(
|
|
q.ctx, events.TrackMetadataChanged,
|
|
)
|
|
}
|
|
}
|