Admin
5df5e635f3
"Listening time this week" summed the full duration of every track whose
stream ticket was issued, so pressing play and skipping counted the whole
song. Playback is now measured on the client and reported to the API.
Backend:
- ListeningHistory gains PlayedSeconds, LastProgressAt and IsCounted
(migration TrackPlayedSeconds marks existing rows as counted).
- /tracks/{id}/stream returns a listenId; new
PUT /tracks/listens/{listenId}/progress stores the accumulated seconds,
capped by track duration and elapsed wall-clock time, monotonic and
owner-only.
- A listen counts once it reaches min(30s, 50% of the track). Weekly
stats, streak, recent history/albums, mixes and listensCount only use
counted listens; seconds sum PlayedSeconds.
- ListeningHistoryCleanupJob (daily) deletes uncounted listens older
than 8 days.
web-player:
- ListenTracker accumulates played time (seeks are ignored) and flushes
on pause, track change, ended, every 30s, and on pagehide.
- Proxy route /api/listens/[id]/progress; repeat starts a new listen per
loop.
54 lines
2.0 KiB
C#
54 lines
2.0 KiB
C#
using ErrorOr;
|
|
using Mediator;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using Musify.Application.Tracks.Responses;
|
|
using X.PagedList;
|
|
using X.PagedList.EF;
|
|
using Musify.Application.Contracts;
|
|
|
|
namespace Musify.Application.Tracks
|
|
{
|
|
public record GetTracksQuery(string? Name, int PageNumber, int PageSize)
|
|
: IQuery<ErrorOr<TracksSearchResponse>>;
|
|
|
|
public class GetTracksQueryHandler(IDatabase database)
|
|
: IQueryHandler<GetTracksQuery, ErrorOr<TracksSearchResponse>>
|
|
{
|
|
public async ValueTask<ErrorOr<TracksSearchResponse>> Handle(GetTracksQuery request, CancellationToken cancellationToken)
|
|
{
|
|
var tracksQuery = database.UserHasTracks
|
|
.AsNoTracking()
|
|
.Include(ut => ut.Track.Owner)
|
|
.Include(ut => ut.Track.Tags)
|
|
.AsQueryable();
|
|
|
|
if (!string.IsNullOrEmpty(request.Name))
|
|
{
|
|
var normalizedName = request.Name.Trim().ToUpperInvariant();
|
|
tracksQuery = tracksQuery.Where(t => t.Track.NormalizedTitle.Contains(normalizedName));
|
|
}
|
|
|
|
var totalCount = await tracksQuery.CountAsync(cancellationToken);
|
|
|
|
var pagedEntities = await tracksQuery
|
|
.OrderByDescending(t => t.Track.CreatedAt)
|
|
.ThenBy(t => t.Id)
|
|
.Select(t => new { t.Track, ListensCount = t.Track.ListeningHistories.Count(l => l.IsCounted) })
|
|
.ToPagedListAsync(request.PageNumber, request.PageSize, totalCount, cancellationToken);
|
|
|
|
var items = pagedEntities
|
|
.Select(x => TrackSearchItemResponse.FromTrack(TrackApplicationResponse.FromEntity(x.Track, x.ListensCount)))
|
|
.ToList();
|
|
|
|
return new TracksSearchResponse(
|
|
items,
|
|
pagedEntities.PageNumber,
|
|
pagedEntities.PageSize,
|
|
pagedEntities.PageCount,
|
|
pagedEntities.TotalItemCount,
|
|
pagedEntities.HasPreviousPage,
|
|
pagedEntities.HasNextPage);
|
|
}
|
|
}
|
|
}
|