NewsEntryPoint.cs 9.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275
  1. using MediaBrowser.Common.Configuration;
  2. using MediaBrowser.Common.Extensions;
  3. using MediaBrowser.Common.Net;
  4. using MediaBrowser.Controller.Library;
  5. using MediaBrowser.Controller.Notifications;
  6. using MediaBrowser.Controller.Plugins;
  7. using MediaBrowser.Model.Logging;
  8. using MediaBrowser.Model.News;
  9. using MediaBrowser.Model.Notifications;
  10. using MediaBrowser.Model.Serialization;
  11. using System;
  12. using System.Collections.Generic;
  13. using System.IO;
  14. using System.Linq;
  15. using System.Threading;
  16. using System.Threading.Tasks;
  17. using System.Xml;
  18. using MediaBrowser.Model.IO;
  19. using MediaBrowser.Model.Threading;
  20. namespace Emby.Server.Implementations.News
  21. {
  22. public class NewsEntryPoint : IServerEntryPoint
  23. {
  24. private ITimer _timer;
  25. private readonly IHttpClient _httpClient;
  26. private readonly IApplicationPaths _appPaths;
  27. private readonly IFileSystem _fileSystem;
  28. private readonly ILogger _logger;
  29. private readonly IJsonSerializer _json;
  30. private readonly INotificationManager _notifications;
  31. private readonly IUserManager _userManager;
  32. private readonly TimeSpan _frequency = TimeSpan.FromHours(24);
  33. private readonly ITimerFactory _timerFactory;
  34. public NewsEntryPoint(IHttpClient httpClient, IApplicationPaths appPaths, IFileSystem fileSystem, ILogger logger, IJsonSerializer json, INotificationManager notifications, IUserManager userManager, ITimerFactory timerFactory)
  35. {
  36. _httpClient = httpClient;
  37. _appPaths = appPaths;
  38. _fileSystem = fileSystem;
  39. _logger = logger;
  40. _json = json;
  41. _notifications = notifications;
  42. _userManager = userManager;
  43. _timerFactory = timerFactory;
  44. }
  45. public void Run()
  46. {
  47. _timer = _timerFactory.Create(OnTimerFired, null, TimeSpan.FromMilliseconds(500), _frequency);
  48. }
  49. /// <summary>
  50. /// Called when [timer fired].
  51. /// </summary>
  52. /// <param name="state">The state.</param>
  53. private async void OnTimerFired(object state)
  54. {
  55. var path = Path.Combine(_appPaths.CachePath, "news.json");
  56. try
  57. {
  58. await DownloadNews(path).ConfigureAwait(false);
  59. }
  60. catch (Exception ex)
  61. {
  62. _logger.ErrorException("Error downloading news", ex);
  63. }
  64. }
  65. private async Task DownloadNews(string path)
  66. {
  67. DateTime? lastUpdate = null;
  68. if (_fileSystem.FileExists(path))
  69. {
  70. lastUpdate = _fileSystem.GetLastWriteTimeUtc(path);
  71. }
  72. var requestOptions = new HttpRequestOptions
  73. {
  74. Url = "http://emby.media/community/index.php?/blog/rss/1-media-browser-developers-blog",
  75. Progress = new Progress<double>(),
  76. UserAgent = "Mozilla/5.0 (Windows NT 6.3; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/46.0.2490.42 Safari/537.36",
  77. BufferContent = false
  78. };
  79. using (var stream = await _httpClient.Get(requestOptions).ConfigureAwait(false))
  80. {
  81. using (var reader = XmlReader.Create(stream))
  82. {
  83. var news = ParseRssItems(reader).ToList();
  84. _json.SerializeToFile(news, path);
  85. await CreateNotifications(news, lastUpdate, CancellationToken.None).ConfigureAwait(false);
  86. }
  87. }
  88. }
  89. private Task CreateNotifications(List<NewsItem> items, DateTime? lastUpdate, CancellationToken cancellationToken)
  90. {
  91. if (lastUpdate.HasValue)
  92. {
  93. items = items.Where(i => i.Date.ToUniversalTime() >= lastUpdate.Value)
  94. .ToList();
  95. }
  96. var tasks = items.Select(i => _notifications.SendNotification(new NotificationRequest
  97. {
  98. Date = i.Date,
  99. Name = i.Title,
  100. Description = i.Description,
  101. Url = i.Link,
  102. UserIds = _userManager.Users.Select(u => u.Id.ToString("N")).ToList()
  103. }, cancellationToken));
  104. return Task.WhenAll(tasks);
  105. }
  106. private IEnumerable<NewsItem> ParseRssItems(XmlReader reader)
  107. {
  108. reader.MoveToContent();
  109. reader.Read();
  110. while (!reader.EOF && reader.ReadState == ReadState.Interactive)
  111. {
  112. if (reader.NodeType == XmlNodeType.Element)
  113. {
  114. switch (reader.Name)
  115. {
  116. case "channel":
  117. {
  118. if (!reader.IsEmptyElement)
  119. {
  120. using (var subReader = reader.ReadSubtree())
  121. {
  122. return ParseFromChannelNode(subReader);
  123. }
  124. }
  125. else
  126. {
  127. reader.Read();
  128. }
  129. break;
  130. }
  131. default:
  132. {
  133. reader.Skip();
  134. break;
  135. }
  136. }
  137. }
  138. else
  139. {
  140. reader.Read();
  141. }
  142. }
  143. return new List<NewsItem>();
  144. }
  145. private IEnumerable<NewsItem> ParseFromChannelNode(XmlReader reader)
  146. {
  147. var list = new List<NewsItem>();
  148. reader.MoveToContent();
  149. reader.Read();
  150. while (!reader.EOF && reader.ReadState == ReadState.Interactive)
  151. {
  152. if (reader.NodeType == XmlNodeType.Element)
  153. {
  154. switch (reader.Name)
  155. {
  156. case "item":
  157. {
  158. if (!reader.IsEmptyElement)
  159. {
  160. using (var subReader = reader.ReadSubtree())
  161. {
  162. list.Add(ParseItem(subReader));
  163. }
  164. }
  165. else
  166. {
  167. reader.Read();
  168. }
  169. break;
  170. }
  171. default:
  172. {
  173. reader.Skip();
  174. break;
  175. }
  176. }
  177. }
  178. else
  179. {
  180. reader.Read();
  181. }
  182. }
  183. return list;
  184. }
  185. private NewsItem ParseItem(XmlReader reader)
  186. {
  187. var item = new NewsItem();
  188. reader.MoveToContent();
  189. reader.Read();
  190. while (!reader.EOF && reader.ReadState == ReadState.Interactive)
  191. {
  192. if (reader.NodeType == XmlNodeType.Element)
  193. {
  194. switch (reader.Name)
  195. {
  196. case "title":
  197. {
  198. item.Title = reader.ReadElementContentAsString();
  199. break;
  200. }
  201. case "link":
  202. {
  203. item.Link = reader.ReadElementContentAsString();
  204. break;
  205. }
  206. case "description":
  207. {
  208. item.DescriptionHtml = reader.ReadElementContentAsString();
  209. item.Description = item.DescriptionHtml.StripHtml();
  210. break;
  211. }
  212. case "pubDate":
  213. {
  214. var date = reader.ReadElementContentAsString();
  215. DateTime parsedDate;
  216. if (DateTime.TryParse(date, out parsedDate))
  217. {
  218. item.Date = parsedDate;
  219. }
  220. break;
  221. }
  222. default:
  223. {
  224. reader.Skip();
  225. break;
  226. }
  227. }
  228. }
  229. else
  230. {
  231. reader.Read();
  232. }
  233. }
  234. return item;
  235. }
  236. public void Dispose()
  237. {
  238. if (_timer != null)
  239. {
  240. _timer.Dispose();
  241. _timer = null;
  242. }
  243. }
  244. }
  245. }