#1127 Create DataSource#getEmail

src/main/java/fr/xephi/authme/command/executable/authme/GetEmailCommand.java

@@ -1,8 +1,8 @@
 package fr.xephi.authme.command.executable.authme;
 
 import fr.xephi.authme.command.ExecutableCommand;
-import fr.xephi.authme.data.auth.PlayerAuth;
 import fr.xephi.authme.datasource.DataSource;
+import fr.xephi.authme.datasource.DataSourceResult;
 import fr.xephi.authme.message.MessageKey;
 import fr.xephi.authme.service.CommonService;
 import org.bukkit.command.CommandSender;
@@ -25,11 +25,11 @@ public class GetEmailCommand implements ExecutableCommand {
     public void executeCommand(CommandSender sender, List<String> arguments) {
         String playerName = arguments.isEmpty() ? sender.getName() : arguments.get(0);
 
-        PlayerAuth auth = dataSource.getAuth(playerName);
-        if (auth == null) {
-            commonService.send(sender, MessageKey.UNKNOWN_USER);
+        DataSourceResult<String> email = dataSource.getEmail(playerName);
+        if (email.playerExists()) {
+            sender.sendMessage("[AuthMe] " + playerName + "'s email: " + email.getValue());
         } else {
-            sender.sendMessage("[AuthMe] " + playerName + "'s email: " + auth.getEmail());
+            commonService.send(sender, MessageKey.UNKNOWN_USER);
         }
     }
 }

src/main/java/fr/xephi/authme/command/executable/authme/debug/TestEmailSender.java

@@ -1,8 +1,8 @@
 package fr.xephi.authme.command.executable.authme.debug;
 
 import fr.xephi.authme.ConsoleLogger;
-import fr.xephi.authme.data.auth.PlayerAuth;
 import fr.xephi.authme.datasource.DataSource;
+import fr.xephi.authme.datasource.DataSourceResult;
 import fr.xephi.authme.mail.SendMailSsl;
 import fr.xephi.authme.util.StringUtils;
 import org.apache.commons.mail.EmailException;
@@ -62,13 +62,13 @@ class TestEmailSender implements DebugSection {
 
     private String getEmail(CommandSender sender, List<String> arguments) {
         if (arguments.isEmpty()) {
-            PlayerAuth auth = dataSource.getAuth(sender.getName());
-            if (auth == null) {
+            DataSourceResult<String> emailResult = dataSource.getEmail(sender.getName());
+            if (!emailResult.playerExists()) {
                 sender.sendMessage(ChatColor.RED + "Please provide an email address, "
                     + "e.g. /authme debug mail test@example.com");
                 return null;
             }
-            String email = auth.getEmail();
+            final String email = emailResult.getValue();
             if (email == null || "your@email.com".equals(email)) {
                 sender.sendMessage(ChatColor.RED + "No email set for your account!"
                     + " Please use /authme debug mail <email>");

src/main/java/fr/xephi/authme/command/executable/email/RecoverEmailCommand.java

@@ -2,9 +2,9 @@ package fr.xephi.authme.command.executable.email;
 
 import fr.xephi.authme.ConsoleLogger;
 import fr.xephi.authme.command.PlayerCommand;
-import fr.xephi.authme.data.auth.PlayerAuth;
 import fr.xephi.authme.data.auth.PlayerCache;
 import fr.xephi.authme.datasource.DataSource;
+import fr.xephi.authme.datasource.DataSourceResult;
 import fr.xephi.authme.mail.EmailService;
 import fr.xephi.authme.message.MessageKey;
 import fr.xephi.authme.service.CommonService;
@@ -53,13 +53,13 @@ public class RecoverEmailCommand extends PlayerCommand {
             return;
         }
 
-        PlayerAuth auth = dataSource.getAuth(playerName); // TODO #1127: Create method to get email only
-        if (auth == null) {
+        DataSourceResult<String> emailResult = dataSource.getEmail(playerName);
+        if (!emailResult.playerExists()) {
             commonService.send(player, MessageKey.USAGE_REGISTER);
             return;
         }
 
-        final String email = auth.getEmail();
+        final String email = emailResult.getValue();
         if (email == null || !email.equalsIgnoreCase(playerMail) || "your@email.com".equalsIgnoreCase(email)) {
             commonService.send(player, MessageKey.INVALID_EMAIL);
             return;

src/main/java/fr/xephi/authme/datasource/CacheDataSource.java

@@ -23,16 +23,20 @@ import java.util.concurrent.TimeUnit;
 public class CacheDataSource implements DataSource {
 
     private final DataSource source;
+    private final PlayerCache playerCache;
     private final LoadingCache<String, Optional<PlayerAuth>> cachedAuths;
     private final ListeningExecutorService executorService;
 
     /**
      * Constructor for CacheDataSource.
      *
-     * @param src DataSource
+     * @param source the source
+     * @param playerCache the player cache
      */
-    public CacheDataSource(DataSource src) {
-        source = src;
+    public CacheDataSource(DataSource source, PlayerCache playerCache) {
+        this.source = source;
+        this.playerCache = playerCache;
+
         executorService = MoreExecutors.listeningDecorator(
             Executors.newCachedThreadPool(new ThreadFactoryBuilder()
                 .setDaemon(true)
@@ -168,17 +172,17 @@ public class CacheDataSource implements DataSource {
     }
 
     @Override
-    public List<String> getAllAuthsByIp(final String ip) {
+    public List<String> getAllAuthsByIp(String ip) {
         return source.getAllAuthsByIp(ip);
     }
 
     @Override
-    public int countAuthsByEmail(final String email) {
+    public int countAuthsByEmail(String email) {
         return source.countAuthsByEmail(email);
     }
 
     @Override
-    public void purgeRecords(final Collection<String> banned) {
+    public void purgeRecords(Collection<String> banned) {
         source.purgeRecords(banned);
         cachedAuths.invalidateAll(banned);
     }
@@ -190,7 +194,7 @@ public class CacheDataSource implements DataSource {
 
     @Override
     public boolean isLogged(String user) {
-        return PlayerCache.getInstance().isAuthenticated(user);
+        return playerCache.isAuthenticated(user);
     }
 
     @Override
@@ -223,6 +227,13 @@ public class CacheDataSource implements DataSource {
         return result;
     }
 
+    @Override
+    public DataSourceResult<String> getEmail(String user) {
+        return cachedAuths.getUnchecked(user)
+            .map(auth -> DataSourceResult.of(auth.getEmail()))
+            .orElse(DataSourceResult.unknownPlayer());
+    }
+
     @Override
     public List<PlayerAuth> getAllAuths() {
         return source.getAllAuths();
@@ -230,6 +241,6 @@ public class CacheDataSource implements DataSource {
 
     @Override
     public List<PlayerAuth> getLoggedPlayers() {
-        return new ArrayList<>(PlayerCache.getInstance().getCache().values());
+        return new ArrayList<>(playerCache.getCache().values());
     }
 }

src/main/java/fr/xephi/authme/datasource/DataSource.java

@@ -189,6 +189,14 @@ public interface DataSource extends Reloadable {
      */
     boolean updateRealName(String user, String realName);
 
+    /**
+     * Returns the email of the user.
+     *
+     * @param user the user to retrieve an email for
+     * @return the email saved for the user, or null if user or email is not present
+     */
+    DataSourceResult<String> getEmail(String user);
+
     /**
      * Return all players of the database.
      *

src/main/java/fr/xephi/authme/datasource/DataSourceResult.java

@@ -0,0 +1,53 @@
+package fr.xephi.authme.datasource;
+
+/**
+ * Wraps a value and allows to specify whether a value is missing or the player is not registered.
+ */
+public class DataSourceResult<T> {
+
+    /** Instance used when a player does not exist. */
+    private static final DataSourceResult UNKNOWN_PLAYER = new DataSourceResult<>(null);
+    private final T value;
+
+    private DataSourceResult(T value) {
+        this.value = value;
+    }
+
+    /**
+     * Returns a {@link DataSourceResult} for the given value.
+     *
+     * @param value the value to wrap
+     * @param <T> the value's type
+     * @return DataSourceResult object for the given value
+     */
+    public static <T> DataSourceResult<T> of(T value) {
+        return new DataSourceResult<>(value);
+    }
+
+    /**
+     * Returns a {@link DataSourceResult} specifying that the player does not exist.
+     *
+     * @param <T> the value type
+     * @return data source result for unknown player
+     */
+    public static <T> DataSourceResult<T> unknownPlayer() {
+        return UNKNOWN_PLAYER;
+    }
+
+    /**
+     * @return whether the player of the associated value exists
+     */
+    public boolean playerExists() {
+        return this != UNKNOWN_PLAYER;
+    }
+
+    /**
+     * Returns the value. It is {@code null} if the player is unknown. It is also {@code null}
+     * if the player exists but does not have the value defined.
+     *
+     * @return the value, or null
+     */
+    public T getValue() {
+        return value;
+    }
+}

src/main/java/fr/xephi/authme/datasource/FlatFile.java

@@ -396,6 +396,11 @@ public class FlatFile implements DataSource {
         throw new UnsupportedOperationException("Flat file no longer supported");
     }
 
+    @Override
+    public DataSourceResult<String> getEmail(String user) {
+        throw new UnsupportedOperationException("Flat file no longer supported");
+    }
+
     @Override
     public List<PlayerAuth> getAllAuths() {
         BufferedReader br = null;

src/main/java/fr/xephi/authme/datasource/MySQL.java

@@ -879,6 +879,22 @@ public class MySQL implements DataSource {
         return false;
     }
 
+    @Override
+    public DataSourceResult<String> getEmail(String user) {
+        String sql = "SELECT " + col.EMAIL + " FROM " + tableName + " WHERE " + col.NAME + "=?;";
+        try (Connection con = getConnection(); PreparedStatement pst = con.prepareStatement(sql)) {
+            pst.setString(1, user);
+            try (ResultSet rs = pst.executeQuery()) {
+                if (rs.next()) {
+                    return DataSourceResult.of(rs.getString(1));
+                }
+            }
+        } catch (SQLException ex) {
+            logSqlException(ex);
+        }
+        return DataSourceResult.unknownPlayer();
+    }
+
     @Override
     public List<PlayerAuth> getAllAuths() {
         List<PlayerAuth> auths = new ArrayList<>();

src/main/java/fr/xephi/authme/datasource/SQLite.java

@@ -559,6 +559,22 @@ public class SQLite implements DataSource {
         return false;
     }
 
+    @Override
+    public DataSourceResult<String> getEmail(String user) {
+        String sql = "SELECT " + col.EMAIL + " FROM " + tableName + " WHERE " + col.NAME + "=?;";
+        try (PreparedStatement pst = con.prepareStatement(sql)) {
+            pst.setString(1, user);
+            try (ResultSet rs = pst.executeQuery()) {
+                if (rs.next()) {
+                    return DataSourceResult.of(rs.getString(1));
+                }
+            }
+        } catch (SQLException ex) {
+            logSqlException(ex);
+        }
+        return DataSourceResult.unknownPlayer();
+    }
+
     @Override
     public List<PlayerAuth> getAllAuths() {
         List<PlayerAuth> auths = new ArrayList<>();

src/main/java/fr/xephi/authme/initialization/DataSourceProvider.java

@@ -1,6 +1,7 @@
 package fr.xephi.authme.initialization;
 
 import fr.xephi.authme.ConsoleLogger;
+import fr.xephi.authme.data.auth.PlayerCache;
 import fr.xephi.authme.datasource.CacheDataSource;
 import fr.xephi.authme.datasource.DataSource;
 import fr.xephi.authme.datasource.DataSourceType;
@@ -33,6 +34,8 @@ public class DataSourceProvider implements Provider<DataSource> {
     private Settings settings;
     @Inject
     private BukkitService bukkitService;
+    @Inject
+    private PlayerCache playerCache;
 
     DataSourceProvider() {
     }
@@ -76,7 +79,7 @@ public class DataSourceProvider implements Provider<DataSource> {
         dataSource = convertFlatfileToSqlite(dataSource);
 
         if (settings.getProperty(DatabaseSettings.USE_CACHING)) {
-            dataSource = new CacheDataSource(dataSource);
+            dataSource = new CacheDataSource(dataSource, playerCache);
         }
         if (DataSourceType.SQLITE.equals(dataSourceType)) {
             checkDataSourceSize(dataSource, bukkitService);