Blazor & WASM in combination to get statistics from Spotify API for performing the song analysis. With separate microservices for auth, Spotify, user data tracking, and application, connected through gRPC with Polly.
您最多选择25个主题 主题必须以字母或数字开头,可以包含连字符 (-),并且长度不得超过35个字符

TrackService.cs 6.3KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167
  1. using Google.Rpc;
  2. using Grpc.Core;
  3. using GrpcShared;
  4. using GrpcShared.DTO;
  5. using GrpcShared.DTO.Search;
  6. using GrpcShared.DTO.Track;
  7. using GrpcShared.DTO.Track.MultipleTrack;
  8. using GrpcShared.DTO.Track.SaveTracks;
  9. using GrpcShared.DTO.Track.SingleTrack;
  10. using GrpcShared.DTO.TrackByID;
  11. using GrpcShared.Interfaces;
  12. using Microsoft.AspNetCore.Authorization;
  13. using Microsoft.Net.Http.Headers;
  14. using NemAnBlazor.Services;
  15. using Newtonsoft.Json;
  16. using System.Text;
  17. using System.Text.Json;
  18. using System.Web;
  19. using static GrpcShared.DTO.Search.SearchDetails;
  20. namespace SpotifyService.Services
  21. {
  22. public class TrackService : ITrackService
  23. {
  24. private readonly IHttpClientFactory _httpClientFactory;
  25. private IIdentityService _identityService;
  26. private IAuthService _authService;
  27. public TrackService(IHttpClientFactory httpClientFactory, IIdentityService identityService, IAuthService authService)
  28. {
  29. _httpClientFactory = httpClientFactory;
  30. _identityService = identityService;
  31. _authService = authService;
  32. }
  33. public async Task<SearchResponse> ListSearchAsync(SearchRequest request)
  34. {
  35. string url = $"search?q={request.Query}&type={request.Type}";
  36. var response = await HttpUtils.HttpUtils<SearchResponse>
  37. .GetData(_httpClientFactory,
  38. url,
  39. request.UserId!,
  40. _identityService,
  41. _authService);
  42. //ovo je ako hocemo da dodamo da se prikazuje dal je sacuvana pesma od onih koje se pretrazuju,
  43. //al ce potencijalno da prepuni requests ako ne optimizujemo pretragu
  44. //if (response != null)
  45. //{
  46. // List<string> ids = response.Tracks!.Items!.Select(x => x.Id!).ToList();
  47. // var param = new Dictionary<string, List<string>>();
  48. // param["ids"] = ids;
  49. // var query = UriUtil(param);
  50. // string savedUrl = $"tracks/contains{query}";
  51. // var isSavedResponse = await HttpUtils.HttpUtils<IsSavedResponse>
  52. // .GetData(_httpClientFactory,
  53. // savedUrl,
  54. // request.UserId!,
  55. // _identityService,
  56. // _authService);
  57. // for (int i = 0; i < response.Tracks.Items.Count; i++)
  58. // {
  59. // response.Tracks.Items[i].IsSaved = isSavedResponse.AreSaved[i];
  60. // }
  61. //}
  62. return response;
  63. }
  64. public async Task<SingleTrackResponse> ListSingleTrackAsync(SingleTrackRequest request)
  65. {
  66. string url = $"audio-features/{request.Id}";
  67. var response = await HttpUtils.HttpUtils<SingleTrackResponse>
  68. .GetData(_httpClientFactory,
  69. url,
  70. request.UserId!,
  71. _identityService,
  72. _authService);
  73. string savedUrl = $"tracks/contains?ids={request.Id}";
  74. var savedResponse = await HttpUtils.HttpUtils <List<bool>>
  75. .GetData(_httpClientFactory,
  76. savedUrl,
  77. request.UserId!,
  78. _identityService,
  79. _authService);
  80. response.IsSaved = savedResponse[0];
  81. return response;
  82. }
  83. public async Task<MultipleTrackResponse> ListMultipleTrackAsync(MultipleTrackRequest request)
  84. {
  85. var param = new Dictionary<string, List<string>>();
  86. param["ids"] = request.Ids!;
  87. var query = UriUtil(param);
  88. string url = $"audio-features{query}";
  89. return await HttpUtils.HttpUtils<MultipleTrackResponse>
  90. .GetData(_httpClientFactory,
  91. url,
  92. request.UserId!,
  93. _identityService,
  94. _authService);
  95. }
  96. public async Task SaveTracks(SaveTracksRequest request)
  97. {
  98. var client = _httpClientFactory.CreateClient("HttpClient");
  99. var param = new Dictionary<string, List<string>>();
  100. param["ids"] = request.Ids!;
  101. var query = UriUtil(param);
  102. string url = $"me/tracks/{query}";
  103. //the response type has nothing to do with the method, it's there so that the method can be called
  104. await HttpUtils.HttpUtils<StatusCodeMessage>
  105. .PutData(client,
  106. url,
  107. request.UserId!,
  108. _identityService,
  109. _authService);
  110. }
  111. public static string UriUtil(Dictionary<string, List<string>> param)
  112. {
  113. bool startingQuestionMarkAdded = false;
  114. var sb = new StringBuilder();
  115. foreach (var id in param)
  116. {
  117. sb.Append(startingQuestionMarkAdded ? '&' : '?');
  118. sb.Append(id.Key);
  119. sb.Append('=');
  120. foreach (var Xid in id.Value)
  121. {
  122. sb.Append(Xid);
  123. sb.Append("%2C");
  124. startingQuestionMarkAdded = true;
  125. }
  126. }
  127. sb.Length = sb.Length - 3;
  128. return sb.ToString();
  129. }
  130. public async Task<TrackResponse> GetById(TrackRequest request)
  131. {
  132. string url = $"tracks/{request.TrackID}";
  133. return await HttpUtils.HttpUtils<TrackResponse>
  134. .GetData(_httpClientFactory,
  135. url,
  136. request.UserId!,
  137. _identityService,
  138. _authService);
  139. }
  140. }
  141. }