Add files and push support

c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/ChatEventTests.cs

@@ -28,7 +28,7 @@ public async Task Setup()
     [TearDown]
     public async Task CleanUp()
     {
-        channel.Leave();
+        await channel.Leave();
         await Task.Delay(3000);
         chat.Destroy();
         await Task.Delay(3000);

c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/FilesTests.cs

@@ -0,0 +1,203 @@
+using PubnubApi;
+using PubnubChatApi;
+using Channel = PubnubChatApi.Channel;
+
+namespace PubNubChatApi.Tests;
+
+[TestFixture]
+public class FilesTests
+{
+    private const string FILE_NAME = "fileupload.txt";
+    private const string FILE_LOCATION = @"fileupload.txt";
+    private const string LARGE_FILE_NAME = "file_large.png";
+    private const string LARGE_FILE_LOCATION = @"file_large.png";
+
+    private Chat chat;
+    private Channel channel;
+    private User user;
+
+    [SetUp]
+    public async Task Setup()
+    {
+        chat = TestUtils.AssertOperation(await Chat.CreateInstance(new PubnubChatConfig(),
+            new PNConfiguration(new UserId("file_tests_user"))
+            {
+                PublishKey = PubnubTestsParameters.PublishKey,
+                SubscribeKey = PubnubTestsParameters.SubscribeKey,
+            }));
+        channel = TestUtils.AssertOperation(await chat.CreatePublicConversation("file_tests_channel"));
+        user = TestUtils.AssertOperation(await chat.GetCurrentUser());
+        await channel.Join();
+        await Task.Delay(3500);
+    }
+
+    [TearDown]
+    public async Task CleanUp()
+    {
+        await ClearChannelOfFiles();
+        await channel.Leave();
+        await Task.Delay(3000);
+        chat.Destroy();
+        await Task.Delay(3000);
+    }
+
+    private async Task ClearChannelOfFiles()
+    {
+        var files = await channel.GetFiles();
+        if (files.Error)
+        {
+            Assert.Fail($"Error in files cleanup: {files.Exception.Message}");
+            return;
+        }
+
+        foreach (var file in files.Result.Files)
+        {
+            var result = await channel.DeleteFile(file.Id, file.Name);
+            if (result.Error)
+            {
+                Assert.Fail($"Error in files cleanup: {files.Exception.Message}");
+            }
+        }
+    }
+
+    [Test]
+    public async Task TestFileUploadInMessage()
+    {
+        //Cleanup: delete files from channel
+        await ClearChannelOfFiles();
+
+        await channel.Join();
+        await Task.Delay(250);
+
+        var receivedMessageReset = new ManualResetEvent(false);
+        Message receivedMessage = null;
+        channel.OnMessageReceived += message =>
+        {
+            if (message.MessageText == "FILE")
+            {
+                receivedMessage = message;
+                receivedMessageReset.Set();
+            }
+        };
+
+        //Add file to SendTextParams and send message
+        TestUtils.AssertOperation(await channel.SendText("FILE", new SendTextParams()
+        {
+            Files =
+            [
+                new ChatInputFile()
+                {
+                    Name = FILE_NAME,
+                    Type = "text",
+                    Source = FILE_LOCATION
+                }
+            ]
+        }));
+
+        //Receive message and check message.Files
+        var received = receivedMessageReset.WaitOne(10000);
+        Assert.True(received, "Did not receive message with file at all!");
+        Assert.True(receivedMessage != null, "receivedMessage was null!");
+        Assert.True(receivedMessage.Files != null, "receivedMessage.Files was null!");
+        Assert.True(receivedMessage.Files.Count == 1,
+            $"receivedMessage.Files.Count was {receivedMessage.Files.Count} instead of 1!");
+        var receivedFile = receivedMessage.Files[0];
+        Assert.True(receivedFile.Name == FILE_NAME,
+            $"Expected file name \"the_file\" but got \"{receivedFile.Name}\"");
+        Assert.True(receivedFile.Type == "text", $"Expected file type \"text\" but got \"{receivedFile.Type}\"");
+        Assert.True(!string.IsNullOrEmpty(receivedFile.Id), "File ID is empty");
+        Assert.True(!string.IsNullOrEmpty(receivedFile.Url), "File URL is empty");
+
+        //Check channel.GetFiles() for the file and check if data matches with the one from message.Files
+        var channelFiles = TestUtils.AssertOperation(await channel.GetFiles());
+        Assert.True(
+            channelFiles.Files.Any(x =>
+                x.Id == receivedFile.Id && x.Name == receivedFile.Name && x.Url == receivedFile.Url),
+            "Did not find message file in channel.GetFiles()!");
+    }
+
+    [Test]
+    public async Task TestFileUploadInMessageDraft()
+    {
+        //Cleanup: delete files from channel
+        await ClearChannelOfFiles();
+
+        await channel.Join();
+        await Task.Delay(250);
+
+        var receivedMessageReset = new ManualResetEvent(false);
+        Message receivedMessage = null;
+        channel.OnMessageReceived += message =>
+        {
+            if (message.MessageText == "FILE")
+            {
+                receivedMessage = message;
+                receivedMessageReset.Set();
+            }
+        };
+
+        //Add file to SendTextParams in a MessageDraft and send message
+        var messageDraft = channel.CreateMessageDraft();
+        messageDraft.InsertText(0, "FILE");
+        messageDraft.Files.Add(new ChatInputFile()
+        {
+            Name = FILE_NAME,
+            Type = "text",
+            Source = FILE_LOCATION
+        });
+
+        TestUtils.AssertOperation(await messageDraft.Send());
+
+        //Receive message and check message.Files
+        var received = receivedMessageReset.WaitOne(10000);
+        Assert.True(received, "Did not receive message with file at all!");
+        Assert.True(receivedMessage != null, "receivedMessage was null!");
+        Assert.True(receivedMessage.Files != null, "receivedMessage.Files was null!");
+        Assert.True(receivedMessage.Files.Count == 1,
+            $"receivedMessage.Files.Count was {receivedMessage.Files.Count} instead of 1!");
+        var receivedFile = receivedMessage.Files[0];
+        Assert.True(receivedFile.Name == FILE_NAME,
+            $"Expected file name \"the_file\" but got \"{receivedFile.Name}\"");
+        Assert.True(receivedFile.Type == "text", $"Expected file type \"text\" but got \"{receivedFile.Type}\"");
+        Assert.True(!string.IsNullOrEmpty(receivedFile.Id), "File ID is empty");
+        Assert.True(!string.IsNullOrEmpty(receivedFile.Url), "File URL is empty");
+
+        //Check channel.GetFiles() for the file and check if data matches with the one from message.Files
+        var channelFiles = TestUtils.AssertOperation(await channel.GetFiles());
+        Assert.True(
+            channelFiles.Files.Any(x =>
+                x.Id == receivedFile.Id && x.Name == receivedFile.Name && x.Url == receivedFile.Url),
+            "Did not find message file in channel.GetFiles()!");
+    }
+
+    [Test]
+    public async Task TestFileUploadErrorHandling()
+    {
+        var receivedMessageReset = new ManualResetEvent(false);
+        channel.OnMessageReceived += message =>
+        {
+            if (message.MessageText == "FILE TOO BIG")
+            {
+                receivedMessageReset.Set();
+            }
+        };
+
+        var sendResult = await channel.SendText("FILE TOO BIG", new SendTextParams()
+        {
+            Files =
+            [
+                new ChatInputFile()
+                {
+                    Name = LARGE_FILE_NAME,
+                    Type = "image",
+                    Source = LARGE_FILE_LOCATION
+                }
+            ]
+        });
+        Assert.True(sendResult.Error, "sendResult.Error should be true for file over size limit");
+        Assert.True(sendResult.Exception.Message.Contains("Your proposed upload exceeds the maximum allowed size"), "Error message should contain info about file size");
+
+        var received = receivedMessageReset.WaitOne(5000);
+        Assert.False(received, "SendText should abort and not send message in case of file upload error");
+    }
+}

c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/PubNubChatApi.Tests.csproj

@@ -25,4 +25,13 @@
       <ProjectReference Include="..\PubnubChatApi\PubnubChatApi.csproj" />
     </ItemGroup>
 
+    <ItemGroup>
+      <None Update="file_large.png">
+        <CopyToOutputDirectory>Always</CopyToOutputDirectory>
+      </None>
+      <None Update="fileupload.txt">
+        <CopyToOutputDirectory>Always</CopyToOutputDirectory>
+      </None>
+    </ItemGroup>
+
 </Project>

c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/PushTests.cs

@@ -0,0 +1,80 @@
+using PubnubApi;
+using PubnubChatApi;
+using Channel = PubnubChatApi.Channel;
+
+namespace PubNubChatApi.Tests;
+
+[TestFixture]
+public class PushTests
+{
+    private Chat chat;
+    private Channel channel;
+    private User user;
+
+    [SetUp]
+    public async Task Setup()
+    {
+        chat = TestUtils.AssertOperation(await Chat.CreateInstance(
+            new PubnubChatConfig(pushNotifications: new PubnubChatConfig.PushNotificationsConfig()
+            {
+                APNSEnvironment = PushEnvironment.Development,
+                APNSTopic = "someTopic",
+                DeviceGateway = PNPushType.FCM,
+                DeviceToken = "sometoken",
+                SendPushes = true
+            }),
+            new PNConfiguration(new UserId("push_tests_user"))
+            {
+                PublishKey = PubnubTestsParameters.PublishKey,
+                SubscribeKey = PubnubTestsParameters.SubscribeKey,
+            }));
+        channel = TestUtils.AssertOperation(await chat.CreatePublicConversation("push_tests_channel",
+            new ChatChannelData() { Name = "Push Channels Name" }));
+        user = TestUtils.AssertOperation(await chat.GetCurrentUser());
+        await channel.Join();
+        await Task.Delay(3500);
+    }
+
+    [TearDown]
+    public async Task CleanUp()
+    {
+        await channel.Leave();
+        await Task.Delay(3000);
+        chat.Destroy();
+        await Task.Delay(3000);
+    }
+
+    [Test]
+    public async Task TestAddAndRemovePushChannel()
+    {
+        var res = await channel.RegisterForPush();
+        TestUtils.AssertOperation(res);
+        await Task.Delay(2000);
+        var pushChannels = TestUtils.AssertOperation(await chat.GetPushChannels());
+        Assert.True(pushChannels.Contains(channel.Id), "Push channels don't contain registered channel ID");
+        TestUtils.AssertOperation(await channel.UnRegisterFromPush());
+        await Task.Delay(2000);
+        pushChannels = TestUtils.AssertOperation(await chat.GetPushChannels());
+        Assert.False(pushChannels.Contains(channel.Id), "Push channels contain unregistered channel ID");
+    }
+
+    [Test]
+    public async Task TestRemoveAllPushChannel()
+    {
+        TestUtils.AssertOperation(await channel.RegisterForPush());
+        await Task.Delay(2000);
+        var pushChannels = TestUtils.AssertOperation(await chat.GetPushChannels());
+        Assert.True(pushChannels.Contains(channel.Id), "Push channels don't contain registered channel ID");
+        TestUtils.AssertOperation(await chat.UnRegisterAllPushChannels());
+        pushChannels = TestUtils.AssertOperation(await chat.GetPushChannels());
+        Assert.False(pushChannels.Contains(channel.Id), "Push channels contain unregistered channel ID");
+    }
+
+    [Test]
+    public async Task TestPublishWithPushData()
+    {
+        TestUtils.AssertOperation(await channel.SendText("some_message",
+            new SendTextParams()
+                { CustomPushData = new Dictionary<string, string>() { { "some_key", "some_value" } } }));
+    }
+}

c-sharp-chat/PubnubChatApi/PubNubChatApi.Tests/fileupload.txt

@@ -0,0 +1 @@
+This is the file to be uploaded for testing.