Skip to content

Commit a58efac

Browse files
committed
handle auth callbacks
1 parent 069d58a commit a58efac

2 files changed

Lines changed: 14 additions & 2 deletions

File tree

whip/src/main/java/com/pedro/whip/WhipClient.kt

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -229,7 +229,18 @@ class WhipClient(private val connectChecker: ConnectChecker) {
229229
Log.i(TAG, "found ${localCandidates.size} candidates")
230230
val offerResponse = commandsManager.writeOffer()
231231
Log.i(TAG, offerResponse.body)
232-
232+
if (offerResponse.statusCode !in 200..299) {
233+
if (offerResponse.statusCode == 401 || offerResponse.statusCode == 403) {
234+
onMainThread { connectChecker.onAuthError() }
235+
} else {
236+
onMainThread {
237+
connectChecker.onConnectionFailed("Write offer failed: ${offerResponse.statusCode}")
238+
}
239+
}
240+
return@launch
241+
} else if (commandsManager.authEnabled()) {
242+
onMainThread { connectChecker.onAuthSuccess() }
243+
}
233244

234245
val localFrag = commandsManager.localSdpInfo?.uFrag ?: return@launch
235246
val remoteFrag = commandsManager.remoteSdpInfo?.uFrag ?: return@launch
@@ -495,5 +506,4 @@ class WhipClient(private val connectChecker: ConnectChecker) {
495506
whipSender.resetBytesSend()
496507
}
497508

498-
499509
}

whip/src/main/java/com/pedro/whip/webrtc/CommandsManager.kt

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -351,4 +351,6 @@ class CommandsManager {
351351
fun generateTransactionId(): ByteArray {
352352
return secureRandom.nextBytes(12)
353353
}
354+
355+
fun authEnabled(): Boolean = token != null
354356
}

0 commit comments

Comments
 (0)