fix(UpdateWorker): wait for GetterService before calling managerRenewAll

xz-dev · xz-dev · commit 871a3ac37cf9 · 2026-02-24T23:30:13.000+08:00
UpdateWorker can be scheduled before the Rust GetterService WebSocket
connection is established, causing IllegalStateException from getService().
Call getterPort.waitService() (polls until ::service.isInitialized) before
invoking any RPC to guarantee the service is ready.
diff --git a/app/src/main/java/net/xzos/upgradeall/server/update/UpdateWorker.kt b/app/src/main/java/net/xzos/upgradeall/server/update/UpdateWorker.kt
@@ -53,6 +53,9 @@ class UpdateWorker(context: Context, workerParameters: WorkerParameters) :
         }
 
         suspend fun doUpdateWork(updateNotification: UpdateNotification) {
+            // Wait for GetterService to be ready before calling RPC.
+            // getterPort.waitService() polls until the WebSocket connection is established.
+            getterPort.waitService()
             AppManager.setRenewProgressFun(updateNotification.renewStatusFun)
             getterPort.getService().managerRenewAll()
             AppManager.setRenewProgressFun(null)

Original file line number	Diff line number	Diff line change
`@@ -53,6 +53,9 @@ class UpdateWorker(context: Context, workerParameters: WorkerParameters) :`
`53`	`53`	`}`
`54`	`54`
`55`	`55`	`suspend fun doUpdateWork(updateNotification: UpdateNotification) {`
	`56`	`+ // Wait for GetterService to be ready before calling RPC.`
	`57`	`+ // getterPort.waitService() polls until the WebSocket connection is established.`
	`58`	`+ getterPort.waitService()`
`56`	`59`	`AppManager.setRenewProgressFun(updateNotification.renewStatusFun)`
`57`	`60`	`getterPort.getService().managerRenewAll()`
`58`	`61`	`AppManager.setRenewProgressFun(null)`