roadie/Roadie.Api.Services/TrackService.cs

645 lines
34 KiB
C#
Raw Normal View History

2018-11-17 02:14:32 +00:00
using Mapster;
using Microsoft.AspNetCore.Http;
2018-11-23 04:18:48 +00:00
using Microsoft.EntityFrameworkCore;
2018-11-17 02:14:32 +00:00
using Microsoft.Extensions.Logging;
2018-12-09 14:33:40 +00:00
using Newtonsoft.Json;
2018-11-17 02:14:32 +00:00
using Roadie.Library;
2018-11-12 00:28:37 +00:00
using Roadie.Library.Caching;
using Roadie.Library.Configuration;
using Roadie.Library.Encoding;
2018-12-12 14:31:39 +00:00
using Roadie.Library.Enums;
2018-11-17 02:14:32 +00:00
using Roadie.Library.Extensions;
2018-11-12 00:28:37 +00:00
using Roadie.Library.Models;
using Roadie.Library.Models.Pagination;
2018-12-07 21:02:38 +00:00
using Roadie.Library.Models.Releases;
2018-11-12 00:28:37 +00:00
using Roadie.Library.Models.Users;
using Roadie.Library.Utility;
using System;
using System.Collections.Generic;
using System.Diagnostics;
2018-11-17 02:14:32 +00:00
using System.IO;
2018-11-12 00:28:37 +00:00
using System.Linq;
using System.Linq.Dynamic.Core;
using System.Threading.Tasks;
using data = Roadie.Library.Data;
namespace Roadie.Api.Services
{
public class TrackService : ServiceBase, ITrackService
{
2018-12-12 14:31:39 +00:00
private IBookmarkService BookmarkService { get; } = null;
2018-11-12 00:28:37 +00:00
public TrackService(IRoadieSettings configuration,
IHttpEncoder httpEncoder,
IHttpContext httpContext,
data.IRoadieDbContext dbContext,
ICacheManager cacheManager,
2018-12-12 14:31:39 +00:00
ILogger<TrackService> logger,
IBookmarkService bookmarkService)
2018-11-12 00:28:37 +00:00
: base(configuration, httpEncoder, dbContext, cacheManager, logger, httpContext)
{
2018-12-12 14:31:39 +00:00
this.BookmarkService = bookmarkService;
2018-11-12 00:28:37 +00:00
}
2018-11-17 02:14:32 +00:00
public static long DetermineByteEndFromHeaders(IHeaderDictionary headers, long fileLength)
{
var defaultFileLength = fileLength - 1;
if (headers == null || !headers.Any(x => x.Key == "Range"))
{
return defaultFileLength;
}
long? result = null;
var rangeHeader = headers["Range"];
string rangeEnd = null;
var rangeBegin = rangeHeader.FirstOrDefault();
if (!string.IsNullOrEmpty(rangeBegin))
{
//bytes=0-
rangeBegin = rangeBegin.Replace("bytes=", "");
var parts = rangeBegin.Split('-');
rangeBegin = parts[0];
if (parts.Length > 1)
{
rangeEnd = parts[1];
}
if (!string.IsNullOrEmpty(rangeEnd))
{
result = long.TryParse(rangeEnd, out long outValue) ? (int?)outValue : null;
}
}
return result ?? defaultFileLength;
}
public static long DetermineByteStartFromHeaders(IHeaderDictionary headers)
{
if (headers == null || !headers.Any(x => x.Key == "Range"))
{
return 0;
}
long result = 0;
var rangeHeader = headers["Range"];
var rangeBegin = rangeHeader.FirstOrDefault();
if (!string.IsNullOrEmpty(rangeBegin))
{
//bytes=0-
rangeBegin = rangeBegin.Replace("bytes=", "");
var parts = rangeBegin.Split('-');
rangeBegin = parts[0];
if (!string.IsNullOrEmpty(rangeBegin))
{
long.TryParse(rangeBegin, out result);
}
}
return result;
}
2019-01-05 22:40:33 +00:00
public async Task<OperationResult<Track>> ById(User roadieUser, Guid id, IEnumerable<string> includes)
{
var sw = Stopwatch.StartNew();
sw.Start();
var cacheKey = string.Format("urn:track_by_id_operation:{0}:{1}", id, includes == null ? "0" : string.Join("|", includes));
var result = await this.CacheManager.GetAsync<OperationResult<Track>>(cacheKey, async () =>
{
return await this.TrackByIdAction(id, includes);
}, data.Track.CacheRegionUrn(id));
if (result?.Data != null && roadieUser != null)
{
var user = this.GetUser(roadieUser.UserId);
var track = this.GetTrack(id);
result.Data.TrackPlayUrl = this.MakeTrackPlayUrl(user, track.Id, track.RoadieId);
var userBookmarkResult = await this.BookmarkService.List(roadieUser, new PagedRequest(), false, BookmarkType.Track);
if (userBookmarkResult.IsSuccess)
{
result.Data.UserBookmarked = userBookmarkResult?.Rows?.FirstOrDefault(x => x.Bookmark.Value == track.RoadieId.ToString()) != null;
}
var userTrack = this.DbContext.UserTracks.FirstOrDefault(x => x.TrackId == track.Id && x.UserId == roadieUser.Id);
if (userTrack != null)
{
result.Data.UserRating = new UserTrack
{
Rating = userTrack.Rating,
IsDisliked = userTrack.IsDisliked ?? false,
IsFavorite = userTrack.IsFavorite ?? false,
LastPlayed = userTrack.LastPlayed,
PlayedCount = userTrack.PlayedCount
};
}
}
sw.Stop();
return new OperationResult<Track>(result.Messages)
{
Data = result?.Data,
Errors = result?.Errors,
IsNotFoundResult = result?.IsNotFoundResult ?? false,
IsSuccess = result?.IsSuccess ?? false,
OperationTime = sw.ElapsedMilliseconds
};
}
2018-12-24 19:40:49 +00:00
public Task<Library.Models.Pagination.PagedResult<TrackList>> List(PagedRequest request, User roadieUser, bool? doRandomize = false, Guid? releaseId = null)
2018-11-12 00:28:37 +00:00
{
2018-12-09 14:33:40 +00:00
try
2018-11-23 04:18:48 +00:00
{
2018-12-09 14:33:40 +00:00
var sw = new Stopwatch();
sw.Start();
2018-12-09 17:58:31 +00:00
int? rowCount = null;
2019-01-05 22:40:33 +00:00
if (!string.IsNullOrEmpty(request.Sort))
2018-12-24 19:40:49 +00:00
{
request.Sort = request.Sort.Replace("Release.Text", "Release.Release.Text");
}
2018-12-09 14:33:40 +00:00
IQueryable<int> favoriteTrackIds = (new int[0]).AsQueryable();
if (request.FilterFavoriteOnly)
{
favoriteTrackIds = (from t in this.DbContext.Tracks
join ut in this.DbContext.UserTracks on t.Id equals ut.TrackId
2019-01-09 04:43:19 +00:00
where ut.UserId == roadieUser.Id
2018-12-09 14:33:40 +00:00
where ut.IsFavorite ?? false
select t.Id
2019-01-09 04:43:19 +00:00
);
2018-12-09 14:33:40 +00:00
}
Dictionary<int, int> playListTrackPositions = new Dictionary<int, int>();
int[] playlistTrackIds = new int[0];
if (request.FilterToPlaylistId.HasValue)
{
2018-12-09 17:58:31 +00:00
var playlistTrackInfos = (from plt in this.DbContext.PlaylistTracks
2018-12-09 14:33:40 +00:00
join p in this.DbContext.Playlists on plt.PlayListId equals p.Id
join t in this.DbContext.Tracks on plt.TrackId equals t.Id
where p.RoadieId == request.FilterToPlaylistId.Value
orderby plt.ListNumber
select new
{
plt.ListNumber,
t.Id
2018-12-09 17:58:31 +00:00
});
rowCount = playlistTrackInfos.Count();
playListTrackPositions = playlistTrackInfos.Skip(request.SkipValue).Take(request.LimitValue).ToDictionary(x => x.Id, x => x.ListNumber);
2018-12-09 14:33:40 +00:00
playlistTrackIds = playListTrackPositions.Select(x => x.Key).ToArray();
request.Sort = "TrackNumber";
request.Order = "ASC";
2018-12-09 20:31:02 +00:00
request.Page = 1; // Set back to first or it skips already paged tracks for playlist
request.SkipValue = 0;
}
2018-12-09 14:33:40 +00:00
int[] topTrackids = new int[0];
if (request.FilterTopPlayedOnly)
{
2018-12-09 14:33:40 +00:00
// Get request number of top played songs for artist
topTrackids = (from t in this.DbContext.Tracks
join ut in this.DbContext.UserTracks on t.Id equals ut.TrackId
join rm in this.DbContext.ReleaseMedias on t.ReleaseMediaId equals rm.Id
join r in this.DbContext.Releases on rm.ReleaseId equals r.Id
join a in this.DbContext.Artists on r.ArtistId equals a.Id
where a.RoadieId == request.FilterToArtistId
orderby ut.PlayedCount descending
select t.Id
).Skip(request.SkipValue).Take(request.LimitValue).ToArray();
}
int[] randomTrackIds = null;
2019-01-09 04:43:19 +00:00
if (doRandomize ?? false) {
2019-01-06 19:05:45 +00:00
request.Limit = roadieUser?.RandomReleaseLimit ?? 50;
2019-01-09 04:43:19 +00:00
if (!request.FilterRatedOnly && !request.FilterFavoriteOnly)
{
var sql = "SELECT t.* " +
"FROM `track` t " +
"WHERE t.Hash IS NOT NULL " +
"ORDER BY RAND() LIMIT {0}";
randomTrackIds = this.DbContext.Tracks.FromSql(sql, request.LimitValue).Select(x => x.Id).ToArray();
}
if(request.FilterRatedOnly && !request.FilterFavoriteOnly)
{
var sql = "SELECT t.* " +
"FROM `track` t " +
"WHERE t.Hash IS NOT NULL " +
"AND t.rating > 0 " +
"ORDER BY RAND() LIMIT {0}";
randomTrackIds = this.DbContext.Tracks.FromSql(sql, request.LimitValue).Select(x => x.Id).ToArray();
}
if(request.FilterFavoriteOnly)
{
randomTrackIds = favoriteTrackIds.OrderBy(x => Guid.NewGuid()).ToArray();
}
2018-12-21 22:59:33 +00:00
rowCount = this.DbContext.Tracks.Where(x => x.Hash != null).Count();
2018-12-09 14:33:40 +00:00
}
Guid?[] filterToTrackIds = null;
if (request.FilterToTrackId.HasValue || request.FilterToTrackIds != null)
{
var f = new List<Guid?>();
if (request.FilterToTrackId.HasValue)
{
2018-12-09 14:33:40 +00:00
f.Add(request.FilterToTrackId);
}
if (request.FilterToTrackIds != null)
{
foreach (var ft in request.FilterToTrackIds)
{
2018-12-09 14:33:40 +00:00
if (!f.Contains(ft))
{
f.Add(ft);
}
}
}
2018-12-09 14:33:40 +00:00
filterToTrackIds = f.ToArray();
}
2018-12-09 14:33:40 +00:00
// Did this for performance against the Track table, with just * selcts the table scans are too much of a performance hit.
var resultQuery = (from t in this.DbContext.Tracks
join rm in this.DbContext.ReleaseMedias on t.ReleaseMediaId equals rm.Id
join r in this.DbContext.Releases on rm.ReleaseId equals r.Id
join releaseArtist in this.DbContext.Artists on r.ArtistId equals releaseArtist.Id
join trackArtist in this.DbContext.Artists on t.ArtistId equals trackArtist.Id into tas
from trackArtist in tas.DefaultIfEmpty()
where (t.Hash != null)
where (releaseId == null || (releaseId != null && r.RoadieId == releaseId))
where (filterToTrackIds == null || filterToTrackIds.Contains(t.RoadieId))
where (request.FilterMinimumRating == null || t.Rating >= request.FilterMinimumRating.Value)
where (request.FilterValue == "" || (t.Title.Contains(request.FilterValue) || t.AlternateNames.Contains(request.FilterValue)))
where (!request.FilterFavoriteOnly || favoriteTrackIds.Contains(t.Id))
where (request.FilterToPlaylistId == null || playlistTrackIds.Contains(t.Id))
where (!request.FilterTopPlayedOnly || topTrackids.Contains(t.Id))
where (randomTrackIds == null || randomTrackIds.Contains(t.Id))
2019-01-05 22:40:33 +00:00
where (request.FilterToArtistId == null || request.FilterToArtistId != null && ((t.TrackArtist != null && t.TrackArtist.RoadieId == request.FilterToArtistId) || r.Artist.RoadieId == request.FilterToArtistId))
2019-01-06 00:00:17 +00:00
where (!request.IsHistoryRequest || t.PlayedCount > 0)
2018-12-09 14:33:40 +00:00
select new
2018-12-08 19:47:19 +00:00
{
2018-12-09 14:33:40 +00:00
ti = new
2018-12-08 19:47:19 +00:00
{
2018-12-09 14:33:40 +00:00
t.Id,
t.RoadieId,
t.CreatedDate,
t.LastUpdated,
t.LastPlayed,
t.Duration,
t.FileSize,
t.PlayedCount,
t.Rating,
t.Tags,
t.TrackNumber,
t.Title
2018-12-08 19:47:19 +00:00
},
2018-12-09 14:33:40 +00:00
rmi = new
2018-12-08 19:47:19 +00:00
{
2018-12-09 14:33:40 +00:00
rm.MediaNumber
2018-12-08 19:47:19 +00:00
},
2018-12-09 14:33:40 +00:00
rl = new ReleaseList
{
DatabaseId = r.Id,
Id = r.RoadieId,
Artist = new DataToken
{
Value = releaseArtist.RoadieId.ToString(),
Text = releaseArtist.Name
},
Release = new DataToken
{
Text = r.Title,
Value = r.RoadieId.ToString()
},
ArtistThumbnail = this.MakeArtistThumbnailImage(releaseArtist.RoadieId),
CreatedDate = r.CreatedDate,
Duration = r.Duration,
LastPlayed = r.LastPlayed,
LastUpdated = r.LastUpdated,
LibraryStatus = r.LibraryStatus,
MediaCount = r.MediaCount,
Rating = r.Rating,
ReleaseDateDateTime = r.ReleaseDate,
ReleasePlayUrl = $"{ this.HttpContext.BaseUrl }/play/release/{ r.RoadieId}",
Status = r.Status,
Thumbnail = this.MakeReleaseThumbnailImage(r.RoadieId),
TrackCount = r.TrackCount,
TrackPlayedCount = r.PlayedCount
},
ta = trackArtist == null ? null : new ArtistList
{
DatabaseId = trackArtist.Id,
Id = trackArtist.RoadieId,
Artist = new DataToken { Text = trackArtist.Name, Value = trackArtist.RoadieId.ToString() },
Rating = trackArtist.Rating,
CreatedDate = trackArtist.CreatedDate,
LastUpdated = trackArtist.LastUpdated,
LastPlayed = trackArtist.LastPlayed,
PlayedCount = trackArtist.PlayedCount,
ReleaseCount = trackArtist.ReleaseCount,
TrackCount = trackArtist.TrackCount,
SortName = trackArtist.SortName,
Thumbnail = this.MakeArtistThumbnailImage(trackArtist.RoadieId)
},
ra = new ArtistList
{
DatabaseId = releaseArtist.Id,
Id = releaseArtist.RoadieId,
Artist = new DataToken { Text = releaseArtist.Name, Value = releaseArtist.RoadieId.ToString() },
Rating = releaseArtist.Rating,
CreatedDate = releaseArtist.CreatedDate,
LastUpdated = releaseArtist.LastUpdated,
LastPlayed = releaseArtist.LastPlayed,
PlayedCount = releaseArtist.PlayedCount,
ReleaseCount = releaseArtist.ReleaseCount,
TrackCount = releaseArtist.TrackCount,
SortName = releaseArtist.SortName,
Thumbnail = this.MakeArtistThumbnailImage(releaseArtist.RoadieId)
}
});
2018-11-12 00:28:37 +00:00
2018-12-09 14:33:40 +00:00
if (!string.IsNullOrEmpty(request.FilterValue))
2018-11-15 00:16:25 +00:00
{
2018-12-09 14:33:40 +00:00
if (request.FilterValue.StartsWith("#"))
{
// Find any releases by tags
var tagValue = request.FilterValue.Replace("#", "");
resultQuery = resultQuery.Where(x => x.ti.Tags != null && x.ti.Tags.Contains(tagValue));
}
2018-11-15 00:16:25 +00:00
}
2019-01-02 02:03:17 +00:00
var user = this.GetUser(roadieUser.UserId);
2018-12-09 14:33:40 +00:00
var result = resultQuery.Select(x =>
new TrackList
2018-11-12 00:28:37 +00:00
{
2018-12-09 14:33:40 +00:00
DatabaseId = x.ti.Id,
Id = x.ti.RoadieId,
Track = new DataToken
{
Text = x.ti.Title,
Value = x.ti.RoadieId.ToString()
},
Artist = x.ra,
CreatedDate = x.ti.CreatedDate,
Duration = x.ti.Duration,
FileSize = x.ti.FileSize,
2019-01-05 22:40:33 +00:00
LastPlayed = x.ti.LastPlayed,
LastUpdated = x.ti.LastUpdated,
MediaNumber = x.rmi.MediaNumber,
2019-01-08 22:40:26 +00:00
PlayedCount = x.ti.PlayedCount,
2018-12-09 14:33:40 +00:00
Rating = x.ti.Rating,
2019-01-05 22:40:33 +00:00
Release = x.rl,
ReleaseDate = x.rl.ReleaseDateDateTime,
Thumbnail = this.MakeTrackThumbnailImage(x.ti.RoadieId),
2018-12-09 14:33:40 +00:00
Title = x.ti.Title,
2019-01-05 22:40:33 +00:00
TrackArtist = x.ta,
TrackNumber = playListTrackPositions.ContainsKey(x.ti.Id) ? playListTrackPositions[x.ti.Id] : x.ti.TrackNumber,
TrackPlayUrl = this.MakeTrackPlayUrl(user, x.ti.Id, x.ti.RoadieId)
2018-12-09 14:33:40 +00:00
});
string sortBy = null;
2018-11-12 00:28:37 +00:00
2018-12-09 17:58:31 +00:00
rowCount = rowCount ?? result.Count();
2018-12-09 14:33:40 +00:00
TrackList[] rows = null;
2018-11-15 00:16:25 +00:00
2018-12-09 14:33:40 +00:00
if (request.Action == User.ActionKeyUserRated)
{
sortBy = string.IsNullOrEmpty(request.Sort) ? request.OrderValue(new Dictionary<string, string> { { "UserTrack.Rating", "DESC" }, { "MediaNumber", "ASC" }, { "TrackNumber", "ASC" } }) : request.OrderValue(null);
}
else
{
sortBy = string.IsNullOrEmpty(request.Sort) ? request.OrderValue(new Dictionary<string, string> { { "Release.Release.Text", "ASC" }, { "MediaNumber", "ASC" }, { "TrackNumber", "ASC" } }) : request.OrderValue(null);
}
rows = result.OrderBy(sortBy).Skip(request.SkipValue).Take(request.LimitValue).ToArray();
if (rows.Any() && roadieUser != null)
2018-11-15 00:16:25 +00:00
{
2018-12-09 14:33:40 +00:00
var rowIds = rows.Select(x => x.DatabaseId).ToArray();
var userTrackRatings = (from ut in this.DbContext.UserTracks
where ut.UserId == roadieUser.Id
where rowIds.Contains(ut.TrackId)
select ut).ToArray();
foreach (var userTrackRating in userTrackRatings)
2018-11-15 00:16:25 +00:00
{
2018-12-09 14:33:40 +00:00
var row = rows.FirstOrDefault(x => x.DatabaseId == userTrackRating.TrackId);
if (row != null)
2018-11-15 00:16:25 +00:00
{
2018-12-09 14:33:40 +00:00
row.UserRating = new UserTrack
{
IsDisliked = userTrackRating.IsDisliked ?? false,
IsFavorite = userTrackRating.IsFavorite ?? false,
Rating = userTrackRating.Rating,
LastPlayed = userTrackRating.LastPlayed,
PlayedCount = userTrackRating.PlayedCount
};
}
2018-11-15 00:16:25 +00:00
}
var releaseIds = rows.Select(x => x.Release.DatabaseId).Distinct().ToArray();
var userReleaseRatings = (from ur in this.DbContext.UserReleases
where releaseIds.Contains(ur.ReleaseId)
select ur).ToArray();
2019-01-05 22:40:33 +00:00
foreach (var userReleaseRating in userReleaseRatings)
{
2019-01-05 22:40:33 +00:00
foreach (var row in rows.Where(x => x.Release.DatabaseId == userReleaseRating.ReleaseId))
{
row.Release.UserRating = userReleaseRating.Adapt<UserRelease>();
}
}
var artistIds = rows.Select(x => x.Artist.DatabaseId).ToArray();
if (artistIds != null && artistIds.Any())
{
var userArtistRatings = (from ua in this.DbContext.UserArtists
where ua.UserId == roadieUser.Id
where artistIds.Contains(ua.ArtistId)
select ua).ToArray();
foreach (var userArtistRating in userArtistRatings)
{
foreach (var artistTrack in rows.Where(x => x.Artist.DatabaseId == userArtistRating.ArtistId))
{
artistTrack.Artist.UserRating = userArtistRating.Adapt<UserArtist>();
}
}
}
var trackArtistIds = rows.Where(x => x.TrackArtist != null).Select(x => x.TrackArtist.DatabaseId).ToArray();
if (trackArtistIds != null && trackArtistIds.Any())
{
var userTrackArtistRatings = (from ua in this.DbContext.UserArtists
where ua.UserId == roadieUser.Id
where trackArtistIds.Contains(ua.ArtistId)
select ua).ToArray();
if (userTrackArtistRatings != null && userTrackArtistRatings.Any())
{
foreach (var userTrackArtistRating in userTrackArtistRatings)
{
foreach (var artistTrack in rows.Where(x => x.TrackArtist != null && x.TrackArtist.DatabaseId == userTrackArtistRating.ArtistId))
{
artistTrack.Artist.UserRating = userTrackArtistRating.Adapt<UserArtist>();
}
}
}
}
2018-11-15 00:16:25 +00:00
}
2018-12-09 14:33:40 +00:00
if (rows.Any())
2018-11-15 00:16:25 +00:00
{
2018-12-09 14:33:40 +00:00
foreach (var row in rows)
{
row.FavoriteCount = (from ut in this.DbContext.UserTracks
join tr in this.DbContext.Tracks on ut.TrackId equals tr.Id
where ut.TrackId == row.DatabaseId
where ut.IsFavorite ?? false
select ut.Id).Count();
}
2018-11-15 00:16:25 +00:00
}
2018-12-09 14:33:40 +00:00
sw.Stop();
2018-12-24 19:40:49 +00:00
return Task.FromResult(new Library.Models.Pagination.PagedResult<TrackList>
2018-12-09 14:33:40 +00:00
{
2018-12-09 17:58:31 +00:00
TotalCount = rowCount ?? 0,
2018-12-09 14:33:40 +00:00
CurrentPage = request.PageValue,
TotalPages = (int)Math.Ceiling((double)rowCount / request.LimitValue),
OperationTime = sw.ElapsedMilliseconds,
Rows = rows
2018-12-24 19:40:49 +00:00
});
2018-12-09 14:33:40 +00:00
}
catch (Exception ex)
2018-11-15 00:16:25 +00:00
{
2018-12-09 14:33:40 +00:00
this.Logger.LogError(ex, "Error In List, Request [{0}], User [{1}]", JsonConvert.SerializeObject(request), roadieUser);
2018-12-24 19:40:49 +00:00
return Task.FromResult(new Library.Models.Pagination.PagedResult<TrackList>
2019-01-05 22:40:33 +00:00
{
Message = "An Error has occured"
2018-12-24 19:40:49 +00:00
});
2018-12-09 14:33:40 +00:00
}
2018-11-12 00:28:37 +00:00
}
2018-11-17 02:14:32 +00:00
public async Task<OperationResult<TrackStreamInfo>> TrackStreamInfo(Guid trackId, long beginBytes, long endBytes)
{
var track = this.GetTrack(trackId);
if (track == null)
{
return new OperationResult<TrackStreamInfo>($"TrackStreamInfo: Unable To Find Track [{ trackId }]");
}
if (!track.IsValid)
{
return new OperationResult<TrackStreamInfo>($"TrackStreamInfo: Invalid Track. Track Id [{trackId}], FilePath [{track.FilePath}], Filename [{track.FileName}]");
}
string trackPath = null;
try
{
trackPath = track.PathToTrack(this.Configuration, this.Configuration.LibraryFolder);
}
catch (Exception ex)
{
return new OperationResult<TrackStreamInfo>(ex);
}
var trackFileInfo = new FileInfo(trackPath);
if (!trackFileInfo.Exists)
{
track.UpdateTrackMissingFile();
await this.DbContext.SaveChangesAsync();
return new OperationResult<TrackStreamInfo>($"TrackStreamInfo: TrackId [{trackId}] Unable to Find Track [{trackFileInfo.FullName}]");
}
var contentDurationTimeSpan = TimeSpan.FromMilliseconds((double)(track.Duration ?? 0));
var info = new TrackStreamInfo
{
FileName = this.HttpEncoder.UrlEncode(track.FileName).ToContentDispositionFriendly(),
ContentDisposition = $"attachment; filename=\"{ this.HttpEncoder.UrlEncode(track.FileName).ToContentDispositionFriendly() }\"",
ContentDuration = contentDurationTimeSpan.TotalSeconds.ToString(),
};
var cacheTimeout = 86400; // 24 hours
var contentLength = (endBytes - beginBytes) + 1;
info.Track = new DataToken
{
Text = track.Title,
Value = track.RoadieId.ToString()
};
info.BeginBytes = beginBytes;
info.EndBytes = endBytes;
info.ContentRange = $"bytes {beginBytes}-{endBytes}/{contentLength}";
info.ContentLength = contentLength.ToString();
info.IsFullRequest = beginBytes == 0 && endBytes == (trackFileInfo.Length - 1);
info.IsEndRangeRequest = beginBytes > 0 && endBytes != (trackFileInfo.Length - 1);
info.LastModified = (track.LastUpdated ?? track.CreatedDate).ToString("R");
info.Etag = track.Etag;
info.CacheControl = $"public, max-age={ cacheTimeout.ToString() } ";
info.Expires = DateTime.UtcNow.AddMinutes(cacheTimeout).ToString("R");
int bytesToRead = (int)(endBytes - beginBytes) + 1;
byte[] trackBytes = new byte[bytesToRead];
using (var fs = trackFileInfo.OpenRead())
{
try
{
fs.Seek(beginBytes, SeekOrigin.Begin);
var r = fs.Read(trackBytes, 0, bytesToRead);
}
catch (Exception ex)
{
return new OperationResult<TrackStreamInfo>(ex);
}
}
info.Bytes = trackBytes;
return new OperationResult<TrackStreamInfo>
{
2018-11-24 01:46:12 +00:00
IsSuccess = true,
2018-11-17 02:14:32 +00:00
Data = info
};
}
2019-01-05 22:40:33 +00:00
private Task<OperationResult<Track>> TrackByIdAction(Guid id, IEnumerable<string> includes)
{
var sw = Stopwatch.StartNew();
sw.Start();
var track = this.GetTrack(id);
if (track == null)
{
return Task.FromResult(new OperationResult<Track>(true, string.Format("Track Not Found [{0}]", id)));
}
var result = track.Adapt<Track>();
result.IsLocked = (track.IsLocked ?? false) ||
(track.ReleaseMedia.IsLocked ?? false) ||
(track.ReleaseMedia.Release.IsLocked ?? false) ||
(track.ReleaseMedia.Release.Artist.IsLocked ?? false);
result.Thumbnail = base.MakeTrackThumbnailImage(id);
result.MediumThumbnail = base.MakeThumbnailImage(id, "track", this.Configuration.MediumImageSize.Width, this.Configuration.MediumImageSize.Height);
result.ReleaseMediaId = track.ReleaseMedia.RoadieId.ToString();
result.Artist = ArtistList.FromDataArtist(track.ReleaseMedia.Release.Artist, this.MakeArtistThumbnailImage(track.ReleaseMedia.Release.Artist.RoadieId));
result.ArtistThumbnail = this.MakeArtistThumbnailImage(track.ReleaseMedia.Release.Artist.RoadieId);
result.Release = ReleaseList.FromDataRelease(track.ReleaseMedia.Release, track.ReleaseMedia.Release.Artist, this.HttpContext.BaseUrl, this.MakeArtistThumbnailImage(track.ReleaseMedia.Release.Artist.RoadieId), this.MakeReleaseThumbnailImage(track.ReleaseMedia.Release.RoadieId));
result.ReleaseThumbnail = this.MakeReleaseThumbnailImage(track.ReleaseMedia.Release.RoadieId);
if (track.ArtistId.HasValue)
{
var trackArtist = this.DbContext.Artists.FirstOrDefault(x => x.Id == track.ArtistId);
if (trackArtist == null)
{
this.Logger.LogWarning($"Unable to find Track Artist [{ track.ArtistId }");
}
else
{
result.TrackArtist = ArtistList.FromDataArtist(trackArtist, this.MakeArtistThumbnailImage(trackArtist.RoadieId));
result.TrackArtistThumbnail = this.MakeArtistThumbnailImage(trackArtist.RoadieId);
}
}
if (includes != null && includes.Any())
{
if (includes.Contains("stats"))
{
result.Statistics = new Library.Models.Statistics.TrackStatistics
{
FileSizeFormatted = ((long?)track.FileSize).ToFileSize(),
Time = new TimeInfo((decimal)track.Duration).ToFullFormattedString(),
PlayedCount = track.PlayedCount
};
var userTracks = (from t in this.DbContext.Tracks
join ut in this.DbContext.UserTracks on t.Id equals ut.TrackId
where t.Id == track.Id
select ut).ToArray();
if (userTracks != null && userTracks.Any())
{
result.Statistics.DislikedCount = userTracks.Count(x => x.IsDisliked ?? false);
result.Statistics.FavoriteCount = userTracks.Count(x => x.IsFavorite ?? false);
}
}
}
sw.Stop();
return Task.FromResult(new OperationResult<Track>
{
Data = result,
IsSuccess = result != null,
OperationTime = sw.ElapsedMilliseconds
});
}
2018-11-12 00:28:37 +00:00
}
}