From acef82fecd92aec828a05fabc1fb29da7a645d33 Mon Sep 17 00:00:00 2001 From: Vitaly Takmazov Date: Fri, 13 Jan 2017 17:03:26 +0300 Subject: juick-crosspost: xmpp -> ws --- .../main/java/com/juick/components/Crosspost.java | 66 +++++++--------------- .../configuration/CrosspostAppConfiguration.java | 15 +++++ 2 files changed, 36 insertions(+), 45 deletions(-) (limited to 'juick-crosspost/src') diff --git a/juick-crosspost/src/main/java/com/juick/components/Crosspost.java b/juick-crosspost/src/main/java/com/juick/components/Crosspost.java index 769fb892..d7c0ec14 100644 --- a/juick-crosspost/src/main/java/com/juick/components/Crosspost.java +++ b/juick-crosspost/src/main/java/com/juick/components/Crosspost.java @@ -17,6 +17,9 @@ */ package com.juick.components; +import com.fasterxml.jackson.annotation.JsonInclude; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.juick.Message; import com.juick.Tag; import com.juick.service.CrosspostService; import com.juick.service.MessagesService; @@ -24,20 +27,15 @@ import org.apache.commons.codec.binary.Base64; import org.apache.commons.io.IOUtils; import org.apache.commons.lang3.CharEncoding; import org.apache.commons.lang3.StringUtils; -import org.apache.commons.lang3.math.NumberUtils; import org.apache.commons.lang3.tuple.Pair; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.core.env.Environment; import org.springframework.util.Assert; -import rocks.xmpp.core.XmppException; -import rocks.xmpp.core.session.Extension; -import rocks.xmpp.core.session.XmppSession; -import rocks.xmpp.core.session.XmppSessionConfiguration; -import rocks.xmpp.core.stanza.model.Message; -import rocks.xmpp.extensions.component.accept.ExternalComponent; - -import javax.annotation.PostConstruct; +import org.springframework.web.socket.TextMessage; +import org.springframework.web.socket.WebSocketSession; +import org.springframework.web.socket.handler.TextWebSocketHandler; + import javax.crypto.Mac; import javax.crypto.spec.SecretKeySpec; import javax.inject.Inject; @@ -53,7 +51,7 @@ import java.util.UUID; /** * @author Ugnich Anton */ -public class Crosspost implements AutoCloseable { +public class Crosspost extends TextWebSocketHandler { final static String TWITTERURL = "https://api.twitter.com/1.1/statuses/update.json"; final static String FBURL = "https://graph.facebook.com/me/feed"; final static String VKURL = "https://api.vk.com/method/wall.post"; @@ -61,13 +59,10 @@ public class Crosspost implements AutoCloseable { private static Logger logger = LoggerFactory.getLogger(Crosspost.class); private final CrosspostService crosspostService; - private XmppSession xmpp; private final String twitter_consumer_key; private final String twitter_consumer_secret; - private final String crosspostJid; - private final String password; - private final int port; + private ObjectMapper ms; @Inject MessagesService messagesService; @@ -80,9 +75,10 @@ public class Crosspost implements AutoCloseable { twitter_consumer_key = env.getProperty("twitter_consumer_key", StringUtils.EMPTY); twitter_consumer_secret = env.getProperty("twitter_consumer_secret", StringUtils.EMPTY); - crosspostJid = env.getProperty("crosspost_jid", "crosspost.juick.local"); - password = env.getProperty("xmpp_password", StringUtils.EMPTY); - port = NumberUtils.toInt(env.getProperty("xmpp_port"), 5347); + ms = new ObjectMapper(); + ms.setSerializationInclusion(JsonInclude.Include.NON_EMPTY); + ms.setSerializationInclusion(JsonInclude.Include.NON_NULL); + ms.setSerializationInclusion(JsonInclude.Include.NON_DEFAULT); } public static String percentEncode(final String s) { @@ -94,40 +90,20 @@ public class Crosspost implements AutoCloseable { return ret; } - @PostConstruct - public void init() { - XmppSessionConfiguration configuration = XmppSessionConfiguration.builder() - .extensions(Extension.of(com.juick.Message.class)) - .build(); - xmpp = ExternalComponent.create(crosspostJid, password, configuration, "localhost", port); - xmpp.addInboundMessageListener(e -> { - Message msg = e.getMessage(); - com.juick.Message jmsg = messagesService.getMessage(msg.getExtension(com.juick.Message.class).getMid()); - if (msg.getTo() != null && msg.getTo().getLocal() != null && jmsg != null && jmsg.getRid() == 0) { - if (msg.getTo().getLocal().equals("twitter")) { + @Override + protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception { + Message msg = ms.readValue(message.asBytes(), Message.class); + if (msg.getMid() > 0 && msg.getRid() == 0) { + Message jmsg = messagesService.getMessage(msg.getMid()); + if (StringUtils.isNotEmpty(crosspostService.getTwitterName(msg.getUser().getUid()))) { + if (jmsg.getTags().stream().noneMatch(t -> t.getName().equals("notwitter"))) { twitterPost(jmsg); - } else if (msg.getTo().getLocal().equals("fb")) { - facebookPost(jmsg); - } else if (msg.getTo().getLocal().equals("vk")) { - vkontaktePost(jmsg); } } - }); - try { - xmpp.connect(); - } catch (XmppException e) { - logger.warn("xmpp exception", e); + // TODO: approve application for facebook crosspost } } - @Override - public void close() throws Exception { - if (xmpp != null) - xmpp.close(); - - logger.info("XmppSession on crosspost destroyed"); - } - public boolean facebookPost(final com.juick.Message jmsg) { String token = crosspostService.getFacebookToken(jmsg.getUser().getUid()).orElse(StringUtils.EMPTY); if (token.isEmpty()) { diff --git a/juick-crosspost/src/main/java/com/juick/components/configuration/CrosspostAppConfiguration.java b/juick-crosspost/src/main/java/com/juick/components/configuration/CrosspostAppConfiguration.java index 95449589..2fcd3bfe 100644 --- a/juick-crosspost/src/main/java/com/juick/components/configuration/CrosspostAppConfiguration.java +++ b/juick-crosspost/src/main/java/com/juick/components/configuration/CrosspostAppConfiguration.java @@ -6,6 +6,8 @@ import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.PropertySource; import org.springframework.core.env.Environment; +import org.springframework.web.socket.client.WebSocketConnectionManager; +import org.springframework.web.socket.client.standard.StandardWebSocketClient; import javax.inject.Inject; @@ -24,4 +26,17 @@ public class CrosspostAppConfiguration { public Crosspost crosspost() { return new Crosspost(env, crosspostService); } + private static final String WS_URI = "wss://ws.juick.com/"; + + @Bean + public WebSocketConnectionManager connectionManager() { + WebSocketConnectionManager manager = new WebSocketConnectionManager(client(), crosspost(), WS_URI); + manager.setAutoStartup(true); + return manager; + } + + @Bean + public StandardWebSocketClient client() { + return new StandardWebSocketClient(); + } } -- cgit v1.2.3