parent
fdb35d4f77
commit
2525304215
|
@ -32,7 +32,7 @@ public class ConnectListener implements WebSocketConnectListener {
|
|||
|
||||
@Override
|
||||
public void onWebSocketConnect(WebSocketSessionContext context) {
|
||||
Optional<Account> account = Optional.fromNullable((Account) context.getAuthenticated());
|
||||
Optional<Account> account = context.getAuthenticated(Account.class);
|
||||
|
||||
if (!account.isPresent()) {
|
||||
logger.debug("WS Connection with no authentication...");
|
||||
|
|
|
@ -1,6 +1,5 @@
|
|||
package org.whispersystems.textsecuregcm.tests.websocket;
|
||||
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
import com.google.common.base.Optional;
|
||||
import com.google.common.util.concurrent.SettableFuture;
|
||||
import org.eclipse.jetty.websocket.api.UpgradeRequest;
|
||||
|
@ -79,7 +78,7 @@ public class WebSocketConnectionTest {
|
|||
}});
|
||||
|
||||
Optional<Account> account = webSocketAuthenticator.authenticate(upgradeRequest);
|
||||
when(sessionContext.getAuthenticated()).thenReturn(account.orNull());
|
||||
when(sessionContext.getAuthenticated(Account.class)).thenReturn(account);
|
||||
|
||||
connectListener.onWebSocketConnect(sessionContext);
|
||||
|
||||
|
@ -98,7 +97,7 @@ public class WebSocketConnectionTest {
|
|||
}});
|
||||
|
||||
account = webSocketAuthenticator.authenticate(upgradeRequest);
|
||||
when(sessionContext.getAuthenticated()).thenReturn(account.orNull());
|
||||
when(sessionContext.getAuthenticated(Account.class)).thenReturn(account);
|
||||
|
||||
WebSocketClient client = mock(WebSocketClient.class);
|
||||
when(sessionContext.getClient()).thenReturn(client);
|
||||
|
|
Loading…
Reference in New Issue