felixfoertsch/bundesmessenger-ios
1
0
Fork 0
mirror of https://gitlab.opencode.de/bwi/bundesmessenger/clients/bundesmessenger-ios.git synced 2026-04-24 18:42:47 +02:00
Code Issues Packages Projects Releases Wiki Activity

Update sequence number associated to chunk file sending

Browse Source
This commit is contained in:
Philippe Loriaux
2022-10-20 14:50:41 +02:00
parent 2359f9b568
commit d5b56f4dc8
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
RiotSwiftUI/Modules/Room/VoiceBroadcastRecorder/Service/VoiceBroadcastRecorderService.swift
+6 -5
View File
@@ -87,7 +87,7 @@ class VoiceBroadcastRecorderService: VoiceBroadcastRecorderServiceProtocol {
self.serviceDelegate?.voiceBroadcastRecorderService(self, didUpdateState: .stopped)
// Send current chunk
self.sendChunkFile(at: self.chunkFile.url)
self.sendChunkFile(at: self.chunkFile.url, sequence: self.chunkFileNumber)
self.session.tearDownVoiceBroadcastService()
}, failure: { error in
@@ -102,7 +102,7 @@ class VoiceBroadcastRecorderService: VoiceBroadcastRecorderServiceProtocol {
guard let self = self else { return }
// Send current chunk
self.sendChunkFile(at: self.chunkFile.url)
self.sendChunkFile(at: self.chunkFile.url, sequence: self.chunkFileNumber)
self.chunkFile = nil
}, failure: { error in
@@ -129,6 +129,7 @@ class VoiceBroadcastRecorderService: VoiceBroadcastRecorderServiceProtocol {
/// Write audio buffer to chunk file.
private func writeBuffer(_ buffer: AVAudioPCMBuffer) {
MXLog.debug("[VoiceBroadcastRecorderService] writeBuffer")
let sampleRate = buffer.format.sampleRate
if chunkFile == nil {
@@ -139,7 +140,7 @@ class VoiceBroadcastRecorderService: VoiceBroadcastRecorderServiceProtocol {
chunkFrames += buffer.frameLength
if chunkFrames > AVAudioFrameCount(Double(BuildSettings.voiceBroadcastChunkLength) * sampleRate) {
sendChunkFile(at: chunkFile.url)
sendChunkFile(at: chunkFile.url, sequence: self.chunkFileNumber)
// Reset chunkFile
chunkFile = nil
}
@@ -175,7 +176,7 @@ class VoiceBroadcastRecorderService: VoiceBroadcastRecorderServiceProtocol {
}
/// Send chunk file to the server.
private func sendChunkFile(at url: URL) {
private func sendChunkFile(at url: URL, sequence: Int) {
guard let voiceBroadcastService = voiceBroadcastService else {
// FIXME: Manage error
return
@@ -205,7 +206,7 @@ class VoiceBroadcastRecorderService: VoiceBroadcastRecorderServiceProtocol {
mimeType: "audio/mp4",
duration: UInt(duration * 1000),
samples: nil,
sequence: UInt(self.chunkFileNumber)) { eventId in
sequence: UInt(sequence)) { eventId in
MXLog.debug("[VoiceBroadcastRecorderService] Send voice broadcast chunk with success.")
if eventId != nil {
self.deleteRecording(at: url)