add rtmp opus tests

Author: pedroSG94

app/src/main/java/com/pedro/streamer/rotation/CameraFragment.kt

@@ -86,7 +86,7 @@ class CameraFragment: Fragment(), ConnectChecker {
   val height = 480
   val vBitrate = 1200 * 1000
   private var rotation = 0
-  private val sampleRate = 48000
+  private val sampleRate = 32000
   private val isStereo = true
   private val aBitrate = 128 * 1000
   private var recordPath = ""
@@ -205,7 +205,7 @@ class CameraFragment: Fragment(), ConnectChecker {
 
   override fun onConnectionFailed(reason: String) {
     if (genericStream.getStreamClient().reTry(5000, reason, null)) {
-      toast("Retry, $reason")
+      toast("Retry")
     } else {
       genericStream.stopStream()
       bStartStop.setImageResource(R.drawable.stream_icon)

rtmp/src/main/java/com/pedro/rtmp/flv/audio/config/OpusAudioSpecificConfig.kt

@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2024 pedroSG94.
+ * Copyright (C) 2025 pedroSG94.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

rtmp/src/main/java/com/pedro/rtmp/flv/audio/packet/OpusPacket.kt

@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2024 pedroSG94.
+ * Copyright (C) 2025 pedroSG94.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

rtmp/src/test/java/com/pedro/rtmp/flv/audio/AacPacketTest.kt

@@ -30,7 +30,7 @@ import java.nio.ByteBuffer
 class AacPacketTest {
 
   @Test
-  fun `GIVEN a aac buffer WHEN call create a aac packet 2 times THEN return config and expected buffer`() = runTest {
+  fun `GIVEN an AAC buffer WHEN call create an AAC packet 2 times THEN return config and expected buffer`() = runTest {
     val timestamp = 123456789L
     val buffer = ByteArray(256) { 0x00 }
     val info = MediaFrame.Info(0, buffer.size, timestamp, false)

rtmp/src/test/java/com/pedro/rtmp/flv/audio/AudioConfigTest.kt

@@ -17,13 +17,14 @@
 package com.pedro.rtmp.flv.audio
 
 import com.pedro.rtmp.flv.audio.config.AacAudioSpecificConfig
+import com.pedro.rtmp.flv.audio.config.OpusAudioSpecificConfig
 import org.junit.Assert.assertArrayEquals
 import org.junit.Test
 
 class AudioConfigTest {
 
   @Test
-  fun `GIVEN sps and pps WHEN create a video config for sequence packet THEN return a bytearray with the config`() {
+  fun `GIVEN objectType, sampleRate and channels WHEN create an AAC audio config for sequence packet THEN return a bytearray with the config`() {
     val sampleRate = 44100
     val isStereo = true
     val objectType = AudioObjectType.AAC_LC
@@ -34,4 +35,16 @@ class AudioConfigTest {
     config.write(data, 0)
     assertArrayEquals(expectedConfig, data)
   }
+
+  @Test
+  fun `GIVEN sampleRate and channels WHEN create an Opus audio config for sequence packet THEN return a bytearray with the config`() {
+    val sampleRate = 48000
+    val isStereo = true
+    val expectedConfig = byteArrayOf(79, 112, 117, 115, 72, 101, 97, 100, 1, 2, 15, 0, 0, 0, -69, -128, 0, 0, 0)
+
+    val config = OpusAudioSpecificConfig(sampleRate, if (isStereo) 2 else 1)
+    val data = ByteArray(config.size)
+    config.write(data, 0)
+    assertArrayEquals(expectedConfig, data)
+  }
 }

rtmp/src/test/java/com/pedro/rtmp/flv/audio/OpusPacketTest.kt

@@ -0,0 +1,51 @@
+/*
+ * Copyright (C) 2024 pedroSG94.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.pedro.rtmp.flv.audio
+
+import com.pedro.common.frame.MediaFrame
+import com.pedro.rtmp.flv.FlvType
+import com.pedro.rtmp.flv.audio.packet.OpusPacket
+import kotlinx.coroutines.test.runTest
+import org.junit.Assert.assertEquals
+import org.junit.Test
+import java.nio.ByteBuffer
+
+/**
+ * Created by pedro on 9/9/23.
+ */
+class OpusPacketTest {
+
+  @Test
+  fun `GIVEN an Opus buffer WHEN call create an Opus packet 2 times THEN return config and expected buffer`() = runTest {
+    val timestamp = 123456789L
+    val buffer = ByteArray(256) { 0x00 }
+    val info = MediaFrame.Info(0, buffer.size, timestamp, false)
+    val mediaFrame = MediaFrame(ByteBuffer.wrap(buffer), info, MediaFrame.Type.AUDIO)
+    val opusPacket = OpusPacket()
+    opusPacket.sendAudioInfo(48000, true)
+    opusPacket.createFlvPacket(mediaFrame) { flvPacket ->
+      assertEquals(FlvType.AUDIO, flvPacket.type)
+      assertEquals(((AudioFormat.EX_HEADER.value shl 4) or (AudioFourCCPacketType.SEQUENCE_START.value and 0x0F)).toByte(), flvPacket.buffer[0])
+      assertEquals(5 + 19, flvPacket.length)
+    }
+    opusPacket.createFlvPacket(mediaFrame) { flvPacket ->
+      assertEquals(FlvType.AUDIO, flvPacket.type)
+      assertEquals(((AudioFormat.EX_HEADER.value shl 4) or (AudioFourCCPacketType.CODED_FRAMES.value and 0x0F)).toByte(), flvPacket.buffer[0])
+      assertEquals(5 + buffer.size, flvPacket.length)
+    }
+  }
+}