Allow extraction for Condenser (#3179)

fixes #2960, fixes #2017, fixes #2602

src/main/java/appeng/tile/misc/CondenserItemInventory.java

@@ -19,23 +19,37 @@
 package appeng.tile.misc;
 
 
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map.Entry;
+
+import net.minecraft.item.ItemStack;
+
 import appeng.api.AEApi;
 import appeng.api.config.AccessRestriction;
 import appeng.api.config.Actionable;
 import appeng.api.networking.security.IActionSource;
+import appeng.api.networking.ticking.TickRateModulation;
 import appeng.api.storage.IMEMonitor;
 import appeng.api.storage.IMEMonitorHandlerReceiver;
 import appeng.api.storage.IStorageChannel;
 import appeng.api.storage.channels.IItemStorageChannel;
 import appeng.api.storage.data.IAEItemStack;
 import appeng.api.storage.data.IItemList;
+import appeng.me.helpers.BaseActionSource;
+import appeng.me.storage.ITickingMonitor;
+import appeng.util.item.AEItemStack;
 import appeng.util.item.ItemList;
 
 
-class CondenserItemInventory implements IMEMonitor<IAEItemStack>
+class CondenserItemInventory implements IMEMonitor<IAEItemStack>, ITickingMonitor
 {
-
+	private final HashMap<IMEMonitorHandlerReceiver<IAEItemStack>, Object> listeners = new HashMap<>();
 	private final TileCondenser target;
+	private boolean hasChanged = true;
+	private final ItemList cachedList = new ItemList();
+	private IActionSource actionSource = new BaseActionSource();
+	private ItemList changeSet = new ItemList();
 
 	CondenserItemInventory( final TileCondenser te )
 	{
@@ -49,30 +63,46 @@ class CondenserItemInventory implements IMEMonitor<IAEItemStack>
 		{
 			this.target.addPower( input.getStackSize() );
 		}
-
 		return null;
 	}
 
 	@Override
 	public IAEItemStack extractItems( final IAEItemStack request, final Actionable mode, final IActionSource src )
 	{
-		return null;
+		AEItemStack ret = null;
+		ItemStack slotItem = target.getOutputSlot().getStackInSlot( 0 );
+		if( !slotItem.isEmpty() && request.isSameType( slotItem ) )
+		{
+			int count = (int) Math.min( request.getStackSize(), Integer.MAX_VALUE );
+			ret = AEItemStack.fromItemStack( target.getOutputSlot().extractItem( 0, count, mode == Actionable.SIMULATE ) );
+		}
+		return ret;
 	}
 
 	@Override
-	public IItemList<IAEItemStack> getAvailableItems( final IItemList out )
+	public IItemList<IAEItemStack> getAvailableItems( final IItemList<IAEItemStack> out )
 	{
+		if( !target.getOutputSlot().getStackInSlot( 0 ).isEmpty() )
+		{
+			out.add( AEItemStack.fromItemStack( target.getOutputSlot().getStackInSlot( 0 ) ) );
+		}
 		return out;
 	}
 
 	@Override
 	public IItemList<IAEItemStack> getStorageList()
 	{
-		return new ItemList();
+		if( this.hasChanged )
+		{
+			this.hasChanged = false;
+			this.cachedList.resetStatus();
+			return this.getAvailableItems( this.cachedList );
+		}
+		return this.cachedList;
 	}
 
 	@Override
-	public IStorageChannel getChannel()
+	public IStorageChannel<IAEItemStack> getChannel()
 	{
 		return AEApi.instance().storage().getStorageChannel( IItemStorageChannel.class );
 	}
@@ -80,7 +110,7 @@ class CondenserItemInventory implements IMEMonitor<IAEItemStack>
 	@Override
 	public AccessRestriction getAccess()
 	{
-		return AccessRestriction.WRITE;
+		return AccessRestriction.READ_WRITE;
 	}
 
 	@Override
@@ -114,14 +144,62 @@ class CondenserItemInventory implements IMEMonitor<IAEItemStack>
 	}
 
 	@Override
-	public void addListener( IMEMonitorHandlerReceiver<IAEItemStack> l, Object verificationToken )
+	public void addListener( final IMEMonitorHandlerReceiver<IAEItemStack> l, final Object verificationToken )
 	{
-		// Not implemented since the Condenser automatically voids everything, and there are no updates
+		this.listeners.put( l, verificationToken );
 	}
 
 	@Override
-	public void removeListener( IMEMonitorHandlerReceiver<IAEItemStack> l )
+	public void removeListener( final IMEMonitorHandlerReceiver<IAEItemStack> l )
 	{
-		// Not implemented since we don't remember registered listeners anyway
+		this.listeners.remove( l );
+	}
+
+	public void updateOutput( ItemStack added, ItemStack removed )
+	{
+		this.hasChanged = true;
+		if( !added.isEmpty() )
+		{
+			this.changeSet.add( AEItemStack.fromItemStack( added ) );
+		}
+		if( !removed.isEmpty() )
+		{
+			this.changeSet.add( AEItemStack.fromItemStack( removed ).setStackSize( -removed.getCount() ) );
+		}
+	}
+
+	@Override
+	public TickRateModulation onTick()
+	{
+		final ItemList currentChanges = this.changeSet;
+
+		if( currentChanges.isEmpty() )
+		{
+			return TickRateModulation.IDLE;
+		}
+
+		this.changeSet = new ItemList();
+		final Iterator<Entry<IMEMonitorHandlerReceiver<IAEItemStack>, Object>> i = this.listeners.entrySet().iterator();
+		while( i.hasNext() )
+		{
+			final Entry<IMEMonitorHandlerReceiver<IAEItemStack>, Object> l = i.next();
+			final IMEMonitorHandlerReceiver<IAEItemStack> key = l.getKey();
+			if( key.isValid( l.getValue() ) )
+			{
+				key.postChange( this, currentChanges, this.actionSource );
+			}
+			else
+			{
+				i.remove();
+			}
+		}
+
+		return TickRateModulation.URGENT;
+	}
+
+	@Override
+	public void setActionSource( IActionSource actionSource )
+	{
+		this.actionSource = actionSource;
 	}
 }