/* * This file is part of Applied Energistics 2. * Copyright (c) 2013 - 2014, 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 . */ package appeng.parts.automation; import net.minecraft.entity.player.EntityPlayer; import net.minecraft.item.ItemStack; import net.minecraft.util.EnumHand; import net.minecraft.util.math.Vec3d; import appeng.api.AEApi; import appeng.api.config.Actionable; import appeng.api.config.FuzzyMode; import appeng.api.config.PowerMultiplier; import appeng.api.config.RedstoneMode; import appeng.api.config.Settings; import appeng.api.config.Upgrades; import appeng.api.networking.IGridNode; import appeng.api.networking.energy.IEnergyGrid; import appeng.api.networking.energy.IEnergySource; import appeng.api.networking.security.BaseActionSource; import appeng.api.networking.security.MachineSource; import appeng.api.networking.ticking.TickRateModulation; import appeng.api.networking.ticking.TickingRequest; import appeng.api.parts.IPartCollisionHelper; import appeng.api.storage.IMEInventory; import appeng.api.storage.IMEMonitor; import appeng.api.storage.data.IAEItemStack; import appeng.core.settings.TickRates; import appeng.core.sync.GuiBridge; import appeng.helpers.Reflected; import appeng.me.GridAccessException; import appeng.util.InventoryAdaptor; import appeng.util.Platform; import appeng.util.inv.IInventoryDestination; import appeng.util.item.AEItemStack; public class PartImportBus extends PartSharedItemBus implements IInventoryDestination { private final BaseActionSource source; private IMEInventory destination = null; private IAEItemStack lastItemChecked = null; private int itemToSend; // used in tickingRequest private boolean worked; // used in tickingRequest @Reflected public PartImportBus( final ItemStack is ) { super( is ); this.getConfigManager().registerSetting( Settings.REDSTONE_CONTROLLED, RedstoneMode.IGNORE ); this.getConfigManager().registerSetting( Settings.FUZZY_MODE, FuzzyMode.IGNORE_ALL ); this.source = new MachineSource( this ); } @Override public boolean canInsert( final ItemStack stack ) { if( stack == null || stack.getItem() == null ) { return false; } final IAEItemStack out = this.destination.injectItems( this.lastItemChecked = AEApi.instance().storage().createItemStack( stack ), Actionable.SIMULATE, this.source ); if( out == null ) { return true; } return out.getStackSize() != stack.stackSize; } @Override public void getBoxes( final IPartCollisionHelper bch ) { bch.addBox( 6, 6, 11, 10, 10, 13 ); bch.addBox( 5, 5, 13, 11, 11, 14 ); bch.addBox( 4, 4, 14, 12, 12, 16 ); } @Override public int getCableConnectionLength() { return 5; } @Override public boolean onPartActivate( final EntityPlayer player, final EnumHand hand, final Vec3d pos ) { if( !player.isSneaking() ) { if( Platform.isClient() ) { return true; } Platform.openGUI( player, this.getHost().getTile(), this.getSide(), GuiBridge.GUI_BUS ); return true; } return false; } @Override public TickingRequest getTickingRequest( final IGridNode node ) { return new TickingRequest( TickRates.ImportBus.getMin(), TickRates.ImportBus.getMax(), this.getHandler() == null, false ); } @Override public TickRateModulation tickingRequest( final IGridNode node, final int ticksSinceLastCall ) { return this.doBusWork(); } @Override protected TickRateModulation doBusWork() { if( !this.getProxy().isActive() || !this.canDoBusWork() ) { return TickRateModulation.IDLE; } this.worked = false; final InventoryAdaptor myAdaptor = this.getHandler(); final FuzzyMode fzMode = (FuzzyMode) this.getConfigManager().getSetting( Settings.FUZZY_MODE ); if( myAdaptor != null ) { try { this.itemToSend = this.calculateItemsToSend(); this.itemToSend = Math.min( this.itemToSend, (int) ( 0.01 + this.getProxy().getEnergy().extractAEPower( this.itemToSend, Actionable.SIMULATE, PowerMultiplier.CONFIG ) ) ); final IMEMonitor inv = this.getProxy().getStorage().getItemInventory(); final IEnergyGrid energy = this.getProxy().getEnergy(); boolean Configured = false; for( int x = 0; x < this.availableSlots(); x++ ) { final IAEItemStack ais = this.getConfig().getAEStackInSlot( x ); if( ais != null && this.itemToSend > 0 ) { Configured = true; while( this.itemToSend > 0 ) { if( this.importStuff( myAdaptor, ais, inv, energy, fzMode ) ) { break; } } } } if( !Configured ) { while( this.itemToSend > 0 ) { if( this.importStuff( myAdaptor, null, inv, energy, fzMode ) ) { break; } } } } catch( final GridAccessException e ) { // :3 } } else { return TickRateModulation.SLEEP; } return this.worked ? TickRateModulation.FASTER : TickRateModulation.SLOWER; } private boolean importStuff( final InventoryAdaptor myAdaptor, final IAEItemStack whatToImport, final IMEMonitor inv, final IEnergySource energy, final FuzzyMode fzMode ) { final int toSend = this.calculateMaximumAmountToImport( myAdaptor, whatToImport, inv, fzMode ); final ItemStack newItems; if( this.getInstalledUpgrades( Upgrades.FUZZY ) > 0 ) { newItems = myAdaptor.removeSimilarItems( toSend, whatToImport == null ? null : whatToImport.getItemStack(), fzMode, this.configDestination( inv ) ); } else { newItems = myAdaptor.removeItems( toSend, whatToImport == null ? null : whatToImport.getItemStack(), this.configDestination( inv ) ); } if( newItems != null ) { newItems.stackSize = (int) ( Math.min( newItems.stackSize, energy.extractAEPower( newItems.stackSize, Actionable.SIMULATE, PowerMultiplier.CONFIG ) ) + 0.01 ); this.itemToSend -= newItems.stackSize; if( this.lastItemChecked == null || !this.lastItemChecked.isSameType( newItems ) ) { this.lastItemChecked = AEApi.instance().storage().createItemStack( newItems ); } else { this.lastItemChecked.setStackSize( newItems.stackSize ); } final IAEItemStack failed = Platform.poweredInsert( energy, this.destination, this.lastItemChecked, this.source ); if( failed != null ) { myAdaptor.addItems( failed.getItemStack() ); return true; } else { this.worked = true; } } else { return true; } return false; } private int calculateMaximumAmountToImport( final InventoryAdaptor myAdaptor, final IAEItemStack whatToImport, final IMEMonitor inv, final FuzzyMode fzMode ) { final int toSend = Math.min( this.itemToSend, 64 ); final ItemStack itemStackToImport; if( whatToImport == null ) { itemStackToImport = null; } else { itemStackToImport = whatToImport.getItemStack(); } final IAEItemStack itemAmountNotStorable; final ItemStack simResult; if( this.getInstalledUpgrades( Upgrades.FUZZY ) > 0 ) { simResult = myAdaptor.simulateSimilarRemove( toSend, itemStackToImport, fzMode, this.configDestination( inv ) ); itemAmountNotStorable = this.destination.injectItems( AEItemStack.create( simResult ), Actionable.SIMULATE, this.source ); } else { simResult = myAdaptor.simulateRemove( toSend, itemStackToImport, this.configDestination( inv ) ); itemAmountNotStorable = this.destination.injectItems( AEItemStack.create( simResult ), Actionable.SIMULATE, this.source ); } if( itemAmountNotStorable != null ) { return (int) Math.min( simResult.stackSize - itemAmountNotStorable.getStackSize(), toSend ); } return toSend; } private IInventoryDestination configDestination( final IMEMonitor itemInventory ) { this.destination = itemInventory; return this; } @Override protected boolean isSleeping() { return this.getHandler() == null || super.isSleeping(); } @Override public RedstoneMode getRSMode() { return (RedstoneMode) this.getConfigManager().getSetting( Settings.REDSTONE_CONTROLLED ); } }