Replaced RestSharp with Refit

src/Novu.Tests/Events/EventUnitTest.cs

@@ -59,18 +59,18 @@
             new()
             {
                 EventName = "test",
                 To = { SubscriberId = subscriber.SubscriberId},
                 Payload = new TestRecord(){ Message = "Hello"}
             },
             new()
             {
                 EventName = "test",
                 To = { SubscriberId = subscriber.SubscriberId},
                 Payload = new TestRecord(){ Message = "World"}
             },
         };
 
-        var trigger = await client.Event.TriggerBulkAsync(payload);
+        var trigger = await client.Event.TriggerBulkAsync(new SendBulkRequest(payload));
 
         if (trigger.PayloadDtos.Count != 2)
         {
@@ -97,16 +97,8 @@
         };
 
         if (subscriber.SubscriberId == null) throw new Exception("Subscriber Id is null");
-
-        var dto = new EventTriggerDataDto()
-        {
-            EventName = "test",
-            To =
-            {
-                SubscriberId = subscriber.SubscriberId
-            },
-            Payload = testRecord
-        };
+
+        var dto = new BroadcastMessageRequest("test", testRecord, default);
 
         var trigger = await client.Event.TriggerBroadcastAsync(dto);
 
@@ -129,16 +121,8 @@
         };
 
         if (subscriber.SubscriberId == null) throw new Exception("Subscriber Id is null");
-
-        var dto = new EventTriggerDataDto()
-        {
-            EventName = "test",
-            To =
-            {
-                SubscriberId = subscriber.SubscriberId
-            },
-            Payload = testRecord
-        };
+
+        var dto = new BroadcastMessageRequest("test", testRecord, default);
 
         var trigger = await client.Event.TriggerBroadcastAsync(dto);
 
@@ -185,4 +169,4 @@
 public record TestRecord
 {
     [JsonProperty("message")]
     public string Message { get; set; }

src/Novu.Tests/Subscribers/SubscriberUnitTest.cs

@@ -21,7 +21,7 @@
 
     // Clean up
 
     await _fixture.NovuClient.Subscriber.DeleteSubscriber(subscriber.SubscriberId);
   }
 
   [Fact]
@@ -41,7 +41,7 @@
   public async void Should_Get_One_Subscriber()
   {
     var testSub = await _fixture.GenerateTestSubscriber();
     var subscriber = await _fixture.NovuClient.Subscriber.GetSubscriber(testSub.SubscriberId);
 
     Assert.Equal(subscriber.SubscriberId, testSub.SubscriberId);
   }
@@ -54,7 +54,7 @@
     subToUpdate.FirstName = "Updated";
     subToUpdate.LastName = "Subscriber";
 
-    var updatedSub = await _fixture.NovuClient.Subscriber.UpdateSubscriber(subToUpdate);
+    var updatedSub = await _fixture.NovuClient.Subscriber.UpdateSubscriber(subToUpdate.SubscriberId!, subToUpdate);
 
     // Check to make sure fields changed
     Assert.Equal(updatedSub.FirstName, subToUpdate.FirstName);
@@ -68,7 +68,7 @@
   public async void Should_Delete_Subscriber()
   {
     var subscriber = await _fixture.GenerateTestSubscriber();
-    var deleteResponse = await _fixture.NovuClient.Subscriber.DeleteSubscriber(subscriber.SubscriberId);
+    var deleteResponse = await _fixture.NovuClient.Subscriber.DeleteSubscriber(subscriber.SubscriberId!);
 
     Assert.True(deleteResponse.Data.Acknowledged);
   }
@@ -77,13 +77,11 @@
   public async void Should_Update_Online_Status()
   {
     var subscriber = await _fixture.GenerateTestSubscriber();
-    var updateResponse = await _fixture.NovuClient.Subscriber.UpdateOnlineStatus(subscriber.SubscriberId, new SubscriberOnlineDto
+    var updateResponse = await _fixture.NovuClient.Subscriber.UpdateOnlineStatus(subscriber.SubscriberId!, new SubscriberOnlineDto
     {
       IsOnline = true
     });
 
     Assert.True(updateResponse.IsOnline);
   }
-
-
 }

