github/Ombi
1
0
Fork 0
mirror of https://github.com/Ombi-app/Ombi.git synced 2025-08-14 02:26:55 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge branch 'develop' of https://github.com/tidusjar/Ombi into develop

Browse source
This commit is contained in:
tidusjar 2021-10-11 09:45:21 +01:00
commit 52d236a4f4
28 changed files with 314 additions and 87 deletions
Download patch file Download diff file Expand all files Collapse all files

28
.github/workflows/build.yml vendored
View file

@ -55,23 +55,20 @@ jobs:
versioning:
runs-on: ubuntu-latest
needs: [ build-ui, unit-test ]
outputs:
changelog: ${{ steps.changelog.outputs.clean_changelog }}
tag: ${{ steps.changelog.outputs.tag }}
version: ${{ steps.changelog.outputs.version }}
steps:
- uses: actions/checkout@v2
# This is only to get the next version number so we can set the version before compile
- name: Conventional Changelog Action
id: changelog
uses: TriPSs/conventional-changelog-action@v3
with:
skip-version-file: 'true'
skip-commit: 'true'
version-file: 'version.json'
output-file: 'false'
skip-on-empty: 'false'
git-push: 'false'
version-file: 'version.json'
skip-on-empty: 'false'
git-message: 'chore(release): :rocket: {version}'
- name: Output version
run: |
@ -162,14 +159,7 @@ jobs:
runs-on: ubuntu-latest
steps:
- uses: actions/checkout@v2
- name: Conventional Changelog Action
id: changelog
uses: TriPSs/conventional-changelog-action@v3
with:
version-file: 'version.json'
skip-on-empty: 'false'
git-message: 'chore(release): :rocket: {version}'
- name: Download Artifacts
id: download
uses: actions/download-artifact@v2
@ -192,9 +182,9 @@ jobs:
if: contains(github.ref, 'develop')
with:
prerelease: true
body: ${{ steps.changelog.outputs.changelog }}
name: ${{ steps.changelog.outputs.tag }}
tag_name: ${{ steps.changelog.outputs.tag }}
body: ${{ needs.versioning.outputs.changelog }}
name: ${{ needs.versioning.outputs.tag }}
tag_name: ${{ needs.versioning.outputs.tag }}
files: |
artifacts/**/*.tar.gz
artifacts/**/*.zip
@ -209,7 +199,7 @@ jobs:
url: 'https://api.github.com/repos/Ombi-app/Ombi.Apt/actions/workflows/build-deb.yml/dispatches'
method: 'POST'
contentType: 'application/json'
data: '{ "ref":"main", "inputs": { "version": "${{ steps.changelog.outputs.tag }}"} }'
data: '{ "ref":"main", "inputs": { "version": "${{ needs.versioning.outputs.tag }}"} }'
customHeaders: "{'Accept':'application/vnd.github.v3+json', 'Authorization':'Bearer ${{secrets.APT_PAT}}', 'User-Agent':'Ombi'}"

27
CHANGELOG.md
View file

