1 files changed, 65 insertions, 1 deletions
diff --git a/juick-core/src/main/java/com/juick/server/UserQueries.java b/juick-core/src/main/java/com/juick/server/UserQueries.java
index b79f179c..50e3562f 100644
--- a/juick-core/src/main/java/com/juick/server/UserQueries.java
+++ b/juick-core/src/main/java/com/juick/server/UserQueries.java
@@ -18,6 +18,9 @@
 package com.juick.server;
 
 import com.juick.User;
+import com.juick.server.helpers.Auth;
+import com.juick.server.helpers.EmailOpts;
+import com.juick.server.helpers.UserInfo;
 import org.springframework.dao.DuplicateKeyException;
 import org.springframework.dao.EmptyResultDataAccessException;
 import org.springframework.jdbc.core.JdbcTemplate;
@@ -31,7 +34,6 @@ import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Statement;
 import java.util.*;
-import java.util.stream.Collectors;
 
 /**
  *
@@ -242,6 +244,18 @@ public class UserQueries {
         }
     }
 
+    public static boolean updatePassword(JdbcTemplate sql, User user, String newPassword) {
+        return user.getUID() > 0 && sql.update("UPDATE users SET passw=? WHERE id=?", newPassword, user.getUID()) > 0;
+    }
+
+    public static String updateSecretEmail(JdbcTemplate sql, User user) {
+        String newHash = generateHash(16);
+        if (sql.update("INSERT INTO mail(user_id,hash) VALUES (?,?) ON DUPLICATE KEY UPDATE hash=?", user.getUID(), newHash, newHash) > 0) {
+            return newHash;
+        }
+        return "";
+    }
+
     public static int getUserOptionInt(JdbcTemplate sql, int uid, String option, int defaultValue) {
         try {
             return sql.queryForObject("SELECT " + option + " FROM useroptions WHERE user_id=?", Integer.class, uid);
@@ -254,6 +268,28 @@ public class UserQueries {
         sql.update("UPDATE useroptions SET " + option + "=? WHERE user_id=?", value, uid);
     }
 
+    public static UserInfo getUserInfo(JdbcTemplate sql, User user) {
+        try {
+            return sql.queryForObject("SELECT fullname,country,url,descr FROM usersinfo WHERE user_id=?", ((rs, rowNum) -> {
+                UserInfo info = new UserInfo();
+                info.setFullName(rs.getString(1));
+                info.setCountry(rs.getString(2));
+                info.setUrl(rs.getString(3));
+                info.setDescription(rs.getString(4));
+                return info;
+            }), user.getUID());
+        } catch (EmptyResultDataAccessException e) {
+            return new UserInfo();
+        }
+    }
+
+    public static boolean updateUserInfo(JdbcTemplate sql, User user, UserInfo info) {
+        return sql.update("INSERT INTO usersinfo(user_id,fullname,country,url,descr) VALUES (?,?,?,?,?) " +
+                "ON DUPLICATE KEY UPDATE fullname=?,country=?,url=?,descr=?", user.getUID(), info.getFullName(),
+                info.getCountry(), info.getUrl(), info.getDescription(), info.getFullName(),
+                info.getCountry(), info.getUrl(), info.getDescription()) > 0;
+    }
+
     public static boolean getCanMedia(JdbcTemplate sql, int uid) {
         try {
             int res = sql.queryForObject("SELECT users.lastphoto-UNIX_TIMESTAMP() FROM users WHERE id=?",
@@ -429,4 +465,32 @@ public class UserQueries {
         }
         return false;
     }
+    public static List<String> getAllJIDs(JdbcTemplate sql, User user) {
+        return sql.queryForList("SELECT jid FROM jids WHERE user_id=?", String.class, user.getUID());
+    }
+    public static List<Auth> getAuthCodes(JdbcTemplate sql, User user) {
+        return sql.query("SELECT account,authcode FROM auth WHERE user_id=? AND protocol='xmpp'",
+                (rs, num) -> new Auth(rs.getString(1), rs.getString(2)), user.getUID());
+    }
+
+    public static List<String> getEmails(JdbcTemplate sql, User user) {
+        return sql.queryForList("SELECT email FROM emails WHERE user_id=?", String.class, user.getUID());
+    }
+
+    public static EmailOpts getEmailOpts(JdbcTemplate sql, User user) {
+        try {
+            return sql.queryForObject("SELECT email,subscr_hour FROM emails WHERE user_id=? AND subscr_hour IS NOT NULL",
+                    (rs, num) ->new EmailOpts(rs.getString(1), rs.getInt(2)), user.getUID());
+        } catch (EmptyResultDataAccessException e) {
+            return null;
+        }
+    }
+    public static String getEmailHash(JdbcTemplate sql, User user) {
+        try {
+            return sql.queryForObject("SELECT hash FROM mail WHERE user_id=?", String.class, user.getUID())
+                    + "@mail.juick.com";
+        } catch (EmptyResultDataAccessException e) {
+            return "";
+        }
+    }
 }