juick-crosspost: get full message from database

1 files changed, 5 insertions, 1 deletions

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 7cf4ad3e..769fb892 100644
--- a/juick-crosspost/src/main/java/com/juick/components/Crosspost.java
+++ b/juick-crosspost/src/main/java/com/juick/components/Crosspost.java
@@ -19,6 +19,7 @@ package com.juick.components;
 
 import com.juick.Tag;
 import com.juick.service.CrosspostService;
+import com.juick.service.MessagesService;
 import org.apache.commons.codec.binary.Base64;
 import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang3.CharEncoding;
@@ -39,6 +40,7 @@ import rocks.xmpp.extensions.component.accept.ExternalComponent;
 import javax.annotation.PostConstruct;
 import javax.crypto.Mac;
 import javax.crypto.spec.SecretKeySpec;
+import javax.inject.Inject;
 import javax.net.ssl.HttpsURLConnection;
 import java.io.OutputStreamWriter;
 import java.io.UnsupportedEncodingException;
@@ -66,6 +68,8 @@ public class Crosspost implements AutoCloseable {
     private final String crosspostJid;
     private final String password;
     private final int port;
+    @Inject
+    MessagesService messagesService;
 
     public Crosspost(final Environment env, final CrosspostService crosspostService) {
         Assert.notNull(env);
@@ -98,7 +102,7 @@ public class Crosspost implements AutoCloseable {
         xmpp = ExternalComponent.create(crosspostJid, password, configuration, "localhost", port);
         xmpp.addInboundMessageListener(e -> {
             Message msg = e.getMessage();
-            com.juick.Message jmsg = msg.getExtension(com.juick.Message.class);
+            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")) {
                     twitterPost(jmsg);