From 1fcd1e33c554e6058bb3974b10c8278beee3d2a2 Mon Sep 17 00:00:00 2001 From: Moxie Marlinspike Date: Tue, 24 Mar 2015 14:13:32 -0700 Subject: [PATCH] Log keepalives for unsubscribed channels. // FREEBIE --- .../textsecuregcm/controllers/KeepAliveController.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/main/java/org/whispersystems/textsecuregcm/controllers/KeepAliveController.java b/src/main/java/org/whispersystems/textsecuregcm/controllers/KeepAliveController.java index 903d56b30..0b0108c1d 100644 --- a/src/main/java/org/whispersystems/textsecuregcm/controllers/KeepAliveController.java +++ b/src/main/java/org/whispersystems/textsecuregcm/controllers/KeepAliveController.java @@ -1,6 +1,8 @@ package org.whispersystems.textsecuregcm.controllers; import com.codahale.metrics.annotation.Timed; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.whispersystems.textsecuregcm.storage.Account; import org.whispersystems.textsecuregcm.storage.PubSubManager; import org.whispersystems.textsecuregcm.websocket.WebsocketAddress; @@ -17,6 +19,8 @@ import io.dropwizard.auth.Auth; @Path("/v1/keepalive") public class KeepAliveController { + private final Logger logger = LoggerFactory.getLogger(KeepAliveController.class); + private final PubSubManager pubSubManager; public KeepAliveController(PubSubManager pubSubManager) { @@ -33,6 +37,7 @@ public class KeepAliveController { account.getAuthenticatedDevice().get().getId()); if (!pubSubManager.hasLocalSubscription(address)) { + logger.warn("***** No local subscription found for: " + address); context.getClient().close(1000, "OK"); } }