@ -1,3 +1,18 @@
# [4.2.0](https://github.com/Ombi-app/Ombi/compare/v4.1.1...v4.2.0) (2021-10-09)
### Bug Fixes
* **settings:** :bug: Fixed the issue where you couldn't save the Plex settings ([89a856a](https://github.com/Ombi-app/Ombi/commit/89a856a5d22a5f517702642876652d451f6e9b3e))
### Features
* :sparkles: Added the ability to specify which branch you are on ([777ed2f](https://github.com/Ombi-app/Ombi/commit/777ed2f3224b91a0acb47c30efa96adaaba46fd2))
* **notifications:** :sparkles: Added Partially Available Notifications ([1ef45dc](https://github.com/Ombi-app/Ombi/commit/1ef45dc44c93d566a0f04c011bfcefe2009a24b5))
## [4.1.1](https://github.com/Ombi-app/Ombi/compare/v4.0.1511...v4.1.1) (2021-10-08)
@ -23,16 +38,4 @@
## [4.0.1510](https://github.com/Ombi-app/Ombi/compare/v4.0.1602...v4.0.1510) (2021-10-07)
### Bug Fixes
* :bookmark: Set version to correct number ([1a7b9b5](https://github.com/Ombi-app/Ombi/commit/1a7b9b50578675532fdb0f656cbaf51306166b84))
* :bug: bump ver ([5207b21](https://github.com/Ombi-app/Ombi/commit/5207b21f2f98cc63f16a72bd79ecac6abf838139))
* :bug: Pretending to fix a bug ([5351c14](https://github.com/Ombi-app/Ombi/commit/5351c14cb087f9ecbb37b784724bb35107d17cb8))
* :bug: Set the real tag version now ([9287d83](https://github.com/Ombi-app/Ombi/commit/9287d83c134e62c9f0a5d271cfd88eefc9dcae39))
* :bug: Stop Devops from building and releasing, GH Actions will now call the APT Build ([1fda2a1](https://github.com/Ombi-app/Ombi/commit/1fda2a1d37c1182177fdca55e38b98a85dc1fe05))
* :bug: updated contributors PAT ([a1d22db](https://github.com/Ombi-app/Ombi/commit/a1d22db4d14c63c39e79d47d99cc7ca2efe393df))
* :bug: Upload the correct artifacts ([a249805](https://github.com/Ombi-app/Ombi/commit/a2498051cfd679dd19206571883a08d77e159e2b))
* try and fix the artifact upload ([fb9ff4c](https://github.com/Ombi-app/Ombi/commit/fb9ff4ccde9121dce6da379198de225686123457))

1
src/Ombi.Helpers/NotificationType.cs
View file

@ -14,5 +14,6 @@
IssueResolved = 9,
IssueComment = 10,
Newsletter = 11,
PartiallyAvailable = 12
}
}

48
src/Ombi.Notifications.Tests/NotificationMessageCurlysTests.cs
View file

@ -213,7 +213,10 @@ namespace Ombi.Notifications.Tests
[Test]
public void TvNotificationTests()
{
var notificationOptions = new NotificationOptions();
var notificationOptions = new NotificationOptions
{
NotificationType = Helpers.NotificationType.PartiallyAvailable
};
var req = F.Build<ChildRequests>()
.With(x => x.RequestType, RequestType.TvShow)
.With(x => x.Available, true)
@ -246,6 +249,49 @@ namespace Ombi.Notifications.Tests
Assert.That("name", Is.EqualTo(sut.ApplicationName));
}
[Test]
public void TvNotificationPartialAvailablilityTests()
{
var notificationOptions = new NotificationOptions {
NotificationType = Helpers.NotificationType.PartiallyAvailable
};
notificationOptions.Substitutes.Add("Season", "1");
notificationOptions.Substitutes.Add("Episodes", "1, 2");
var req = F.Build<ChildRequests>()
.With(x => x.RequestType, RequestType.TvShow)
.With(x => x.Available, true)
.Create();
var customization = new CustomizationSettings
{
ApplicationUrl = "url",
ApplicationName = "name"
};
var userPrefs = new UserNotificationPreferences();
sut.Setup(notificationOptions, req, customization, userPrefs);
Assert.That(req.Id.ToString(), Is.EqualTo(sut.RequestId));
Assert.That(req.ParentRequest.ExternalProviderId.ToString(), Is.EqualTo(sut.ProviderId));
Assert.That(req.ParentRequest.Title.ToString(), Is.EqualTo(sut.Title));
Assert.That(req.RequestedUser.UserName, Is.EqualTo(sut.RequestedUser));
Assert.That(req.RequestedUser.Alias, Is.EqualTo(sut.Alias));
Assert.That(req.RequestedDate.ToString("D"), Is.EqualTo(sut.RequestedDate));
Assert.That("TV Show", Is.EqualTo(sut.Type));
Assert.That(req.ParentRequest.Overview, Is.EqualTo(sut.Overview));
Assert.That(req.ParentRequest.ReleaseDate.Year.ToString(), Is.EqualTo(sut.Year));
Assert.That(req.DeniedReason, Is.EqualTo(sut.DenyReason));
Assert.That(req.MarkedAsAvailable?.ToString("D"), Is.EqualTo(sut.AvailableDate));
Assert.That("https://image.tmdb.org/t/p/w300/" + req.ParentRequest.PosterPath, Is.EqualTo(sut.PosterImage));
Assert.That(req.DeniedReason, Is.EqualTo(sut.DenyReason));
Assert.That(req.RequestedUser.Alias, Is.EqualTo(sut.UserPreference));
Assert.That(null, Is.EqualTo(sut.AdditionalInformation));
Assert.That("Available", Is.EqualTo(sut.RequestStatus));
Assert.That("url", Is.EqualTo(sut.ApplicationUrl));
Assert.That("name", Is.EqualTo(sut.ApplicationName));
Assert.That(sut.PartiallyAvailableEpisodeNumbers, Is.EqualTo("1, 2"));
Assert.That(sut.PartiallyAvailableSeasonNumber, Is.EqualTo("1"));
}
[Test]
public void TvNotification_EpisodeList()
{

6
src/Ombi.Notifications/Agents/DiscordNotification.cs
View file

@ -94,6 +94,10 @@ namespace Ombi.Notifications.Agents
{
await Run(model, settings, NotificationType.RequestAvailable);
}
protected override async Task PartiallyAvailable(NotificationOptions model, DiscordNotificationSettings settings)
{
await Run(model, settings, NotificationType.PartiallyAvailable);
}
protected override async Task Send(NotificationMessage model, DiscordNotificationSettings settings)
{
@ -166,8 +170,6 @@ namespace Ombi.Notifications.Agents
author.name = appName;
}
var embed = new DiscordEmbeds
{
fields = fields,

19
src/Ombi.Notifications/Agents/EmailNotification.cs
View file

@ -219,6 +219,25 @@ namespace Ombi.Notifications.Agents
}
protected override async Task PartiallyAvailable(NotificationOptions model, EmailNotificationSettings settings)
{
var message = await LoadTemplate(NotificationType.PartiallyAvailable, model, settings);
if (message == null)
{
return;
}
var plaintext = await LoadPlainTextMessage(NotificationType.PartiallyAvailable, model, settings);
message.Other.Add("PlainTextBody", plaintext);
await SendToSubscribers(settings, message);
message.To = model.RequestType == RequestType.Movie
? MovieRequest.RequestedUser.Email
: TvRequest.RequestedUser.Email;
await Send(message, settings);
}
protected override async Task RequestApproved(NotificationOptions model, EmailNotificationSettings settings)
{
var message = await LoadTemplate(NotificationType.RequestApproved, model, settings);

5
src/Ombi.Notifications/Agents/GotifyNotification.cs
View file

@ -112,5 +112,10 @@ namespace Ombi.Notifications.Agents
await Send(notification, settings);
}
protected override async Task PartiallyAvailable(NotificationOptions model, GotifySettings settings)
{
await Run(model, settings, NotificationType.PartiallyAvailable);
}
}
}

20
src/Ombi.Notifications/Agents/LegacyMobileNotification.cs
View file

@ -316,5 +316,25 @@ namespace Ombi.Notifications.Agents
}
}
}
protected override async Task PartiallyAvailable(NotificationOptions model, MobileNotificationSettings settings)
{
var parsed = await LoadTemplate(NotificationAgent.Mobile, NotificationType.PartiallyAvailable, model);
if (parsed.Disabled)
{
_logger.LogInformation($"Template {NotificationType.PartiallyAvailable} is disabled for {NotificationAgent.Mobile}");
return;
}
var notification = new NotificationMessage
{
Message = parsed.Message,
};
// Send to user
var playerIds = GetUsers(model, NotificationType.PartiallyAvailable);
await AddSubscribedUsers(playerIds);
await Send(playerIds, notification, settings, model);
}
}
}

4
src/Ombi.Notifications/Agents/MattermostNotification.cs
View file

@ -90,6 +90,10 @@ namespace Ombi.Notifications.Agents
{
await Run(model, settings, NotificationType.RequestAvailable);
}
protected override async Task PartiallyAvailable(NotificationOptions model, MattermostNotificationSettings settings)
{
await Run(model, settings, NotificationType.PartiallyAvailable);
}
protected override async Task Send(NotificationMessage model, MattermostNotificationSettings settings)
{

21
src/Ombi.Notifications/Agents/MobileNotification.cs
View file

@ -359,5 +359,26 @@ namespace Ombi.Notifications.Agents
}
}
}
protected override async Task PartiallyAvailable(NotificationOptions model, MobileNotificationSettings settings)
{
var parsed = await LoadTemplate(NotificationAgent.Mobile, NotificationType.PartiallyAvailable, model);
if (parsed.Disabled)
{
_logger.LogInformation($"Template {NotificationType.PartiallyAvailable} is disabled for {NotificationAgent.Mobile}");
return;
}
var notification = new NotificationMessage
{
Message = parsed.Message,
Subject = "New Request",
Data = GetNotificationData(parsed, NotificationType.PartiallyAvailable)
};
// Get admin devices
var playerIds = await GetAdmins(NotificationType.PartiallyAvailable);
await Send(playerIds, notification, settings, model, true);
}
}
}

5
src/Ombi.Notifications/Agents/PushbulletNotification.cs
View file

@ -121,5 +121,10 @@ namespace Ombi.Notifications.Agents
await Send(notification, settings);
}
protected override async Task PartiallyAvailable(NotificationOptions model, PushbulletSettings settings)
{
await Run(model, settings, NotificationType.PartiallyAvailable);
}
}
}

5
src/Ombi.Notifications/Agents/PushoverNotification.cs
View file

@ -121,5 +121,10 @@ namespace Ombi.Notifications.Agents
};
await Send(notification, settings);
}
protected override async Task PartiallyAvailable(NotificationOptions model, PushoverSettings settings)
{
await Run(model, settings, NotificationType.PartiallyAvailable);
}
}
}

5
src/Ombi.Notifications/Agents/SlackNotification.cs
View file

@ -138,5 +138,10 @@ namespace Ombi.Notifications.Agents
notification.Other.Add("image", parsed.Image);
await Send(notification, settings);
}
protected override async Task PartiallyAvailable(NotificationOptions model, SlackNotificationSettings settings)
{
await Run(model, settings, NotificationType.PartiallyAvailable);
}
}
}

