File tree Expand file tree Collapse file tree
app/src/main/java/com/anthroid/gateway Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -264,9 +264,14 @@ class GatewayManager(
264264
265265 /* * Drain ALL pending messages across all sessions in one call. */
266266 suspend fun drainAllPendingMessages (): List <DrainedMessage > {
267- val gs = session ? : return emptyList()
267+ val gs = session
268+ if (gs == null ) {
269+ Log .w(TAG , " drainAllPendingMessages: session is null" )
270+ return emptyList()
271+ }
268272 return try {
269273 val response = gs.request(" session.drainAllPending" , " {}" , timeoutMs = 10_000 )
274+ Log .i(TAG , " drainAllPending response: ${response?.take(200 )} " )
270275 val obj = JSONObject (response)
271276 val messages = obj.optJSONArray(" messages" ) ? : return emptyList()
272277 val result = mutableListOf<DrainedMessage >()
@@ -287,7 +292,7 @@ class GatewayManager(
287292 if (result.isNotEmpty() || skipped > 0 ) Log .i(TAG , " DrainAll: ${result.size} messages (skipped $skipped duplicates)" )
288293 result
289294 } catch (err: Throwable ) {
290- Log .d (TAG , " drainAllPendingMessages failed: ${err.message} " )
295+ Log .w (TAG , " drainAllPendingMessages failed: ${err.message} " )
291296 emptyList()
292297 }
293298 }
You can’t perform that action at this time.
0 commit comments