1 files changed, 31 insertions, 6 deletions

diff --git a/juick-core/src/main/java/com/juick/server/CrosspostQueries.java b/juick-core/src/main/java/com/juick/server/CrosspostQueries.java
index 04898d0a..827dad09 100644
--- a/juick-core/src/main/java/com/juick/server/CrosspostQueries.java
+++ b/juick-core/src/main/java/com/juick/server/CrosspostQueries.java
@@ -17,6 +17,7 @@
  */
 package com.juick.server;
 
+import com.juick.server.helpers.ApplicationStatus;
 import org.apache.commons.lang3.tuple.Pair;
 import org.springframework.dao.EmptyResultDataAccessException;
 import org.springframework.jdbc.core.JdbcTemplate;
@@ -32,9 +33,7 @@ public class CrosspostQueries {
     public static Optional<Pair<String, String>> getTwitterTokens(JdbcTemplate sql, int uid) {
         try {
             return sql.queryForObject("SELECT access_token,access_token_secret FROM twitter WHERE user_id=? AND crosspost=1",
-                    (rs, num) -> {
-                        return Optional.of(Pair.of(rs.getString(1), rs.getString(2)));
-                    }, uid);
+                    (rs, num) -> Optional.of(Pair.of(rs.getString(1), rs.getString(2))), uid);
         } catch (EmptyResultDataAccessException e) {
             return Optional.empty();
         }
@@ -48,13 +47,39 @@ public class CrosspostQueries {
             return Optional.empty();
         }
     }
+    public static ApplicationStatus isFBCrossPostEnabled(JdbcTemplate sql, int uid) {
+        try {
+            return sql.queryForObject("SELECT 1, crosspost FROM facebook WHERE user_id=? LIMIT 1", (rs, num) -> {
+                ApplicationStatus status = new ApplicationStatus();
+                status.setConnected(rs.getInt(1) > 0);
+                status.setCrosspostEnabled(rs.getBoolean(2));
+                return status;
+            }, uid);
+        } catch (EmptyResultDataAccessException e) {
+            return new ApplicationStatus();
+        }
+    }
+
+    public static String getTwitterName(JdbcTemplate sql, int uid) {
+        try {
+            return sql.queryForObject("SELECT uname FROM twitter WHERE user_id=?", String.class, uid);
+        } catch (EmptyResultDataAccessException e) {
+            return "";
+        }
+    }
+
+    public static String getTelegramName(JdbcTemplate sql, int uid) {
+        try {
+            return sql.queryForObject("SELECT tg_name FROM telegram WHERE user_id=?", String.class, uid);
+        } catch (EmptyResultDataAccessException e) {
+            return "";
+        }
+    }
 
     public static Optional<Pair<String, String>> getVKTokens(JdbcTemplate sql, int uid) {
         try {
             return sql.queryForObject("SELECT vk_id,access_token FROM vk WHERE user_id=? AND crosspost=1",
-                    (rs, num) -> {
-                        return Optional.of(Pair.of(rs.getString(1), rs.getString(2)));
-                    }, uid);
+                    (rs, num) -> Optional.of(Pair.of(rs.getString(1), rs.getString(2))), uid);
         } catch (EmptyResultDataAccessException e) {
             return Optional.empty();
         }