Renamed Managers to Connectors

This commit is contained in:
glax 2023-08-31 16:02:02 +02:00
parent d5d34c5381
commit 1c1169e5ce
6 changed files with 29 additions and 29 deletions

View File

@ -58,10 +58,10 @@ public abstract class GlobalBase
File.WriteAllText(settings.notificationConnectorsFilePath, JsonConvert.SerializeObject(notificationConnectors)); File.WriteAllText(settings.notificationConnectorsFilePath, JsonConvert.SerializeObject(notificationConnectors));
} }
protected void DeleteNotificationConnector(NotificationConnector.NotificationManagerType notificationManagerType) protected void DeleteNotificationConnector(NotificationConnector.NotificationConnectorType notificationConnectorType)
{ {
Log($"Removing {notificationManagerType}"); Log($"Removing {notificationConnectorType}");
notificationConnectors.RemoveWhere(nc => nc.notificationManagerType == notificationManagerType); notificationConnectors.RemoveWhere(nc => nc.notificationConnectorType == notificationConnectorType);
} }
protected void UpdateLibraries() protected void UpdateLibraries()

View File

@ -11,7 +11,7 @@ public class Gotify : NotificationConnector
private readonly HttpClient _client = new(); private readonly HttpClient _client = new();
[JsonConstructor] [JsonConstructor]
public Gotify(GlobalBase clone, string endpoint, string appToken) : base(clone, NotificationManagerType.Gotify) public Gotify(GlobalBase clone, string endpoint, string appToken) : base(clone, NotificationConnectorType.Gotify)
{ {
this.endpoint = endpoint; this.endpoint = endpoint;
this.appToken = appToken; this.appToken = appToken;

View File

@ -10,7 +10,7 @@ public class LunaSea : NotificationConnector
private readonly HttpClient _client = new(); private readonly HttpClient _client = new();
[JsonConstructor] [JsonConstructor]
public LunaSea(GlobalBase clone, string id) : base(clone, NotificationManagerType.LunaSea) public LunaSea(GlobalBase clone, string id) : base(clone, NotificationConnectorType.LunaSea)
{ {
this.id = id; this.id = id;
} }

View File

@ -2,14 +2,14 @@
public abstract class NotificationConnector : GlobalBase public abstract class NotificationConnector : GlobalBase
{ {
public readonly NotificationManagerType notificationManagerType; public readonly NotificationConnectorType notificationConnectorType;
protected NotificationConnector(GlobalBase clone, NotificationManagerType notificationManagerType) : base(clone) protected NotificationConnector(GlobalBase clone, NotificationConnectorType notificationConnectorType) : base(clone)
{ {
this.notificationManagerType = notificationManagerType; this.notificationConnectorType = notificationConnectorType;
} }
public enum NotificationManagerType : byte { Gotify = 0, LunaSea = 1 } public enum NotificationConnectorType : byte { Gotify = 0, LunaSea = 1 }
public abstract void SendNotification(string title, string notificationText); public abstract void SendNotification(string title, string notificationText);
} }

View File

@ -21,10 +21,10 @@ public class NotificationManagerJsonConverter : JsonConverter
JsonSerializer serializer) JsonSerializer serializer)
{ {
JObject jo = JObject.Load(reader); JObject jo = JObject.Load(reader);
if (jo["notificationManagerType"]!.Value<byte>() == (byte)NotificationConnector.NotificationManagerType.Gotify) if (jo["notificationConnectorType"]!.Value<byte>() == (byte)NotificationConnector.NotificationConnectorType.Gotify)
return new Gotify(this._clone, jo.GetValue("endpoint")!.Value<string>()!, jo.GetValue("appToken")!.Value<string>()!); return new Gotify(this._clone, jo.GetValue("endpoint")!.Value<string>()!, jo.GetValue("appToken")!.Value<string>()!);
else if (jo["notificationManagerType"]!.Value<byte>() == else if (jo["notificationConnectorType"]!.Value<byte>() ==
(byte)NotificationConnector.NotificationManagerType.LunaSea) (byte)NotificationConnector.NotificationConnectorType.LunaSea)
return new LunaSea(this._clone, jo.GetValue("id")!.Value<string>()!); return new LunaSea(this._clone, jo.GetValue("id")!.Value<string>()!);
throw new Exception(); throw new Exception();

View File

@ -173,7 +173,7 @@ public class Server : GlobalBase
break; break;
case "NotificationConnectors/Types": case "NotificationConnectors/Types":
SendResponse(HttpStatusCode.OK, response, SendResponse(HttpStatusCode.OK, response,
Enum.GetValues<NotificationConnector.NotificationManagerType>().Select(nc => new KeyValuePair<byte, string?>((byte)nc, Enum.GetName(nc)))); Enum.GetValues<NotificationConnector.NotificationConnectorType>().Select(nc => new KeyValuePair<byte, string?>((byte)nc, Enum.GetName(nc))));
break; break;
case "LibraryConnectors": case "LibraryConnectors":
SendResponse(HttpStatusCode.OK, response, libraryConnectors); SendResponse(HttpStatusCode.OK, response, libraryConnectors);
@ -259,13 +259,13 @@ public class Server : GlobalBase
break;*/ break;*/
case "NotificationConnectors/Update": case "NotificationConnectors/Update":
if (!requestVariables.TryGetValue("notificationConnector", out string? notificationConnectorStr) || if (!requestVariables.TryGetValue("notificationConnector", out string? notificationConnectorStr) ||
!Enum.TryParse(notificationConnectorStr, out NotificationConnector.NotificationManagerType notificationManagerType)) !Enum.TryParse(notificationConnectorStr, out NotificationConnector.NotificationConnectorType notificationConnectorType))
{ {
SendResponse(HttpStatusCode.BadRequest, response); SendResponse(HttpStatusCode.BadRequest, response);
break; break;
} }
if (notificationManagerType is NotificationConnector.NotificationManagerType.Gotify) if (notificationConnectorType is NotificationConnector.NotificationConnectorType.Gotify)
{ {
if (!requestVariables.TryGetValue("gotifyUrl", out string? gotifyUrl) || if (!requestVariables.TryGetValue("gotifyUrl", out string? gotifyUrl) ||
!requestVariables.TryGetValue("gotifyAppToken", out string? gotifyAppToken)) !requestVariables.TryGetValue("gotifyAppToken", out string? gotifyAppToken))
@ -278,7 +278,7 @@ public class Server : GlobalBase
break; break;
} }
if (notificationManagerType is NotificationConnector.NotificationManagerType.LunaSea) if (notificationConnectorType is NotificationConnector.NotificationConnectorType.LunaSea)
{ {
if (!requestVariables.TryGetValue("lunaseaWebhook", out string? lunaseaWebhook)) if (!requestVariables.TryGetValue("lunaseaWebhook", out string? lunaseaWebhook))
{ {
@ -290,16 +290,16 @@ public class Server : GlobalBase
break; break;
} }
break; break;
case "LibraryManagers/Update": case "LibraryConnectors/Update":
if (!requestVariables.TryGetValue("libraryManager", out string? libraryManagerStr) || if (!requestVariables.TryGetValue("libraryConnector", out string? libraryConnectorStr) ||
!Enum.TryParse(libraryManagerStr, !Enum.TryParse(libraryConnectorStr,
out LibraryConnector.LibraryType libraryManagerType)) out LibraryConnector.LibraryType libraryConnectorType))
{ {
SendResponse(HttpStatusCode.BadRequest, response); SendResponse(HttpStatusCode.BadRequest, response);
break; break;
} }
if (libraryManagerType is LibraryConnector.LibraryType.Kavita) if (libraryConnectorType is LibraryConnector.LibraryType.Kavita)
{ {
if (!requestVariables.TryGetValue("kavitaUrl", out string? kavitaUrl) || if (!requestVariables.TryGetValue("kavitaUrl", out string? kavitaUrl) ||
!requestVariables.TryGetValue("kavitaUsername", out string? kavitaUsername) || !requestVariables.TryGetValue("kavitaUsername", out string? kavitaUsername) ||
@ -313,7 +313,7 @@ public class Server : GlobalBase
break; break;
} }
if (libraryManagerType is LibraryConnector.LibraryType.Komga) if (libraryConnectorType is LibraryConnector.LibraryType.Komga)
{ {
if (!requestVariables.TryGetValue("komgaUrl", out string? komgaUrl) || if (!requestVariables.TryGetValue("komgaUrl", out string? komgaUrl) ||
!requestVariables.TryGetValue("komgaAuth", out string? komgaAuth)) !requestVariables.TryGetValue("komgaAuth", out string? komgaAuth))
@ -394,23 +394,23 @@ public class Server : GlobalBase
break; break;
case "NotificationConnectors": case "NotificationConnectors":
if (!requestVariables.TryGetValue("notificationConnector", out string? notificationConnectorStr) || if (!requestVariables.TryGetValue("notificationConnector", out string? notificationConnectorStr) ||
!Enum.TryParse(notificationConnectorStr, out NotificationConnector.NotificationManagerType notificationManagerType)) !Enum.TryParse(notificationConnectorStr, out NotificationConnector.NotificationConnectorType notificationConnectorType))
{ {
SendResponse(HttpStatusCode.BadRequest, response); SendResponse(HttpStatusCode.BadRequest, response);
break; break;
} }
DeleteNotificationConnector(notificationManagerType); DeleteNotificationConnector(notificationConnectorType);
SendResponse(HttpStatusCode.Accepted, response); SendResponse(HttpStatusCode.Accepted, response);
break; break;
case "LibraryManagers": case "LibraryConnectors":
if (!requestVariables.TryGetValue("libraryManager", out string? libraryManagerStr) || if (!requestVariables.TryGetValue("libraryConnectors", out string? libraryConnectorStr) ||
!Enum.TryParse(libraryManagerStr, !Enum.TryParse(libraryConnectorStr,
out LibraryConnector.LibraryType libraryManagerType)) out LibraryConnector.LibraryType libraryConnectoryType))
{ {
SendResponse(HttpStatusCode.BadRequest, response); SendResponse(HttpStatusCode.BadRequest, response);
break; break;
} }
DeleteLibraryConnector(libraryManagerType); DeleteLibraryConnector(libraryConnectoryType);
SendResponse(HttpStatusCode.Accepted, response); SendResponse(HttpStatusCode.Accepted, response);
break; break;
default: default: