hailin
/
rwadurian
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(android): simplify keygen join to match Electron behavior exactly 

Removed polling fallback and simplified to match Electron's design:
- If joinSession returns sessionStatus="in_progress", trigger keygen immediately
- Otherwise wait for session_started gRPC event

Added debug log to show sessionStatus value for troubleshooting.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
hailin 2026-01-01 08:14:26 -08:00
parent 50cb10d6a8
commit d90c722c7d
1 changed files with 6 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
backend/mpc-system/services/service-party-android/app/src/main/java/com/durian/tssparty/presentation/viewmodel/MainViewModel.kt
View File

@ -498,36 +498,15 @@ class MainViewModel @Inject constructor(
_uiState.update { it.copy(isLoading = false) }
// If session is already in_progress, trigger keygen immediately (Solution B from Electron)
// Match Electron behavior exactly:
// If session is already in_progress, trigger keygen immediately
// Otherwise wait for session_started event from gRPC subscription
android.util.Log.d("MainViewModel", "Join result sessionStatus: ${joinResult.sessionStatus}")
if (joinResult.sessionStatus == "in_progress") {
android.util.Log.d("MainViewModel", "Session already in_progress, triggering keygen immediately")
android.util.Log.d("MainViewModel", "Session already in_progress, triggering keygen immediately (Solution B)")
startKeygenAsJoiner()
} else {
// Otherwise, wait for session_started event
// But also poll session status immediately and after delays in case we missed the event
// This handles the race condition where session_started is sent before we're ready
// The last joiner triggers session_started but can't receive it themselves
viewModelScope.launch {
// Poll multiple times with short delays
for (attempt in 1..5) {
delay(500) // Check every 500ms
val joinInfo = pendingJoinKeygenInfo
if (joinInfo == null || joinInfo.sessionId != sessionInfo.sessionId) {
android.util.Log.d("MainViewModel", "Polling cancelled - keygen already started or session changed")
break
}
android.util.Log.d("MainViewModel", "Polling session status (attempt $attempt)...")
val statusResult = repository.getSessionStatus(sessionInfo.sessionId)
statusResult.onSuccess { status ->
if (status.status == "in_progress" && pendingJoinKeygenInfo != null) {
android.util.Log.d("MainViewModel", "Session is now in_progress (detected via polling attempt $attempt), triggering keygen")
startKeygenAsJoiner()
}
}
// If keygen was triggered, break out of loop
if (pendingJoinKeygenInfo == null) break
}
}
android.util.Log.d("MainViewModel", "Joined session ${sessionInfo.sessionId}, waiting for session_started event")
}
},
onFailure = { e ->