5
src/Ombi.Notifications/Agents/TelegramNotification.cs
View file

@ -115,5 +115,10 @@ namespace Ombi.Notifications.Agents
};
await Send(notification, settings);
}
protected override async Task PartiallyAvailable(NotificationOptions model, TelegramSettings settings)
{
await Run(model, settings, NotificationType.PartiallyAvailable);
}
}
}

5
src/Ombi.Notifications/Agents/WebhookNotification.cs
View file

@ -119,5 +119,10 @@ namespace Ombi.Notifications.Agents
await Send(notification, settings);
}
protected override async Task PartiallyAvailable(NotificationOptions model, WebhookSettings settings)
{
await Run(model, settings, NotificationType.PartiallyAvailable);
}
}
}

5
src/Ombi.Notifications/Agents/WhatsAppNotification.cs
View file

@ -123,5 +123,10 @@ namespace Ombi.Notifications.Agents
};
await Send(notification, settings);
}
protected override async Task PartiallyAvailable(NotificationOptions model, TwilioSettings settings)
{
await Run(model, settings, NotificationType.PartiallyAvailable);
}
}
}

10
src/Ombi.Notifications/BaseNotification.cs
View file

@ -110,6 +110,15 @@ namespace Ombi.Notifications
case NotificationType.IssueComment:
await IssueComment(model, notificationSettings);
break;
case NotificationType.AdminNote:
break;
case NotificationType.WelcomeEmail:
break;
case NotificationType.Newsletter:
break;
case NotificationType.PartiallyAvailable:
await PartiallyAvailable(model, notificationSettings);
break;
default:
throw new ArgumentOutOfRangeException();
}
@ -236,6 +245,7 @@ namespace Ombi.Notifications
protected abstract Task RequestDeclined(NotificationOptions model, T settings);
protected abstract Task RequestApproved(NotificationOptions model, T settings);
protected abstract Task AvailableRequest(NotificationOptions model, T settings);
protected abstract Task PartiallyAvailable(NotificationOptions model, T settings);
protected abstract Task Send(NotificationMessage model, T settings);
protected abstract Task Test(NotificationOptions model, T settings);
}

