| | | 1 | | using System; |
| | | 2 | | using System.Collections.Generic; |
| | | 3 | | using System.IO; |
| | | 4 | | using System.Linq; |
| | | 5 | | using System.Text; |
| | | 6 | | using System.Threading; |
| | | 7 | | using System.Xml; |
| | | 8 | | using MediaBrowser.Common.Configuration; |
| | | 9 | | using MediaBrowser.Controller.Entities.TV; |
| | | 10 | | using MediaBrowser.Controller.Extensions; |
| | | 11 | | using MediaBrowser.Controller.Library; |
| | | 12 | | using MediaBrowser.Controller.Providers; |
| | | 13 | | using Microsoft.Extensions.Logging; |
| | | 14 | | |
| | | 15 | | namespace MediaBrowser.XbmcMetadata.Parsers |
| | | 16 | | { |
| | | 17 | | /// <summary> |
| | | 18 | | /// Nfo parser for episodes. |
| | | 19 | | /// </summary> |
| | | 20 | | public class EpisodeNfoParser : BaseNfoParser<Episode> |
| | | 21 | | { |
| | | 22 | | /// <summary> |
| | | 23 | | /// Initializes a new instance of the <see cref="EpisodeNfoParser"/> class. |
| | | 24 | | /// </summary> |
| | | 25 | | /// <param name="logger">Instance of the <see cref="ILogger{BaseNfoParser}"/> interface.</param> |
| | | 26 | | /// <param name="config">Instance of the <see cref="IConfigurationManager"/> interface.</param> |
| | | 27 | | /// <param name="providerManager">Instance of the <see cref="IProviderManager"/> interface.</param> |
| | | 28 | | /// <param name="userManager">Instance of the <see cref="IUserManager"/> interface.</param> |
| | | 29 | | /// <param name="userDataManager">Instance of the <see cref="IUserDataManager"/> interface.</param> |
| | | 30 | | /// <param name="directoryService">Instance of the <see cref="IDirectoryService"/> interface.</param> |
| | | 31 | | public EpisodeNfoParser( |
| | | 32 | | ILogger logger, |
| | | 33 | | IConfigurationManager config, |
| | | 34 | | IProviderManager providerManager, |
| | | 35 | | IUserManager userManager, |
| | | 36 | | IUserDataManager userDataManager, |
| | | 37 | | IDirectoryService directoryService) |
| | 7 | 38 | | : base(logger, config, providerManager, userManager, userDataManager, directoryService) |
| | | 39 | | { |
| | 7 | 40 | | } |
| | | 41 | | |
| | | 42 | | /// <inheritdoc /> |
| | | 43 | | protected override void Fetch(MetadataResult<Episode> item, string metadataFile, XmlReaderSettings settings, Can |
| | | 44 | | { |
| | 5 | 45 | | item.ResetPeople(); |
| | | 46 | | |
| | 5 | 47 | | var xmlFile = File.ReadAllText(metadataFile); |
| | | 48 | | |
| | | 49 | | // Split the nfo into its episodedetails blocks. |
| | | 50 | | // This is needed because XBMC metadata uses multiple episodedetails blocks instead of an episodenumberend t |
| | | 51 | | const string Srch = "</episodedetails>"; |
| | 5 | 52 | | var blocks = new List<string>(); |
| | | 53 | | int index; |
| | 15 | 54 | | while ((index = xmlFile.IndexOf(Srch, StringComparison.OrdinalIgnoreCase)) != -1) |
| | | 55 | | { |
| | 10 | 56 | | blocks.Add(xmlFile.Substring(0, index + Srch.Length)); |
| | 10 | 57 | | xmlFile = xmlFile.Substring(index + Srch.Length); |
| | | 58 | | } |
| | | 59 | | |
| | 5 | 60 | | if (blocks.Count == 0) |
| | | 61 | | { |
| | | 62 | | // No closing tag, let the xml reader deal with whatever is in the file |
| | 0 | 63 | | blocks.Add(xmlFile); |
| | | 64 | | } |
| | | 65 | | |
| | | 66 | | // These are not going to be valid xml so no sense in causing the provider to fail and spamming the log with |
| | | 67 | | try |
| | | 68 | | { |
| | 5 | 69 | | if (blocks.Count == 1) |
| | | 70 | | { |
| | 2 | 71 | | ReadEpisodeDetailsFromXml(item, blocks[0], settings, cancellationToken); |
| | 2 | 72 | | return; |
| | | 73 | | } |
| | | 74 | | |
| | | 75 | | // The blocks are not guaranteed to be written in ascending episode order, so parse them all |
| | | 76 | | // and sort them before merging. |
| | 3 | 77 | | var episodes = blocks |
| | 3 | 78 | | .Select(block => |
| | 3 | 79 | | { |
| | 3 | 80 | | var episode = new MetadataResult<Episode>() |
| | 3 | 81 | | { |
| | 3 | 82 | | Item = new Episode() |
| | 3 | 83 | | }; |
| | 3 | 84 | | |
| | 3 | 85 | | ReadEpisodeDetailsFromXml(episode, block, settings, cancellationToken); |
| | 3 | 86 | | |
| | 3 | 87 | | return (Xml: block, Result: episode); |
| | 3 | 88 | | }) |
| | 3 | 89 | | .OrderBy(episode => episode.Result.Item.IndexNumber ?? int.MaxValue) |
| | 3 | 90 | | .ToList(); |
| | | 91 | | |
| | | 92 | | // Extract the details of the lowest numbered episode into the item that is returned to the caller |
| | 3 | 93 | | ReadEpisodeDetailsFromXml(item, episodes[0].Xml, settings, cancellationToken); |
| | | 94 | | |
| | | 95 | | // Concatenate the name, originalTitle and overview tags of the remaining episodes with the first one |
| | | 96 | | // and take the highest episode number as the last episode of the file |
| | 3 | 97 | | var name = new StringBuilder(item.Item.Name); |
| | 3 | 98 | | var originalTitle = new StringBuilder(item.Item.OriginalTitle); |
| | 3 | 99 | | var overview = new StringBuilder(item.Item.Overview); |
| | 16 | 100 | | for (var i = 1; i < episodes.Count; i++) |
| | | 101 | | { |
| | 5 | 102 | | var additionalEpisode = episodes[i].Result; |
| | | 103 | | |
| | 5 | 104 | | if (!string.IsNullOrEmpty(additionalEpisode.Item.Name)) |
| | | 105 | | { |
| | 4 | 106 | | name.Append(" / ").Append(additionalEpisode.Item.Name); |
| | | 107 | | } |
| | | 108 | | |
| | 5 | 109 | | if (!string.IsNullOrEmpty(additionalEpisode.Item.Overview)) |
| | | 110 | | { |
| | 2 | 111 | | overview.Append(" / ").Append(additionalEpisode.Item.Overview); |
| | | 112 | | } |
| | | 113 | | |
| | 5 | 114 | | if (!string.IsNullOrEmpty(additionalEpisode.Item.OriginalTitle)) |
| | | 115 | | { |
| | 3 | 116 | | originalTitle.Append(" / ").Append(additionalEpisode.Item.OriginalTitle); |
| | | 117 | | } |
| | | 118 | | |
| | 5 | 119 | | if (additionalEpisode.Item.IndexNumber is not null) |
| | | 120 | | { |
| | 5 | 121 | | item.Item.IndexNumberEnd = Math.Max((int)additionalEpisode.Item.IndexNumber, item.Item.IndexNumb |
| | | 122 | | } |
| | | 123 | | } |
| | | 124 | | |
| | 3 | 125 | | item.Item.Name = name.ToString(); |
| | 3 | 126 | | item.Item.OriginalTitle = originalTitle.ToString(); |
| | 3 | 127 | | item.Item.Overview = overview.ToString(); |
| | 3 | 128 | | } |
| | 0 | 129 | | catch (XmlException) |
| | | 130 | | { |
| | 0 | 131 | | } |
| | 5 | 132 | | } |
| | | 133 | | |
| | | 134 | | /// <inheritdoc /> |
| | | 135 | | protected override void FetchDataFromXmlNode(XmlReader reader, MetadataResult<Episode> itemResult) |
| | | 136 | | { |
| | 170 | 137 | | var item = itemResult.Item; |
| | | 138 | | |
| | 170 | 139 | | switch (reader.Name) |
| | | 140 | | { |
| | | 141 | | case "season": |
| | 13 | 142 | | if (reader.TryReadInt(out var seasonNumber)) |
| | | 143 | | { |
| | 13 | 144 | | item.ParentIndexNumber = seasonNumber; |
| | | 145 | | } |
| | | 146 | | |
| | 13 | 147 | | break; |
| | | 148 | | case "episode": |
| | 13 | 149 | | if (reader.TryReadInt(out var episodeNumber)) |
| | | 150 | | { |
| | 13 | 151 | | item.IndexNumber = episodeNumber; |
| | | 152 | | } |
| | | 153 | | |
| | 13 | 154 | | break; |
| | | 155 | | case "episodenumberend": |
| | 1 | 156 | | if (reader.TryReadInt(out var episodeNumberEnd)) |
| | | 157 | | { |
| | 1 | 158 | | item.IndexNumberEnd = episodeNumberEnd; |
| | | 159 | | } |
| | | 160 | | |
| | 1 | 161 | | break; |
| | | 162 | | case "airsbefore_episode": |
| | | 163 | | case "displayepisode": |
| | 2 | 164 | | if (reader.TryReadInt(out var airsBeforeEpisode)) |
| | | 165 | | { |
| | 2 | 166 | | item.AirsBeforeEpisodeNumber = airsBeforeEpisode; |
| | | 167 | | } |
| | | 168 | | |
| | 2 | 169 | | break; |
| | | 170 | | case "airsafter_season": |
| | | 171 | | case "displayafterseason": |
| | 1 | 172 | | if (reader.TryReadInt(out var airsAfterSeason)) |
| | | 173 | | { |
| | 1 | 174 | | item.AirsAfterSeasonNumber = airsAfterSeason; |
| | | 175 | | } |
| | | 176 | | |
| | 1 | 177 | | break; |
| | | 178 | | case "airsbefore_season": |
| | | 179 | | case "displayseason": |
| | 2 | 180 | | if (reader.TryReadInt(out var airsBeforeSeason)) |
| | | 181 | | { |
| | 2 | 182 | | item.AirsBeforeSeasonNumber = airsBeforeSeason; |
| | | 183 | | } |
| | | 184 | | |
| | 2 | 185 | | break; |
| | | 186 | | case "showtitle": |
| | 1 | 187 | | item.SeriesName = reader.ReadNormalizedString(); |
| | 1 | 188 | | break; |
| | | 189 | | default: |
| | 137 | 190 | | base.FetchDataFromXmlNode(reader, itemResult); |
| | | 191 | | break; |
| | | 192 | | } |
| | 137 | 193 | | } |
| | | 194 | | |
| | | 195 | | /// <summary> |
| | | 196 | | /// Reads the episode details from the given xml and saves the result in the provided result item. |
| | | 197 | | /// </summary> |
| | | 198 | | private void ReadEpisodeDetailsFromXml(MetadataResult<Episode> item, string xml, XmlReaderSettings settings, Can |
| | | 199 | | { |
| | 13 | 200 | | using (var stringReader = new StringReader(xml)) |
| | 13 | 201 | | using (var reader = XmlReader.Create(stringReader, settings)) |
| | | 202 | | { |
| | 13 | 203 | | reader.MoveToContent(); |
| | 13 | 204 | | reader.Read(); |
| | | 205 | | |
| | | 206 | | // Loop through each element |
| | 414 | 207 | | while (!reader.EOF && reader.ReadState == ReadState.Interactive) |
| | | 208 | | { |
| | 401 | 209 | | cancellationToken.ThrowIfCancellationRequested(); |
| | | 210 | | |
| | 401 | 211 | | if (reader.NodeType == XmlNodeType.Element) |
| | | 212 | | { |
| | 170 | 213 | | FetchDataFromXmlNode(reader, item); |
| | | 214 | | } |
| | | 215 | | else |
| | | 216 | | { |
| | 231 | 217 | | reader.Read(); |
| | | 218 | | } |
| | | 219 | | } |
| | 13 | 220 | | } |
| | 13 | 221 | | } |
| | | 222 | | } |
| | | 223 | | } |