| package li.cil.oc.common.tileentity |
| |
| import cpw.mods.fml.common.Optional |
| import cpw.mods.fml.common.Optional.Method |
| import cpw.mods.fml.relauncher.{Side, SideOnly} |
| import li.cil.oc.api.Network |
| import li.cil.oc.api.network.{Analyzable, Connector, Node, Visibility} |
| import li.cil.oc.client.Sound |
| import li.cil.oc.server.{component, driver, PacketSender => ServerPacketSender} |
| import li.cil.oc.util.ExtendedNBT._ |
| import li.cil.oc.util.mods.Waila |
| import li.cil.oc.{Localization, Settings, api, common} |
| import net.minecraft.entity.player.EntityPlayer |
| import net.minecraft.item.ItemStack |
| import net.minecraft.nbt.{NBTTagCompound, NBTTagString} |
| import net.minecraftforge.common.ForgeDirection |
| import net.minecraftforge.event.ForgeSubscribe |
| import net.minecraftforge.event.world.WorldEvent |
| import stargatetech2.api.bus.IBusDevice |
| |
| import scala.collection.mutable |
| |
| // See AbstractBusAware as to why we have to define the IBusDevice here. |
| @Optional.Interface(iface = "stargatetech2.api.bus.IBusDevice", modid = "StargateTech2") |
| class Rack extends traits.PowerAcceptor with traits.Hub with traits.PowerBalancer with traits.Inventory with traits.Rotatable with traits.BundledRedstoneAware with traits.AbstractBusAware with Analyzable with IBusDevice { |
| val servers = Array.fill(getSizeInventory)(None: Option[component.Server]) |
| |
| val sides = Seq(ForgeDirection.UP, ForgeDirection.EAST, ForgeDirection.WEST, ForgeDirection.DOWN). |
| padTo(servers.length, ForgeDirection.UNKNOWN).toArray |
| |
| val terminals = (0 until servers.length).map(new common.component.Terminal(this, _)).toArray |
| |
| var range = 16 |
| |
| // For client side, where we don't create the component. |
| private val _isRunning = new Array[Boolean](getSizeInventory) |
| |
| private var hasChanged = false |
| |
| // For client side rendering. |
| var isPresent = Array.fill[Option[String]](getSizeInventory)(None) |
| |
| @SideOnly(Side.CLIENT) |
| override protected def hasConnector(side: ForgeDirection) = side != facing |
| |
| override protected def connector(side: ForgeDirection) = Option(if (side != facing) sidedNode(side).asInstanceOf[Connector] else null) |
| |
| override def getWorld = world |
| |
| // ----------------------------------------------------------------------- // |
| |
| override def canConnect(side: ForgeDirection) = side != facing |
| |
| @Method(modid = "StargateTech2") |
| override def getInterfaces(side: Int) = if (side != facing.ordinal) { |
| super.getInterfaces(side) |
| } |
| else null |
| |
| // ----------------------------------------------------------------------- // |
| |
| def isRunning(number: Int) = |
| if (isServer) servers(number).fold(false)(_.machine.isRunning) |
| else _isRunning(number) |
| |
| @SideOnly(Side.CLIENT) |
| def setRunning(number: Int, value: Boolean) = { |
| _isRunning(number) = value |
| world.markBlockForRenderUpdate(x, y, z) |
| if (anyRunning) Sound.startLoop(this, "computer_running", 1.5f, 50 + world.rand.nextInt(50)) |
| else Sound.stopLoop(this) |
| this |
| } |
| |
| def anyRunning = (0 until servers.length).exists(isRunning) |
| |
| // ----------------------------------------------------------------------- // |
| |
| def markAsChanged() = hasChanged = true |
| |
| override def installedComponents = servers.flatMap { |
| case Some(server) => server.inventory.components collect { |
| case Some(component) => component |
| } |
| case _ => Iterable.empty |
| } |
| |
| def hasAbstractBusCard = servers exists { |
| case Some(server) => server.machine.isRunning && server.inventory.items.exists { |
| case Some(stack) => driver.item.AbstractBusCard.worksWith(stack) |
| case _ => false |
| } |
| case _ => false |
| } |
| |
| def hasRedstoneCard = servers exists { |
| case Some(server) => server.machine.isRunning && server.inventory.items.exists { |
| case Some(stack) => driver.item.RedstoneCard.worksWith(stack) |
| case _ => false |
| } |
| case _ => false |
| } |
| |
| def reconnectServer(number: Int, server: component.Server) { |
| val serverSide = sides(number) |
| val serverNode = server.machine.node |
| for (side <- ForgeDirection.VALID_DIRECTIONS) { |
| if (toGlobal(serverSide) == side) sidedNode(side).connect(serverNode) |
| else sidedNode(side).disconnect(serverNode) |
| } |
| } |
| |
| // ----------------------------------------------------------------------- // |
| |
| override protected def distribute() = { |
| def node(side: Int) = if (sides(side) == ForgeDirection.UNKNOWN) servers(side).fold(null: Connector)(_.node.asInstanceOf[Connector]) else null |
| val nodes = (0 to 3).map(node) |
| def network(connector: Connector) = if (connector != null) connector.network else this |
| val (sumBuffer, sumSize) = super.distribute() |
| var sumBufferServers, sumSizeServers = 0.0 |
| network(nodes(0)).synchronized { |
| network(nodes(1)).synchronized { |
| network(nodes(2)).synchronized { |
| network(nodes(3)).synchronized { |
| for (node <- nodes if node != null) { |
| sumBufferServers += node.globalBuffer |
| sumSizeServers += node.globalBufferSize |
| } |
| if (sumSize + sumSizeServers > 0) { |
| val ratio = (sumBuffer + sumBufferServers) / (sumSize + sumSizeServers) |
| for (node <- nodes if node != null) { |
| node.changeBuffer(node.globalBufferSize * ratio - node.globalBuffer) |
| } |
| } |
| } |
| } |
| } |
| } |
| (sumBuffer + sumBufferServers, sumSize + sumSizeServers) |
| } |
| |
| // ----------------------------------------------------------------------- // |
| |
| override def getSizeInventory = 4 |
| |
| override def getInvName = Settings.namespace + "container.Rack" |
| |
| override def getInventoryStackLimit = 1 |
| |
| override def isItemValidForSlot(i: Int, stack: ItemStack) = { |
| val descriptor = api.Items.get(stack) |
| descriptor == api.Items.get("server1") || descriptor == api.Items.get("server2") || descriptor == api.Items.get("server3") |
| } |
| |
| // ----------------------------------------------------------------------- // |
| |
| override def onAnalyze(player: EntityPlayer, side: Int, hitX: Float, hitY: Float, hitZ: Float) = { |
| if (side == facing.ordinal) { |
| val l = 2 / 16.0 |
| val h = 14 / 16.0 |
| val slot = (((1 - hitY) - l) / (h - l) * 4).toInt |
| if (slot >= 0 && slot <= 3 && servers(slot).isDefined) { |
| val computer = servers(slot).get.machine |
| computer.lastError match { |
| case value if value != null => |
| player.sendChatToPlayer(Localization.Analyzer.LastError(value)) |
| case _ => |
| } |
| player.sendChatToPlayer(Localization.Analyzer.Components(computer.componentCount, servers(slot).get.maxComponents)) |
| val list = computer.users |
| if (list.size > 0) { |
| player.sendChatToPlayer(Localization.Analyzer.Users(list)) |
| } |
| Array(computer.node) |
| } |
| else null |
| } |
| else Array(sidedNode(ForgeDirection.getOrientation(side))) |
| } |
| |
| // ----------------------------------------------------------------------- // |
| |
| override def canUpdate = isServer |
| |
| override def updateEntity() { |
| super.updateEntity() |
| if (isServer && isConnected) { |
| if (range > 0 && !Settings.get.ignorePower && anyRunning) { |
| val running = servers.count { |
| case Some(server) => server.machine.isRunning |
| case _ => false |
| } |
| var cost = -(running * range * Settings.get.wirelessCostPerRange) |
| for (side <- ForgeDirection.VALID_DIRECTIONS if cost < 0) { |
| sidedNode(side) match { |
| case connector: Connector => cost = connector.changeBuffer(cost) |
| case _ => |
| } |
| } |
| } |
| |
| servers collect { |
| case Some(server) => server.machine.update() |
| } |
| |
| if (hasChanged) { |
| hasChanged = false |
| world.markTileEntityChunkModified(x, y, z, this) |
| } |
| |
| for (i <- 0 until servers.length) { |
| val isRunning = servers(i).fold(false)(_.machine.isRunning) |
| if (_isRunning(i) != isRunning) { |
| _isRunning(i) = isRunning |
| ServerPacketSender.sendServerState(this, i) |
| } |
| } |
| isOutputEnabled = hasRedstoneCard |
| isAbstractBusAvailable = hasAbstractBusCard |
| |
| servers collect { |
| case Some(server) => server.inventory.updateComponents() |
| } |
| } |
| } |
| |
| // ----------------------------------------------------------------------- // |
| |
| override protected def initialize() { |
| super.initialize() |
| Rack.list += this -> Unit |
| } |
| |
| override protected def dispose() { |
| super.dispose() |
| Rack.list -= this |
| } |
| |
| override def readFromNBT(nbt: NBTTagCompound) { |
| super.readFromNBT(nbt) |
| for (slot <- 0 until getSizeInventory) { |
| if (getStackInSlot(slot) != null) { |
| val server = new component.Server(this, slot) |
| servers(slot) = Some(server) |
| } |
| } |
| for ((serverNbt, slot) <- nbt.getTagList(Settings.namespace + "servers").iterator[NBTTagCompound].zipWithIndex if slot < servers.length) { |
| servers(slot) match { |
| case Some(server) => server.load(serverNbt) |
| case _ => |
| } |
| } |
| val sidesNbt = nbt.getByteArray(Settings.namespace + "sides").byteArray.map(ForgeDirection.getOrientation(_)) |
| Array.copy(sidesNbt, 0, sides, 0, math.min(sidesNbt.length, sides.length)) |
| val terminalsNbt = nbt.getTagList(Settings.namespace + "terminals").iterator[NBTTagCompound].toArray |
| for (i <- 0 until math.min(terminals.length, terminalsNbt.length)) { |
| terminals(i).load(terminalsNbt(i)) |
| } |
| range = nbt.getInteger(Settings.namespace + "range") |
| } |
| |
| // Side check for Waila (and other mods that may call this client side). |
| override def writeToNBT(nbt: NBTTagCompound) = if (isServer) { |
| if (!Waila.isSavingForTooltip) { |
| nbt.setNewTagList(Settings.namespace + "servers", servers map { |
| case Some(server) => |
| val serverNbt = new NBTTagCompound() |
| server.save(serverNbt) |
| serverNbt |
| case _ => new NBTTagCompound() |
| }) |
| } |
| super.writeToNBT(nbt) |
| nbt.setByteArray(Settings.namespace + "sides", sides.map(_.ordinal.toByte)) |
| nbt.setNewTagList(Settings.namespace + "terminals", terminals.map(t => { |
| val terminalNbt = new NBTTagCompound() |
| t.save(terminalNbt) |
| terminalNbt |
| })) |
| nbt.setInteger(Settings.namespace + "range", range) |
| } |
| |
| @SideOnly(Side.CLIENT) |
| override def readFromNBTForClient(nbt: NBTTagCompound) { |
| super.readFromNBTForClient(nbt) |
| val isRunningNbt = nbt.getByteArray("isServerRunning").byteArray.map(_ == 1) |
| Array.copy(isRunningNbt, 0, _isRunning, 0, math.min(isRunningNbt.length, _isRunning.length)) |
| val isPresentNbt = nbt.getTagList("isPresent").iterator[NBTTagString].map(value => if (value.data == "") None else Some(value.data)).toArray |
| Array.copy(isPresentNbt, 0, isPresent, 0, math.min(isPresentNbt.length, isPresent.length)) |
| val sidesNbt = nbt.getByteArray("sides").byteArray.map(ForgeDirection.getOrientation(_)) |
| Array.copy(sidesNbt, 0, sides, 0, math.min(sidesNbt.length, sides.length)) |
| val terminalsNbt = nbt.getTagList("terminals").iterator[NBTTagCompound].toArray |
| for (i <- 0 until math.min(terminals.length, terminalsNbt.length)) { |
| terminals(i).readFromNBTForClient(terminalsNbt(i)) |
| } |
| range = nbt.getInteger("range") |
| if (anyRunning) Sound.startLoop(this, "computer_running", 1.5f, 1000 + world.rand.nextInt(2000)) |
| } |
| |
| override def writeToNBTForClient(nbt: NBTTagCompound) { |
| super.writeToNBTForClient(nbt) |
| nbt.setByteArray("isServerRunning", _isRunning.map(value => (if (value) 1 else 0).toByte)) |
| nbt.setNewTagList("isPresent", servers.map(value => new NBTTagString(null, value.fold("")(_.machine.node.address)))) |
| nbt.setByteArray("sides", sides.map(_.ordinal.toByte)) |
| nbt.setNewTagList("terminals", terminals.map(t => { |
| val terminalNbt = new NBTTagCompound() |
| t.writeToNBTForClient(terminalNbt) |
| terminalNbt |
| })) |
| nbt.setInteger("range", range) |
| } |
| |
| // ----------------------------------------------------------------------- // |
| |
| override protected def onPlugConnect(plug: Plug, node: Node) { |
| if (node == plug.node) { |
| for (number <- 0 until servers.length) { |
| val serverSide = sides(number) |
| servers(number) match { |
| case Some(server) if toGlobal(serverSide) == plug.side => |
| plug.node.connect(server.machine.node) |
| terminals(number).connect(server.machine.node) |
| case _ => |
| } |
| } |
| } |
| } |
| |
| override protected def createNode(plug: Plug) = api.Network.newNode(plug, Visibility.Network). |
| withConnector(Settings.get.bufferDistributor). |
| create() |
| |
| override protected def onItemAdded(slot: Int, stack: ItemStack) { |
| super.onItemAdded(slot, stack) |
| if (isServer) { |
| val server = new component.Server(this, slot) |
| servers(slot) = Some(server) |
| reconnectServer(slot, server) |
| Network.joinNewNetwork(server.machine.node) |
| terminals(slot).connect(server.machine.node) |
| } |
| } |
| |
| override protected def onItemRemoved(slot: Int, stack: ItemStack) { |
| super.onItemRemoved(slot, stack) |
| if (isServer) { |
| servers(slot) match { |
| case Some(server) => |
| server.machine.node.remove() |
| server.inventory.containerOverride = stack |
| server.inventory.save(new NBTTagCompound()) // Only flush components. |
| server.inventory.onInventoryChanged() |
| case _ => |
| } |
| servers(slot) = None |
| terminals(slot).keys.clear() |
| } |
| } |
| |
| override def onInventoryChanged() { |
| super.onInventoryChanged() |
| if (isServer) { |
| isOutputEnabled = hasRedstoneCard |
| isAbstractBusAvailable = hasAbstractBusCard |
| ServerPacketSender.sendServerPresence(this) |
| } |
| else { |
| world.markBlockForRenderUpdate(x, y, z) |
| } |
| } |
| |
| override protected def onRotationChanged() { |
| super.onRotationChanged() |
| checkRedstoneInputChanged() |
| } |
| |
| override protected def onRedstoneInputChanged(side: ForgeDirection) { |
| super.onRedstoneInputChanged(side) |
| servers collect { |
| case Some(server) => server.machine.signal("redstone_changed", server.machine.node.address, Int.box(toLocal(side).ordinal())) |
| } |
| } |
| |
| override def rotate(axis: ForgeDirection) = false |
| } |
| |
| object Rack { |
| val list = mutable.WeakHashMap.empty[Rack, Unit] |
| |
| @ForgeSubscribe |
| def onWorldUnload(e: WorldEvent.Unload) { |
| if (e.world.isRemote) { |
| list.clear() |
| } |
| } |
| } |