using System; using System.Collections.Generic; using System.Collections.Specialized; using System.Text; using System.Text.RegularExpressions; using System.Threading.Tasks; using AngleSharp.Parser.Html; using Jackett.Common.Models; using Jackett.Common.Models.IndexerConfig; using Jackett.Common.Services.Interfaces; using Jackett.Common.Utils; using Jackett.Common.Utils.Clients; using Newtonsoft.Json.Linq; using NLog; namespace Jackett.Common.Indexers { public class TVVault : BaseWebIndexer { private string LoginUrl { get { return SiteLink + "login.php"; } } private string BrowseUrl { get { return SiteLink + "torrents.php"; } } private new ConfigurationDataBasicLoginWithRSSAndDisplay configData { get { return (ConfigurationDataBasicLoginWithRSSAndDisplay)base.configData; } set { base.configData = value; } } public TVVault(IIndexerConfigurationService configService, WebClient wc, Logger l, IProtectionService ps) : base(name: "TV-Vault", description: "A TV tracker for old shows.", link: "https://tv-vault.me/", caps: TorznabUtil.CreateDefaultTorznabTVCaps(), configService: configService, client: wc, logger: l, p: ps, configData: new ConfigurationDataBasicLoginWithRSSAndDisplay()) { Encoding = Encoding.UTF8; Language = "en-us"; Type = "private"; AddCategoryMapping(1, TorznabCatType.TV); AddCategoryMapping(2, TorznabCatType.Movies); } public override async Task ApplyConfiguration(JToken configJson) { LoadValuesFromJson(configJson); var pairs = new Dictionary { { "username", configData.Username.Value }, { "password", configData.Password.Value }, { "keeplogged", "1" }, { "login", "Log+In!" } }; var result = await RequestLoginAndFollowRedirect(LoginUrl, pairs, null, true, null, LoginUrl, true); await ConfigureIfOK(result.Cookies, result.Content != null && result.Content.Contains("logout.php"), () => { var errorMessage = result.Content; throw new ExceptionWithConfigData(errorMessage, configData); }); return IndexerConfigurationStatus.RequiresTesting; } private string StripSearchString(string term) { // Search does not support searching with episode numbers so strip it if we have one // Ww AND filter the result later to archive the proper result term = Regex.Replace(term, @"[S|E]\d\d", string.Empty); return term.Trim(); } protected override async Task> PerformQuery(TorznabQuery query) { var releases = new List(); var searchString = query.GetQueryString(); var searchUrl = BrowseUrl; var queryCollection = new NameValueCollection(); queryCollection.Add("searchstr", StripSearchString(searchString)); queryCollection.Add("order_by", "s3"); queryCollection.Add("order_way", "desc"); queryCollection.Add("disablegrouping", "1"); searchUrl += "?" + queryCollection.GetQueryString(); var results = await RequestStringWithCookies(searchUrl); try { string RowsSelector = "table.torrent_table > tbody > tr.torrent"; var SearchResultParser = new HtmlParser(); var SearchResultDocument = SearchResultParser.Parse(results.Content); var Rows = SearchResultDocument.QuerySelectorAll(RowsSelector); foreach (var Row in Rows) { var release = new ReleaseInfo(); release.MinimumRatio = 1; release.MinimumSeedTime = 0; var qDetailsLink = Row.QuerySelector("a[href^=\"torrents.php?id=\"]"); var DescStr = qDetailsLink.NextSibling; var Files = Row.QuerySelector("td:nth-child(3)"); var Added = Row.QuerySelector("td:nth-child(4)"); var Size = Row.QuerySelector("td:nth-child(5)").FirstChild; var Grabs = Row.QuerySelector("td:nth-child(6)"); var Seeders = Row.QuerySelector("td:nth-child(7)"); var Leechers = Row.QuerySelector("td:nth-child(8)"); var FreeLeech = Row.QuerySelector("strong.freeleech_normal"); var TorrentIdParts = qDetailsLink.GetAttribute("href").Split('='); var TorrentId = TorrentIdParts[TorrentIdParts.Length - 1]; var DLLink = "torrents.php?action=download&id=" + TorrentId.ToString(); release.Description = DescStr.TextContent.Trim(); release.Title = qDetailsLink.TextContent + " " + release.Description; release.PublishDate = DateTimeUtil.FromTimeAgo(Added.TextContent); release.Category = new List { TvCategoryParser.ParseTvShowQuality(release.Description) }; release.Link = new Uri(SiteLink + DLLink); release.Comments = new Uri(SiteLink + qDetailsLink.GetAttribute("href")); release.Guid = release.Link; release.Seeders = ParseUtil.CoerceInt(Seeders.TextContent); release.Peers = ParseUtil.CoerceInt(Leechers.TextContent) + release.Seeders; release.Size = ReleaseInfo.GetBytes(Size.TextContent); release.Grabs = ReleaseInfo.GetBytes(Grabs.TextContent); release.Files = ReleaseInfo.GetBytes(Files.TextContent); if (FreeLeech != null) release.DownloadVolumeFactor = 0; else release.DownloadVolumeFactor = 1; release.UploadVolumeFactor = 1; releases.Add(release); } } catch (Exception ex) { OnParseError(results.Content, ex); } return releases; } } }