package name change to net.ess3

3 files changed, 294 insertions, 0 deletions

diff --git a/EssentialsGeoIP/src/net/ess3/geoip/ConfigHolder.java b/EssentialsGeoIP/src/net/ess3/geoip/ConfigHolder.java
new file mode 100644
index 000000000..068a1ba45
--- /dev/null
+++ b/EssentialsGeoIP/src/net/ess3/geoip/ConfigHolder.java
@@ -0,0 +1,37 @@
+package net.ess3.geoip;
+
+import net.ess3.api.IEssentials;
+import net.ess3.settings.geoip.GeoIP;
+import net.ess3.storage.AsyncStorageObjectHolder;
+import java.io.File;
+import java.io.IOException;
+import org.bukkit.plugin.Plugin;
+
+
+public class ConfigHolder extends AsyncStorageObjectHolder<GeoIP>
+{
+	private final transient Plugin geoip;
+
+	public ConfigHolder(final IEssentials ess, final Plugin geoip)
+	{
+		super(ess, GeoIP.class);
+		this.geoip = geoip;
+		onReload();
+	}
+
+	@Override
+	public File getStorageFile() throws IOException
+	{
+		return new File(geoip.getDataFolder(), "config.yml");
+	}
+
+	@Override
+	public void finishRead()
+	{
+	}
+
+	@Override
+	public void finishWrite()
+	{
+	}
+}
diff --git a/EssentialsGeoIP/src/net/ess3/geoip/EssentialsGeoIP.java b/EssentialsGeoIP/src/net/ess3/geoip/EssentialsGeoIP.java
new file mode 100644
index 000000000..9767f213b
--- /dev/null
+++ b/EssentialsGeoIP/src/net/ess3/geoip/EssentialsGeoIP.java
@@ -0,0 +1,32 @@
+package net.ess3.geoip;
+
+import static net.ess3.I18n._;
+import net.ess3.api.IEssentials;
+import java.util.logging.Level;
+import org.bukkit.plugin.PluginManager;
+import org.bukkit.plugin.java.JavaPlugin;
+
+
+public class EssentialsGeoIP extends JavaPlugin
+{
+	@Override
+	public void onEnable()
+	{
+		final PluginManager pm = getServer().getPluginManager();
+		final IEssentials ess = (IEssentials)pm.getPlugin("Essentials-3");
+		if (!this.getDescription().getVersion().equals(ess.getDescription().getVersion()))
+		{
+			getLogger().log(Level.WARNING, _("versionMismatchAll"));
+		}
+		if (!ess.isEnabled())
+		{
+			this.setEnabled(false);
+			return;
+		}
+		final EssentialsGeoIPPlayerListener playerListener = new EssentialsGeoIPPlayerListener(this, ess);
+		pm.registerEvents(playerListener, this);
+		ess.addReloadListener(playerListener);
+
+		getLogger().log(Level.INFO, "This product includes GeoLite data created by MaxMind, available from http://www.maxmind.com/.");
+	}
+}
diff --git a/EssentialsGeoIP/src/net/ess3/geoip/EssentialsGeoIPPlayerListener.java b/EssentialsGeoIP/src/net/ess3/geoip/EssentialsGeoIPPlayerListener.java
new file mode 100644
index 000000000..a6bbeffec
--- /dev/null
+++ b/EssentialsGeoIP/src/net/ess3/geoip/EssentialsGeoIPPlayerListener.java
@@ -0,0 +1,225 @@
+package net.ess3.geoip;
+
+import static net.ess3.I18n._;
+import net.ess3.api.IEssentials;
+import net.ess3.api.IReload;
+import net.ess3.api.IUser;
+import net.ess3.permissions.Permissions;
+import com.maxmind.geoip.Location;
+import com.maxmind.geoip.LookupService;
+import com.maxmind.geoip.regionName;
+import java.io.*;
+import java.net.InetAddress;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.net.URLConnection;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+import java.util.zip.GZIPInputStream;
+import org.bukkit.entity.Player;
+import org.bukkit.event.EventHandler;
+import org.bukkit.event.EventPriority;
+import org.bukkit.event.Listener;
+import org.bukkit.event.player.PlayerJoinEvent;
+import org.bukkit.plugin.Plugin;
+
+
+public class EssentialsGeoIPPlayerListener implements Listener, IReload
+{
+	private transient LookupService ls = null;
+	private static final Logger LOGGER = Logger.getLogger("Minecraft");
+	private transient File databaseFile;
+	private final transient ConfigHolder config;
+	private final transient IEssentials ess;
+	private final transient Plugin geoip;
+
+	public EssentialsGeoIPPlayerListener(final Plugin geoip, final IEssentials ess)
+	{
+		super();
+		this.ess = ess;
+		this.geoip = geoip;
+		this.config = new ConfigHolder(ess, geoip);
+		onReload();
+	}
+
+	@EventHandler(priority = EventPriority.MONITOR)
+	public void onPlayerJoin(final PlayerJoinEvent event)
+	{
+		final IUser u = ess.getUser(event.getPlayer());
+		if (Permissions.GEOIP_HIDE.isAuthorized(u))
+		{
+			return;
+		}
+		config.acquireReadLock();
+		try
+		{
+			final InetAddress address = event.getPlayer().getAddress().getAddress();
+			final StringBuilder builder = new StringBuilder();
+			if (config.getData().getDatabase().isShowCities())
+			{
+				final Location loc = ls.getLocation(address);
+				if (loc == null)
+				{
+					return;
+				}
+				if (loc.city != null)
+				{
+					builder.append(loc.city).append(", ");
+				}
+				final String region = regionName.regionNameByCode(loc.countryCode, loc.region);
+				if (region != null)
+				{
+					builder.append(region).append(", ");
+				}
+				builder.append(loc.countryName);
+			}
+			else
+			{
+				builder.append(ls.getCountry(address).getName());
+			}
+			if (config.getData().isShowOnWhois())
+			{
+				u.acquireWriteLock();
+				try
+				{
+					u.getData().setGeolocation(builder.toString());
+				}
+				finally
+				{
+					u.unlock();
+				}
+			}
+			if (config.getData().isShowOnLogin() && !u.isHidden())
+			{
+				for (Player player : event.getPlayer().getServer().getOnlinePlayers())
+				{
+					final IUser user = ess.getUser(player);
+					if (Permissions.GEOIP_SHOW.isAuthorized(user))
+					{
+						user.sendMessage(_("geoipJoinFormat", user.getDisplayName(), builder.toString()));
+					}
+				}
+			}
+		}
+		finally
+		{
+			config.unlock();
+		}
+	}
+
+	@Override
+	public final void onReload()
+	{
+		config.onReload();
+		config.acquireReadLock();
+		try
+		{
+			if (config.getData().getDatabase().isShowCities())
+			{
+				databaseFile = new File(geoip.getDataFolder(), "GeoIPCity.dat");
+			}
+			else
+			{
+				databaseFile = new File(geoip.getDataFolder(), "GeoIP.dat");
+			}
+			if (!databaseFile.exists())
+			{
+				if (config.getData().getDatabase().isDownloadIfMissing())
+				{
+					if (config.getData().getDatabase().isShowCities())
+					{
+						downloadDatabase(config.getData().getDatabase().getDownloadUrlCity());
+					}
+					else
+					{
+						downloadDatabase(config.getData().getDatabase().getDownloadUrl());
+					}
+				}
+				else
+				{
+					LOGGER.log(Level.SEVERE, _("cantFindGeoIpDB"));
+					return;
+				}
+			}
+			try
+			{
+				ls = new LookupService(databaseFile);
+			}
+			catch (IOException ex)
+			{
+				LOGGER.log(Level.SEVERE, _("cantReadGeoIpDB"), ex);
+			}
+		}
+		finally
+		{
+			config.unlock();
+		}
+	}
+
+	private void downloadDatabase(final String url)
+	{
+		if (url == null || url.isEmpty())
+		{
+			LOGGER.log(Level.SEVERE, _("geoIpUrlEmpty"));
+			return;
+		}
+		InputStream input = null;
+		OutputStream output = null;
+		try
+		{
+			LOGGER.log(Level.INFO, _("downloadingGeoIp"));
+			final URL downloadUrl = new URL(url);
+			final URLConnection conn = downloadUrl.openConnection();
+			conn.setConnectTimeout(10000);
+			conn.connect();
+			input = conn.getInputStream();
+			if (url.endsWith(".gz"))
+			{
+				input = new GZIPInputStream(input);
+			}
+			output = new FileOutputStream(databaseFile);
+			final byte[] buffer = new byte[2048];
+			int length = input.read(buffer);
+			while (length >= 0)
+			{
+				output.write(buffer, 0, length);
+				length = input.read(buffer);
+			}
+			input.close();
+			output.close();
+		}
+		catch (MalformedURLException ex)
+		{
+			LOGGER.log(Level.SEVERE, _("geoIpUrlInvalid"), ex);
+		}
+		catch (IOException ex)
+		{
+			LOGGER.log(Level.SEVERE, _("connectionFailed"), ex);
+		}
+		finally
+		{
+			if (output != null)
+			{
+				try
+				{
+					output.close();
+				}
+				catch (IOException ex)
+				{
+					LOGGER.log(Level.SEVERE, _("connectionFailed"), ex);
+				}
+			}
+			if (input != null)
+			{
+				try
+				{
+					input.close();
+				}
+				catch (IOException ex)
+				{
+					LOGGER.log(Level.SEVERE, _("connectionFailed"), ex);
+				}
+			}
+		}
+	}
+}