src/Novu.Tests/Topics/TopicUnitTest.cs

@@ -37,25 +37,22 @@
         var topicRequest = new TopicCreateDto
         {
             Key = $"test:topic:{Guid.NewGuid().ToString()}",
-            Name = "Test Topic",
-
+            Name = "Test Topic"
         };
-
+        var subscriber = await client.Subscriber.CreateSubscriber(new CreateSubscriberDto()
+        {
+            SubscriberId = "test:subscriber:1",
+            Email = "noreply@novu.com"
+        });
         var topic = await client.Topic.CreateTopicAsync(topicRequest);
 
-        var subscriberList = new TopicSubscriberUpdateDto
-        {
-            Keys = new List<string>
-            {
-                "test:subscriber:1",
-            }
-        };
+        var subscriberList = new TopicSubscriberUpdateDto(new() {"test:subscriber:1" });
 
         var result = await client.Topic.AddSubscriberAsync(topic.Data.Key, subscriberList);
 
         Assert.Single(result.Data.Succeeded);
 
-        Assert.Contains(subscriberList.Keys, x => x == result.Data.Succeeded.First());
+        Assert.Contains(subscriberList.Subscribers, x => x == result.Data.Succeeded.First());
     }
 
     [Fact]
@@ -80,39 +77,35 @@
             Key = $"test:topic:{Guid.NewGuid().ToString()}",
             Name = "Test Topic - Should_Validate_Topic_Subscriber",
         });
-
-        var subscriberList = new TopicSubscriberUpdateDto
+        var subscriber = await client.Subscriber.CreateSubscriber(new CreateSubscriberDto()
         {
-            Keys = new List<string>
-            {
-                "test:subscriber:1",
-            }
-        };
-
+            SubscriberId = "test:subscriber:1",
+        });
+        var subscriberList = new TopicSubscriberUpdateDto(new() { "test:subscriber:1" });
+
         await client.Topic.AddSubscriberAsync(topic.Data.Key, subscriberList);
 
-        await client.Topic.VerifySubscriberAsync(topic.Data.Key, subscriberList.Keys.First());
+        await client.Topic.VerifySubscriberAsync(topic.Data.Key, subscriberList.Subscribers.First());
     }
 
     [Fact]
     public async void Should_Remove_Subscriber_From_Topic()
     {
         var client = _fixture.NovuClient;
 
+        var subscriber = await client.Subscriber.CreateSubscriber(new CreateSubscriberDto()
+        {
+            SubscriberId = "test:subscriber:1",
+            Email = "noreply@novu.com"
+        });
         var topic = await client.Topic.CreateTopicAsync(new TopicCreateDto
         {
             Key = $"test:topic:{Guid.NewGuid().ToString()}",
             Name = "Test Topic - Should_Validate_Topic_Subscriber",
         });
-
-        var subscriberList = new TopicSubscriberUpdateDto
-        {
-            Keys = new List<string>
-            {
-                "test:subscriber:1",
-            }
-        };
-
+
+        var subscriberList = new TopicSubscriberUpdateDto(new() {subscriber.SubscriberId });
+
         await client.Topic.AddSubscriberAsync(topic.Data.Key, subscriberList);
 
         await client.Topic.RemoveSubscriberAsync(topic.Data.Key, subscriberList);
@@ -161,7 +154,7 @@
 
         var newTopicName = $"test:topic-rename:{Guid.NewGuid().ToString()}";
 
-        var result = await client.Topic.RenameTopicAsync(topic.Data.Key, newTopicName);
+        var result = await client.Topic.RenameTopicAsync(topic.Data.Key, new RenameTopicRequest(newTopicName));
 
         Assert.Equal(newTopicName, result.Data.Name);
     }