24
src/Ombi.Notifications/NotificationMessageCurlys.cs
View file

@ -33,7 +33,7 @@ namespace Ombi.Notifications
UserNotificationPreferences pref)
{
LoadIssues(opts);
LoadCommon(req, s, pref);
LoadCommon(req, s, pref, opts);
LoadTitle(opts, req);
ProviderId = req?.TheMovieDbId.ToString() ?? string.Empty;
Year = req?.ReleaseDate.Year.ToString();
@ -47,7 +47,7 @@ namespace Ombi.Notifications
UserNotificationPreferences pref)
{
LoadIssues(opts);
LoadCommon(req, s, pref);
LoadCommon(req, s, pref, opts);
LoadTitle(opts, req);
ProviderId = req?.ParentRequest?.ExternalProviderId.ToString() ?? string.Empty;
Year = req?.ParentRequest?.ReleaseDate.Year.ToString();
@ -83,7 +83,7 @@ namespace Ombi.Notifications
UserNotificationPreferences pref)
{
LoadIssues(opts);
LoadCommon(req, s, pref);
LoadCommon(req, s, pref, opts);
LoadTitle(opts, req);
ProviderId = req?.ForeignArtistId ?? string.Empty;
Year = req?.ReleaseDate.Year.ToString();
@ -106,7 +106,7 @@ namespace Ombi.Notifications
: string.Empty;
}
private void LoadCommon(BaseRequest req, CustomizationSettings s, UserNotificationPreferences pref)
private void LoadCommon(BaseRequest req, CustomizationSettings s, UserNotificationPreferences pref, NotificationOptions opts)
{
ApplicationName = string.IsNullOrEmpty(s?.ApplicationName) ? "Ombi" : s.ApplicationName;
ApplicationUrl = s?.ApplicationUrl.HasValue() ?? false ? s.ApplicationUrl : string.Empty;
@ -137,6 +137,18 @@ namespace Ombi.Notifications
{
UserPreference = pref.Value.HasValue() ? pref.Value : Alias;
}
if (opts.NotificationType == NotificationType.PartiallyAvailable)
{
if (opts.Substitutes.TryGetValue("Season", out var sNumber))
{
PartiallyAvailableSeasonNumber = sNumber;
}
if (opts.Substitutes.TryGetValue("Episodes", out var epNumber))
{
PartiallyAvailableEpisodeNumbers = epNumber;
}
}
}
private static string HumanizeReturnType(RequestType? requestType)
@ -220,6 +232,8 @@ namespace Ombi.Notifications
public string AvailableDate { get; set; }
public string RequestStatus { get; set; }
public string ProviderId { get; set; }
public string PartiallyAvailableEpisodeNumbers { get; set; }
public string PartiallyAvailableSeasonNumber { get; set; }
// System Defined
private string LongDate => DateTime.Now.ToString("D");
@ -259,6 +273,8 @@ namespace Ombi.Notifications
{ nameof(AvailableDate), AvailableDate },
{ nameof(RequestStatus), RequestStatus },
{ nameof(ProviderId), ProviderId },
{ nameof(PartiallyAvailableEpisodeNumbers), PartiallyAvailableEpisodeNumbers },
{ nameof(PartiallyAvailableSeasonNumber), PartiallyAvailableSeasonNumber },
};
}
}

