// $Id$ /* * WorldEdit * Copyright (C) 2010 sk89q and contributors * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program 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 General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ package com.sk89q.worldedit.bukkit; import org.bukkit.entity.Player; import org.bukkit.inventory.ItemStack; import com.sk89q.worldedit.Vector; import com.sk89q.worldedit.bags.*; import com.sk89q.worldedit.blocks.BaseItem; import com.sk89q.worldedit.blocks.BaseItemStack; import com.sk89q.worldedit.blocks.BlockID; import com.sk89q.worldedit.blocks.ItemType; public class BukkitPlayerBlockBag extends BlockBag { /** * Player instance. */ private Player player; /** * The player's inventory; */ private ItemStack[] items; /** * Construct the object. * * @param player */ public BukkitPlayerBlockBag(Player player) { this.player = player; } /** * Loads inventory on first use. */ private void loadInventory() { if (items == null) { items = player.getInventory().getContents(); } } /** * Get the player. * * @return */ public Player getPlayer() { return player; } /** * Get a block. * * @param id */ @Override public void fetchItem(BaseItem item) throws BlockBagException { final int id = item.getType(); final int damage = item.getDamage(); int amount = (item instanceof BaseItemStack) ? ((BaseItemStack) item).getAmount() : 1; assert(amount == 1); boolean usesDamageValue = ItemType.usesDamageValue(id); if (id == BlockID.AIR) { throw new IllegalArgumentException("Can't fetch air block"); } loadInventory(); boolean found = false; for (int slot = 0; slot < items.length; ++slot) { ItemStack bukkitItem = items[slot]; if (bukkitItem == null) { continue; } if (bukkitItem.getTypeId() != id) { // Type id doesn't fit continue; } if (usesDamageValue && bukkitItem.getDurability() != damage) { // Damage value doesn't fit. continue; } int currentAmount = bukkitItem.getAmount(); if (currentAmount < 0) { // Unlimited return; } if (currentAmount > 1) { bukkitItem.setAmount(currentAmount - 1); found = true; } else { items[slot] = null; found = true; } break; } if (!found) { throw new OutOfBlocksException(); } } /** * Store a block. * * @param id */ @Override public void storeItem(BaseItem item) throws BlockBagException { final int id = item.getType(); final int damage = item.getDamage(); int amount = (item instanceof BaseItemStack) ? ((BaseItemStack) item).getAmount() : 1; assert(amount <= 64); boolean usesDamageValue = ItemType.usesDamageValue(id); if (id == BlockID.AIR) { throw new IllegalArgumentException("Can't store air block"); } loadInventory(); int freeSlot = -1; for (int slot = 0; slot < items.length; ++slot) { ItemStack bukkitItem = items[slot]; if (bukkitItem == null) { // Delay using up a free slot until we know there are no stacks // of this item to merge into if (freeSlot == -1) { freeSlot = slot; } continue; } if (bukkitItem.getTypeId() != id) { // Type id doesn't fit continue; } if (usesDamageValue && bukkitItem.getDurability() != damage) { // Damage value doesn't fit. continue; } int currentAmount = bukkitItem.getAmount(); if (currentAmount < 0) { // Unlimited return; } if (currentAmount >= 64) { // Full stack continue; } int spaceLeft = 64 - currentAmount; if (spaceLeft >= amount) { bukkitItem.setAmount(currentAmount + amount); return; } bukkitItem.setAmount(64); amount -= spaceLeft; } if (freeSlot > -1) { items[freeSlot] = new ItemStack(id, amount); return; } throw new OutOfSpaceException(id); } /** * Flush any changes. This is called at the end. */ @Override public void flushChanges() { if (items != null) { player.getInventory().setContents(items); items = null; } } /** * Adds a position to be used a source. * * @param pos */ @Override public void addSourcePosition(Vector pos) { } /** * Adds a position to be used a source. * * @param pos */ @Override public void addSingleSourcePosition(Vector pos) { } }