Feature/workflowgroups

.gitignore

@@ -6,3 +6,4 @@ bin
 obj
 .DS_STORE
 src/Novu.sln.DotSettings.user
+**/.vs

README.md

@@ -355,6 +355,24 @@ var result = await client.Topic.RenameTopicAsync("my-topic", topicRequest);
 
 ```
 
+## WorkflowGroups
+
+```csharp
+...
+Using Novu.DTO.WorkflowGroup
+
+// Create a new Workflow group
+var request = new WorkflowGroupDto
+{
+    WorkflowGroupName = "<name of workflow group to be created>"
+}
+
+var response = await client.WorkflowGroup.CreateWorkflowGroup(request);
+
+
+// Get All Workflow groups
+var response = await client.WorkflowGroup.GetWorkflowGroups();
+```
 
 ## Repository Overview
 

src/Novu.Tests/Novu.Tests.csproj

@@ -1,4 +1,4 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
 
     <PropertyGroup>
         <TargetFramework>net7.0</TargetFramework>

src/Novu.Tests/WorkflowGroups/WorkflowGroupFixture.cs

@@ -0,0 +1,26 @@
+using Novu.Models;
+
+namespace Novu.Tests.WorkflowGroups
+{
+    public class WorkflowGroupFixture : IDisposable
+    {
+        public NovuClient NovuClient { get; }
+
+        public WorkflowGroupFixture()
+        {
+            var novuConfiguration = new NovuClientConfiguration
+            {
+                ApiKey = Environment.GetEnvironmentVariable("NOVU_API_KEY") ?? throw new InvalidOperationException(),
+            };
+            var novu = new NovuClient(novuConfiguration);
+
+            NovuClient = novu;
+        }
+
+        public async void Dispose()
+        {
+            //Delete resources created
+        }
+
+    }
+}

src/Novu.Tests/WorkflowGroups/WorkflowGroupUnitTests.cs

@@ -0,0 +1,40 @@
+using Novu.DTO.WorkflowGroup;
+
+namespace Novu.Tests.WorkflowGroups
+{
+    public class WorkflowGroupUnitTests
+    {
+        public readonly WorkflowGroupFixture _fixture;
+
+        public WorkflowGroupUnitTests(WorkflowGroupFixture fixture)
+        {
+            _fixture = fixture;
+        }
+
+        [Fact]
+        public async void Should_Create_WorkflowGroup()
+        {
+            var client = _fixture.NovuClient;
+
+            var requestBody = new WorkflowGroupDto
+            {
+                WorkflowGroupName = "workflowGroup123"
+            };
+
+            var workflowGroup = await client.WorkflowGroup.CreateWorkflowGroup(requestBody);
+
+            Assert.Equal(requestBody.WorkflowGroupName, workflowGroup.PayloadDto.Name);
+        }
+
+        [Fact]
+        public async void Should_Return_WorkflowGroup_List()
+        {
+            var client = _fixture.NovuClient;
+
+            var listOfWorkflowGroups = await client.WorkflowGroup.GetWorkflowGroups();
+
+            Assert.NotNull(listOfWorkflowGroups);
+            Assert.NotEmpty(listOfWorkflowGroups.PayloadDtos);
+        }
+    }
+}

src/Novu/DTO/WorkflowGroup/WorkflowGroupDto.cs

@@ -0,0 +1,10 @@
+using Newtonsoft.Json;
+
+namespace Novu.DTO.WorkflowGroup
+{
+    public class WorkflowGroupDto
+    {
+        [JsonProperty("name")]
+        public string WorkflowGroupName { get; set; }
+    }
+}

src/Novu/DTO/WorkflowGroup/WorkflowGroupResponsePayloadDto.cs

@@ -0,0 +1,30 @@
+using Newtonsoft.Json;
+
+namespace Novu.DTO.WorkflowGroup
+{
+    public class WorkflowGroupResponsePayloadDto
+    {
+        [JsonProperty("_id")]
+        public string Id { get; set; }
+        [JsonProperty("name")]
+        public string Name { get; set; }
+        [JsonProperty("_environmentId")]
+        public string EnvironmentId { get; set; }
+        [JsonProperty("_organizationId")]
+        public string OrganizationId { get; set; }
+        [JsonProperty("_parentId")]
+        public string ParentId { get; set; }
+    }
+
+    public class WorkflowGroupSingleResponseDto
+    {
+        [JsonProperty("data")]
+        public WorkflowGroupResponsePayloadDto PayloadDto { get; set; }
+    }
+
+    public class WorkflowGroupBulkResponseDto
+    {
+        [JsonProperty("data")]
+        public List<WorkflowGroupResponsePayloadDto> PayloadDtos { get; set; }
+    }
+}

src/Novu/Interfaces/INovuClient.cs

@@ -11,4 +11,5 @@ public interface INovuClient
 
     public ITopicClient Topic { get; }
     public INotificationTemplatesClient NotificationTemplates { get; }
+    public IWorkflowGroupClient WorkflowGroup { get; }
 }

src/Novu/Interfaces/IWorkflowGroupClient.cs

@@ -0,0 +1,26 @@
+using Novu.DTO.WorkflowGroup;
+using Refit;
+
+namespace Novu.Interfaces
+{
+    public interface IWorkflowGroupClient
+    {
+        /// <summary>
+        /// Create a Workflow Group
+        /// </summary>
+        /// <param name="requestBody"></param>
+        /// <returns>
+        /// <see cref="WorkflowGroupSingleResponseDto"/> - The created workflow group
+        /// </returns>
+        [Post("/notification-groups")]
+        public Task<WorkflowGroupSingleResponseDto> CreateWorkflowGroup([Body] WorkflowGroupDto requestBody);
+        /// <summary>
+        /// Get All Workflow Groups
+        /// </summary>
+        /// <returns>
+        /// <see cref="WorkflowGroupBulkResponseDto"/> - List of workflow groups
+        /// </returns>
+        [Get("/notification-groups")]
+        public Task<WorkflowGroupBulkResponseDto> GetWorkflowGroups();
+    }
+}

src/Novu/Novu.csproj

@@ -1,4 +1,4 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
 
     <!-- General Settings -->
     <PropertyGroup>

src/Novu/NovuClient.cs

@@ -41,6 +41,10 @@ public NovuClient(INovuClientConfiguration configuration,HttpClient? client = de
         {
             ContentSerializer = new NewtonsoftJsonContentSerializer(SerializerSettings)
         });
+        WorkflowGroup = RestService.For<IWorkflowGroupClient>(httpClient, new RefitSettings
+        {   
+            ContentSerializer = new NewtonsoftJsonContentSerializer(SerializerSettings)
+        });
     }
 
     public ISubscriberClient Subscriber { get; }
@@ -49,4 +53,5 @@ public NovuClient(INovuClientConfiguration configuration,HttpClient? client = de
 
     public ITopicClient Topic { get; }
     public INotificationTemplatesClient NotificationTemplates { get; }
+    public IWorkflowGroupClient WorkflowGroup { get; }
 }