25
src/Ombi.Schedule/Jobs/ArrAvailabilityChecker.cs
View file

@ -154,24 +154,19 @@ namespace Ombi.Schedule.Jobs.Radarr
{
availableEpisode.Add(new AvailabilityModel
{
Id = episode.Id
Id = episode.Id,
EpisodeNumber = episode.EpisodeNumber,
SeasonNumber = episode.Season.SeasonNumber
});
episode.Available = true;
}
}
}
//TODO Partial avilability notifications here
if (availableEpisode.Any())
{
//await _hub.Clients.Clients(NotificationHub.AdminConnectionIds)
// .SendAsync(NotificationHub.NotificationEvent, "Sonarr Availability Checker found some new available episodes!");
await _tvRequest.Save();
}
//foreach(var c in availableEpisode)
//{
// await _tvRepo.MarkEpisodeAsAvailable(c.Id);
//}
// Check to see if all of the episodes in all seasons are available for this request
var allAvailable = child.SeasonRequests.All(x => x.Episodes.All(c => c.Available));
@ -193,6 +188,20 @@ namespace Ombi.Schedule.Jobs.Radarr
Recipient = child.RequestedUser.Email
});
}
else if (availableEpisode.Any())
{
var notification = new NotificationOptions
{
DateTime = DateTime.Now,
NotificationType = NotificationType.PartiallyAvailable,
RequestId = child.Id,
RequestType = RequestType.TvShow,
Recipient = child.RequestedUser.Email,
};
notification.Substitutes.Add("Season", availableEpisode.First().SeasonNumber.ToString());
notification.Substitutes.Add("Episodes", string.Join(", ", availableEpisode.Select(x => x.EpisodeNumber)));
await _notification.Notify(notification);
}
}
await _tvRequest.Save();

