(#125) notifications service implementation -- external events arrangement.

.github/workflows/cloud_deploy.yml

@@ -3,10 +3,10 @@ name: Deploy to Cloud
 on:
   push:
     branches:
-      - dev # dev for the test purposes here
+      - main 
   pull_request:
     branches:
-      - dev 
+      - main 
 
 jobs:
   deploy:

MiniSpace.APIGateway/src/MiniSpace.APIGateway/ntrada-async.docker.yml

@@ -200,13 +200,42 @@ modules:
         method: POST
         use: downstream
         downstream: notifications-service/notifications
-        auth: true
+        auth: true 
 
       - upstream: /{userId}
         method: GET
         use: downstream
         downstream: notifications-service/notifications/{userId}
+        auth: true 
+
+      - upstream: /notification/{notificationId}
+        method: GET
+        use: downstream
+        downstream: notifications-service/notifications/notification/{notificationId}
+        auth: true  
+
+      - upstream: /notification/{userId}/{notificationId}
+        method: DELETE
+        use: downstream
+        downstream: notifications-service/notifications/notification/{userId}/{notificationId}
+        auth: true 
+        bind:
+          - userId:{userId}
+          - notificationId:{notificationId}
+
+      - upstream: /{userId}/{notificationId}
+        method: GET
+        use: downstream
+        downstream: notifications-service/notifications/{userId}/{notificationId}
         auth: true
+        description: Retrieves a specific notification for a user by notification ID.
+
+      - upstream: /{userId}/{notificationId}/status
+        method: PUT
+        use: downstream
+        downstream: notifications-service/notifications/{userId}/{notificationId}/status
+        auth: true  
+        description: Updates the status of a specific notification.
 
     services:
       notifications-service:
@@ -513,6 +542,12 @@ modules:
           bind:
             - userId: {userId}
           auth: true
+          afterDispatch:
+            - use: publish
+              event: FriendInviteSent
+              target: notifications-service/events
+              routingKey: friend_request_created
+
 
         - upstream: /{requesterId}/{friendId}/remove
           method: DELETE
@@ -565,10 +600,13 @@ modules:
           downstream: friends-service/friends/requests/sent/{userId}
           auth: true
 
-      services:
-        friends-service:
-          localUrl: localhost:5012
-          url: friends-service
+        - upstream: /requests/{userId}/withdraw
+          method: PUT
+          use: downstream
+          downstream: friends-service/friends/requests/{userId}/withdraw
+          bind:
+            - userId: {userId}
+          auth: true
 
 
 

MiniSpace.APIGateway/src/MiniSpace.APIGateway/ntrada-async.yml

@@ -513,6 +513,12 @@ modules:
           bind:
             - userId: {userId}
           auth: true
+          afterDispatch:
+            - use: publish
+              event: FriendInviteSent
+              target: notifications-service/events
+              routingKey: friend_request_created
+
 
         - upstream: /{requesterId}/{friendId}/remove
           method: DELETE
@@ -565,10 +571,13 @@ modules:
           downstream: friends-service/friends/requests/sent/{userId}
           auth: true
 
-      services:
-        friends-service:
-          localUrl: localhost:5012
-          url: friends-service
+        - upstream: /requests/{userId}/withdraw
+          method: PUT
+          use: downstream
+          downstream: friends-service/friends/requests/{userId}/withdraw
+          bind:
+            - userId: {userId}
+          auth: true
 
 
 

MiniSpace.APIGateway/src/MiniSpace.APIGateway/ntrada.docker.yml

@@ -177,13 +177,42 @@ modules:
         method: POST
         use: downstream
         downstream: notifications-service/notifications
-        auth: true
+        auth: true 
 
       - upstream: /{userId}
         method: GET
         use: downstream
         downstream: notifications-service/notifications/{userId}
+        auth: true 
+
+      - upstream: /notification/{notificationId}
+        method: GET
+        use: downstream
+        downstream: notifications-service/notifications/notification/{notificationId}
+        auth: true  
+
+      - upstream: /notification/{userId}/{notificationId}
+        method: DELETE
+        use: downstream
+        downstream: notifications-service/notifications/notification/{userId}/{notificationId}
+        auth: true 
+        bind:
+          - userId:{userId}
+          - notificationId:{notificationId}
+
+      - upstream: /{userId}/{notificationId}
+        method: GET
+        use: downstream
+        downstream: notifications-service/notifications/{userId}/{notificationId}
         auth: true
+        description: Retrieves a specific notification for a user by notification ID.
+
+      - upstream: /{userId}/{notificationId}/status
+        method: PUT
+        use: downstream
+        downstream: notifications-service/notifications/{userId}/{notificationId}/status
+        auth: true  
+        description: Updates the status of a specific notification.
 
     services:
       notifications-service:
@@ -490,6 +519,12 @@ modules:
           bind:
             - userId: {userId}
           auth: true
+          afterDispatch:
+            - use: publish
+              event: FriendInviteSent
+              target: notifications-service/events
+              routingKey: friend_request_created
+
 
         - upstream: /{requesterId}/{friendId}/remove
           method: DELETE
@@ -542,10 +577,13 @@ modules:
           downstream: friends-service/friends/requests/sent/{userId}
           auth: true
 
-      services:
-        friends-service:
-          localUrl: localhost:5012
-          url: friends-service
+        - upstream: /requests/{userId}/withdraw
+          method: PUT
+          use: downstream
+          downstream: friends-service/friends/requests/{userId}/withdraw
+          bind:
+            - userId: {userId}
+          auth: true
 
 
 

MiniSpace.APIGateway/src/MiniSpace.APIGateway/ntrada.yml

@@ -179,18 +179,52 @@ modules:
         method: POST
         use: downstream
         downstream: notifications-service/notifications
-        auth: true
+        auth: true 
 
       - upstream: /{userId}
         method: GET
         use: downstream
         downstream: notifications-service/notifications/{userId}
+        auth: true 
+
+      - upstream: /notification/{notificationId}
+        method: GET
+        use: downstream
+        downstream: notifications-service/notifications/notification/{notificationId}
+        auth: true  
+
+      - upstream: /notification/{userId}/{notificationId}
+        method: DELETE
+        use: downstream
+        downstream: notifications-service/notifications/notification/{userId}/{notificationId}
+        auth: true 
+        bind:
+          - userId:{userId}
+          - notificationId:{notificationId}
+
+      - upstream: /{userId}/{notificationId}
+        method: GET
+        use: downstream
+        downstream: notifications-service/notifications/{userId}/{notificationId}
         auth: true
+        description: Retrieves a specific notification for a user by notification ID.
+
+      - upstream: /{userId}/{notificationId}/status
+        method: PUT
+        use: downstream
+        downstream: notifications-service/notifications/{userId}/{notificationId}/status
+        auth: true  
+        description: Updates the status of a specific notification.
 
     services:
       notifications-service:
         localUrl: localhost:5006
         url: notifications-service
+
+
+
+
+
 
 
 
@@ -492,6 +526,12 @@ modules:
           bind:
             - userId: {userId}
           auth: true
+          afterDispatch:
+            - use: publish
+              event: FriendInviteSent
+              target: notifications-service/events
+              routingKey: friend_request_created
+
 
         - upstream: /{requesterId}/{friendId}/remove
           method: DELETE
@@ -544,6 +584,14 @@ modules:
           downstream: friends-service/friends/requests/sent/{userId}
           auth: true
 
+        - upstream: /requests/{userId}/withdraw
+          method: PUT
+          use: downstream
+          downstream: friends-service/friends/requests/{userId}/withdraw
+          bind:
+            - userId: {userId}
+          auth: true
+
       services:
         friends-service:
           localUrl: localhost:5012
@@ -700,5 +748,4 @@ modules:
       organizations-service:
         localUrl: localhost:5015
         url: organizations-service
-
-
+

MiniSpace.Services.Events/src/MiniSpace.Services.Events.Api/MiniSpace.Services.Events.Api.sln

@@ -0,0 +1,25 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.5.002.0
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "MiniSpace.Services.Events.Api", "MiniSpace.Services.Events.Api.csproj", "{075CA7F0-8B43-4F73-8A1B-31C246206002}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{075CA7F0-8B43-4F73-8A1B-31C246206002}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{075CA7F0-8B43-4F73-8A1B-31C246206002}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{075CA7F0-8B43-4F73-8A1B-31C246206002}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{075CA7F0-8B43-4F73-8A1B-31C246206002}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {65FCD660-A2AF-4F11-AFD6-C07F118AC0D7}
+	EndGlobalSection
+EndGlobal

MiniSpace.Services.Events/src/MiniSpace.Services.Events.Application/Events/EventCreated.cs

@@ -1,9 +1,11 @@
 using System;
 using System.Collections.Generic;
 using Convey.CQRS.Events;
+using Convey.MessageBrokers;
 
 namespace MiniSpace.Services.Events.Application.Events
 {
+    [Message("notifications")]
     public class EventCreated(Guid eventId, Guid organizerId, IEnumerable<Guid> mediaFilesIds) : IEvent
     {
         public Guid EventId { get; set; } = eventId;

MiniSpace.Services.Events/src/MiniSpace.Services.Events.Application/Events/EventParticipantAdded.cs

@@ -1,8 +1,10 @@
 using System;
 using Convey.CQRS.Events;
+using Convey.MessageBrokers;
 
 namespace MiniSpace.Services.Events.Application.Events
 {
+    [Message("notifications")]
     public class EventParticipantAdded: IEvent
     {
         public Guid EventId { get; }

MiniSpace.Services.Events/src/MiniSpace.Services.Events.Application/Events/EventParticipantRemoved.cs

@@ -1,9 +1,11 @@
 using System;
 using System.Collections.Generic;
 using Convey.CQRS.Events;
+using Convey.MessageBrokers;
 
 namespace MiniSpace.Services.Events.Application.Events
 {
+    [Message("notifications")]
     public class EventParticipantRemoved: IEvent
     {
         public Guid EventId { get; }

MiniSpace.Services.Events/src/MiniSpace.Services.Events.Application/Events/EventUpdated.cs

@@ -2,9 +2,11 @@
 using System.Collections;
 using System.Collections.Generic;
 using Convey.CQRS.Events;
+using Convey.MessageBrokers;
 
 namespace MiniSpace.Services.Events.Application.Events
 {
+    [Message("notifications")]
     public class EventUpdated(Guid eventId, DateTime updatedAt, Guid updatedBy, IEnumerable<Guid> mediaFilesIds) : IEvent
     {
         public Guid EventId { get; set; } = eventId;

MiniSpace.Services.Events/src/MiniSpace.Services.Events.Application/Events/StudentCancelledInterestInEvent.cs

@@ -1,8 +1,10 @@
 using System;
 using Convey.CQRS.Events;
+using Convey.MessageBrokers;
 
 namespace MiniSpace.Services.Events.Application.Events
 {
+    [Message("notifications")]
     public class StudentCancelledInterestInEvent: IEvent
     {
         public Guid EventId { get; }

MiniSpace.Services.Events/src/MiniSpace.Services.Events.Application/Events/StudentCancelledSignUpToEvent.cs

@@ -1,8 +1,10 @@
 using System;
 using Convey.CQRS.Events;
+using Convey.MessageBrokers;
 
 namespace MiniSpace.Services.Events.Application.Events
 {
+    [Message("notifications")]
     public class StudentCancelledSignUpToEvent: IEvent
     {
         public Guid EventId { get; }