#region Copyright // /************************************************************************ // Copyright (c) 2016 Jamie Rees // File: RecentlyAdded.cs // Created By: Jamie Rees // // Permission is hereby granted, free of charge, to any person obtaining // a copy of this software and associated documentation files (the // "Software"), to deal in the Software without restriction, including // without limitation the rights to use, copy, modify, merge, publish, // distribute, sublicense, and/or sell copies of the Software, and to // permit persons to whom the Software is furnished to do so, subject to // the following conditions: // // The above copyright notice and this permission notice shall be // included in all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. // ************************************************************************/ #endregion using System; using System.Collections.Generic; using System.Linq; using System.Text; using MailKit.Net.Smtp; using MimeKit; using NLog; using PlexRequests.Api; using PlexRequests.Api.Interfaces; using PlexRequests.Api.Models.Plex; using PlexRequests.Core; using PlexRequests.Core.SettingModels; using PlexRequests.Helpers; using PlexRequests.Services.Interfaces; using PlexRequests.Services.Jobs.Templates; using PlexRequests.Store.Models.Plex; using Quartz; namespace PlexRequests.Services.Jobs { public class RecentlyAdded : IJob, IRecentlyAdded { public RecentlyAdded(IPlexApi api, ISettingsService plexSettings, ISettingsService email, ISettingsService scheduledService, IJobRecord rec, ISettingsService plexRequest, IPlexReadOnlyDatabase db) { JobRecord = rec; Api = api; PlexSettings = plexSettings; EmailSettings = email; ScheduledJobsSettings = scheduledService; PlexRequestSettings = plexRequest; PlexDb = db; } private IPlexApi Api { get; } private TvMazeApi TvApi = new TvMazeApi(); private readonly TheMovieDbApi _movieApi = new TheMovieDbApi(); private ISettingsService PlexSettings { get; } private ISettingsService EmailSettings { get; } private ISettingsService PlexRequestSettings { get; } private ISettingsService ScheduledJobsSettings { get; } private IJobRecord JobRecord { get; } private IPlexReadOnlyDatabase PlexDb { get; } private static readonly Logger Log = LogManager.GetCurrentClassLogger(); public void Execute(IJobExecutionContext context) { try { var settings = PlexRequestSettings.GetSettings(); if (!settings.SendRecentlyAddedEmail) { return; } var jobs = JobRecord.GetJobs(); var thisJob = jobs.FirstOrDefault( x => x.Name.Equals(JobNames.RecentlyAddedEmail, StringComparison.CurrentCultureIgnoreCase)); var jobSettings = ScheduledJobsSettings.GetSettings(); if (thisJob?.LastRun > DateTime.Now.AddHours(-jobSettings.RecentlyAdded)) { return; } Start(); } catch (Exception e) { Log.Error(e); } finally { JobRecord.Record(JobNames.RecentlyAddedEmail); } } public void Test() { StartDb(true); } private void Start(bool testEmail = false) { var sb = new StringBuilder(); var plexSettings = PlexSettings.GetSettings(); var recentlyAdded = Api.RecentlyAdded(plexSettings.PlexAuthToken, plexSettings.FullUri); var movies = recentlyAdded._children.Where(x => x.type.Equals("Movie", StringComparison.CurrentCultureIgnoreCase)); var tv = recentlyAdded._children.Where( x => x.type.Equals("season", StringComparison.CurrentCultureIgnoreCase)) .GroupBy(x => x.parentTitle) .Select(x => x.FirstOrDefault()); GenerateMovieHtml(movies, plexSettings, ref sb); GenerateTvHtml(tv, plexSettings, ref sb); var template = new RecentlyAddedTemplate(); var html = template.LoadTemplate(sb.ToString()); Send(html, plexSettings, testEmail); } private void StartDb(bool testEmail = false) { var sb = new StringBuilder(); var plexSettings = PlexSettings.GetSettings(); var recentlyAdded = PlexDb.GetItemsAddedAfterDate(DateTime.Now.AddDays(-7)); var movies = recentlyAdded.Where(x => x.MetadataType == 1); var tv = recentlyAdded.Where(x => x.MetadataType == 4); GenerateMovieHtmlDb(movies, ref sb); GenerateTvHtml(tv, ref sb); var template = new RecentlyAddedTemplate(); var html = template.LoadTemplate(sb.ToString()); Send(html, plexSettings, testEmail); } private void GenerateMovieHtml(IEnumerable movies, PlexSettings plexSettings,ref StringBuilder sb) { sb.Append("