6
src/Ombi.Schedule/Jobs/Plex/Models/AvailabilityModel.cs → src/Ombi.Schedule/Jobs/AvailabilityModel.cs
View file

@ -1,10 +1,10 @@
using Ombi.Store.Entities;
namespace Ombi.Schedule.Jobs.Plex.Models
namespace Ombi.Schedule.Jobs
{
public class AvailabilityModel
{
public int Id { get; set; }
public int SeasonNumber { get; set; }
public int EpisodeNumber { get; set; }
public string RequestedUser { get; set; }
}
}

56
src/Ombi.Schedule/Jobs/Emby/EmbyAvaliabilityChecker.cs
View file

@ -1,31 +1,5 @@
#region Copyright
// /************************************************************************
// Copyright (c) 2017 Jamie Rees
// File: EmbyAvaliabilityCheker.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;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.AspNetCore.SignalR;
@ -173,6 +147,7 @@ namespace Ombi.Schedule.Jobs.Emby
x.Series.Title == child.Title);
}
var availableEpisode = new List<AvailabilityModel>();
foreach (var season in child.SeasonRequests)
{
foreach (var episode in season.Episodes)
@ -188,11 +163,22 @@ namespace Ombi.Schedule.Jobs.Emby
if (foundEp != null)
{
availableEpisode.Add(new AvailabilityModel
{
Id = episode.Id,
EpisodeNumber = episode.EpisodeNumber,
SeasonNumber = episode.Season.SeasonNumber
});
episode.Available = true;
}
}
}
if (availableEpisode.Any())
{
await _tvRepo.Save();
}
// Check to see if all of the episodes in all seasons are available for this request
var allAvailable = child.SeasonRequests.All(x => x.Episodes.All(c => c.Available));
if (allAvailable)
@ -209,6 +195,20 @@ namespace Ombi.Schedule.Jobs.Emby
Recipient = child.RequestedUser.Email
});
}
else if (availableEpisode.Any())
{
var notification = new NotificationOptions
{
DateTime = DateTime.Now,
NotificationType = NotificationType.PartiallyAvailable,
RequestId = child.Id,
RequestType = RequestType.TvShow,
Recipient = child.RequestedUser.Email,
};
notification.Substitutes.Add("Season", availableEpisode.First().SeasonNumber.ToString());
notification.Substitutes.Add("Episodes", string.Join(", ", availableEpisode.Select(x => x.EpisodeNumber)));
await _notificationService.Notify(notification);
}
}
await _tvRepo.Save();

27
src/Ombi.Schedule/Jobs/Jellyfin/JellyfinAvaliabilityChecker.cs
View file

@ -26,6 +26,7 @@
#endregion
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.AspNetCore.SignalR;
@ -173,6 +174,7 @@ namespace Ombi.Schedule.Jobs.Jellyfin
x.Series.Title == child.Title);
}
var availableEpisode = new List<AvailabilityModel>();
foreach (var season in child.SeasonRequests)
{
foreach (var episode in season.Episodes)
@ -188,11 +190,22 @@ namespace Ombi.Schedule.Jobs.Jellyfin
if (foundEp != null)
{
availableEpisode.Add(new AvailabilityModel
{
Id = episode.Id,
EpisodeNumber = episode.EpisodeNumber,
SeasonNumber = episode.Season.SeasonNumber
});
episode.Available = true;
}
}
}
if (availableEpisode.Any())
{
await _tvRepo.Save();
}
// Check to see if all of the episodes in all seasons are available for this request
var allAvailable = child.SeasonRequests.All(x => x.Episodes.All(c => c.Available));
if (allAvailable)
@ -209,6 +222,20 @@ namespace Ombi.Schedule.Jobs.Jellyfin
Recipient = child.RequestedUser.Email
});
}
else if (availableEpisode.Any())
{
var notification = new NotificationOptions
{
DateTime = DateTime.Now,
NotificationType = NotificationType.PartiallyAvailable,
RequestId = child.Id,
RequestType = RequestType.TvShow,
Recipient = child.RequestedUser.Email,
};
notification.Substitutes.Add("Season", availableEpisode.First().SeasonNumber.ToString());
notification.Substitutes.Add("Episodes", string.Join(", ", availableEpisode.Select(x => x.EpisodeNumber)));
await _notificationService.Notify(notification);
}
}
await _tvRepo.Save();

