MagicBotandClaude Opus 5.5
6b4e9815e0
Item.template is now the cache template from CObjectTemplate.lookup instead of the legacy DB ItemTemplate, so item.template.cacheTemplate.X becomes item.template.X. MobLoot, LootManager, ItemManager.isTwoHanded/ isShield and CombatManager.getSwingAnimation take a CObjectTemplate. No value changes: every getter already read the cache template through the bridge, and the lookup resolves the same 7586 ids as static_item_templates with the same item_type (offline parity p17.py, 0 differences). Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
389 lines
13 KiB
Java
389 lines
13 KiB
Java
// • ▌ ▄ ·. ▄▄▄· ▄▄ • ▪ ▄▄· ▄▄▄▄· ▄▄▄· ▐▄▄▄ ▄▄▄ .
|
|
// ·██ ▐███▪▐█ ▀█ ▐█ ▀ ▪██ ▐█ ▌▪▐█ ▀█▪▐█ ▀█ •█▌ ▐█▐▌·
|
|
// ▐█ ▌▐▌▐█·▄█▀▀█ ▄█ ▀█▄▐█·██ ▄▄▐█▀▀█▄▄█▀▀█ ▐█▐ ▐▌▐▀▀▀
|
|
// ██ ██▌▐█▌▐█ ▪▐▌▐█▄▪▐█▐█▌▐███▌██▄▪▐█▐█ ▪▐▌██▐ █▌▐█▄▄▌
|
|
// ▀▀ █▪▀▀▀ ▀ ▀ ·▀▀▀▀ ▀▀▀·▀▀▀ ·▀▀▀▀ ▀ ▀ ▀▀ █▪ ▀▀▀
|
|
// Magicbane Emulator Project © 2013 - 2026
|
|
// https://www.magicbane.com
|
|
|
|
|
|
package engine.objects;
|
|
|
|
import engine.gameManager.*;
|
|
import engine.mbEnums;
|
|
import engine.mbEnums.DispatchChannel;
|
|
import engine.mbEnums.ItemContainerType;
|
|
import engine.net.Dispatch;
|
|
import engine.net.client.ClientConnection;
|
|
import engine.net.client.handlers.ItemFromVaultMsgHandler;
|
|
import engine.net.client.handlers.ItemToVaultMsgHandler;
|
|
import engine.net.client.msg.*;
|
|
import engine.util.ByteUtils;
|
|
import org.pmw.tinylog.Logger;
|
|
|
|
import java.io.UnsupportedEncodingException;
|
|
import java.security.MessageDigest;
|
|
import java.security.NoSuchAlgorithmException;
|
|
import java.sql.ResultSet;
|
|
import java.sql.SQLException;
|
|
import java.util.ArrayList;
|
|
import java.util.HashMap;
|
|
import java.util.concurrent.ConcurrentHashMap;
|
|
|
|
public class Account extends AbstractGameObject {
|
|
|
|
public static ConcurrentHashMap<String, Integer> AccountsMap = new ConcurrentHashMap<>();
|
|
private final String uname;
|
|
public String discordAccount;
|
|
public HashMap<Integer, PlayerCharacter> characterMap = new HashMap<>();
|
|
public Item vaultGold = null;
|
|
public long lastPasswordCheck = 0;
|
|
public mbEnums.AccountStatus status;
|
|
private String passwd;
|
|
private int lastCharIDUsed;
|
|
private String salt;
|
|
private byte loginAttempts = 0;
|
|
private long lastLoginFailure = System.currentTimeMillis();
|
|
private ArrayList<Item> vault = new ArrayList<>();
|
|
|
|
public Account(ResultSet resultSet) throws SQLException {
|
|
super(resultSet);
|
|
|
|
this.uname = resultSet.getString("acct_uname");
|
|
this.passwd = resultSet.getString("acct_passwd");
|
|
this.lastCharIDUsed = resultSet.getInt("acct_lastCharUID");
|
|
this.salt = resultSet.getString("acct_salt");
|
|
this.discordAccount = resultSet.getString("discordAccount");
|
|
this.status = mbEnums.AccountStatus.valueOf(resultSet.getString("status"));
|
|
}
|
|
|
|
public ArrayList<Item> getVault() {
|
|
return vault;
|
|
}
|
|
|
|
public String getUname() {
|
|
return uname;
|
|
}
|
|
|
|
public String getPasswd() {
|
|
return passwd;
|
|
}
|
|
|
|
public String getSalt() {
|
|
return salt;
|
|
}
|
|
|
|
public int getLastCharIDUsed() {
|
|
return lastCharIDUsed;
|
|
}
|
|
|
|
public void setLastCharIDUsed(int lastCharIDUsed) {
|
|
this.lastCharIDUsed = lastCharIDUsed;
|
|
}
|
|
|
|
public byte getLoginAttempts() {
|
|
return loginAttempts;
|
|
}
|
|
|
|
public long getLastLoginFailure() {
|
|
return this.lastLoginFailure;
|
|
}
|
|
|
|
public void setLastLoginFailure() {
|
|
this.lastLoginFailure = System.currentTimeMillis();
|
|
}
|
|
|
|
public void setLastCharacter(int uuid) {
|
|
this.lastCharIDUsed = uuid;
|
|
// this.updateDatabase();
|
|
}
|
|
|
|
public void incrementLoginAttempts() {
|
|
++this.loginAttempts;
|
|
this.setLastLoginFailure();
|
|
}
|
|
|
|
public void resetLoginAttempts() {
|
|
this.loginAttempts = 0;
|
|
}
|
|
|
|
/*
|
|
* on successfully matching the password, this method additionally calls to
|
|
* associateIpToAccount for IPAddress tracking. dokks
|
|
*/
|
|
public boolean passIsValid(String pw, String ip, String machineID) throws IllegalArgumentException {
|
|
boolean result = false;
|
|
// see if it was entered in plain text first, if the plain text matches,
|
|
// hash it and save to the database.
|
|
try {
|
|
pw = ByteUtils.byteArrayToSafeStringHex(MessageDigest
|
|
.getInstance("md5").digest(pw.getBytes("UTF-8")))
|
|
+ salt;
|
|
pw = ByteUtils.byteArrayToSafeStringHex(MessageDigest
|
|
.getInstance("md5").digest(pw.getBytes()));
|
|
result = this.passwd.equals(pw);
|
|
} catch (NoSuchAlgorithmException | UnsupportedEncodingException e) {
|
|
Logger.error(e.toString());
|
|
}
|
|
|
|
if (result) {
|
|
// TODO: should use an executor here so that we can
|
|
// fire and forget this update.
|
|
// this is a valid user, so let's also update the
|
|
// database with login time and IP.
|
|
if ((ip == null) || (ip.length() == 0)) {
|
|
throw new IllegalArgumentException();
|
|
}
|
|
}
|
|
return result;
|
|
}
|
|
|
|
public ClientConnection getClientConnection() {
|
|
return SessionManager.getClientConnection(this);
|
|
}
|
|
|
|
public PlayerCharacter getPlayerCharacter() {
|
|
return SessionManager.getPlayerCharacter(this);
|
|
}
|
|
|
|
@Override
|
|
public void updateDatabase() {
|
|
DbManager.AccountQueries.updateDatabase(this);
|
|
}
|
|
|
|
//this should be called to handle any after load functions.
|
|
|
|
public void runAfterLoad() {
|
|
|
|
try {
|
|
|
|
if (ConfigManager.serverType.equals(mbEnums.ServerType.LOGINSERVER)) {
|
|
ArrayList<PlayerCharacter> playerList = DbManager.PlayerCharacterQueries.GET_CHARACTERS_FOR_ACCOUNT(this.getObjectUUID());
|
|
|
|
for (PlayerCharacter player : playerList) {
|
|
PlayerCharacter.initializePlayer(player);
|
|
this.characterMap.putIfAbsent(player.getObjectUUID(), player);
|
|
}
|
|
|
|
playerList.clear();
|
|
}
|
|
|
|
if (ConfigManager.serverType.equals(mbEnums.ServerType.WORLDSERVER)) {
|
|
this.vault = DbManager.ItemQueries.GET_ITEMS_FOR_ACCOUNT(this.getObjectUUID());
|
|
|
|
for (Item item : this.vault) {
|
|
if (item.template.getItemType().equals(mbEnums.ItemType.GOLD)) {
|
|
this.vaultGold = item;
|
|
}
|
|
}
|
|
|
|
if (this.vaultGold == null) {
|
|
this.vaultGold = Item.newGoldItem(this.getObjectUUID(), ItemContainerType.VAULT);
|
|
|
|
if (this.vaultGold != null)
|
|
this.vault.add(this.vaultGold);
|
|
}
|
|
}
|
|
|
|
} catch (Exception e) {
|
|
Logger.error(e);
|
|
}
|
|
}
|
|
|
|
public synchronized void transferItemFromInventoryToVault(ItemToVaultMsg msg, ClientConnection origin) {
|
|
|
|
PlayerCharacter player = origin.getPlayerCharacter();
|
|
Dispatch dispatch;
|
|
|
|
if (player == null)
|
|
return;
|
|
|
|
if (!NPCManager.NPCVaultBankRangeCheck(player, origin, "vault")) {
|
|
ItemToVaultMsgHandler.forceTransferFromVaultToInventory(msg, origin, "You are out of range of the vault.");
|
|
return;
|
|
}
|
|
|
|
int uuid = msg.getUUID();
|
|
Item item = Item.getFromCache(uuid);
|
|
|
|
if (item == null) {
|
|
ItemToVaultMsgHandler.forceTransferFromVaultToInventory(msg, origin, "Can't find the item.");
|
|
return;
|
|
}
|
|
|
|
//dupe check
|
|
if (!item.validForInventory(origin, player, player.charItemManager))
|
|
return;
|
|
|
|
if (item.containerType == mbEnums.ItemContainerType.INVENTORY && player.charItemManager.isVaultOpen()) {
|
|
if (!player.charItemManager.hasRoomVault(item.template.getItemWt())) {
|
|
ItemToVaultMsgHandler.forceTransferFromVaultToInventory(msg, origin, "There is no room in your vault.");
|
|
return;
|
|
}
|
|
|
|
if (player.charItemManager.moveItemToVault(item)) {
|
|
this.vault.add(item);
|
|
dispatch = Dispatch.borrow(player, msg);
|
|
DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.SECONDARY);
|
|
} else
|
|
ItemToVaultMsgHandler.forceTransferFromVaultToInventory(msg, origin, "Failed to transfer item.");
|
|
}
|
|
}
|
|
|
|
public synchronized void transferItemFromVaultToInventory(ItemFromVaultMsg msg, ClientConnection origin) {
|
|
|
|
PlayerCharacter player = origin.getPlayerCharacter();
|
|
Dispatch dispatch;
|
|
|
|
if (player == null)
|
|
return;
|
|
|
|
if (!NPCManager.NPCVaultBankRangeCheck(player, origin, "vault")) {
|
|
ItemFromVaultMsgHandler.forceTransferFromInventoryToVault(msg, origin, "You are out of range of the vault.");
|
|
return;
|
|
}
|
|
|
|
CharacterItemManager itemManager = player.charItemManager;
|
|
|
|
if (itemManager == null) {
|
|
ItemFromVaultMsgHandler.forceTransferFromInventoryToVault(msg, origin, "Can't find your item manager.");
|
|
return;
|
|
}
|
|
|
|
Item item = Item.getFromCache(msg.getUUID());
|
|
|
|
if (item == null) {
|
|
ItemFromVaultMsgHandler.forceTransferFromInventoryToVault(msg, origin, "Can't find the item.");
|
|
return;
|
|
}
|
|
|
|
//dupe check
|
|
if (!item.validForVault(origin, player, itemManager))
|
|
return;
|
|
|
|
if (item.containerType == mbEnums.ItemContainerType.VAULT && itemManager.isVaultOpen()) {
|
|
if (!itemManager.hasRoomInventory(item.template.getItemWt())) {
|
|
ItemFromVaultMsgHandler.forceTransferFromInventoryToVault(msg, origin, "There is no room in your inventory.");
|
|
return;
|
|
}
|
|
if (itemManager.moveItemToInventory(item)) {
|
|
this.vault.remove(item);
|
|
|
|
dispatch = Dispatch.borrow(player, msg);
|
|
DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.SECONDARY);
|
|
|
|
} else
|
|
ItemFromVaultMsgHandler.forceTransferFromInventoryToVault(msg, origin, "Failed to transfer item.");
|
|
}
|
|
}
|
|
|
|
public synchronized void transferGoldFromVaultToInventory(GoldFromVaultMsg msg, ClientConnection origin) {
|
|
|
|
PlayerCharacter player = origin.getPlayerCharacter();
|
|
Dispatch dispatch;
|
|
|
|
if (player == null)
|
|
return;
|
|
|
|
Account account = player.getAccount();
|
|
|
|
if (account == null)
|
|
return;
|
|
|
|
if (!NPCManager.NPCVaultBankRangeCheck(player, origin, "vault"))
|
|
return;
|
|
|
|
NPC npc = player.getLastNPCDialog();
|
|
|
|
if (npc == null)
|
|
return;
|
|
|
|
CharacterItemManager itemManager = player.charItemManager;
|
|
|
|
if (itemManager == null)
|
|
return;
|
|
|
|
if (itemManager.isVaultOpen() == false)
|
|
return;
|
|
|
|
if (itemManager.moveGoldToInventory(itemManager.getGoldVault(), msg.getAmount()) == false)
|
|
return;
|
|
|
|
OpenVaultMsg open = new OpenVaultMsg(player, npc);
|
|
ShowVaultInventoryMsg show = new ShowVaultInventoryMsg(player, account, npc); // 37??
|
|
|
|
UpdateGoldMsg ugm = new UpdateGoldMsg(player);
|
|
ugm.configure();
|
|
dispatch = Dispatch.borrow(player, ugm);
|
|
DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.SECONDARY);
|
|
|
|
UpdateVaultMsg uvm = new UpdateVaultMsg(account);
|
|
dispatch = Dispatch.borrow(player, uvm);
|
|
DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.SECONDARY);
|
|
|
|
dispatch = Dispatch.borrow(player, open);
|
|
DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.SECONDARY);
|
|
|
|
dispatch = Dispatch.borrow(player, show);
|
|
DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.SECONDARY);
|
|
|
|
}
|
|
|
|
public synchronized void transferGoldFromInventoryToVault(GoldToVaultMsg msg, ClientConnection origin) {
|
|
|
|
PlayerCharacter player = origin.getPlayerCharacter();
|
|
Dispatch dispatch;
|
|
|
|
if (player == null)
|
|
return;
|
|
|
|
Account account = player.getAccount();
|
|
|
|
if (account == null)
|
|
return;
|
|
|
|
if (!NPCManager.NPCVaultBankRangeCheck(player, origin, "vault"))
|
|
return;
|
|
|
|
CharacterItemManager itemManager = player.charItemManager;
|
|
|
|
if (itemManager == null)
|
|
return;
|
|
|
|
NPC npc = player.getLastNPCDialog();
|
|
|
|
if (npc == null)
|
|
return;
|
|
|
|
// Cannot have bank and vault open concurrently
|
|
// Dupe prevention
|
|
|
|
if (itemManager.isVaultOpen() == false)
|
|
return;
|
|
|
|
// Something went horribly wrong. Should be log this?
|
|
|
|
if (itemManager.moveGoldToVault(itemManager.getGoldInventory(), msg.getAmount()) == false)
|
|
return;
|
|
|
|
UpdateGoldMsg ugm = new UpdateGoldMsg(player);
|
|
ugm.configure();
|
|
dispatch = Dispatch.borrow(player, ugm);
|
|
DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.SECONDARY);
|
|
|
|
UpdateVaultMsg uvm = new UpdateVaultMsg(account);
|
|
dispatch = Dispatch.borrow(player, uvm);
|
|
DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.SECONDARY);
|
|
|
|
OpenVaultMsg open = new OpenVaultMsg(player, npc);
|
|
dispatch = Dispatch.borrow(player, open);
|
|
DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.SECONDARY);
|
|
//
|
|
//
|
|
ShowVaultInventoryMsg show = new ShowVaultInventoryMsg(player, account, npc); // 37??
|
|
dispatch = Dispatch.borrow(player, show);
|
|
DispatchManager.dispatchMsgDispatch(dispatch, DispatchChannel.SECONDARY);
|
|
|
|
}
|
|
}
|