Fix login race condition and JWT FAIL_UNAUTHORIZED blocking callers

1. Make non-suspend login()/logout() block the caller via runBlocking
   instead of fire-and-forget (Thread/suspendifyOnIO), restoring pre-5.3
   behavior so tags target the correct user after each login.

2. Wake enqueueAndWait waiters on FAIL_UNAUTHORIZED and FAIL_PAUSE_OPREPO
   before re-queuing operations. Re-queued items use waiter=null so future
   retries don't reference stale waiters. This prevents loginSuspend from
   hanging forever when a JWT is invalid or the op repo pauses.

Fixes SDK-4338

Made-with: Cursor

Author: AR Abdul Azeez

OneSignalSDK/onesignal/core/src/main/java/com/onesignal/core/internal/operations/impl/OperationRepo.kt

@@ -288,8 +288,11 @@ internal class OperationRepo(
                     if (externalId != null) {
                         _jwtTokenStore.invalidateJwt(externalId)
                         Logging.warn("Operation execution failed with 401 Unauthorized, JWT invalidated for user: $externalId. Operations re-queued.")
+                        ops.forEach { it.waiter?.wake(false) }
                         synchronized(queue) {
-                            ops.reversed().forEach { queue.add(0, it) }
+                            ops.reversed().forEach {
+                                queue.add(0, OperationQueueItem(it.operation, waiter = null, bucket = it.bucket, retries = it.retries))
+                            }
                         }
                         dispatchJwtInvalidatedToApp(externalId)
                     } else {
@@ -331,9 +334,12 @@ internal class OperationRepo(
                     Logging.error("Operation execution failed with eventual retry, pausing the operation repo: $operations")
                     // keep the failed operation and pause the operation repo from executing
                     paused = true
+                    ops.forEach { it.waiter?.wake(false) }
                     // add back all operations to the front of the queue to be re-executed.
                     synchronized(queue) {
-                        ops.reversed().forEach { queue.add(0, it) }
+                        ops.reversed().forEach {
+                            queue.add(0, OperationQueueItem(it.operation, waiter = null, bucket = it.bucket, retries = it.retries))
+                        }
                     }
                 }
             }

OneSignalSDK/onesignal/core/src/main/java/com/onesignal/internal/OneSignalImp.kt

@@ -384,16 +384,16 @@ internal class OneSignalImp(
 
         if (isBackgroundThreadingEnabled) {
             waitForInit(operationName = "login")
-            suspendifyOnIO { loginHelper.login(externalId, jwtBearerToken) }
+            runBlocking(runtimeIoDispatcher) {
+                loginHelper.login(externalId, jwtBearerToken)
+            }
         } else {
             if (!isInitialized) {
                 throw IllegalStateException("Must call 'initWithContext' before 'login'")
             }
-            Thread {
-                runBlocking(runtimeIoDispatcher) {
-                    loginHelper.login(externalId, jwtBearerToken)
-                }
-            }.start()
+            runBlocking(runtimeIoDispatcher) {
+                loginHelper.login(externalId, jwtBearerToken)
+            }
         }
     }
 
@@ -402,16 +402,16 @@ internal class OneSignalImp(
 
         if (isBackgroundThreadingEnabled) {
             waitForInit(operationName = "logout")
-            suspendifyOnIO { logoutHelper.logout() }
+            runBlocking(runtimeIoDispatcher) {
+                logoutHelper.logout()
+            }
         } else {
             if (!isInitialized) {
                 throw IllegalStateException("Must call 'initWithContext' before 'logout'")
             }
-            Thread {
-                runBlocking(runtimeIoDispatcher) {
-                    logoutHelper.logout()
-                }
-            }.start()
+            runBlocking(runtimeIoDispatcher) {
+                logoutHelper.logout()
+            }
         }
     }