Merge pull request #264 from SaintAngeLs/notifications_service

(#263) AddOrUpdate async method update, favicon update, new message retrieval affecting the title of the page

MiniSpace.Services.Notifications/src/MiniSpace.Services.Notifications.Application/Events/External/Handlers/FriendInvitedHandler.cs

@@ -36,7 +36,7 @@ public async Task HandleAsync(FriendInvited @event, CancellationToken cancellati
         {
             var inviter = await _studentsServiceClient.GetAsync(@event.InviterId);
             var notificationMessage = $"You have been invited by {inviter.FirstName} {inviter.LastName} to be friends.";
-            var detailsHtml = $"<p>View <a href='https://minispace.itsharppro.com/user-details/{@event.InviterId}'>{inviter.FirstName} {inviter.LastName}</a>'s profile to respond to the friend invitation.</p>";
+            var detailsHtml = $"<p>View <a href='https://minispace.itsharppro.com/student-details/{@event.InviterId}'>{inviter.FirstName} {inviter.LastName}</a>'s profile to respond to the friend invitation.</p>";
 
             var notificationId = Guid.NewGuid();
             var notification = new Notification(

MiniSpace.Services.Notifications/src/MiniSpace.Services.Notifications.Application/Events/External/Handlers/FriendRequestSentHandler.cs

@@ -30,7 +30,7 @@ public async Task HandleAsync(FriendRequestSent @event, CancellationToken cancel
         {
             var inviter = await _studentsServiceClient.GetAsync(@event.InviterId);
             var notificationMessage = $"You have been invited by {inviter.FirstName} {inviter.LastName} to be friends.";
-            var detailsHtml = $"<p>View <a href='https://minispace.itsharppro.com/user-details/{@event.InviterId}'>{inviter.FirstName} {inviter.LastName}</a>'s profile to respond to the friend invitation.</p>";
+            var detailsHtml = $"<p>View <a href='https://minispace.itsharppro.com/student-details/{@event.InviterId}'>{inviter.FirstName} {inviter.LastName}</a>'s profile to respond to the friend invitation.</p>";
 
             var notification = new Notification(
                 notificationId: Guid.NewGuid(),

MiniSpace.Services.Notifications/src/MiniSpace.Services.Notifications.Infrastructure/Mongo/Repositories/StudentNotificationsMongoRepository.cs

@@ -41,26 +41,63 @@ public async Task UpdateAsync(StudentNotifications studentNotifications)
             await _repository.Collection.UpdateOneAsync(filter, update, options);
         }
 
-         public async Task AddOrUpdateAsync(StudentNotifications studentNotifications)
+        //  public async Task AddOrUpdateAsync(StudentNotifications studentNotifications)
+        // {
+        //     var document = studentNotifications.AsDocument();
+        //     var filter = Builders<StudentNotificationsDocument>.Filter.Eq(doc => doc.StudentId, studentNotifications.StudentId);
+        //     var updates = new List<UpdateDefinition<StudentNotificationsDocument>>();
+
+        //     foreach (var notification in studentNotifications.Notifications)
+        //     {
+        //         updates.Add(Builders<StudentNotificationsDocument>.Update.Push(doc => doc.Notifications, notification.AsDocument()));
+        //     }
+
+        //     var update = Builders<StudentNotificationsDocument>.Update
+        //         .SetOnInsert(doc => doc.Id, studentNotifications.StudentId) 
+        //         .AddToSetEach(doc => doc.Notifications, studentNotifications.Notifications.Select(n => n.AsDocument())); 
+
+        //     var options = new UpdateOptions { IsUpsert = true };
+        //     await _repository.Collection.UpdateOneAsync(filter, update, options);
+        // }
+
+        public async Task AddOrUpdateAsync(StudentNotifications studentNotifications)
         {
             var document = studentNotifications.AsDocument();
             var filter = Builders<StudentNotificationsDocument>.Filter.Eq(doc => doc.StudentId, studentNotifications.StudentId);
-            var updates = new List<UpdateDefinition<StudentNotificationsDocument>>();
 
+            // Ensure the document is initialized with an empty list if not present
+            var initializationUpdate = Builders<StudentNotificationsDocument>.Update
+                .SetOnInsert(doc => doc.Notifications, new List<NotificationDocument>());
+
+            var addToSetUpdates = new List<UpdateDefinition<StudentNotificationsDocument>>();
             foreach (var notification in studentNotifications.Notifications)
             {
-                updates.Add(Builders<StudentNotificationsDocument>.Update.Push(doc => doc.Notifications, notification.AsDocument()));
-            }
+                var notificationDocument = notification.AsDocument();
+                var notificationFilter = Builders<StudentNotificationsDocument>.Filter.And(
+                    Builders<StudentNotificationsDocument>.Filter.Eq("Notifications.Message", notificationDocument.Message),
+                    Builders<StudentNotificationsDocument>.Filter.Eq("Notifications.CreatedAt", notificationDocument.CreatedAt),
+                    Builders<StudentNotificationsDocument>.Filter.Eq("Notifications.EventType", notificationDocument.EventType)
+                );
 
-            var update = Builders<StudentNotificationsDocument>.Update
-                .SetOnInsert(doc => doc.Id, studentNotifications.StudentId) 
-                .AddToSetEach(doc => doc.Notifications, studentNotifications.Notifications.Select(n => n.AsDocument())); 
+                var combinedFilter = Builders<StudentNotificationsDocument>.Filter.And(filter, notificationFilter);
+                var update = Builders<StudentNotificationsDocument>.Update.AddToSet(doc => doc.Notifications, notificationDocument);
+
+                addToSetUpdates.Add(update);
+            }
 
             var options = new UpdateOptions { IsUpsert = true };
-            await _repository.Collection.UpdateOneAsync(filter, update, options);
+            // Initialize document if it doesn't exist
+            await _repository.Collection.UpdateOneAsync(filter, initializationUpdate, options);
+
+            // Apply each AddToSet operation
+            foreach (var update in addToSetUpdates)
+            {
+                await _repository.Collection.UpdateOneAsync(filter, update, options);
+            }
         }
 
 
+
        public async Task<List<StudentNotifications>> FindAsync(FilterDefinition<StudentNotificationsDocument> filter, FindOptions options)
         {
             var documents = await _repository.Collection.Find(filter, options).ToListAsync();

MiniSpace.Web/src/MiniSpace.Web/Pages/_Host.cshtml

@@ -7,7 +7,7 @@
 <head>
     <meta charset="utf-8" />
     <meta name="viewport" content="width=device-width, initial-scale=1.0" />
-    <title>MiniSpace.Web</title>
+    <title>MiniSpace | Social</title>
     <base href="~/" />
     <link rel="stylesheet" href="_content/Radzen.Blazor/css/humanistic-base.css">
     <link href="css/site.css" rel="stylesheet" />
@@ -56,6 +56,11 @@
             return new Date().getTimezoneOffset();
         }
 
+        function updateTitle(message) {
+            document.title = message;
+            setTimeout(() => document.title = "MiniSpace | Social", 8000); 
+        }
+
     </script>
 </body>
 </html>

MiniSpace.Web/src/MiniSpace.Web/Shared/NotificationComponent.razor

@@ -60,9 +60,10 @@
             var paginatedResponse = await NotificationsService.GetNotificationsByUserAsync(userId, status: "Unread");
             var latestNotifications = paginatedResponse.Results;
 
-            if (latestNotifications.Any(n => n.CreatedAt > lastCheckedTime))
+             if (latestNotifications.Any(n => n.CreatedAt > lastCheckedTime))
             {
                 PlayNotificationSound();
+                await JSRuntime.InvokeVoidAsync("updateTitle", "New Notification - MiniSpace | Social");
                 lastCheckedTime = DateTime.Now; 
             }