diff options
author | Vitaly Takmazov | 2018-08-20 13:20:14 +0300 |
---|---|---|
committer | Vitaly Takmazov | 2018-08-20 13:20:14 +0300 |
commit | 80c2829a19ce8192dd4db891246fecd5177e09f1 (patch) | |
tree | fe252cff8c810516adb744ff6c2ecc4853e016e2 /juick-server/src/main/java/com | |
parent | 5741586f1ca63447adf12f63a83eb1cd0837833d (diff) |
update xmpp status api
Diffstat (limited to 'juick-server/src/main/java/com')
3 files changed, 15 insertions, 8 deletions
diff --git a/juick-server/src/main/java/com/juick/server/XMPPServer.java b/juick-server/src/main/java/com/juick/server/XMPPServer.java index 4a5d577d..675d79da 100644 --- a/juick-server/src/main/java/com/juick/server/XMPPServer.java +++ b/juick-server/src/main/java/com/juick/server/XMPPServer.java @@ -434,4 +434,8 @@ public class XMPPServer implements ConnectionListener { service.shutdown(); logger.info("XMPP server destroyed"); } + + public int getServerPort() { + return s2sPort; + } } diff --git a/juick-server/src/main/java/com/juick/server/api/Index.java b/juick-server/src/main/java/com/juick/server/api/Index.java index eafde85b..5ffa6341 100644 --- a/juick-server/src/main/java/com/juick/server/api/Index.java +++ b/juick-server/src/main/java/com/juick/server/api/Index.java @@ -28,10 +28,12 @@ import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.servlet.support.ServletUriComponentsBuilder; +import rocks.xmpp.addr.Jid; import springfox.documentation.annotations.ApiIgnore; import javax.inject.Inject; import java.net.URI; +import java.util.stream.Collectors; /** * Created by vitalyster on 25.07.2016. @@ -58,8 +60,9 @@ public class Index { public XMPPStatus xmppStatus() { XMPPStatus status = new XMPPStatus(); if (xmpp != null) { - status.setInbound(xmpp.getInConnections()); - status.setOutbound(xmpp.getOutConnections().keySet()); + status.setInbound(xmpp.getInConnections().stream().map(c -> c.from).flatMap(j -> j.stream().map(Jid::getDomain)).collect(Collectors.toList())); + status.setOutbound(xmpp.getOutConnections().keySet().stream() + .map(c -> c.to).map(Jid::getDomain).collect(Collectors.toList())); } return status; } diff --git a/juick-server/src/main/java/com/juick/server/xmpp/helpers/XMPPStatus.java b/juick-server/src/main/java/com/juick/server/xmpp/helpers/XMPPStatus.java index 7978ceb3..99d89866 100644 --- a/juick-server/src/main/java/com/juick/server/xmpp/helpers/XMPPStatus.java +++ b/juick-server/src/main/java/com/juick/server/xmpp/helpers/XMPPStatus.java @@ -27,22 +27,22 @@ import java.util.Set; * Created by vitalyster on 16.02.2017. */ public class XMPPStatus { - private List<ConnectionIn> inbound; - private Set<ConnectionOut> outbound; + private List<String> inbound; + private List<String> outbound; - public List<ConnectionIn> getInbound() { + public List<String> getInbound() { return inbound; } - public void setInbound(List<ConnectionIn> inbound) { + public void setInbound(List<String> inbound) { this.inbound = inbound; } - public Set<ConnectionOut> getOutbound() { + public List<String> getOutbound() { return outbound; } - public void setOutbound(Set<ConnectionOut> outbound) { + public void setOutbound(List<String> outbound) { this.outbound = outbound; } } |