1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.syncope.client.console.rest;
20
21 import java.util.List;
22 import javax.ws.rs.core.GenericType;
23 import javax.ws.rs.core.MediaType;
24 import javax.ws.rs.core.Response;
25 import org.apache.syncope.client.console.SyncopeWebApplication;
26 import org.apache.syncope.client.lib.WebClientBuilder;
27 import org.apache.syncope.common.keymaster.client.api.model.NetworkService;
28 import org.apache.syncope.common.lib.AMSession;
29
30 public final class SRASessionRestClient extends AMSessionRestClient {
31
32 private static final long serialVersionUID = 22118820292494L;
33
34 public SRASessionRestClient(final List<NetworkService> list) {
35 super(list);
36 }
37
38 @Override
39 protected String getActuatorEndpoint() {
40 return instances.get(0).getAddress() + "actuator/sraSessions";
41 }
42
43 @Override
44 public List<AMSession> list() {
45 try {
46 Response response = WebClientBuilder.build(getActuatorEndpoint(),
47 SyncopeWebApplication.get().getAnonymousUser(),
48 SyncopeWebApplication.get().getAnonymousKey(),
49 JAX_RS_PROVIDERS).accept(MediaType.APPLICATION_JSON_TYPE).get();
50 if (response.getStatus() == Response.Status.OK.getStatusCode()) {
51 return response.readEntity(new GenericType<>() {
52 });
53 }
54
55 LOG.error("Unexpected response for SSO Sessions from {}: {}",
56 getActuatorEndpoint(), response.getStatus());
57 } catch (Exception e) {
58 LOG.error("Could not fetch SSO Sessions from {}", getActuatorEndpoint(), e);
59 }
60
61 return List.of();
62 }
63 }