// (c) Copyright Ascensio System SIA 2010-2022 // // This program is a free software product. // You can redistribute it and/or modify it under the terms // of the GNU Affero General Public License (AGPL) version 3 as published by the Free Software // Foundation. In accordance with Section 7(a) of the GNU AGPL its Section 15 shall be amended // to the effect that Ascensio System SIA expressly excludes the warranty of non-infringement of // any third-party rights. // // This program is distributed WITHOUT ANY WARRANTY, without even the implied warranty // of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. For details, see // the GNU AGPL at: http://www.gnu.org/licenses/agpl-3.0.html // // You can contact Ascensio System SIA at Lubanas st. 125a-25, Riga, Latvia, EU, LV-1021. // // The interactive user interfaces in modified source and object code versions of the Program must // display Appropriate Legal Notices, as required under Section 5 of the GNU AGPL version 3. // // Pursuant to Section 7(b) of the License you must retain the original Product logo when // distributing the program. Pursuant to Section 7(e) we decline to grant you any rights under // trademark law for use of our trademarks. // // All the Product's GUI elements, including illustrations and icon sets, as well as technical writing // content are licensed under the terms of the Creative Commons Attribution-ShareAlike 4.0 // International. See the License terms at http://creativecommons.org/licenses/by-sa/4.0/legalcode using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; namespace ASC.Core.Common.Notify.Push; [Scope] public class FirebaseDao { private readonly IDbContextFactory _dbContextFactory; public FirebaseDao(IDbContextFactory dbContextFactory) { _dbContextFactory = dbContextFactory; } public FireBaseUser RegisterUserDevice(Guid userId, int tenantId, string fbDeviceToken, bool isSubscribed, string application) { using var dbContext = _dbContextFactory.CreateDbContext(); var count = dbContext.Users .AsNoTracking() .Where(r => r.UserId == userId) .Where(r => r.TenantId == tenantId) .Where(r => r.Application == application) .Where(r => r.FirebaseDeviceToken == fbDeviceToken) .Count(); var user = new FireBaseUser { UserId = userId, TenantId = tenantId, FirebaseDeviceToken = fbDeviceToken, IsSubscribed = isSubscribed, Application = application }; if (count == 0) { dbContext.AddOrUpdate(r => r.Users, user); dbContext.SaveChanges(); } return user; } public List GetUserDeviceTokens(Guid userId, int tenantId, string application) { using var dbContext = _dbContextFactory.CreateDbContext(); return dbContext.Users .AsNoTracking() .Where(r => r.UserId == userId) .Where(r => r.TenantId == tenantId) .Where(r => r.Application == application) .ToList(); } public FireBaseUser UpdateUser(Guid userId, int tenantId, string fbDeviceToken, bool isSubscribed, string application) { using var dbContext = _dbContextFactory.CreateDbContext(); var user = new FireBaseUser { UserId = userId, TenantId = tenantId, FirebaseDeviceToken = fbDeviceToken, IsSubscribed = isSubscribed, Application = application }; dbContext.Update(user); dbContext.SaveChanges(); return user; } }