413 lines
9.1 KiB
Java
413 lines
9.1 KiB
Java
/*
|
|
* This file is part of Applied Energistics 2.
|
|
* Copyright (c) 2013 - 2015, AlgorithmX2, All rights reserved.
|
|
*
|
|
* Applied Energistics 2 is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU Lesser General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* Applied Energistics 2 is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public License
|
|
* along with Applied Energistics 2. If not, see <http://www.gnu.org/licenses/lgpl>.
|
|
*/
|
|
|
|
package appeng.parts.p2p;
|
|
|
|
|
|
import java.util.LinkedList;
|
|
import java.util.List;
|
|
|
|
import net.minecraft.entity.player.EntityPlayer;
|
|
import net.minecraft.inventory.IInventory;
|
|
import net.minecraft.inventory.ISidedInventory;
|
|
import net.minecraft.item.ItemStack;
|
|
import net.minecraft.tileentity.TileEntity;
|
|
import net.minecraft.tileentity.TileEntityChest;
|
|
import net.minecraft.util.EnumFacing;
|
|
import net.minecraft.util.IChatComponent;
|
|
|
|
import appeng.api.networking.IGridNode;
|
|
import appeng.api.networking.events.MENetworkBootingStatusChange;
|
|
import appeng.api.networking.events.MENetworkChannelsChanged;
|
|
import appeng.api.networking.events.MENetworkEventSubscribe;
|
|
import appeng.api.networking.events.MENetworkPowerStatusChange;
|
|
import appeng.api.networking.ticking.IGridTickable;
|
|
import appeng.api.networking.ticking.TickRateModulation;
|
|
import appeng.api.networking.ticking.TickingRequest;
|
|
import appeng.core.settings.TickRates;
|
|
import appeng.integration.IntegrationRegistry;
|
|
import appeng.integration.IntegrationType;
|
|
import appeng.integration.abstraction.IBuildCraftTransport;
|
|
import appeng.me.GridAccessException;
|
|
import appeng.me.cache.helpers.TunnelCollection;
|
|
import appeng.tile.inventory.AppEngNullInventory;
|
|
import appeng.util.Platform;
|
|
import appeng.util.inv.WrapperBCPipe;
|
|
import appeng.util.inv.WrapperChainedInventory;
|
|
import appeng.util.inv.WrapperMCISidedInventory;
|
|
|
|
|
|
// TODO: BC Integration
|
|
//@Integration.Interface( iface = "buildcraft.api.transport.IPipeConnection", iname = "BuildCraftTransport" )
|
|
public class PartP2PItems extends PartP2PTunnel<PartP2PItems> implements ISidedInventory, IGridTickable
|
|
{
|
|
|
|
final LinkedList<IInventory> which = new LinkedList<IInventory>();
|
|
int oldSize = 0;
|
|
boolean requested;
|
|
IInventory cachedInv;
|
|
|
|
public PartP2PItems( ItemStack is )
|
|
{
|
|
super( is );
|
|
}
|
|
|
|
@Override
|
|
public void onNeighborChanged()
|
|
{
|
|
this.cachedInv = null;
|
|
PartP2PItems input = this.getInput();
|
|
if( input != null && this.output )
|
|
{
|
|
input.onTunnelNetworkChange();
|
|
}
|
|
}
|
|
|
|
IInventory getDestination()
|
|
{
|
|
this.requested = true;
|
|
|
|
if( this.cachedInv != null )
|
|
{
|
|
return this.cachedInv;
|
|
}
|
|
|
|
List<IInventory> outs = new LinkedList<IInventory>();
|
|
TunnelCollection<PartP2PItems> itemTunnels;
|
|
|
|
try
|
|
{
|
|
itemTunnels = this.getOutputs();
|
|
}
|
|
catch( GridAccessException e )
|
|
{
|
|
return new AppEngNullInventory();
|
|
}
|
|
|
|
for( PartP2PItems t : itemTunnels )
|
|
{
|
|
IInventory inv = t.getOutputInv();
|
|
if( inv != null )
|
|
{
|
|
if( Platform.getRandomInt() % 2 == 0 )
|
|
{
|
|
outs.add( inv );
|
|
}
|
|
else
|
|
{
|
|
outs.add( 0, inv );
|
|
}
|
|
}
|
|
}
|
|
|
|
return this.cachedInv = new WrapperChainedInventory( outs );
|
|
}
|
|
|
|
IInventory getOutputInv()
|
|
{
|
|
IInventory output = null;
|
|
|
|
if( this.proxy.isActive() )
|
|
{
|
|
TileEntity te = this.tile.getWorld().getTileEntity( this.tile.getPos().offset( side.getFacing() ) );
|
|
|
|
if( this.which.contains( this ) )
|
|
{
|
|
return null;
|
|
}
|
|
|
|
this.which.add( this );
|
|
|
|
if( IntegrationRegistry.INSTANCE.isEnabled( IntegrationType.BuildCraftTransport ) )
|
|
{
|
|
final IBuildCraftTransport buildcraft = (IBuildCraftTransport) IntegrationRegistry.INSTANCE.getInstance( IntegrationType.BuildCraftTransport );
|
|
if( buildcraft.isPipe( te, this.side.getOpposite().getFacing() ) )
|
|
{
|
|
try
|
|
{
|
|
output = new WrapperBCPipe( te, this.side.getFacing().getOpposite() );
|
|
}
|
|
catch( Throwable ignore )
|
|
{
|
|
}
|
|
}
|
|
}
|
|
|
|
/*
|
|
* if ( AppEng.INSTANCE.isIntegrationEnabled( "TE" ) ) { ITE thermal = (ITE) AppEng.INSTANCE.getIntegration(
|
|
* "TE" ); if ( thermal != null ) { if ( thermal.isPipe( te, side.getOpposite() ) ) { try { output = new
|
|
* WrapperTEPipe( te, side.getOpposite() ); } catch (Throwable ignore) { } } } }
|
|
*/
|
|
|
|
if( output == null )
|
|
{
|
|
if( te instanceof TileEntityChest )
|
|
{
|
|
output = Platform.GetChestInv( te );
|
|
}
|
|
else if( te instanceof ISidedInventory )
|
|
{
|
|
output = new WrapperMCISidedInventory( (ISidedInventory) te, this.side.getFacing().getOpposite() );
|
|
}
|
|
else if( te instanceof IInventory )
|
|
{
|
|
output = (IInventory) te;
|
|
}
|
|
}
|
|
|
|
this.which.pop();
|
|
}
|
|
|
|
return output;
|
|
}
|
|
|
|
@Override
|
|
public TickingRequest getTickingRequest( IGridNode node )
|
|
{
|
|
return new TickingRequest( TickRates.ItemTunnel.min, TickRates.ItemTunnel.max, false, false );
|
|
}
|
|
|
|
@Override
|
|
public TickRateModulation tickingRequest( IGridNode node, int ticksSinceLastCall )
|
|
{
|
|
boolean wasReq = this.requested;
|
|
|
|
if( this.requested && this.cachedInv != null )
|
|
{
|
|
( (WrapperChainedInventory) this.cachedInv ).cycleOrder();
|
|
}
|
|
|
|
this.requested = false;
|
|
return wasReq ? TickRateModulation.FASTER : TickRateModulation.SLOWER;
|
|
}
|
|
|
|
@MENetworkEventSubscribe
|
|
public void changeStateA( MENetworkBootingStatusChange bs )
|
|
{
|
|
if( !this.output )
|
|
{
|
|
this.cachedInv = null;
|
|
int olderSize = this.oldSize;
|
|
this.oldSize = this.getDestination().getSizeInventory();
|
|
if( olderSize != this.oldSize )
|
|
{
|
|
this.getHost().notifyNeighbors();
|
|
}
|
|
}
|
|
}
|
|
|
|
@MENetworkEventSubscribe
|
|
public void changeStateB( MENetworkChannelsChanged bs )
|
|
{
|
|
if( !this.output )
|
|
{
|
|
this.cachedInv = null;
|
|
int olderSize = this.oldSize;
|
|
this.oldSize = this.getDestination().getSizeInventory();
|
|
if( olderSize != this.oldSize )
|
|
{
|
|
this.getHost().notifyNeighbors();
|
|
}
|
|
}
|
|
}
|
|
|
|
@MENetworkEventSubscribe
|
|
public void changeStateC( MENetworkPowerStatusChange bs )
|
|
{
|
|
if( !this.output )
|
|
{
|
|
this.cachedInv = null;
|
|
int olderSize = this.oldSize;
|
|
this.oldSize = this.getDestination().getSizeInventory();
|
|
if( olderSize != this.oldSize )
|
|
{
|
|
this.getHost().notifyNeighbors();
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public void onTunnelNetworkChange()
|
|
{
|
|
if( !this.output )
|
|
{
|
|
this.cachedInv = null;
|
|
int olderSize = this.oldSize;
|
|
this.oldSize = this.getDestination().getSizeInventory();
|
|
if( olderSize != this.oldSize )
|
|
{
|
|
this.getHost().notifyNeighbors();
|
|
}
|
|
}
|
|
else
|
|
{
|
|
PartP2PItems input = this.getInput();
|
|
if( input != null )
|
|
{
|
|
input.getHost().notifyNeighbors();
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public int[] getSlotsForFace(
|
|
EnumFacing side )
|
|
{
|
|
int[] slots = new int[this.getSizeInventory()];
|
|
for( int x = 0; x < this.getSizeInventory(); x++ )
|
|
{
|
|
slots[x] = x;
|
|
}
|
|
return slots;
|
|
}
|
|
|
|
@Override
|
|
public int getSizeInventory()
|
|
{
|
|
return this.getDestination().getSizeInventory();
|
|
}
|
|
|
|
@Override
|
|
public ItemStack getStackInSlot( int i )
|
|
{
|
|
return this.getDestination().getStackInSlot( i );
|
|
}
|
|
|
|
@Override
|
|
public ItemStack decrStackSize( int i, int j )
|
|
{
|
|
return this.getDestination().decrStackSize( i, j );
|
|
}
|
|
|
|
@Override
|
|
public ItemStack getStackInSlotOnClosing( int i )
|
|
{
|
|
return null;
|
|
}
|
|
|
|
@Override
|
|
public void setInventorySlotContents( int i, ItemStack itemstack )
|
|
{
|
|
this.getDestination().setInventorySlotContents( i, itemstack );
|
|
}
|
|
|
|
@Override
|
|
public String getCommandSenderName()
|
|
{
|
|
return null;
|
|
}
|
|
|
|
@Override
|
|
public boolean hasCustomName()
|
|
{
|
|
return false;
|
|
}
|
|
|
|
@Override
|
|
public int getInventoryStackLimit()
|
|
{
|
|
return this.getDestination().getInventoryStackLimit();
|
|
}
|
|
|
|
@Override
|
|
public void markDirty()
|
|
{
|
|
// eh?
|
|
}
|
|
|
|
@Override
|
|
public boolean isUseableByPlayer( EntityPlayer entityplayer )
|
|
{
|
|
return false;
|
|
}
|
|
|
|
@Override
|
|
public void openInventory(EntityPlayer p)
|
|
{
|
|
}
|
|
|
|
@Override
|
|
public void closeInventory(EntityPlayer p)
|
|
{
|
|
}
|
|
|
|
@Override
|
|
public boolean isItemValidForSlot( int i, net.minecraft.item.ItemStack itemstack )
|
|
{
|
|
return this.getDestination().isItemValidForSlot( i, itemstack );
|
|
}
|
|
|
|
@Override
|
|
public boolean canInsertItem( int i, ItemStack itemstack, EnumFacing j )
|
|
{
|
|
return this.getDestination().isItemValidForSlot( i, itemstack );
|
|
}
|
|
|
|
@Override
|
|
public boolean canExtractItem( int i, ItemStack itemstack, EnumFacing j )
|
|
{
|
|
return false;
|
|
}
|
|
|
|
public float getPowerDrainPerTick()
|
|
{
|
|
return 2.0f;
|
|
}
|
|
|
|
@Override
|
|
public int getField(
|
|
int id )
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
@Override
|
|
public void setField(
|
|
int id,
|
|
int value )
|
|
{
|
|
|
|
}
|
|
|
|
@Override
|
|
public int getFieldCount()
|
|
{
|
|
return 0;
|
|
}
|
|
|
|
@Override
|
|
public void clear()
|
|
{
|
|
// probobly not...
|
|
}
|
|
|
|
@Override
|
|
public IChatComponent getDisplayName()
|
|
{
|
|
return null;
|
|
}
|
|
|
|
// TODO: BC Integration
|
|
// @Override
|
|
// @Method( iname = "BuildCraftTransport" )
|
|
// public ConnectOverride overridePipeConnection( PipeType type, ForgeDirection with )
|
|
// {
|
|
// return this.side == with && type == PipeType.ITEM ? ConnectOverride.CONNECT : ConnectOverride.DEFAULT;
|
|
// }
|
|
}
|