212 lines
7.7 KiB
C#
212 lines
7.7 KiB
C#
#if !FDROID
|
|
using System;
|
|
using System.Diagnostics;
|
|
using System.Threading.Tasks;
|
|
using Bit.App.Abstractions;
|
|
using Bit.Core;
|
|
using Bit.Core.Abstractions;
|
|
using Bit.Core.Enums;
|
|
using Bit.Core.Exceptions;
|
|
using Bit.Core.Models.Response;
|
|
using Bit.Core.Utilities;
|
|
using Newtonsoft.Json;
|
|
using Newtonsoft.Json.Linq;
|
|
using Xamarin.Forms;
|
|
|
|
namespace Bit.App.Services
|
|
{
|
|
public class PushNotificationListenerService : IPushNotificationListenerService
|
|
{
|
|
const string TAG = "##PUSH NOTIFICATIONS";
|
|
|
|
private bool _showNotification;
|
|
private bool _resolved;
|
|
private ISyncService _syncService;
|
|
private IStateService _stateService;
|
|
private IAppIdService _appIdService;
|
|
private IApiService _apiService;
|
|
private IMessagingService _messagingService;
|
|
|
|
public async Task OnMessageAsync(JObject value, string deviceType)
|
|
{
|
|
Debug.WriteLine($"{TAG} OnMessageAsync called");
|
|
|
|
Resolve();
|
|
if (value == null)
|
|
{
|
|
return;
|
|
}
|
|
|
|
_showNotification = false;
|
|
Debug.WriteLine($"{TAG} Message Arrived: {JsonConvert.SerializeObject(value)}");
|
|
|
|
NotificationResponse notification = null;
|
|
if (deviceType == Device.Android)
|
|
{
|
|
notification = value.ToObject<NotificationResponse>();
|
|
}
|
|
else
|
|
{
|
|
if (!value.TryGetValue("data", StringComparison.OrdinalIgnoreCase, out JToken dataToken) ||
|
|
dataToken == null)
|
|
{
|
|
return;
|
|
}
|
|
notification = dataToken.ToObject<NotificationResponse>();
|
|
}
|
|
|
|
Debug.WriteLine($"{TAG} - Notification object created: t:{notification?.Type} - p:{notification?.Payload}");
|
|
|
|
var appId = await _appIdService.GetAppIdAsync();
|
|
if (notification?.Payload == null || notification.ContextId == appId)
|
|
{
|
|
return;
|
|
}
|
|
|
|
var myUserId = await _stateService.GetActiveUserIdAsync();
|
|
var isAuthenticated = await _stateService.IsAuthenticatedAsync();
|
|
switch (notification.Type)
|
|
{
|
|
case NotificationType.SyncCipherUpdate:
|
|
case NotificationType.SyncCipherCreate:
|
|
var cipherCreateUpdateMessage = JsonConvert.DeserializeObject<SyncCipherNotification>(
|
|
notification.Payload);
|
|
if (isAuthenticated && cipherCreateUpdateMessage.UserId == myUserId)
|
|
{
|
|
await _syncService.SyncUpsertCipherAsync(cipherCreateUpdateMessage,
|
|
notification.Type == NotificationType.SyncCipherUpdate);
|
|
}
|
|
break;
|
|
case NotificationType.SyncFolderUpdate:
|
|
case NotificationType.SyncFolderCreate:
|
|
var folderCreateUpdateMessage = JsonConvert.DeserializeObject<SyncFolderNotification>(
|
|
notification.Payload);
|
|
if (isAuthenticated && folderCreateUpdateMessage.UserId == myUserId)
|
|
{
|
|
await _syncService.SyncUpsertFolderAsync(folderCreateUpdateMessage,
|
|
notification.Type == NotificationType.SyncFolderUpdate);
|
|
}
|
|
break;
|
|
case NotificationType.SyncLoginDelete:
|
|
case NotificationType.SyncCipherDelete:
|
|
var loginDeleteMessage = JsonConvert.DeserializeObject<SyncCipherNotification>(
|
|
notification.Payload);
|
|
if (isAuthenticated && loginDeleteMessage.UserId == myUserId)
|
|
{
|
|
await _syncService.SyncDeleteCipherAsync(loginDeleteMessage);
|
|
}
|
|
break;
|
|
case NotificationType.SyncFolderDelete:
|
|
var folderDeleteMessage = JsonConvert.DeserializeObject<SyncFolderNotification>(
|
|
notification.Payload);
|
|
if (isAuthenticated && folderDeleteMessage.UserId == myUserId)
|
|
{
|
|
await _syncService.SyncDeleteFolderAsync(folderDeleteMessage);
|
|
}
|
|
break;
|
|
case NotificationType.SyncCiphers:
|
|
case NotificationType.SyncVault:
|
|
case NotificationType.SyncSettings:
|
|
if (isAuthenticated)
|
|
{
|
|
await _syncService.FullSyncAsync(false);
|
|
}
|
|
break;
|
|
case NotificationType.SyncOrgKeys:
|
|
if (isAuthenticated)
|
|
{
|
|
await _apiService.RefreshIdentityTokenAsync();
|
|
await _syncService.FullSyncAsync(true);
|
|
}
|
|
break;
|
|
case NotificationType.LogOut:
|
|
if (isAuthenticated)
|
|
{
|
|
_messagingService.Send("logout");
|
|
}
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
public async Task OnRegisteredAsync(string token, string deviceType)
|
|
{
|
|
Resolve();
|
|
Debug.WriteLine($"{TAG} - Device Registered - Token : {token}");
|
|
var isAuthenticated = await _stateService.IsAuthenticatedAsync();
|
|
if (!isAuthenticated)
|
|
{
|
|
Debug.WriteLine($"{TAG} - not auth");
|
|
return;
|
|
}
|
|
|
|
var appId = await _appIdService.GetAppIdAsync();
|
|
try
|
|
{
|
|
#if DEBUG
|
|
await _stateService.SetPushInstallationRegistrationErrorAsync(null);
|
|
#endif
|
|
|
|
await _apiService.PutDeviceTokenAsync(appId,
|
|
new Core.Models.Request.DeviceTokenRequest { PushToken = token });
|
|
|
|
Debug.WriteLine($"{TAG} Registered device with server.");
|
|
|
|
await _stateService.SetPushLastRegistrationDateAsync(DateTime.UtcNow);
|
|
if (deviceType == Device.Android)
|
|
{
|
|
await _stateService.SetPushCurrentTokenAsync(token);
|
|
}
|
|
}
|
|
#if DEBUG
|
|
catch (ApiException apiEx)
|
|
{
|
|
Debug.WriteLine($"{TAG} Failed to register device.");
|
|
|
|
await _stateService.SetPushInstallationRegistrationErrorAsync(apiEx.Error?.Message);
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
await _stateService.SetPushInstallationRegistrationErrorAsync(e.Message);
|
|
throw;
|
|
}
|
|
#else
|
|
catch (ApiException)
|
|
{
|
|
}
|
|
#endif
|
|
}
|
|
|
|
public void OnUnregistered(string deviceType)
|
|
{
|
|
Debug.WriteLine($"{TAG} - Device Unnregistered");
|
|
}
|
|
|
|
public void OnError(string message, string deviceType)
|
|
{
|
|
Debug.WriteLine($"{TAG} error - {message}");
|
|
}
|
|
|
|
public bool ShouldShowNotification()
|
|
{
|
|
return _showNotification;
|
|
}
|
|
|
|
private void Resolve()
|
|
{
|
|
if (_resolved)
|
|
{
|
|
return;
|
|
}
|
|
_syncService = ServiceContainer.Resolve<ISyncService>("syncService");
|
|
_stateService = ServiceContainer.Resolve<IStateService>("stateService");
|
|
_appIdService = ServiceContainer.Resolve<IAppIdService>("appIdService");
|
|
_apiService = ServiceContainer.Resolve<IApiService>("apiService");
|
|
_messagingService = ServiceContainer.Resolve<IMessagingService>("messagingService");
|
|
_resolved = true;
|
|
}
|
|
}
|
|
}
|
|
#endif
|