ws: fix injections

8 files changed, 87 insertions, 136 deletions

diff --git a/juick-ws/src/main/java/com/juick/ws/XMPPConnection.java b/juick-ws/src/main/java/com/juick/ws/XMPPConnection.java
index 24041eeb..ea02db76 100644
--- a/juick-ws/src/main/java/com/juick/ws/XMPPConnection.java
+++ b/juick-ws/src/main/java/com/juick/ws/XMPPConnection.java
@@ -3,7 +3,6 @@ package com.juick.ws;
 import com.juick.User;
 import com.juick.json.MessageSerializer;
 import com.juick.server.SubscriptionsQueries;
-import com.juick.ws.components.JuickComponent;
 import com.juick.xmpp.JID;
 import com.juick.xmpp.Message;
 import com.juick.xmpp.Stream;
@@ -20,6 +19,7 @@ import javax.inject.Inject;
 import java.io.IOException;
 import java.net.Socket;
 import java.util.List;
+import java.util.concurrent.ExecutorService;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 import java.util.stream.Collectors;
@@ -29,17 +29,19 @@ import java.util.stream.Collectors;
  * @author ugnich
  */
 @Component
-public class XMPPConnection implements JuickComponent, Stream.StreamListener, Message.MessageListener {
+public class XMPPConnection implements Stream.StreamListener, Message.MessageListener {
     private static final Logger logger = Logger.getLogger(XMPPConnection.class.getName());
     @Inject
     JdbcTemplate sql;
+    ExecutorService service;
     Stream xmpp;
     String xmppPassword;
     MessageSerializer ms;
     WebsocketComponent wsHandler;
 
     @Inject
-    public XMPPConnection(Environment env) {
+    public XMPPConnection(Environment env, ExecutorService service) {
+        this.service = service;
         xmppPassword = env.getProperty("xmpp_password");
         ms = new MessageSerializer();
         try {
@@ -48,16 +50,12 @@ public class XMPPConnection implements JuickComponent, Stream.StreamListener, Me
             xmpp.addChildParser(new JuickMessage());
             xmpp.addListener((Stream.StreamListener) this);
             xmpp.addListener((Message.MessageListener) this);
+            service.submit(() -> xmpp.startParsing());
         } catch (IOException e) {
             logger.log(Level.SEVERE, "XMPPConnection error", e);
         }
     }
 
-    @Async
-    @Override
-    public void init() {
-        xmpp.startParsing();
-    }
 
     @Override
     public void onStreamReady() {
diff --git a/juick-ws/src/main/java/com/juick/ws/components/CrosspostComponent.java b/juick-ws/src/main/java/com/juick/ws/components/CrosspostComponent.java
index 8cda122e..dcb4a709 100644
--- a/juick-ws/src/main/java/com/juick/ws/components/CrosspostComponent.java
+++ b/juick-ws/src/main/java/com/juick/ws/components/CrosspostComponent.java
@@ -27,11 +27,9 @@ import org.apache.commons.codec.binary.Base64;
 import org.apache.commons.lang3.math.NumberUtils;
 import org.apache.commons.lang3.tuple.Pair;
 import org.springframework.beans.factory.DisposableBean;
-import org.springframework.beans.factory.InitializingBean;
 import org.springframework.core.env.Environment;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.jdbc.datasource.DriverManagerDataSource;
-import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Component;
 
 import javax.crypto.Mac;
@@ -44,6 +42,7 @@ import java.net.URL;
 import java.net.URLEncoder;
 import java.security.Key;
 import java.util.UUID;
+import java.util.concurrent.ExecutorService;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
@@ -52,51 +51,41 @@ import java.util.logging.Logger;
  * @author Ugnich Anton
  */
 @Component
-public class CrosspostComponent implements JuickComponent, DisposableBean, Stream.StreamListener, Message.MessageListener {
+public class CrosspostComponent implements DisposableBean, Stream.StreamListener, Message.MessageListener {
 
     private static Logger logger = Logger.getLogger(CrosspostComponent.class.getName());
 
     public final static String TWITTERURL = "https://api.twitter.com/1.1/statuses/update.json";
     public final static String FBURL = "https://graph.facebook.com/me/feed";
     public final static String VKURL = "https://api.vk.com/method/wall.post";
-    JdbcTemplate sql;
+    @Inject
+    JdbcTemplate jdbc;
     Stream xmpp;
     String twitter_consumer_key;
     String twitter_consumer_secret;
+    ExecutorService service;
 
     @Inject
-    public CrosspostComponent(Environment env) {
+    public CrosspostComponent(Environment env, ExecutorService service) {
+        this.service = service;
         logger.info("component initialized");
         try {
             twitter_consumer_key = env.getProperty("twitter_consumer_key", "");
             twitter_consumer_secret = env.getProperty("twitter_consumer_secret", "");
 
-            setupSql(env.getProperty("datasource_driver", "com.mysql.jdbc.Driver"), env.getProperty("datasource_url", ""));
             setupXmppComponent(env.getProperty("crosspost_jid", "crosspost.juick.local"),
                     env.getProperty("xmpp_password", ""), NumberUtils.toInt(env.getProperty("xmpp_port", ""), 5347));
+            service.submit(() -> xmpp.startParsing());
         } catch (Exception e) {
             logger.log(Level.SEVERE, e.getMessage(), e);
         }
     }
 
-    @Async
-    @Override
-    public void init() {
-        xmpp.startParsing();
-    }
-
     @Override
     public void destroy() {
         logger.info("component destroyed");
     }
 
-    public void setupSql(String driver, String url) {
-        DriverManagerDataSource dataSource = new DriverManagerDataSource();
-        dataSource.setDriverClassName(driver);
-        dataSource.setUrl(url);
-        sql = new JdbcTemplate(dataSource);
-    }
-
     public void setupXmppComponent(String jid, String password, int port) {
         try {
             Socket socket = new Socket("localhost", port);
@@ -131,7 +120,7 @@ public class CrosspostComponent implements JuickComponent, DisposableBean, Strea
     }
 
     public boolean facebookPost(com.juick.Message jmsg) {
-        String token = CrosspostQueries.getFacebookToken(sql, jmsg.getUser().getUID()).orElse("");
+        String token = CrosspostQueries.getFacebookToken(jdbc, jmsg.getUser().getUID()).orElse("");
         if (token.isEmpty()) {
             return false;
         }
@@ -168,7 +157,7 @@ public class CrosspostComponent implements JuickComponent, DisposableBean, Strea
     }
 
     public boolean vkontaktePost(com.juick.Message jmsg) {
-        Pair<String, String> tokens = CrosspostQueries.getVKTokens(sql, jmsg.getUser().getUID()).orElse(Pair.of("", ""));
+        Pair<String, String> tokens = CrosspostQueries.getVKTokens(jdbc, jmsg.getUser().getUID()).orElse(Pair.of("", ""));
         if (tokens.getLeft().isEmpty() || tokens.getRight().isEmpty()) {
             return false;
         }
@@ -205,7 +194,7 @@ public class CrosspostComponent implements JuickComponent, DisposableBean, Strea
     }
 
     public boolean twitterPost(com.juick.Message jmsg) {
-        Pair<String, String> tokens = CrosspostQueries.getTwitterTokens(sql, jmsg.getUser().getUID()).orElse(Pair.of("", ""));
+        Pair<String, String> tokens = CrosspostQueries.getTwitterTokens(jdbc, jmsg.getUser().getUID()).orElse(Pair.of("", ""));
         if (tokens.getLeft().isEmpty() || tokens.getRight().isEmpty()) {
             return false;
         }
diff --git a/juick-ws/src/main/java/com/juick/ws/components/JuickComponent.java b/juick-ws/src/main/java/com/juick/ws/components/JuickComponent.java
deleted file mode 100644
index 0f53ed66..00000000
--- a/juick-ws/src/main/java/com/juick/ws/components/JuickComponent.java
+++ /dev/null
@@ -1,8 +0,0 @@
-package com.juick.ws.components;
-
-/**
- * Created by vitalyster on 08.08.2016.
- */
-public interface JuickComponent {
-    void init();
-}
diff --git a/juick-ws/src/main/java/com/juick/ws/components/PushComponent.java b/juick-ws/src/main/java/com/juick/ws/components/PushComponent.java
index 7be2f797..5c4fc969 100644
--- a/juick-ws/src/main/java/com/juick/ws/components/PushComponent.java
+++ b/juick-ws/src/main/java/com/juick/ws/components/PushComponent.java
@@ -59,6 +59,7 @@ import java.net.Socket;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
+import java.util.concurrent.ExecutorService;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 import java.util.stream.Collectors;
@@ -68,33 +69,30 @@ import java.util.stream.Collectors;
  * @author Ugnich Anton
  */
 @Component
-public class PushComponent implements JuickComponent, DisposableBean, Stream.StreamListener, MessageListener {
+public class PushComponent implements DisposableBean, Stream.StreamListener, MessageListener {
 
     private static Logger logger = Logger.getLogger(PushComponent.class.getName());
 
     String wns_application_sip;
     String wns_client_secret;
-    JdbcTemplate sql;
+    @Inject
+    JdbcTemplate jdbc;
     Socket socket;
     Stream xmpp;
     Sender GCMSender;
+    ExecutorService service;
 
     @Inject
-    public PushComponent(Environment env) {
+    public PushComponent(Environment env, ExecutorService service) {
+        this.service = service;
         logger.info("component initialized");
         wns_application_sip = env.getProperty("wns_application_sip", "");
         wns_client_secret = env.getProperty("wns_client_secret", "");
         GCMSender = new Sender(env.getProperty("gcm_key", ""));
 
-        setupSql(env.getProperty("datasource_driver", "com.mysql.jdbc.Driver"), env.getProperty("datasource_url", ""));
         setupXmppComponent(new JID("", env.getProperty("push_jid"), ""), env.getProperty("xmpp_host", "localhost"),
                 NumberUtils.toInt(env.getProperty("xmpp_port", ""), 5347), env.getProperty("push_xmpp_password", ""));
-    }
-
-    @Async
-    @Override
-    public void init() {
-        xmpp.startParsing();
+        service.submit(() -> xmpp.startParsing());
     }
 
     @Override
@@ -102,13 +100,6 @@ public class PushComponent implements JuickComponent, DisposableBean, Stream.Str
         logger.info("component destroyed");
     }
 
-    public void setupSql(String driver, String url) {
-        DriverManagerDataSource dataSource = new DriverManagerDataSource();
-        dataSource.setDriverClassName(driver);
-        dataSource.setUrl(url);
-        sql = new JdbcTemplate(dataSource);
-    }
-
     public void setupXmppComponent(JID jid, String host, int port, String password) {
         try {
             socket = new Socket(host, port);
@@ -141,21 +132,21 @@ public class PushComponent implements JuickComponent, DisposableBean, Stream.Str
         } else {
             if (isReply) {
                 subscribedUsers =
-                        SubscriptionsQueries.getUsersSubscribedToComments(sql, jmsg.getMID(), jmsg.getUser().getUID());
+                        SubscriptionsQueries.getUsersSubscribedToComments(jdbc, jmsg.getMID(), jmsg.getUser().getUID());
             } else {
                 // new message
-                subscribedUsers = SubscriptionsQueries.getSubscribedUsers(sql, jmsg.getUser().getUID(), jmsg.getMID());
+                subscribedUsers = SubscriptionsQueries.getSubscribedUsers(jdbc, jmsg.getUser().getUID(), jmsg.getMID());
             }
         }
 
         /*** ANDROID ***/
         final List<String> regids = new ArrayList<>();
         if (isPM) {
-            regids.addAll(PushQueries.getAndroidRegID(sql, pmTo));
+            regids.addAll(PushQueries.getAndroidRegID(jdbc, pmTo));
         } else {
             List<Integer> uids = subscribedUsers.stream().map(com.juick.User::getUID).collect(Collectors.toList());
             if (uids.size() > 0) {
-                regids.addAll(PushQueries.getAndroidTokens(sql, uids));
+                regids.addAll(PushQueries.getAndroidTokens(jdbc, uids));
             }
         }
 
@@ -182,11 +173,11 @@ public class PushComponent implements JuickComponent, DisposableBean, Stream.Str
         /*** WinPhone ***/
         final List<String> urls = new ArrayList<>();
         if (isPM) {
-            urls.addAll(PushQueries.getWinPhoneURL(sql, pmTo));
+            urls.addAll(PushQueries.getWinPhoneURL(jdbc, pmTo));
         } else {
             List<Integer> uids = subscribedUsers.stream().map(com.juick.User::getUID).collect(Collectors.toList());
             if (uids.size() > 0) {
-                urls.addAll(PushQueries.getWindowsTokens(sql, uids));
+                urls.addAll(PushQueries.getWindowsTokens(jdbc, uids));
             }
         }
 
@@ -227,11 +218,11 @@ public class PushComponent implements JuickComponent, DisposableBean, Stream.Str
         /*** iOS ***/
         final List<String> tokens = new ArrayList<>();
         if (isPM) {
-            tokens.addAll(PushQueries.getAPNSToken(sql, pmTo));
+            tokens.addAll(PushQueries.getAPNSToken(jdbc, pmTo));
         } else {
             List<Integer> uids = subscribedUsers.stream().map(com.juick.User::getUID).collect(Collectors.toList());
             if (uids.size() > 0) {
-                tokens.addAll(PushQueries.getAPNSTokens(sql, uids));
+                tokens.addAll(PushQueries.getAPNSTokens(jdbc, uids));
             }
         }
         if (!tokens.isEmpty()) {
diff --git a/juick-ws/src/main/java/com/juick/ws/components/XMPPComponent.java b/juick-ws/src/main/java/com/juick/ws/components/XMPPComponent.java
index 1db8c604..2cc898ec 100644
--- a/juick-ws/src/main/java/com/juick/ws/components/XMPPComponent.java
+++ b/juick-ws/src/main/java/com/juick/ws/components/XMPPComponent.java
@@ -12,10 +12,8 @@ import com.juick.xmpp.extensions.XOOB;
 import org.apache.commons.dbcp2.BasicDataSource;
 import org.apache.commons.lang3.math.NumberUtils;
 import org.springframework.beans.factory.DisposableBean;
-import org.springframework.beans.factory.InitializingBean;
 import org.springframework.core.env.Environment;
 import org.springframework.jdbc.core.JdbcTemplate;
-import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Component;
 import org.xmlpull.v1.XmlPullParserException;
 
@@ -30,7 +28,6 @@ import java.security.UnrecoverableKeyException;
 import java.security.cert.CertificateException;
 import java.util.*;
 import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
@@ -44,7 +41,7 @@ public class XMPPComponent implements DisposableBean, Stream.StreamListener,
 
     private static final Logger logger = Logger.getLogger(XMPPComponent.class.getName());
 
-    public final ExecutorService executorService = Executors.newCachedThreadPool();
+    public ExecutorService service;
     private StreamComponent router;
     JuickBot bot;
 
@@ -57,11 +54,13 @@ public class XMPPComponent implements DisposableBean, Stream.StreamListener,
     private final List<ConnectionIn> inConnections = Collections.synchronizedList(new ArrayList<>());
     private final List<ConnectionOut> outConnections = Collections.synchronizedList(new ArrayList<>());
     private final List<CacheEntry> outCache = Collections.synchronizedList(new ArrayList<>());
-    private JdbcTemplate sql;
+    @Inject
+    public JdbcTemplate jdbc;
     final public HashMap<String, StanzaChild> childParsers = new HashMap<>();
 
     @Inject
-    public XMPPComponent(Environment env) {
+    public XMPPComponent(Environment env, ExecutorService service) {
+        this.service = service;
         logger.info("component initialized");
         try {
             HOSTNAME = env.getProperty("hostname");
@@ -74,15 +73,11 @@ public class XMPPComponent implements DisposableBean, Stream.StreamListener,
             keystorePassword = env.getProperty("keystore_password");
             brokenSSLhosts = Arrays.asList(env.getProperty("broken_ssl_hosts", "").split(","));
             bannedHosts = Arrays.asList(env.getProperty("banned_hosts", "").split(","));
-            BasicDataSource dataSource = new BasicDataSource();
-            dataSource.setDriverClassName(env.getProperty("datasource_driver", "com.mysql.jdbc.Driver"));
-            dataSource.setUrl(env.getProperty("datasource_url"));
-            setSql(new JdbcTemplate(dataSource));
             bot = new JuickBot(this, Jid);
 
             childParsers.put(JuickMessage.XMLNS, new JuickMessage());
 
-            executorService.submit(() -> {
+            service.submit(() -> {
                 try {
                     Socket routerSocket = new Socket("localhost", componentPort);
                     router = new StreamComponent(new JID("s2s"), routerSocket.getInputStream(), routerSocket.getOutputStream(), env.getProperty("xmpp_password"));
@@ -95,7 +90,7 @@ public class XMPPComponent implements DisposableBean, Stream.StreamListener,
                     logger.log(Level.SEVERE, "router error", e);
                 }
             });
-            executorService.submit(() -> {
+            service.submit(() -> {
                 final ServerSocket listener = new ServerSocket(s2sPort);
                 logger.info("s2s listener ready");
                 while (true) {
@@ -103,13 +98,13 @@ public class XMPPComponent implements DisposableBean, Stream.StreamListener,
                         Socket socket = listener.accept();
                         ConnectionIn client = new ConnectionIn(this, bot, socket);
                         addConnectionIn(client);
-                        executorService.submit(client);
+                        service.submit(client);
                     } catch (Exception e) {
                         logger.log(Level.SEVERE, "s2s error", e);
                     }
                 }
             });
-            executorService.submit(new CleaningUp(this));
+            service.submit(new CleaningUp(this));
 
         } catch (Exception e) {
             logger.log(Level.SEVERE, "XMPPComponent error", e);
@@ -225,7 +220,7 @@ public class XMPPComponent implements DisposableBean, Stream.StreamListener,
         if (!haveAnyConn) {
             try {
                 ConnectionOut connectionOut = new ConnectionOut(this, hostname);
-                executorService.submit(connectionOut);
+                service.submit(connectionOut);
             } catch (CertificateException | UnrecoverableKeyException | NoSuchAlgorithmException | XmlPullParserException | KeyStoreException | KeyManagementException | IOException e) {
                 logger.log(Level.SEVERE, "s2s out error", e);
             }
@@ -256,7 +251,7 @@ public class XMPPComponent implements DisposableBean, Stream.StreamListener,
         } catch (IOException e) {
             logger.log(Level.WARNING, "router warning", e);
         }
-        executorService.shutdown();
+        service.shutdown();
         logger.info("component destroyed");
     }
     public void closeRouterConnection() throws IOException {
@@ -267,11 +262,11 @@ public class XMPPComponent implements DisposableBean, Stream.StreamListener,
         List<String> jids = new ArrayList<>();
 
         if (jmsg.FriendsOnly) {
-            jids = SubscriptionsQueries.getJIDSubscribedToUser(getSql(), jmsg.getUser().getUID(), jmsg.FriendsOnly);
+            jids = SubscriptionsQueries.getJIDSubscribedToUser(jdbc, jmsg.getUser().getUID(), jmsg.FriendsOnly);
         } else {
-            List<User> users = SubscriptionsQueries.getSubscribedUsers(getSql(), jmsg.getUser().getUID(), jmsg.getMID());
+            List<User> users = SubscriptionsQueries.getSubscribedUsers(jdbc, jmsg.getUser().getUID(), jmsg.getMID());
             for (User user : users) {
-                for (String jid : UserQueries.getJIDsbyUID(getSql(), user.getUID())) {
+                for (String jid : UserQueries.getJIDsbyUID(jdbc, user.getUID())) {
                     jids.add(jid);
                 }
             }
@@ -312,9 +307,9 @@ public class XMPPComponent implements DisposableBean, Stream.StreamListener,
         String replyQuote;
         String replyTo;
 
-        users = SubscriptionsQueries.getUsersSubscribedToComments(getSql(), jmsg.getMID(), jmsg.getUser().getUID());
-        com.juick.Message replyMessage = jmsg.ReplyTo > 0 ? MessagesQueries.getReply(getSql(), jmsg.getMID(), jmsg.ReplyTo)
-                : MessagesQueries.getMessage(getSql(), jmsg.getMID());
+        users = SubscriptionsQueries.getUsersSubscribedToComments(jdbc, jmsg.getMID(), jmsg.getUser().getUID());
+        com.juick.Message replyMessage = jmsg.ReplyTo > 0 ? MessagesQueries.getReply(jdbc, jmsg.getMID(), jmsg.ReplyTo)
+                : MessagesQueries.getMessage(jdbc, jmsg.getMID());
         replyTo = replyMessage.getUser().getUName();
         replyQuote = getReplyQuote(replyMessage);
 
@@ -331,7 +326,7 @@ public class XMPPComponent implements DisposableBean, Stream.StreamListener,
         msg.type = Message.Type.chat;
         msg.addChild(jmsg);
         for (User user : users) {
-            for (String jid : UserQueries.getJIDsbyUID(getSql(), user.getUID())) {
+            for (String jid : UserQueries.getJIDsbyUID(jdbc, user.getUID())) {
                 msg.to = new JID(jid);
                 sendOut(msg);
             }
@@ -351,8 +346,8 @@ public class XMPPComponent implements DisposableBean, Stream.StreamListener,
     public void sendJuickRecommendation(JuickMessage recomm) {
         List<User> users;
         JuickMessage jmsg;
-        jmsg = new JuickMessage(MessagesQueries.getMessage(getSql(), recomm.getMID()));
-        users = SubscriptionsQueries.getUsersSubscribedToUserRecommendations(getSql(),
+        jmsg = new JuickMessage(MessagesQueries.getMessage(jdbc, recomm.getMID()));
+        users = SubscriptionsQueries.getUsersSubscribedToUserRecommendations(jdbc,
                 recomm.getUser().getUID(), recomm.getMID(), jmsg.getUser().getUID());
 
         String txt = "Recommended by @" + recomm.getUser().getUName() + ":\n";
@@ -389,7 +384,7 @@ public class XMPPComponent implements DisposableBean, Stream.StreamListener,
         }
 
         for (User user : users) {
-            for (String jid : UserQueries.getJIDsbyUID(getSql(), user.getUID())) {
+            for (String jid : UserQueries.getJIDsbyUID(jdbc, user.getUID())) {
                 msg.to = new JID(jid);
                 sendOut(msg);
             }
@@ -463,11 +458,4 @@ public class XMPPComponent implements DisposableBean, Stream.StreamListener,
         return outCache;
     }
 
-    public JdbcTemplate getSql() {
-        return sql;
-    }
-
-    public void setSql(JdbcTemplate sql) {
-        this.sql = sql;
-    }
 }
diff --git a/juick-ws/src/main/java/com/juick/ws/configuration/WebsocketConfiguration.java b/juick-ws/src/main/java/com/juick/ws/configuration/WebsocketConfiguration.java
index 3b75028e..a05457fa 100644
--- a/juick-ws/src/main/java/com/juick/ws/configuration/WebsocketConfiguration.java
+++ b/juick-ws/src/main/java/com/juick/ws/configuration/WebsocketConfiguration.java
@@ -34,6 +34,8 @@ import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry
 import javax.inject.Inject;
 import javax.servlet.ServletContext;
 import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 /**
  * Created by vitalyster on 28.06.2016.
@@ -46,13 +48,7 @@ public class WebsocketConfiguration extends WebMvcConfigurationSupport implement
     @Inject
     Environment env;
     @Inject
-    XMPPComponent ws;
-    @Inject
-    CrosspostComponent crosspost;
-    @Inject
-    PushComponent push;
-    @Inject
-    XMPPConnection xmpp;
+    ExecutorService service;
     @Bean
     WebsocketComponent wsHandler() {
         return new WebsocketComponent();
@@ -96,26 +92,23 @@ public class WebsocketConfiguration extends WebMvcConfigurationSupport implement
     }
     @Bean
     public XMPPConnection ws() {
-        XMPPConnection ws = new XMPPConnection(env);
-        ws.init();
-        return ws;
+        return new XMPPConnection(env, service);
     }
     @Bean
     public XMPPComponent xmpp() {
-        XMPPComponent xmpp = new XMPPComponent(env);
-        return xmpp;
+        return new XMPPComponent(env, service);
     }
     @Bean
     public CrosspostComponent crosspost() {
-        CrosspostComponent crosspost = new CrosspostComponent(env);
-        crosspost.init();
-        return crosspost;
+        return new CrosspostComponent(env, service);
     }
     @Bean
     public PushComponent push() {
-        PushComponent push = new PushComponent(env);
-        push.init();
-        return push;
+        return new PushComponent(env, service);
+    }
+    @Bean
+    public ExecutorService service() {
+        return Executors.newCachedThreadPool();
     }
 
     @Override
diff --git a/juick-ws/src/main/java/com/juick/ws/s2s/ConnectionIn.java b/juick-ws/src/main/java/com/juick/ws/s2s/ConnectionIn.java
index a57623c4..d1d69dd0 100644
--- a/juick-ws/src/main/java/com/juick/ws/s2s/ConnectionIn.java
+++ b/juick-ws/src/main/java/com/juick/ws/s2s/ConnectionIn.java
@@ -88,7 +88,7 @@ public class ConnectionIn extends Connection implements Runnable {
                             c.sendDialbackVerify(streamID, dbKey);
                         } else {
                             c = new ConnectionOut(xmpp, dfrom, streamID, dbKey);
-                            xmpp.executorService.submit(c);
+                            xmpp.service.submit(c);
                         }
                     } else {
                         throw new HostUnknownException("STREAM FROM " + dfrom + " " + streamID + " INVALID TO " + to);
diff --git a/juick-ws/src/main/java/com/juick/ws/s2s/JuickBot.java b/juick-ws/src/main/java/com/juick/ws/s2s/JuickBot.java
index 14c63b59..659b7ecd 100644
--- a/juick-ws/src/main/java/com/juick/ws/s2s/JuickBot.java
+++ b/juick-ws/src/main/java/com/juick/ws/s2s/JuickBot.java
@@ -75,7 +75,7 @@ public class JuickBot {
         } else if (p.type.equals(Presence.Type.probe)) {
             int uid_to = 0;
             if (!toJuick) {
-                uid_to = UserQueries.getUIDbyName(xmpp.getSql(), username);
+                uid_to = UserQueries.getUIDbyName(xmpp.jdbc, username);
             }
 
             if (toJuick || uid_to > 0) {
@@ -98,9 +98,9 @@ public class JuickBot {
             if (toJuick) {
                 canSubscribe = true;
             } else {
-                int uid_to = UserQueries.getUIDbyName(xmpp.getSql(), username);
+                int uid_to = UserQueries.getUIDbyName(xmpp.jdbc, username);
                 if (uid_to > 0) {
-                    PMQueries.addPMinRoster(xmpp.getSql(), uid_to, p.from.Bare());
+                    PMQueries.addPMinRoster(xmpp.jdbc, uid_to, p.from.Bare());
                     canSubscribe = true;
                 }
             }
@@ -124,9 +124,9 @@ public class JuickBot {
             }
         } else if (p.type.equals(Presence.Type.unsubscribe)) {
             if (!toJuick) {
-                int uid_to = UserQueries.getUIDbyName(xmpp.getSql(), username);
+                int uid_to = UserQueries.getUIDbyName(xmpp.jdbc, username);
                 if (uid_to > 0) {
-                    PMQueries.removePMinRoster(xmpp.getSql(), uid_to, p.from.Bare());
+                    PMQueries.removePMinRoster(xmpp.jdbc, uid_to, p.from.Bare());
                 }
             }
 
@@ -146,9 +146,9 @@ public class JuickBot {
 
         User user_from = null;
         String signuphash = "";
-        user_from = UserQueries.getUserByJID(xmpp.getSql(), msg.from.Bare());
+        user_from = UserQueries.getUserByJID(xmpp.jdbc, msg.from.Bare());
         if (user_from == null) {
-            signuphash = UserQueries.getSignUpHashByJID(xmpp.getSql(), msg.from.Bare());
+            signuphash = UserQueries.getSignUpHashByJID(xmpp.jdbc, msg.from.Bare());
         }
 
         if (user_from == null) {
@@ -166,7 +166,7 @@ public class JuickBot {
             return incomingMessageJuick(user_from, msg);
         }
 
-        int uid_to = UserQueries.getUIDbyName(xmpp.getSql(), username);
+        int uid_to = UserQueries.getUIDbyName(xmpp.jdbc, username);
 
         if (uid_to == 0) {
             Message reply = new Message(msg.to, msg.from, Message.Type.error);
@@ -177,8 +177,8 @@ public class JuickBot {
         }
 
         boolean success = false;
-        if (!UserQueries.isInBLAny(xmpp.getSql(), uid_to, user_from.getUID())) {
-            success = PMQueries.createPM(xmpp.getSql(), user_from.getUID(), uid_to, msg.body);
+        if (!UserQueries.isInBLAny(xmpp.jdbc, uid_to, user_from.getUID())) {
+            success = PMQueries.createPM(xmpp.jdbc, user_from.getUID(), uid_to, msg.body);
         }
 
         if (success) {
@@ -196,12 +196,12 @@ public class JuickBot {
 
             List<String> jids;
             boolean inroster = false;
-            jids = UserQueries.getJIDsbyUID(xmpp.getSql(), uid_to);
+            jids = UserQueries.getJIDsbyUID(xmpp.jdbc, uid_to);
             for (String jid : jids) {
                 Message mm = new Message();
                 mm.to = new JID(jid);
                 mm.type = Message.Type.chat;
-                inroster = PMQueries.havePMinRoster(xmpp.getSql(), user_from.getUID(), jid);
+                inroster = PMQueries.havePMinRoster(xmpp.jdbc, user_from.getUID(), jid);
                 if (inroster) {
                     mm.from = new JID(jmsg.getUser().getUName(), "juick.com", "Juick");
                     mm.body = msg.body;
@@ -277,7 +277,7 @@ public class JuickBot {
 
     private void commandLogin(Message m, User user_from) throws Exception {
         Message reply = new Message(JuickJID, m.from, Message.Type.chat);
-        reply.body = "http://juick.com/login?" + UserQueries.getHashByUID(xmpp.getSql(), user_from.getUID());
+        reply.body = "http://juick.com/login?" + UserQueries.getHashByUID(xmpp.jdbc, user_from.getUID());
         xmpp.sendOut(reply);
     }
 
@@ -289,15 +289,15 @@ public class JuickBot {
         boolean haveInRoster = false;
 
         if (user_to.indexOf('@') > 0) {
-            uid_to = UserQueries.getUIDbyJID(xmpp.getSql(), user_to);
+            uid_to = UserQueries.getUIDbyJID(xmpp.jdbc, user_to);
         } else {
-            uid_to = UserQueries.getUIDbyName(xmpp.getSql(), user_to);
+            uid_to = UserQueries.getUIDbyName(xmpp.jdbc, user_to);
         }
 
         if (uid_to > 0) {
-            if (!UserQueries.isInBLAny(xmpp.getSql(), uid_to, user_from.getUID())) {
-                if (PMQueries.createPM(xmpp.getSql(), user_from.getUID(), uid_to, body)) {
-                    jids_to = UserQueries.getJIDsbyUID(xmpp.getSql(), uid_to);
+            if (!UserQueries.isInBLAny(xmpp.jdbc, uid_to, user_from.getUID())) {
+                if (PMQueries.createPM(xmpp.jdbc, user_from.getUID(), uid_to, body)) {
+                    jids_to = UserQueries.getJIDsbyUID(xmpp.jdbc, uid_to);
                     ret = 200;
                 } else {
                     ret = 500;
@@ -326,7 +326,7 @@ public class JuickBot {
                 Message mm = new Message();
                 mm.to = new JID(jid);
                 mm.type = Message.Type.chat;
-                haveInRoster = PMQueries.havePMinRoster(xmpp.getSql(), user_from.getUID(), jid);
+                haveInRoster = PMQueries.havePMinRoster(xmpp.jdbc, user_from.getUID(), jid);
                 if (haveInRoster) {
                     mm.from = new JID(user_from.getUName(), "juick.com", "Juick");
                     mm.body = body;
@@ -350,8 +350,8 @@ public class JuickBot {
     }
 
     private void commandBLShow(Message m, User user_from) throws Exception {
-        List<User> blusers = UserQueries.getUserBLUsers(xmpp.getSql(), user_from.getUID());
-        List<String> bltags = TagQueries.getUserBLTags(xmpp.getSql(), user_from.getUID());
+        List<User> blusers = UserQueries.getUserBLUsers(xmpp.jdbc, user_from.getUID());
+        List<String> bltags = TagQueries.getUserBLTags(xmpp.jdbc, user_from.getUID());
 
         String txt = "";
         if (bltags.size() > 0) {