Inventory/ItemsComponent.java

package com.eu.habbo.habbohotel.users.inventory;

import com.eu.habbo.Emulator;
import com.eu.habbo.habbohotel.users.Habbo;
import com.eu.habbo.habbohotel.users.HabboItem;
import gnu.trove.map.hash.THashMap;
import gnu.trove.set.hash.THashSet;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Map;

/**
 * Created on 28-8-2014 18:45.
 */
public class ItemsComponent {

    private THashMap<Integer, HabboItem> items;

    public ItemsComponent(Habbo habbo)
    {
        this.items = new THashMap<Integer, HabboItem>();
        this.items.putAll(loadItems(habbo));
    }

    public static THashMap<Integer, HabboItem> loadItems(Habbo habbo)
    {
        THashMap<Integer, HabboItem> itemsList = new THashMap<Integer, HabboItem>();

        try
        {
            PreparedStatement statement = Emulator.getDatabase().prepare("SELECT * FROM items WHERE room_id = ? AND user_id = ?");
            statement.setInt(1, 0);
            statement.setInt(2, habbo.getHabboInfo().getId());

            ResultSet set = statement.executeQuery();

            while(set.next())
            {
                itemsList.put(set.getInt("id"), new HabboItem(set));
            }
        }
        catch(SQLException e)
        {
            Emulator.getLogging().logSQLException(e);
        }

        return itemsList;
    }

    public void addItem(HabboItem item)
    {
        this.items.put(item.getId(), item);
    }

    public void addItems(THashSet<HabboItem> items)
    {
        for(HabboItem item : items)
        {
            this.items.put(item.getId(), item);
        }
    }

    public HabboItem getHabboItem(int itemId)
    {
        return this.items.get(itemId);
    }

    public THashMap<Integer, HabboItem> getItems()
    {
        return this.items;
    }

    public void dispose()
    {
        for(Map.Entry<Integer, HabboItem> item : this.items.entrySet())
        {
            if(item.getValue().needsUpdate())
                Emulator.getThreading().run(item.getValue());
        }

        this.items.clear();
    }
}