PersonProviderFromJson.cs 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117
  1. using MediaBrowser.Common.Net;
  2. using MediaBrowser.Controller.Entities;
  3. using MediaBrowser.Model.Serialization;
  4. using System;
  5. using System.IO;
  6. using System.Threading;
  7. using System.Threading.Tasks;
  8. namespace MediaBrowser.Controller.Providers.Movies
  9. {
  10. /// <summary>
  11. /// Class PersonProviderFromJson
  12. /// </summary>
  13. class PersonProviderFromJson : TmdbPersonProvider
  14. {
  15. public PersonProviderFromJson(IHttpClient httpClient, IJsonSerializer jsonSerializer)
  16. : base(httpClient, jsonSerializer)
  17. {
  18. }
  19. /// <summary>
  20. /// Supportses the specified item.
  21. /// </summary>
  22. /// <param name="item">The item.</param>
  23. /// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
  24. public override bool Supports(BaseItem item)
  25. {
  26. return item is Person;
  27. }
  28. /// <summary>
  29. /// Gets a value indicating whether [requires internet].
  30. /// </summary>
  31. /// <value><c>true</c> if [requires internet]; otherwise, <c>false</c>.</value>
  32. public override bool RequiresInternet
  33. {
  34. get
  35. {
  36. return false;
  37. }
  38. }
  39. // Need to re-override to jump over intermediate implementation
  40. /// <summary>
  41. /// Needses the refresh internal.
  42. /// </summary>
  43. /// <param name="item">The item.</param>
  44. /// <param name="providerInfo">The provider info.</param>
  45. /// <returns><c>true</c> if XXXX, <c>false</c> otherwise</returns>
  46. protected override bool NeedsRefreshInternal(BaseItem item, BaseProviderInfo providerInfo)
  47. {
  48. if (!item.ResolveArgs.ContainsMetaFileByName(MetaFileName))
  49. {
  50. return false;
  51. }
  52. return CompareDate(item) > providerInfo.LastRefreshed;
  53. }
  54. /// <summary>
  55. /// Override this to return the date that should be compared to the last refresh date
  56. /// to determine if this provider should be re-fetched.
  57. /// </summary>
  58. /// <param name="item">The item.</param>
  59. /// <returns>DateTime.</returns>
  60. protected override DateTime CompareDate(BaseItem item)
  61. {
  62. var entry = item.ResolveArgs.GetMetaFileByPath(Path.Combine(item.MetaLocation,MetaFileName));
  63. return entry != null ? entry.Value.LastWriteTimeUtc : DateTime.MinValue;
  64. }
  65. /// <summary>
  66. /// Gets the priority.
  67. /// </summary>
  68. /// <value>The priority.</value>
  69. public override MetadataProviderPriority Priority
  70. {
  71. get
  72. {
  73. return MetadataProviderPriority.Third;
  74. }
  75. }
  76. /// <summary>
  77. /// Fetches metadata and returns true or false indicating if any work that requires persistence was done
  78. /// </summary>
  79. /// <param name="item">The item.</param>
  80. /// <param name="force">if set to <c>true</c> [force].</param>
  81. /// <param name="cancellationToken">The cancellation token.</param>
  82. /// <returns>Task{System.Boolean}.</returns>
  83. protected override Task<bool> FetchAsyncInternal(BaseItem item, bool force, CancellationToken cancellationToken)
  84. {
  85. return Task.Run(() =>
  86. {
  87. cancellationToken.ThrowIfCancellationRequested();
  88. try
  89. {
  90. var personInfo = JsonSerializer.DeserializeFromFile<PersonResult>(Path.Combine(item.MetaLocation, MetaFileName));
  91. cancellationToken.ThrowIfCancellationRequested();
  92. ProcessInfo((Person)item, personInfo);
  93. SetLastRefreshed(item, DateTime.UtcNow);
  94. return true;
  95. }
  96. catch (FileNotFoundException)
  97. {
  98. // This is okay - just means we force refreshed and there isn't a json file
  99. return false;
  100. }
  101. });
  102. }
  103. }
  104. }