23
src/Ombi.Schedule/Jobs/Plex/PlexAvailabilityChecker.cs
View file

@ -127,22 +127,19 @@ namespace Ombi.Schedule.Jobs.Plex
{
availableEpisode.Add(new AvailabilityModel
{
Id = episode.Id
Id = episode.Id,
EpisodeNumber = episode.EpisodeNumber,
SeasonNumber = episode.Season.SeasonNumber
});
episode.Available = true;
}
}
}
//TODO Partial avilability notifications here
if (availableEpisode.Any())
{
await _tvRepo.Save();
}
//foreach(var c in availableEpisode)
//{
// await _tvRepo.MarkEpisodeAsAvailable(c.Id);
//}
// Check to see if all of the episodes in all seasons are available for this request
var allAvailable = child.SeasonRequests.All(x => x.Episodes.All(c => c.Available));
@ -162,6 +159,20 @@ namespace Ombi.Schedule.Jobs.Plex
Recipient = child.RequestedUser.Email
});
}
else if (availableEpisode.Any())
{
var notification = new NotificationOptions
{
DateTime = DateTime.Now,
NotificationType = NotificationType.PartiallyAvailable,
RequestId = child.Id,
RequestType = RequestType.TvShow,
Recipient = child.RequestedUser.Email,
};
notification.Substitutes.Add("Season", availableEpisode.First().SeasonNumber.ToString());
notification.Substitutes.Add("Episodes", string.Join(", " ,availableEpisode.Select(x => x.EpisodeNumber)));
await _notificationService.Notify(notification);
}
}
await _tvRepo.Save();

10
src/Ombi.Store/Context/OmbiContext.cs
View file

@ -208,6 +208,16 @@ namespace Ombi.Store.Context
Enabled = true,
};
break;
case NotificationType.PartiallyAvailable:
notificationToAdd = new NotificationTemplates
{
NotificationType = notificationType,
Message = "Your TV request is now partially available! Season {PartiallyAvailableSeasonNumber} Episodes {PartiallyAvailableEpisodeNumbers}!",
Subject = "{ApplicationName}: Partially Available Request!",
Agent = agent,
Enabled = true,
};
break;
default:
throw new ArgumentOutOfRangeException();
}

4
src/Ombi/.vscode/settings.json vendored
View file

@ -13,6 +13,8 @@
"discord.enabled": true,
"conventionalCommits.scopes": [
"discover",
"request-limits"
"request-limits",
"notifications",
"settings"
]
}

2
src/Ombi/ClientApp/src/app/interfaces/INotificationSettings.ts
View file

@ -52,7 +52,7 @@ export enum NotificationType {
IssueResolved = 9,
IssueComment = 10,
Newsletter = 11,
WhatsApp = 12,
PartiallyAvailable = 12,
}
export interface IDiscordNotifcationSettings extends INotificationSettings {

3
src/Ombi/ClientApp/src/app/settings/plex/plex.component.ts
View file

@ -63,6 +63,7 @@ export class PlexComponent implements OnInit, OnDestroy {
server.plexAuthToken = selectedServer.accessToken;
server.port = parseInt(selectedServer.port);
server.ssl = selectedServer.scheme === "http" ? false : true;
server.serverHostname = "";
this.notificationService.success(`Selected ${server.name}!`);
}
@ -128,7 +129,7 @@ export class PlexComponent implements OnInit, OnDestroy {
let invalid = false;
this.settings.servers.forEach(server => {
if (server.serverHostname.length > 0 && !server.serverHostname.startsWith("http")) {
if (server.serverHostname && server.serverHostname.length > 0 && !server.serverHostname.startsWith("http")) {
invalid = true;
}
});

2
version.json
View file

@ -1,3 +1,3 @@
{
"version": "4.1.1"
"version": "4.2.0"
}