New Movies:



"); sb.Append( ""); foreach (var movie in movies) { var plexGUID = string.Empty; try { var metaData = Api.GetMetadata(plexSettings.PlexAuthToken, plexSettings.FullUri, movie.ratingKey.ToString()); plexGUID = metaData.Video.Guid; var imdbId = PlexHelper.GetProviderIdFromPlexGuid(plexGUID); var info = _movieApi.GetMovieInformation(imdbId).Result; sb.Append(""); sb.Append(""); sb.Append(""); sb.Append(""); sb.Append( ""); } catch (Exception e) { Log.Error(e); Log.Error("Exception when trying to process a Movie, either in getting the metadata from Plex OR getting the information from TheMovieDB, Plex GUID = {0}", plexGUID); } } sb.Append("
"); sb.AppendFormat( "", info.BackdropPath); sb.Append("
"); sb.AppendFormat( "

{1} {2}

", info.ImdbId, info.Title, info.ReleaseDate?.ToString("yyyy") ?? string.Empty); if (info.Genres.Any()) { sb.AppendFormat( "

Genre: {0}

", string.Join(", ", info.Genres.Select(x => x.Name.ToString()).ToArray())); } sb.AppendFormat( "

{0}

", info.Overview); sb.Append(""); sb.Append("
"); sb.Append("
"); sb.Append("



"); } private void GenerateMovieHtmlDb(IEnumerable movies, ref StringBuilder sb) { sb.Append("

New Movies:



"); sb.Append( ""); foreach (var movie in movies) { var plexGUID = string.Empty; try { plexGUID = movie.Guid; var imdbId = PlexHelper.GetProviderIdFromPlexGuid(plexGUID); var info = _movieApi.GetMovieInformation(imdbId).Result; sb.Append(""); sb.Append(""); sb.Append(""); sb.Append(""); sb.Append( ""); } catch (Exception e) { Log.Error(e); Log.Error("Exception when trying to process a Movie, either in getting the metadata from Plex OR getting the information from TheMovieDB, Plex GUID = {0}", plexGUID); } } sb.Append("
"); sb.AppendFormat( "", info.BackdropPath); sb.Append("
"); sb.AppendFormat( "

{1} {2}

", info.ImdbId, info.Title, info.ReleaseDate?.ToString("yyyy") ?? string.Empty); if (info.Genres.Any()) { sb.AppendFormat( "

Genre: {0}

", string.Join(", ", info.Genres.Select(x => x.Name.ToString()).ToArray())); } sb.AppendFormat( "

{0}

", info.Overview); sb.Append(""); sb.Append("
"); sb.Append("
"); sb.Append("



"); } private void GenerateTvHtml(IEnumerable tv, PlexSettings plexSettings, ref StringBuilder sb) { // TV sb.Append("

New Episodes:



"); sb.Append( ""); foreach (var t in tv) { var plexGUID = string.Empty; try { var parentMetaData = Api.GetMetadata(plexSettings.PlexAuthToken, plexSettings.FullUri, t.parentRatingKey.ToString()); plexGUID = parentMetaData.Directory.Guid; var info = TvApi.ShowLookupByTheTvDbId(int.Parse(PlexHelper.GetProviderIdFromPlexGuid(plexGUID))); var banner = info.image?.original; if (!string.IsNullOrEmpty(banner)) { banner = banner.Replace("http", "https"); // Always use the Https banners } sb.Append(""); sb.Append(""); sb.Append(""); sb.Append(""); sb.Append(""); } catch (Exception e) { Log.Error(e); Log.Error("Exception when trying to process a TV Show, either in getting the metadata from Plex OR getting the information from TVMaze, Plex GUID = {0}", plexGUID); } } sb.Append("
"); sb.AppendFormat("", banner); sb.Append("
"); sb.AppendFormat("

