DeviceModel.cs

using iGotify_Notification_Assist.Services;
using Newtonsoft.Json;
using SecNtfyNuGet;
using Websocket.Client;
using Environments = iGotify_Notification_Assist.Services.Environments;

namespace iGotify_Notification_Assist.Models;

public class DeviceModel
{
    public string ClientToken { get; set; } = "";
    public string DeviceToken { get; set; } = "";
    public string GotifyUrl { get; set; } = "";

    /// <summary>
    /// Add device token to txt file
    /// </summary>
    /// <returns></returns>
    public async Task<bool> Insert()
    {
        if (!await DatabaseService.CheckIfUserExists(this))
            return await DatabaseService.InsertUser(this);
        else
            return false;
    }

    /// <summary>
    /// delete device token 
    /// </summary>
    /// <returns></returns>
    public async Task<bool> Delete()
    {
        return await DatabaseService.DeleteUser(ClientToken);
    }

    /// <summary>
    /// Send the passed notification from the gotify instance that was passed via WebSocket
    /// </summary>
    /// <param name="iGotifyMessage"></param>
    /// <param name="clientToken"></param>
    public async Task SendNotifications(GotifyMessage iGotifyMessage, WebsocketClient webSock)
    {
        await SendNotifications(iGotifyMessage, webSock.Url.ToString(), webSock.Name ?? "");
    }

    /// <summary>
    /// Send the passed notification from a native websocket context
    /// </summary>
    public async Task SendNotifications(GotifyMessage iGotifyMessage, string wsUrl, string clientToken)
    {
        if (string.IsNullOrWhiteSpace(clientToken))
        {
            AppLog.Warn("Notification", "Cannot send notification because client token is empty.");
            return;
        }

        var title = iGotifyMessage.title;
        var msg = iGotifyMessage.message;

        var protocol = wsUrl.Contains("ws://") ? "http://" : "https://";
        var gotifyServerUrl = wsUrl.Replace("ws://", "").Replace("wss://", "").Replace("\"", "")
            .Split("/stream");
        var imageUrl = gotifyServerUrl.Length > 0
            ? $"{protocol}{gotifyServerUrl[0]}$$${iGotifyMessage.appid}$$${clientToken}"
            : "";

        var usr = await DatabaseService.GetUser(clientToken);

        if (usr.Uid == 0)
        {
            AppLog.Warn("Notification", $"No user found for client={AppLog.MaskSecret(clientToken)}");
        }

        var ntfy = new SecNtfy(Environments.secNtfyUrl);
        var response = await ntfy.SendNotification(usr.DeviceToken, title, msg, iGotifyMessage.priority == 10, imageUrl,
            iGotifyMessage.priority);
        AppLog.Debug("Notification",
            response != null
                ? $"SecNtfy response client={AppLog.MaskSecret(clientToken)} response={JsonConvert.SerializeObject(response)}"
                : $"SecNtfy response client={AppLog.MaskSecret(clientToken)} response=<null>");
    }
}