| package li.cil.oc.common.tileentity |
| |
| import cpw.mods.fml.relauncher.Side |
| import cpw.mods.fml.relauncher.SideOnly |
| import li.cil.oc.Settings |
| import li.cil.oc.api |
| import li.cil.oc.api.machine.Arguments |
| import li.cil.oc.api.machine.Callback |
| import li.cil.oc.api.machine.Context |
| import li.cil.oc.api.network._ |
| import li.cil.oc.common.template.AssemblerTemplates |
| import li.cil.oc.server.{PacketSender => ServerPacketSender} |
| import li.cil.oc.util.ExtendedNBT._ |
| import li.cil.oc.util.ItemUtils |
| import net.minecraft.item.ItemStack |
| import net.minecraft.nbt.NBTTagCompound |
| import net.minecraftforge.common.util.ForgeDirection |
| |
| class Assembler extends traits.Environment with traits.PowerAcceptor with traits.Inventory with traits.Rotatable with SidedEnvironment { |
| val node = api.Network.newNode(this, Visibility.Network). |
| withComponent("assembler"). |
| withConnector(Settings.get.bufferConverter). |
| create() |
| |
| var output: Option[ItemStack] = None |
| |
| var totalRequiredEnergy = 0.0 |
| |
| var requiredEnergy = 0.0 |
| |
| // ----------------------------------------------------------------------- // |
| |
| @SideOnly(Side.CLIENT) |
| override def canConnect(side: ForgeDirection) = side != ForgeDirection.UP |
| |
| override def sidedNode(side: ForgeDirection) = if (side != ForgeDirection.UP) node else null |
| |
| @SideOnly(Side.CLIENT) |
| override protected def hasConnector(side: ForgeDirection) = canConnect(side) |
| |
| override protected def connector(side: ForgeDirection) = Option(if (side != ForgeDirection.UP) node else null) |
| |
| override protected def energyThroughput = Settings.get.assemblerRate |
| |
| // ----------------------------------------------------------------------- // |
| |
| def isAssembling = requiredEnergy > 0 |
| |
| def progress = (1 - requiredEnergy / totalRequiredEnergy) * 100 |
| |
| def timeRemaining = (requiredEnergy / Settings.get.assemblerTickAmount / 20).toInt |
| |
| // ----------------------------------------------------------------------- // |
| |
| def start(finishImmediately: Boolean = false): Boolean = this.synchronized { |
| AssemblerTemplates.select(getStackInSlot(0)) match { |
| case Some(template) if !isAssembling && output.isEmpty && template.validate(this)._1 => |
| for (slot <- 0 until getSizeInventory) { |
| val stack = getStackInSlot(slot) |
| if (stack != null && !isItemValidForSlot(slot, stack)) return false |
| } |
| val (stack, energy) = template.assemble(this) |
| output = Some(stack) |
| if (finishImmediately) { |
| totalRequiredEnergy = 0 |
| } |
| else { |
| totalRequiredEnergy = math.max(1, energy) |
| } |
| requiredEnergy = totalRequiredEnergy |
| ServerPacketSender.sendRobotAssembling(this, assembling = true) |
| |
| for (slot <- 0 until getSizeInventory) items(slot) = None |
| markDirty() |
| |
| true |
| case _ => false |
| } |
| } |
| |
| // ----------------------------------------------------------------------- // |
| |
| @Callback(doc = """function(): string, number or boolean -- The current state of the assembler, `busy' or `idle', followed by the progress or template validity, respectively.""") |
| def status(context: Context, args: Arguments): Array[Object] = { |
| if (isAssembling) result("busy", progress) |
| else AssemblerTemplates.select(getStackInSlot(0)) match { |
| case Some(template) if template.validate(this)._1 => result("idle", true) |
| case _ => result("idle", false) |
| } |
| } |
| |
| @Callback(doc = """function():boolean -- Start assembling, if possible. Returns whether assembly was started or not.""") |
| def start(context: Context, args: Arguments): Array[Object] = result(start()) |
| |
| // ----------------------------------------------------------------------- // |
| |
| override def canUpdate = isServer |
| |
| override def updateEntity() { |
| super.updateEntity() |
| if (output.isDefined && world.getTotalWorldTime % Settings.get.tickFrequency == 0) { |
| val want = math.max(1, math.min(requiredEnergy, Settings.get.assemblerTickAmount * Settings.get.tickFrequency)) |
| val success = Settings.get.ignorePower || node.tryChangeBuffer(-want) |
| if (success) { |
| requiredEnergy -= want |
| } |
| if (requiredEnergy <= 0) { |
| setInventorySlotContents(0, output.get) |
| output = None |
| requiredEnergy = 0 |
| } |
| ServerPacketSender.sendRobotAssembling(this, success && output.isDefined) |
| } |
| } |
| |
| override def readFromNBT(nbt: NBTTagCompound) { |
| super.readFromNBT(nbt) |
| if (nbt.hasKey(Settings.namespace + "output")) { |
| output = Option(ItemUtils.loadStack(nbt.getCompoundTag(Settings.namespace + "output"))) |
| } |
| else if (nbt.hasKey(Settings.namespace + "robot")) { |
| // Backwards compatibility. |
| output = Option(ItemUtils.loadStack(nbt.getCompoundTag(Settings.namespace + "robot"))) |
| } |
| totalRequiredEnergy = nbt.getDouble(Settings.namespace + "total") |
| requiredEnergy = nbt.getDouble(Settings.namespace + "remaining") |
| } |
| |
| override def writeToNBT(nbt: NBTTagCompound) { |
| super.writeToNBT(nbt) |
| output.foreach(stack => nbt.setNewCompoundTag(Settings.namespace + "output", stack.writeToNBT)) |
| nbt.setDouble(Settings.namespace + "total", totalRequiredEnergy) |
| nbt.setDouble(Settings.namespace + "remaining", requiredEnergy) |
| } |
| |
| @SideOnly(Side.CLIENT) override |
| def readFromNBTForClient(nbt: NBTTagCompound) { |
| super.readFromNBTForClient(nbt) |
| requiredEnergy = nbt.getDouble("remaining") |
| } |
| |
| override def writeToNBTForClient(nbt: NBTTagCompound) { |
| super.writeToNBTForClient(nbt) |
| nbt.setDouble("remaining", requiredEnergy) |
| } |
| |
| // ----------------------------------------------------------------------- // |
| |
| override def getSizeInventory = 22 |
| |
| override def getInventoryStackLimit = 1 |
| |
| override def isItemValidForSlot(slot: Int, stack: ItemStack) = |
| if (slot == 0) { |
| !isAssembling && AssemblerTemplates.select(stack).isDefined |
| } |
| else AssemblerTemplates.select(getStackInSlot(0)) match { |
| case Some(template) => |
| val tplSlot = |
| if ((1 until 4) contains slot) template.containerSlots(slot - 1) |
| else if ((4 until 13) contains slot) template.upgradeSlots(slot - 4) |
| else if ((13 until 21) contains slot) template.componentSlots(slot - 13) |
| else AssemblerTemplates.NoSlot |
| tplSlot.validate(this, slot, stack) |
| case _ => false |
| } |
| } |