Fixed some class types for V2, and added test for new method SearchRoom.

Author: jpfigueiras

src/SymphonyOSS.RestApiClient/Api/AgentApi/DatafeedApi.cs

@@ -114,7 +114,7 @@ public void Stop()
             _shouldStop = true;
         }
 
-        private async void NotifyAsync(EventHandler<MessageEventArgs> messageEventHandler, MessageList messageList)
+        private async void NotifyAsync(EventHandler<MessageEventArgs> messageEventHandler, V2MessageList messageList)
         {
             // Notify each handler in a separate task, maintaining the order of messages in the list, and
             // get back to reading the data feed again without waiting for listeners to process messages.
@@ -126,7 +126,7 @@ private async void NotifyAsync(EventHandler<MessageEventArgs> messageEventHandle
             _tasks[messageEventHandler] = Task.Run(() => Notify(messageEventHandler, messageList));
         }
 
-        private void Notify(EventHandler<MessageEventArgs> messageEventHandler, MessageList messageList)
+        private void Notify(EventHandler<MessageEventArgs> messageEventHandler, V2MessageList messageList)
         {
             foreach (var message in messageList)
             {

src/SymphonyOSS.RestApiClient/Api/AgentApi/MessageEventArgs.cs

@@ -25,11 +25,11 @@ namespace SymphonyOSS.RestApiClient.Api.AgentApi
     /// </summary>
     public class MessageEventArgs : EventArgs
     {
-        public MessageEventArgs(Message message)
+        public MessageEventArgs(V2BaseMessage message)
         {
             Message = message;
         }
 
-        public Message Message { get; private set; }
+        public V2BaseMessage Message { get; private set; }
     }
 }

test/SymphonyOSS.RestApiClient.Tests/StreamsApiTest.cs

@@ -52,9 +52,9 @@ public void EnsureCreateStream_uses_retry_strategy()
         [Fact]
         public void EnsureCreateRoom_uses_retry_strategy()
         {
-            var payload = new RoomCreate();
+            var payload = new V2RoomAttributes();
             _streamsApi.CreateRoom(payload);
-            _apiExecutorMock.Verify(obj => obj.Execute(It.IsAny<Func<RoomCreate, string, RoomDetail>>(), payload, "sessionToken"));
+            _apiExecutorMock.Verify(obj => obj.Execute(It.IsAny<Func<V2RoomAttributes, string, RoomDetail>>(), payload, "sessionToken"));
         }
 
         [Fact]
@@ -78,9 +78,19 @@ public void EnsureSetRoomActive_uses_retry_strategy()
         public void EnsureUpdateRoom_uses_retry_strategy()
         {
             const string id = "id";
-            var payload = new RoomAttributes();
+            var payload = new V2RoomAttributes();
             _streamsApi.UpdateRoom(id, payload);
-            _apiExecutorMock.Verify(obj => obj.Execute(It.IsAny<Func<string, RoomAttributes, string, RoomDetail>>(), id, payload, "sessionToken"));
+            _apiExecutorMock.Verify(obj => obj.Execute(It.IsAny<Func<string, V2RoomAttributes, string, RoomDetail>>(), id, payload, "sessionToken"));
+        }
+
+        [Fact]
+        public void EnsureSearchRoom_uses_retry_strategy()
+        {
+            var searchCriteria = new RoomSearchCriteria();
+            int? skip = 0;
+            int? limit = null;
+            _streamsApi.SearchRoom(searchCriteria);
+            _apiExecutorMock.Verify(obj => obj.Execute(It.IsAny<Func<string, RoomSearchCriteria, int?, int?, RoomSearchResults>>(), "sessionToken", searchCriteria, skip, limit));
         }
 
     }