{1} {2}

", info.externals.imdb, info.name, info.premiered.Substring(0, 4)); // Only the year sb.AppendFormat("

Genre: {0}

", string.Join(", ", info.genres.Select(x => x.ToString()).ToArray())); sb.AppendFormat("

{0}

", string.IsNullOrEmpty(parentMetaData.Directory.Summary) ? info.summary : parentMetaData.Directory.Summary); // Episode Summary sb.Append(""); sb.Append("
"); sb.Append("
"); sb.Append("



"); } private void GenerateTvHtml(IEnumerable tv, ref StringBuilder sb) { // TV sb.Append("

New Episodes:



"); sb.Append( ""); foreach (var t in tv) { var plexGUID = string.Empty; try { plexGUID = t.Guid; var seasonInfo = PlexHelper.GetSeasonsAndEpisodesFromPlexGuid(plexGUID); var info = TvApi.ShowLookupByTheTvDbId(int.Parse(PlexHelper.GetProviderIdFromPlexGuid(plexGUID))); var banner = info.image?.original; if (!string.IsNullOrEmpty(banner)) { banner = banner.Replace("http", "https"); // Always use the Https banners } sb.Append(""); sb.Append(""); sb.Append(""); sb.Append(""); sb.Append(""); } catch (Exception e) { Log.Error(e); Log.Error("Exception when trying to process a TV Show, either in getting the metadata from Plex OR getting the information from TVMaze, Plex GUID = {0}", plexGUID); } } sb.Append("
"); sb.AppendFormat("", banner); sb.Append("
"); sb.AppendFormat("

{1} {2}

", info.externals.imdb, info.name, info.premiered.Substring(0, 4)); // Only the year sb.AppendFormat("

Season: {0}, Episode: {1}

", seasonInfo.SeasonNumber, seasonInfo.EpisodeNumber); if (info.genres.Any()) { sb.AppendFormat( "

Genre: {0}

", string.Join(", ", info.genres.Select(x => x.ToString()).ToArray())); } sb.AppendFormat("

{0}

", string.IsNullOrEmpty(t.Summary) ? info.summary : t.Summary); // Episode Summary sb.Append(""); sb.Append("
"); sb.Append("
"); sb.Append("



"); } private void Send(string html, PlexSettings plexSettings, bool testEmail = false) { var settings = EmailSettings.GetSettings(); if (!settings.Enabled || string.IsNullOrEmpty(settings.EmailHost)) { return; } var body = new BodyBuilder { HtmlBody = html, TextBody = "This email is only available on devices that support HTML." }; var message = new MimeMessage { Body = body.ToMessageBody(), Subject = "New Content on Plex!", }; if (!testEmail) { var users = Api.GetUsers(plexSettings.PlexAuthToken); foreach (var user in users.User) { message.Bcc.Add(new MailboxAddress(user.Username, user.Email)); } } message.Bcc.Add(new MailboxAddress(settings.EmailUsername, settings.EmailSender)); // Include the admin message.From.Add(new MailboxAddress(settings.EmailUsername, settings.EmailSender)); try { using (var client = new SmtpClient()) { client.Connect(settings.EmailHost, settings.EmailPort); // Let MailKit figure out the correct SecureSocketOptions. // Note: since we don't have an OAuth2 token, disable // the XOAUTH2 authentication mechanism. client.AuthenticationMechanisms.Remove("XOAUTH2"); if (settings.Authentication) { client.Authenticate(settings.EmailUsername, settings.EmailPassword); } Log.Info("sending message to {0} \r\n from: {1}\r\n Are we authenticated: {2}", message.To, message.From, client.IsAuthenticated); client.Send(message); client.Disconnect(true); } } catch (Exception e) { Log.Error(e); } } } }