add ShutdownListener

Mumfrey
1 parent 3810e896
Showing 4 changed files with 50 additions and 3 deletions
java/client/com/mumfrey/liteloader/client/api/LiteLoaderCoreAPIClient.java
java/common/com/mumfrey/liteloader/ShutdownListener.java
java/common/com/mumfrey/liteloader/core/LiteLoaderEventBroker.java
java/common/com/mumfrey/liteloader/interfaces/FastIterable.java
@@ -125,10 +125,13 @@ public class LiteLoaderCoreAPIClient extends LiteLoaderCoreAPI
 	@Override
 	public List<Observer> getObservers()
 	{
+		ObjectFactory<?, ?> objectFactory = this.getObjectFactory();
+		
 		return ImmutableList.<Observer>of
 		(
 			new ResourceObserver(),
-			this.getObjectFactory().getPanelManager()
+			objectFactory.getPanelManager(),
+			objectFactory.getEventBroker()
 		);
 	}
  
+package com.mumfrey.liteloader;
+
+/**
+ * Interface for mods that want to receive an event when the game is shutting down due to a user request. They do
+ * not receive the callback when the VM is terminating for other reasons, use a regular VM shutdownhook for that.
+ * 
+ * @author Adam Mummery-Smith
+ */
+public interface ShutdownListener extends LiteMod
+{
+	public abstract void onShutDown();
+}
@@ -35,8 +35,10 @@ import com.mumfrey.liteloader.ServerCommandProvider;
 import com.mumfrey.liteloader.ServerPlayerListener;
 import com.mumfrey.liteloader.ServerPluginChannelListener;
 import com.mumfrey.liteloader.ServerTickable;
+import com.mumfrey.liteloader.ShutdownListener;
 import com.mumfrey.liteloader.api.InterfaceProvider;
 import com.mumfrey.liteloader.api.Listener;
+import com.mumfrey.liteloader.api.ShutdownObserver;
 import com.mumfrey.liteloader.common.GameEngine;
 import com.mumfrey.liteloader.common.LoadingProgress;
 import com.mumfrey.liteloader.core.event.HandlerList;
@@ -54,7 +56,7 @@ import com.mumfrey.liteloader.util.log.LiteLoaderLogger;
  * @param <TClient> Type of the client runtime, "Minecraft" on client and null on the server
  * @param <TServer> Type of the server runtime, "IntegratedServer" on the client, "MinecraftServer" on the server 
  */
-public abstract class LiteLoaderEventBroker<TClient, TServer extends MinecraftServer> implements InterfaceProvider
+public abstract class LiteLoaderEventBroker<TClient, TServer extends MinecraftServer> implements InterfaceProvider, ShutdownObserver
 {
 	/**
 	 * @author Adam Mummery-Smith
@@ -152,6 +154,11 @@ public abstract class LiteLoaderEventBroker&lt;TClient, TServer extends MinecraftSe
 	private FastIterable<ServerTickable> serverTickListeners = new HandlerList<ServerTickable>(ServerTickable.class);
  
 	/**
+	 * List of mods which want to be notified when the game is shutting down
+	 */
+	private FastIterable<ShutdownListener> shutdownListeners = new HandlerList<ShutdownListener>(ShutdownListener.class);
+	
+	/**
 	 * ctor
 	 * 
 	 * @param loader
@@ -210,6 +217,7 @@ public abstract class LiteLoaderEventBroker&lt;TClient, TServer extends MinecraftSe
 		delegate.registerInterface(PlayerMoveListener.class);
 		delegate.registerInterface(CommonPluginChannelListener.class);
 		delegate.registerInterface(ServerTickable.class);
+		delegate.registerInterface(ShutdownListener.class);
 	}
  
 	/**
@@ -264,6 +272,14 @@ public abstract class LiteLoaderEventBroker&lt;TClient, TServer extends MinecraftSe
 	{
 		this.serverTickListeners.add(serverTickable);
 	}
+	
+	/**
+	 * @param shutdownListener
+	 */
+	public void addShutdownListener(ShutdownListener shutdownListener)
+	{
+		this.shutdownListeners.add(shutdownListener);
+	}
  
 	/**
 	 * @param instance
@@ -510,4 +526,20 @@ public abstract class LiteLoaderEventBroker&lt;TClient, TServer extends MinecraftSe
 			this.playerStateList.remove(playerState);
 		}
 	}
+	
+	@Override
+	public void onShutDown()
+	{
+		for (ShutdownListener listener : this.shutdownListeners)
+		{
+			try
+			{
+				listener.onShutDown();
+			}
+			catch (Throwable th)
+			{
+				th.printStackTrace();
+			}
+		}
+	}
 }
@@ -7,7 +7,7 @@ package com.mumfrey.liteloader.interfaces;
  *
  * @param <T>
  */
-public interface FastIterable<T>
+public interface FastIterable<T> extends Iterable<T>
 {
 	/**
 	 * Add an entry to the iterable