Added test for sendFile

Author: marcin-cebo

pubnub-kotlin/pubnub-kotlin-api/src/appleTest/kotlin/com/pubnub/kmp/platform.ios.kt

@@ -1,3 +1,22 @@
 package com.pubnub.kmp
 
+import kotlinx.cinterop.ExperimentalForeignApi
+import kotlinx.cinterop.addressOf
+import kotlinx.cinterop.usePinned
+import platform.Foundation.NSData
+import platform.Foundation.dataWithBytes
+
 internal actual val PLATFORM: String = "iOS"
+
+@OptIn(ExperimentalForeignApi::class)
+internal actual fun stringToUploadable(content: String, contentType: String?): Uploadable {
+    val byteArray = content.encodeToByteArray()
+    val nsData = byteArray.usePinned {
+        NSData.dataWithBytes(it.addressOf(0), byteArray.size.toULong())
+    }
+    return DataUploadContent(nsData, contentType)
+}
+
+internal actual fun readAllBytes(stream: Any?): ByteArray {
+    TODO("Not yet implemented")
+}

pubnub-kotlin/pubnub-kotlin-api/src/commonTest/kotlin/com/pubnub/kmp/platform.kt

@@ -1,3 +1,7 @@
 package com.pubnub.kmp
 
 internal expect val PLATFORM: String
+
+internal expect fun stringToUploadable(content: String, contentType: String? = null): Uploadable
+
+internal expect fun readAllBytes(stream: Any?): ByteArray

pubnub-kotlin/pubnub-kotlin-api/src/commonTest/kotlin/com/pubnub/test/integration/ChannelMetadataTest.kt

@@ -6,7 +6,10 @@ import com.pubnub.api.models.consumer.objects.channel.PNChannelMetadata
 import com.pubnub.api.models.consumer.pubsub.objects.PNDeleteChannelMetadataEventMessage
 import com.pubnub.api.models.consumer.pubsub.objects.PNObjectEventResult
 import com.pubnub.api.models.consumer.pubsub.objects.PNSetChannelMetadataEventMessage
+import com.pubnub.kmp.PLATFORM
 import com.pubnub.kmp.createCustomObject
+import com.pubnub.kmp.readAllBytes
+import com.pubnub.kmp.stringToUploadable
 import com.pubnub.test.BaseIntegrationTest
 import com.pubnub.test.await
 import com.pubnub.test.randomString
@@ -52,6 +55,51 @@ class ChannelMetadataTest : BaseIntegrationTest() {
         assertEquals(description, pnuuidMetadata.description?.value)
     }
 
+    @Test
+    fun can_send_file_downloadFile() = runTest {
+        if (PLATFORM == "JS" || PLATFORM == "iOS") { // todo enable for JS/iOS once is implemented
+            return@runTest
+        }
+        val fileName = "test.txt"
+        val fileContent = "Hello, World!"
+        // Upload file
+        val uploadResult = pubnub.sendFile(
+            channel = channel,
+            fileName = fileName,
+            inputStream = stringToUploadable(fileContent, "text/plain"),
+            message = "Test file upload",
+            customMessageType = "somethingCustom"
+        ).await()
+
+        // Assert upload result
+        assertNotNull(uploadResult)
+        assertEquals(fileName, uploadResult.file.name)
+        assertTrue(uploadResult.file.id.isNotBlank())
+
+        // Download file
+        val downloadResult = pubnub.downloadFile(
+            channel = channel,
+            fileName = uploadResult.file.name,
+            fileId = uploadResult.file.id,
+            cipherKey = null
+        ).await()
+
+        assertNotNull(downloadResult)
+        assertEquals(fileName, downloadResult.fileName)
+        assertNotNull(downloadResult.byteStream)
+        val downloadedBytes = readAllBytes(downloadResult.byteStream)
+        val downloadedContent = downloadedBytes.decodeToString()
+        assertEquals(fileContent, downloadedContent)
+
+        // Delete file
+        val deleteResult = pubnub.deleteFile(
+            channel = channel,
+            fileName = uploadResult.file.name,
+            fileId = uploadResult.file.id
+        ).await()
+        assertEquals(200, deleteResult.status)
+    }
+
     @Test
     fun set_metadata_ifMatch_allows_change() = runTest {
         // given
@@ -97,7 +145,8 @@ class ChannelMetadataTest : BaseIntegrationTest() {
 
         // when
         val ex = assertFailsWith<PubNubException> {
-            pubnub.setChannelMetadata(channel, status = "someNewStatus", ifMatchesEtag = pnChannelMetadata.eTag?.value).await()
+            pubnub.setChannelMetadata(channel, status = "someNewStatus", ifMatchesEtag = pnChannelMetadata.eTag?.value)
+                .await()
         }
 
         // then

pubnub-kotlin/pubnub-kotlin-api/src/jsTest/kotlin/com/pubnub/kmp/platform.js.kt

@@ -1,3 +1,10 @@
 package com.pubnub.kmp
 
 internal actual val PLATFORM: String = "JS"
+
+internal actual fun stringToUploadable(content: String, contentType: String?): Uploadable =
+    UploadableImpl(content)
+
+internal actual fun readAllBytes(stream: Any?): ByteArray {
+    TODO("Not yet implemented")
+}

pubnub-kotlin/pubnub-kotlin-api/src/jvmTest/kotlin/com/pubnub/kmp/platform.jvm.kt

@@ -1,3 +1,13 @@
 package com.pubnub.kmp
 
+import java.io.ByteArrayInputStream
+import java.io.InputStream
+
 internal actual val PLATFORM: String = "JVM"
+
+internal actual fun stringToUploadable(content: String, contentType: String?): Uploadable =
+    ByteArrayInputStream(content.toByteArray())
+
+internal actual fun readAllBytes(stream: Any?): ByteArray {
+    return (stream as InputStream).readBytes()
+}