- Joined
- Mar 13, 2010
- Messages
- 291
- Reaction score
- 47
I finally know how to fix this...
For the pros: Flame on me, I dont care the noobs can use v114 now.
For the noobs: Have fun.
MapleServerHandler.java
Channelserver.java
Cashshopserver.java
And use the LIB files from Lithium source.
Have fun bye
For the pros: Flame on me, I dont care the noobs can use v114 now.
For the noobs: Have fun.
MapleServerHandler.java
PHP:
/*
This file is part of the OdinMS Maple Story Server
Copyright (C) 2008 ~ 2012 Patrick Huy <patrick.huy@frz.cc>
Matthias Butz <matze@odinms.de>
Jan Christian Meyer <vimes@odinms.de>
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License version 3
as published by the Free Software Foundation. You may not use, modify
or distribute this program under any other version of the
GNU Affero General Public License.
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 Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package handling;
import constants.ServerConstants;
import java.io.IOException;
import java.util.Arrays;
import java.util.Map;
import java.util.List;
import java.util.ArrayList;
import java.util.concurrent.ConcurrentHashMap;
import client.MapleClient;
import client.inventory.Item;
import client.inventory.MaplePet;
import client.inventory.PetDataFactory;
import constants.GameConstants;
import handling.cashshop.CashShopServer;
import handling.channel.ChannelServer;
import handling.cashshop.handler.*;
import handling.channel.handler.*;
import handling.login.LoginServer;
import handling.login.handler.*;
import handling.mina.MaplePacketDecoder;
import java.io.File;
import java.io.FileWriter;
import java.lang.management.ManagementFactory;
import java.util.EnumSet;
import java.util.HashMap;
import java.util.Scanner;
import java.util.concurrent.locks.ReentrantReadWriteLock;
import javax.management.MBeanServer;
import javax.management.ObjectName;
import server.Randomizer;
import tools.MapleAESOFB;
import tools.packet.LoginPacket;
import tools.data.ByteArrayByteStream;
import tools.data.LittleEndianAccessor;
import tools.Pair;
import org.apache.mina.common.IoHandlerAdapter;
import org.apache.mina.common.IdleStatus;
import org.apache.mina.common.IoSession;
import scripting.NPCScriptManager;
import server.CashItemFactory;
import server.CashItemInfo;
import server.MTSStorage;
import tools.FileoutputUtil;
import tools.HexTool;
import tools.packet.MTSCSPacket;
public class MapleServerHandler extends IoHandlerAdapter implements MapleServerHandlerMBean {
public static boolean Log_Packets = false;
private static int numDC = 0;
private int channel = -1;
private boolean cs;
private static long lastDC = System.currentTimeMillis();
private final List<String> BlockedIP = new ArrayList<String>();
private final Map<String, Pair<Long, Byte>> tracker = new ConcurrentHashMap<String, Pair<Long, Byte>>();
//Screw locking. Doesn't matter.
// private static final ReentrantReadWriteLock IPLoggingLock = new ReentrantReadWriteLock();
private static final String nl = System.getProperty("line.separator");
private static final File loggedIPs = new File("LogIPs.txt");
private static final HashMap<String, FileWriter> logIPMap = new HashMap<String, FileWriter>();
//Note to Zero: Use an enumset. Don't iterate through an array.
private static final EnumSet<RecvPacketOpcode> blocked = EnumSet.noneOf(RecvPacketOpcode.class), sBlocked = EnumSet.noneOf(RecvPacketOpcode.class);
public static void reloadLoggedIPs() {
// IPLoggingLock.writeLock().lock();
// try {
for (FileWriter fw : logIPMap.values()) {
if (fw != null) {
try {
fw.write("=== Closing Log ===");
fw.write(nl);
fw.flush(); //Just in case.
fw.close();
} catch (IOException ex) {
System.out.println("Error closing Packet Log.");
System.out.println(ex);
}
}
}
logIPMap.clear();
try {
Scanner sc = new Scanner(loggedIPs);
while (sc.hasNextLine()) {
String line = sc.nextLine().trim();
if (line.length() > 0) {
addIP(line);
}
}
} catch (Exception e) {
System.out.println("Could not reload packet logged IPs.");
System.out.println(e);
}
// } finally {
// IPLoggingLock.writeLock().unlock();
// }
}
//Return the Filewriter if the IP is logged. Null otherwise.
private static FileWriter isLoggedIP(IoSession sess) {
String a = sess.getRemoteAddress().toString();
String realIP = a.substring(a.indexOf('/') + 1, a.indexOf(':'));
return logIPMap.get(realIP);
}
public static void addIP(String theIP) {
try {
FileWriter fw = new FileWriter(new File("PacketLog_" + theIP + ".txt"), true);
fw.write("=== Creating Log ===");
fw.write(nl);
fw.flush();
logIPMap.put(theIP, fw);
} catch (IOException e) {
FileoutputUtil.outputFileError(FileoutputUtil.PacketEx_Log, e);
}
}
// <editor-fold defaultstate="collapsed" desc="Packet Log Implementation">
private static final int Log_Size = 10000, Packet_Log_Size = 25;
private static final ArrayList<LoggedPacket> Packet_Log = new ArrayList<LoggedPacket>(Log_Size);
private static final ReentrantReadWriteLock Packet_Log_Lock = new ReentrantReadWriteLock();
private static String Packet_Log_Output = "Packet/PacketLog";
private static int Packet_Log_Index = 0;
public static void log(String packet, String op, MapleClient c, IoSession io) {
try {
Packet_Log_Lock.writeLock().lock();
LoggedPacket logged = null;
if (Packet_Log.size() == Log_Size) {
logged = Packet_Log.remove(0);
}
//This way, we don't create new LoggedPacket objects, we reuse them =]
if (logged == null) {
logged = new LoggedPacket(packet, op, io.getRemoteAddress().toString(),
c == null ? -1 : c.getAccID(), FileoutputUtil.CurrentReadable_Time(),
c == null || c.getAccountName() == null ? "[Null]" : c.getAccountName(),
c == null || c.getPlayer() == null || c.getPlayer().getName() == null ? "[Null]" : c.getPlayer().getName(),
c == null || c.getPlayer() == null || c.getPlayer().getMap() == null ? "[Null]" : String.valueOf(c.getPlayer().getMapId()),
c == null || NPCScriptManager.getInstance().getCM(c) == null ? "[Null]" : String.valueOf(NPCScriptManager.getInstance().getCM(c).getNpc()));
} else {
logged.setInfo(packet, op, io.getRemoteAddress().toString(),
c == null ? -1 : c.getAccID(), FileoutputUtil.CurrentReadable_Time(),
c == null || c.getAccountName() == null ? "[Null]" : c.getAccountName(),
c == null || c.getPlayer() == null || c.getPlayer().getName() == null ? "[Null]" : c.getPlayer().getName(),
c == null || c.getPlayer() == null || c.getPlayer().getMap() == null ? "[Null]" : String.valueOf(c.getPlayer().getMapId()),
c == null || NPCScriptManager.getInstance().getCM(c) == null ? "[Null]" : String.valueOf(NPCScriptManager.getInstance().getCM(c).getNpc()));
}
Packet_Log.add(logged);
} finally {
Packet_Log_Lock.writeLock().unlock();
}
}
private static class LoggedPacket {
private static final String nl = System.getProperty("line.separator");
private String ip, accName, accId, chrName, packet, mapId, npcId, op, time;
private long timestamp;
public LoggedPacket(String p, String op, String ip, int id, String time, String accName, String chrName, String mapId, String npcId) {
setInfo(p, op, ip, id, time, accName, chrName, mapId, npcId);
}
public final void setInfo(String p, String op, String ip, int id, String time, String accName, String chrName, String mapId, String npcId) {
this.ip = ip;
this.op = op;
this.time = time;
this.packet = p;
this.accName = accName;
this.chrName = chrName;
this.mapId = mapId;
this.npcId = npcId;
timestamp = System.currentTimeMillis();
this.accId = String.valueOf(id);
}
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append("[IP: ").append(ip).append("] [").append(accId).append('|').append(accName).append('|').append(chrName).append("] [").append(npcId).append('|').append(mapId).append("] [Time: ").append(timestamp).append("] [").append(time).append(']');
sb.append(nl);
sb.append("[Op: ").append(op).append("] [").append(packet).append(']');
return sb.toString();
}
}
public static void registerMBean() {
MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
try {
MapleServerHandler mbean = new MapleServerHandler();
//The log is a static object, so we can just use this hacky method.
mBeanServer.registerMBean(mbean, new ObjectName("handling:type=MapleServerHandler"));
} catch (Exception e) {
System.out.println("Error registering PacketLog MBean");
e.printStackTrace();
}
}
public void writeLog() {
writeLog(false);
}
public void writeLog(boolean crash) {
Packet_Log_Lock.readLock().lock();
try {
FileWriter fw = new FileWriter(new File(Packet_Log_Output + Packet_Log_Index + (crash ? "_DC.txt" : ".txt")), true);
String nl = System.getProperty("line.separator");
for (LoggedPacket loggedPacket : Packet_Log) {
fw.write(loggedPacket.toString());
fw.write(nl);
}
final String logString = "Log has been written at " + lastDC + " [" + FileoutputUtil.CurrentReadable_Time() + "] - " + numDC + " have disconnected, within " + (System.currentTimeMillis() - lastDC) + " milliseconds. (" + System.currentTimeMillis() + ")";
System.out.println(logString);
fw.write(logString);
fw.write(nl);
fw.flush();
fw.close();
Packet_Log.clear();
Packet_Log_Index++;
if (Packet_Log_Index > Packet_Log_Size) {
Packet_Log_Index = 0;
Log_Packets = false;
}
} catch (IOException ex) {
System.out.println("Error writing log to file.");
} finally {
Packet_Log_Lock.readLock().unlock();
}
}
public static final void initiate() {
reloadLoggedIPs();
RecvPacketOpcode[] block = new RecvPacketOpcode[]{RecvPacketOpcode.NPC_ACTION, RecvPacketOpcode.MOVE_PLAYER, RecvPacketOpcode.PONG, RecvPacketOpcode.MOVE_PET, RecvPacketOpcode.MOVE_SUMMON, RecvPacketOpcode.MOVE_DRAGON, RecvPacketOpcode.MOVE_LIFE, RecvPacketOpcode.MOVE_ANDROID, RecvPacketOpcode.HEAL_OVER_TIME, RecvPacketOpcode.STRANGE_DATA, RecvPacketOpcode.AUTO_AGGRO, RecvPacketOpcode.CANCEL_DEBUFF, RecvPacketOpcode.MOVE_FAMILIAR};
RecvPacketOpcode[] serverBlock = new RecvPacketOpcode[]{RecvPacketOpcode.CHANGE_KEYMAP, RecvPacketOpcode.ITEM_PICKUP, RecvPacketOpcode.PET_LOOT, RecvPacketOpcode.TAKE_DAMAGE, RecvPacketOpcode.FACE_EXPRESSION, RecvPacketOpcode.USE_ITEM, RecvPacketOpcode.CLOSE_RANGE_ATTACK, RecvPacketOpcode.MAGIC_ATTACK, RecvPacketOpcode.RANGED_ATTACK, RecvPacketOpcode.ARAN_COMBO, RecvPacketOpcode.SPECIAL_MOVE, RecvPacketOpcode.GENERAL_CHAT, RecvPacketOpcode.MONSTER_BOMB, RecvPacketOpcode.PASSIVE_ENERGY, RecvPacketOpcode.PET_AUTO_POT, RecvPacketOpcode.USE_CASH_ITEM, RecvPacketOpcode.PARTYCHAT, RecvPacketOpcode.CANCEL_BUFF, RecvPacketOpcode.SKILL_EFFECT, RecvPacketOpcode.CHAR_INFO_REQUEST, RecvPacketOpcode.ALLIANCE_OPERATION, RecvPacketOpcode.AUTO_ASSIGN_AP, RecvPacketOpcode.DISTRIBUTE_AP, RecvPacketOpcode.USE_MAGNIFY_GLASS, RecvPacketOpcode.SPAWN_PET, RecvPacketOpcode.SUMMON_ATTACK, RecvPacketOpcode.ITEM_MOVE, RecvPacketOpcode.PARTY_SEARCH_STOP};
blocked.addAll(Arrays.asList(block));
sBlocked.addAll(Arrays.asList(serverBlock));
if (Log_Packets) {
for (int i = 1; i <= Packet_Log_Size; i++) {
if (!(new File(Packet_Log_Output + i + ".txt")).exists() && !(new File(Packet_Log_Output + i + "_DC.txt")).exists()) {
Packet_Log_Index = i;
break;
}
}
if (Packet_Log_Index <= 0) { //25+ files, do not log
Log_Packets = false;
}
}
registerMBean();
}
public MapleServerHandler() {
//ONLY FOR THE MBEAN
}
// </editor-fold>
@Override
public void exceptionCaught(final IoSession session, final Throwable cause) throws Exception {
/*
* MapleClient client = (MapleClient)
* session.getAttribute(MapleClient.CLIENT_KEY);
* log.error(MapleClient.getLogMessage(client, cause.getMessage()),
* cause);
*/
// cause.printStackTrace();
}
@Override
public void sessionOpened(final IoSession session) throws Exception {
// Start of IP checking
final String address = session.getRemoteAddress().toString().split(":")[0];
if (BlockedIP.contains(address)) {
session.close();
return;
}
final Pair<Long, Byte> track = tracker.get(address);
byte count;
if (track == null) {
count = 1;
} else {
count = track.right;
final long difference = System.currentTimeMillis() - track.left;
if (difference < 2000) { // Less than 2 sec
count++;
} else if (difference > 20000) { // Over 20 sec
count = 1;
}
if (count >= 10) {
BlockedIP.add(address);
tracker.remove(address); // Cleanup
session.close();
return;
}
}
tracker.put(address, new Pair<Long, Byte>(System.currentTimeMillis(), count));
// End of IP checking.
String IP = address.substring(address.indexOf('/') + 1, address.length());
if (LoginServer.isShutdown()) {
session.close();
return;
}
LoginServer.removeIPAuth(IP);
final byte ivRecv[] = new byte[]{(byte) Randomizer.nextInt(255), (byte) Randomizer.nextInt(255), (byte) Randomizer.nextInt(255), (byte) Randomizer.nextInt(255)};
final byte ivSend[] = new byte[]{(byte) Randomizer.nextInt(255), (byte) Randomizer.nextInt(255), (byte) Randomizer.nextInt(255), (byte) Randomizer.nextInt(255)};
final MapleClient client = new MapleClient(
new MapleAESOFB(ivSend, (short) (0xFFFF - ServerConstants.MAPLE_VERSION)), // Sent Cypher
new MapleAESOFB(ivRecv, ServerConstants.MAPLE_VERSION), // Recv Cypher
session);
client.setChannel(-1);
MaplePacketDecoder.DecoderState decoderState = new MaplePacketDecoder.DecoderState();
session.setAttribute(MaplePacketDecoder.DECODER_STATE_KEY, decoderState);
session.write(LoginPacket.getHello(ServerConstants.MAPLE_VERSION, ivSend, ivRecv));
//System.out.println("GETHELLO SENT TO " + address);
session.setAttribute(MapleClient.CLIENT_KEY, client);
session.setIdleTime(IdleStatus.READER_IDLE, 60);
session.setIdleTime(IdleStatus.WRITER_IDLE, 60);
if (ServerConstants.Use_Localhost) {
RecvPacketOpcode.reloadValues();
SendPacketOpcode.reloadValues();
}
if (LoginServer.isAdminOnly()) {
StringBuilder sb = new StringBuilder();
sb.append("IoSession opened ").append(address);
System.out.println(sb.toString());
}
FileWriter fw = isLoggedIP(session);
if (fw != null) {
client.setMonitored(true);
}
}
@Override
public void sessionClosed(final IoSession session) throws Exception {
final MapleClient client = (MapleClient) session.getAttribute(MapleClient.CLIENT_KEY);
if (client != null) {
byte state = MapleClient.CHANGE_CHANNEL;
if (Log_Packets && !LoginServer.isShutdown() && client.getPlayer() != null) {
state = client.getLoginState();
}
if (state != MapleClient.CHANGE_CHANNEL) {
log("Data: " + numDC, "CLOSED", client, session);
if (System.currentTimeMillis() - lastDC < 60000) { //within the minute
numDC++;
if (numDC > 100) { //100+ people have dc'd in minute in channelserver
System.out.println("Writing log...");
writeLog();
numDC = 0;
lastDC = System.currentTimeMillis(); //intentionally place here
}
} else {
numDC = 0;
lastDC = System.currentTimeMillis(); //intentionally place here
}
}
try {
FileWriter fw = isLoggedIP(session);
if (fw != null) {
fw.write("=== Session Closed ===");
fw.write(nl);
fw.flush();
}
client.disconnect(true, true);
} finally {
session.close();
session.removeAttribute(MapleClient.CLIENT_KEY);
}
}
super.sessionClosed(session);
}
@Override
public void sessionIdle(final IoSession session, final IdleStatus status) throws Exception {
final MapleClient client = (MapleClient) session.getAttribute(MapleClient.CLIENT_KEY);
/*
* if (client != null && client.getPlayer() != null) {
* System.out.println("Player "+ client.getPlayer().getName() +" went
* idle"); }
*/
if (client != null) {
//client.sendPing();
}
super.sessionIdle(session, status);
}
public MapleServerHandler(final int channel, final boolean cs) {
this.channel = channel;
this.cs = cs;
}
@Override
public void messageReceived(final IoSession session, final Object message) {
if (message == null || session == null) {
return;
}
final LittleEndianAccessor slea = new LittleEndianAccessor(new ByteArrayByteStream((byte[]) message));
if (slea.available() < 2) {
return;
}
final MapleClient c = (MapleClient) session.getAttribute(MapleClient.CLIENT_KEY);
if (c == null || !c.isReceiving()) {
return;
}
final short header_num = slea.readShort();
// final StringBuilder sb = new StringBuilder("Received data :\n");
// sb.append(HexTool.toString((byte[]) message)).append("\n").append(HexTool.toStringFromAscii((byte[]) message));
//System.out.println(sb.toString());
for (final RecvPacketOpcode recv : RecvPacketOpcode.values()) {
if (recv.getValue() == header_num) {
if (recv.NeedsChecking()) {
if (!c.isLoggedIn()) {
return;
}
}
try {
if (c.getPlayer() != null && c.isMonitored() && !blocked.contains(recv)) {
FileWriter fw = new FileWriter(new File("MonitorLogs/" + c.getPlayer().getName() + "_log.txt"), true);
fw.write(String.valueOf(recv) + " (" + Integer.toHexString(header_num) + ") Handled: \r\n" + slea.toString() + "\r\n");
fw.flush();
fw.close();
}
//no login packets
if (Log_Packets && !blocked.contains(recv) && !sBlocked.contains(recv) && c.getPlayer() != null) {
log(slea.toString(), recv.toString(), c, session);
}
handlePacket(recv, slea, c);
//Log after the packet is handle. You'll see why =]
FileWriter fw = isLoggedIP(session);
if (fw != null && !blocked.contains(recv)) {
if (recv == RecvPacketOpcode.PLAYER_LOGGEDIN && c != null) { // << This is why. Win.
fw.write(">> [AccountName: "
+ (c.getAccountName() == null ? "null" : c.getAccountName()) + "] | [IGN: "
+ (c.getPlayer() == null || c.getPlayer().getName() == null ? "null" : c.getPlayer().getName()) + "] | [Time: "
+ FileoutputUtil.CurrentReadable_Time() + "]");
fw.write(nl);
}
fw.write("[" + recv.toString() + "]" + slea.toString(true));
fw.write(nl);
fw.flush();
}
} catch (NegativeArraySizeException e) {
//swallow, no one cares
if (ServerConstants.Use_Localhost) {
FileoutputUtil.outputFileError(FileoutputUtil.PacketEx_Log, e);
FileoutputUtil.log(FileoutputUtil.PacketEx_Log, "Packet: " + header_num + "\n" + slea.toString(true));
}
} catch (ArrayIndexOutOfBoundsException e) {
//swallow, no one cares
if (ServerConstants.Use_Localhost) {
FileoutputUtil.outputFileError(FileoutputUtil.PacketEx_Log, e);
FileoutputUtil.log(FileoutputUtil.PacketEx_Log, "Packet: " + header_num + "\n" + slea.toString(true));
}
} catch (Exception e) {
FileoutputUtil.outputFileError(FileoutputUtil.PacketEx_Log, e);
FileoutputUtil.log(FileoutputUtil.PacketEx_Log, "Packet: " + header_num + "\n" + slea.toString(true));
}
return;
}
}
//final StringBuilder sb = new StringBuilder("Received data : (Unhandled)\n");
//sb.append(HexTool.toString((byte[]) message)).append("\n").append(HexTool.toStringFromAscii((byte[]) message));
//System.out.println(sb.toString());
}
public static final void handlePacket(final RecvPacketOpcode header, final LittleEndianAccessor slea, final MapleClient c) throws Exception {
switch (header) {
case PONG:
c.pongReceived();
break;
case STRANGE_DATA:
// Does nothing for now, HackShield's heartbeat
break;
case LOGIN_PASSWORD:
CharLoginHandler.login(slea, c);
break;
case SEND_ENCRYPTED:
//if (c.isLocalhost()) {
// CharLoginHandler.login(slea, c);
//} else {
// c.getSession().write(LoginPacket.getCustomEncryption());
//}
break;
case CLIENT_START:
if (c.isLocalhost()) {
CharLoginHandler.login(slea, c);
}
break;
case CLIENT_FAILED:
c.getSession().write(LoginPacket.getCustomEncryption());
break;
case VIEW_SERVERLIST:
if (slea.readByte() == 0) {
CharLoginHandler.ServerListRequest(c);
}
break;
case REDISPLAY_SERVERLIST:
case SERVERLIST_REQUEST:
CharLoginHandler.ServerListRequest(c);
break;
case CLIENT_HELLO:
if (slea.readByte() != 8 || slea.readShort() != ServerConstants.MAPLE_VERSION || !String.valueOf(slea.readShort()).equals(ServerConstants.MAPLE_PATCH)) {
c.getSession().close();
}
break;
case CHARLIST_REQUEST:
CharLoginHandler.CharlistRequest(slea, c);
break;
case SERVERSTATUS_REQUEST:
CharLoginHandler.ServerStatusRequest(c);
break;
case CHECK_CHAR_NAME:
CharLoginHandler.CheckCharName(slea.readMapleAsciiString(), c);
break;
case CREATE_CHAR:
case CREATE_SPECIAL_CHAR:
CharLoginHandler.CreateChar(slea, c);
break;
case CREATE_ULTIMATE:
CharLoginHandler.CreateUltimate(slea, c);
break;
case DELETE_CHAR:
CharLoginHandler.DeleteChar(slea, c);
break;
case VIEW_ALL_CHAR:
CharLoginHandler.ViewChar(slea, c);
break;
case PICK_ALL_CHAR:
CharLoginHandler.Character_WithoutSecondPassword(slea, c, false, true);
break;
case CHAR_SELECT_NO_PIC:
CharLoginHandler.Character_WithoutSecondPassword(slea, c, false, false);
break;
case VIEW_REGISTER_PIC:
CharLoginHandler.Character_WithoutSecondPassword(slea, c, true, true);
break;
case CHAR_SELECT:
CharLoginHandler.Character_WithoutSecondPassword(slea, c, true, false);
break;
case VIEW_SELECT_PIC:
CharLoginHandler.Character_WithSecondPassword(slea, c, true);
break;
case AUTH_SECOND_PASSWORD:
CharLoginHandler.Character_WithSecondPassword(slea, c, false);
break;
case CHARACTER_CARDS:
CharLoginHandler.updateCCards(slea, c);
break;
case CLIENT_ERROR:
// System.out.println("Client error: " + slea.toString());
if (slea.available() < 8) {
return;
}
short type = slea.readShort();
String type_str = "Unknown?!";
if (type == 0x01) {
type_str = "SendBackupPacket";
} else if (type == 0x02) {
type_str = "Crash Report";
} else if (type == 0x03) {
type_str = "Exception";
}
int errortype = slea.readInt(); // example error 38
if (errortype == 0) { // i don't wanna log error code 0 stuffs, (usually some bounceback to login)
return;
}
short data_length = slea.readShort();
slea.skip(4); // ?B3 86 01 00 00 00 FF 00 00 00 00 00 9E 05 C8 FF 02 00 CD 05 C9 FF 7D 00 00 00 3F 00 00 00 00 00 02 77 01 00 25 06 C9 FF 7D 00 00 00 40 00 00 00 00 00 02 C1 02
short opcodeheader = slea.readShort();
FileoutputUtil.log("ErrorCodes.txt","Error Type: " + errortype + "\r\n" + "Data Length: " + data_length + "\r\n" + "Error for player ; " + c.getPlayer() + " - account ; " + c.getAccountName() + "\r\n" + SendPacketOpcode.getOpcodeName(opcodeheader) + "Opcode: " + opcodeheader + "\r\n" + HexTool.toString(slea.read((int) slea.available())) + "\r\n\r\n");
break;
case ENABLE_SPECIAL_CREATION:
c.getSession().write(LoginPacket.enableSpecialCreation(c.getAccID(), true));
break;
case RSA_KEY: // Fix this somehow
//c.getSession().write(LoginPacket.getLoginAUTH());
// c.getSession().write(LoginPacket.StrangeDATA());
break;
// END OF LOGIN SERVER
case CHANGE_CHANNEL:
case CHANGE_ROOM_CHANNEL:
InterServerHandler.ChangeChannel(slea, c, c.getPlayer(), header == RecvPacketOpcode.CHANGE_ROOM_CHANNEL);
break;
case PLAYER_LOGGEDIN:
final int playerid = slea.readInt();
InterServerHandler.Loggedin(playerid, c);
break;
case ENTER_PVP:
case ENTER_PVP_PARTY:
PlayersHandler.EnterPVP(slea, c);
break;
case PVP_RESPAWN:
PlayersHandler.RespawnPVP(slea, c);
break;
case LEAVE_PVP:
PlayersHandler.LeavePVP(slea, c);
break;
case PVP_ATTACK:
PlayersHandler.AttackPVP(slea, c);
break;
case PVP_SUMMON:
SummonHandler.SummonPVP(slea, c);
break;
case ENTER_CASH_SHOP:
InterServerHandler.EnterCS(c, c.getPlayer(), false);
break;
case ENTER_MTS:
InterServerHandler.EnterMTS(c, c.getPlayer());
//InterServerHandler.EnterCS(c, c.getPlayer(), true);
break;
case MOVE_PLAYER:
PlayerHandler.MovePlayer(slea, c, c.getPlayer());
break;
case CHAR_INFO_REQUEST:
c.getPlayer().updateTick(slea.readInt());
PlayerHandler.CharInfoRequest(slea.readInt(), c, c.getPlayer());
break;
case CLOSE_RANGE_ATTACK:
PlayerHandler.closeRangeAttack(slea, c, c.getPlayer(), false);
break;
case RANGED_ATTACK:
PlayerHandler.rangedAttack(slea, c, c.getPlayer());
break;
case MAGIC_ATTACK:
PlayerHandler.MagicDamage(slea, c, c.getPlayer());
break;
case SPECIAL_MOVE:
PlayerHandler.SpecialMove(slea, c, c.getPlayer());
break;
case PASSIVE_ENERGY:
PlayerHandler.closeRangeAttack(slea, c, c.getPlayer(), true);
break;
case GET_BOOK_INFO:
PlayersHandler.MonsterBookInfoRequest(slea, c, c.getPlayer());
break;
case MONSTER_BOOK_DROPS:
PlayersHandler.MonsterBookDropsRequest(slea, c, c.getPlayer());
break;
case CHANGE_SET:
PlayersHandler.ChangeSet(slea, c, c.getPlayer());
break;
case PROFESSION_INFO:
ItemMakerHandler.ProfessionInfo(slea, c);
break;
case CRAFT_DONE:
ItemMakerHandler.CraftComplete(slea, c, c.getPlayer());
break;
case CRAFT_MAKE:
ItemMakerHandler.CraftMake(slea, c, c.getPlayer());
break;
case CRAFT_EFFECT:
ItemMakerHandler.CraftEffect(slea, c, c.getPlayer());
break;
case START_HARVEST:
ItemMakerHandler.StartHarvest(slea, c, c.getPlayer());
break;
case STOP_HARVEST:
ItemMakerHandler.StopHarvest(slea, c, c.getPlayer());
break;
case MAKE_EXTRACTOR:
ItemMakerHandler.MakeExtractor(slea, c, c.getPlayer());
break;
case USE_BAG:
ItemMakerHandler.UseBag(slea, c, c.getPlayer());
break;
case USE_FAMILIAR:
MobHandler.UseFamiliar(slea, c, c.getPlayer());
break;
case SPAWN_FAMILIAR:
MobHandler.SpawnFamiliar(slea, c, c.getPlayer());
break;
case RENAME_FAMILIAR:
MobHandler.RenameFamiliar(slea, c, c.getPlayer());
break;
case MOVE_FAMILIAR:
MobHandler.MoveFamiliar(slea, c, c.getPlayer());
break;
case ATTACK_FAMILIAR:
MobHandler.AttackFamiliar(slea, c, c.getPlayer());
break;
case TOUCH_FAMILIAR:
MobHandler.TouchFamiliar(slea, c, c.getPlayer());
break;
case USE_RECIPE:
ItemMakerHandler.UseRecipe(slea, c, c.getPlayer());
break;
case MOVE_ANDROID:
PlayerHandler.MoveAndroid(slea, c, c.getPlayer());
break;
case FACE_EXPRESSION:
PlayerHandler.ChangeEmotion(slea.readInt(), c.getPlayer());
break;
case FACE_ANDROID:
PlayerHandler.ChangeAndroidEmotion(slea.readInt(), c.getPlayer());
break;
case TAKE_DAMAGE:
PlayerHandler.TakeDamage(slea, c, c.getPlayer());
break;
case HEAL_OVER_TIME:
PlayerHandler.Heal(slea, c.getPlayer());
break;
case CANCEL_BUFF:
PlayerHandler.CancelBuffHandler(slea.readInt(), c.getPlayer());
break;
case MECH_CANCEL:
PlayerHandler.CancelMech(slea, c.getPlayer());
break;
case CANCEL_ITEM_EFFECT:
PlayerHandler.CancelItemEffect(slea.readInt(), c.getPlayer());
break;
case USE_TITLE:
PlayerHandler.UseTitle(slea.readInt(), c, c.getPlayer());
break;
case USE_CHAIR:
PlayerHandler.UseChair(slea.readInt(), c, c.getPlayer());
break;
case CANCEL_CHAIR:
PlayerHandler.CancelChair(slea.readShort(), c, c.getPlayer());
break;
case WHEEL_OF_FORTUNE:
break; //whatever
case USE_ITEMEFFECT:
PlayerHandler.UseItemEffect(slea.readInt(), c, c.getPlayer());
break;
case SKILL_EFFECT:
PlayerHandler.SkillEffect(slea, c.getPlayer());
break;
case QUICK_SLOT:
PlayerHandler.QuickSlot(slea, c.getPlayer());
break;
case MESO_DROP:
c.getPlayer().updateTick(slea.readInt());
PlayerHandler.DropMeso(slea.readInt(), c.getPlayer());
break;
case CHANGE_KEYMAP:
PlayerHandler.ChangeKeymap(slea, c.getPlayer());
break;
case UPDATE_ENV:
// We handle this in MapleMap
break;
case CHANGE_MAP:
if (c.getPlayer().getMap() == null) {
CashShopOperation.LeaveCS(slea, c, c.getPlayer());
} else {
PlayerHandler.ChangeMap(slea, c, c.getPlayer());
}
break;
case CHANGE_MAP_SPECIAL:
slea.skip(1);
PlayerHandler.ChangeMapSpecial(slea.readMapleAsciiString(), c, c.getPlayer());
break;
case USE_INNER_PORTAL:
slea.skip(1);
PlayerHandler.InnerPortal(slea, c, c.getPlayer());
break;
case TROCK_ADD_MAP:
PlayerHandler.TrockAddMap(slea, c, c.getPlayer());
break;
case ARAN_COMBO:
PlayerHandler.AranCombo(c, c.getPlayer(), 1);
break;
case SKILL_MACRO:
PlayerHandler.ChangeSkillMacro(slea, c.getPlayer());
break;
case GIVE_FAME:
PlayersHandler.GiveFame(slea, c, c.getPlayer());
break;
case TRANSFORM_PLAYER:
PlayersHandler.TransformPlayer(slea, c, c.getPlayer());
break;
case NOTE_ACTION:
PlayersHandler.Note(slea, c.getPlayer());
break;
case USE_DOOR:
PlayersHandler.UseDoor(slea, c.getPlayer());
break;
case USE_MECH_DOOR:
PlayersHandler.UseMechDoor(slea, c.getPlayer());
break;
case DAMAGE_REACTOR:
PlayersHandler.HitReactor(slea, c);
break;
case CLICK_REACTOR:
case TOUCH_REACTOR:
PlayersHandler.TouchReactor(slea, c);
break;
case CLOSE_CHALKBOARD:
c.getPlayer().setChalkboard(null);
break;
case ITEM_SORT:
InventoryHandler.ItemSort(slea, c);
break;
case ITEM_GATHER:
InventoryHandler.ItemGather(slea, c);
break;
case ITEM_MOVE:
InventoryHandler.ItemMove(slea, c);
break;
case MOVE_BAG:
InventoryHandler.MoveBag(slea, c);
break;
case SWITCH_BAG:
InventoryHandler.SwitchBag(slea, c);
break;
case ITEM_MAKER:
ItemMakerHandler.ItemMaker(slea, c);
break;
case ITEM_PICKUP:
InventoryHandler.Pickup_Player(slea, c, c.getPlayer());
break;
case USE_CASH_ITEM:
InventoryHandler.UseCashItem(slea, c);
break;
case USE_ITEM:
InventoryHandler.UseItem(slea, c, c.getPlayer());
break;
case USE_COSMETIC:
InventoryHandler.UseCosmetic(slea, c, c.getPlayer());
break;
case USE_MAGNIFY_GLASS:
InventoryHandler.UseMagnify(slea, c);
break;
case USE_SCRIPTED_NPC_ITEM:
InventoryHandler.UseScriptedNPCItem(slea, c, c.getPlayer());
break;
case USE_RETURN_SCROLL:
InventoryHandler.UseReturnScroll(slea, c, c.getPlayer());
break;
case USE_NEBULITE:
InventoryHandler.UseNebulite(slea, c);
break;
case USE_ALIEN_SOCKET:
InventoryHandler.UseAlienSocket(slea, c);
break;
case USE_ALIEN_SOCKET_RESPONSE:
slea.skip(4); // all 0
c.getSession().write(MTSCSPacket.useAlienSocket(false));
break;
case VICIOUS_HAMMER:
slea.skip(4); // 3F 00 00 00
slea.skip(4); // all 0
c.getSession().write(MTSCSPacket.ViciousHammer(false, 0));
break;
case USE_NEBULITE_FUSION:
InventoryHandler.UseNebuliteFusion(slea, c);
break;
case USE_UPGRADE_SCROLL:
c.getPlayer().updateTick(slea.readInt());
InventoryHandler.UseUpgradeScroll(slea.readShort(), slea.readShort(), slea.readShort(), c, c.getPlayer(), slea.readByte() > 0);
break;
case USE_FLAG_SCROLL:
case USE_POTENTIAL_SCROLL:
case USE_EQUIP_SCROLL:
c.getPlayer().updateTick(slea.readInt());
InventoryHandler.UseUpgradeScroll(slea.readShort(), slea.readShort(), (short) 0, c, c.getPlayer(), slea.readByte() > 0);
break;
case USE_SUMMON_BAG:
InventoryHandler.UseSummonBag(slea, c, c.getPlayer());
break;
case USE_TREASURE_CHEST:
InventoryHandler.UseTreasureChest(slea, c, c.getPlayer());
break;
case USE_SKILL_BOOK:
c.getPlayer().updateTick(slea.readInt());
InventoryHandler.UseSkillBook((byte) slea.readShort(), slea.readInt(), c, c.getPlayer());
break;
case USE_CATCH_ITEM:
InventoryHandler.UseCatchItem(slea, c, c.getPlayer());
break;
case USE_MOUNT_FOOD:
InventoryHandler.UseMountFood(slea, c, c.getPlayer());
break;
case REWARD_ITEM:
InventoryHandler.UseRewardItem((byte) slea.readShort(), slea.readInt(), c, c.getPlayer());
break;
case HYPNOTIZE_DMG:
MobHandler.HypnotizeDmg(slea, c.getPlayer());
break;
case MOB_NODE:
MobHandler.MobNode(slea, c.getPlayer());
break;
case DISPLAY_NODE:
MobHandler.DisplayNode(slea, c.getPlayer());
break;
case MOVE_LIFE:
MobHandler.MoveMonster(slea, c, c.getPlayer());
break;
case AUTO_AGGRO:
MobHandler.AutoAggro(slea.readInt(), c.getPlayer());
break;
case FRIENDLY_DAMAGE:
MobHandler.FriendlyDamage(slea, c.getPlayer());
break;
case REISSUE_MEDAL:
PlayerHandler.ReIssueMedal(slea, c, c.getPlayer());
break;
case MONSTER_BOMB:
MobHandler.MonsterBomb(slea.readInt(), c.getPlayer());
break;
case MOB_BOMB:
MobHandler.MobBomb(slea, c.getPlayer());
break;
case NPC_SHOP:
NPCHandler.NPCShop(slea, c, c.getPlayer());
break;
case NPC_TALK:
NPCHandler.NPCTalk(slea, c, c.getPlayer());
break;
case NPC_TALK_MORE:
NPCHandler.NPCMoreTalk(slea, c);
break;
case NPC_ACTION:
NPCHandler.NPCAnimation(slea, c);
break;
case QUEST_ACTION:
NPCHandler.QuestAction(slea, c, c.getPlayer());
break;
case STORAGE:
NPCHandler.Storage(slea, c, c.getPlayer());
break;
case GENERAL_CHAT:
if (c.getPlayer() != null && c.getPlayer().getMap() != null) {
c.getPlayer().updateTick(slea.readInt());
ChatHandler.GeneralChat(slea.readMapleAsciiString(), slea.readByte(), c, c.getPlayer());
}
break;
case PARTYCHAT:
c.getPlayer().updateTick(slea.readInt());
ChatHandler.Others(slea, c, c.getPlayer());
break;
case WHISPER:
ChatHandler.Whisper_Find(slea, c);
break;
case MESSENGER:
ChatHandler.Messenger(slea, c);
break;
case AUTO_ASSIGN_AP:
StatsHandling.AutoAssignAP(slea, c, c.getPlayer());
break;
case DISTRIBUTE_AP:
StatsHandling.DistributeAP(slea, c, c.getPlayer());
break;
case DISTRIBUTE_SP:
c.getPlayer().updateTick(slea.readInt());
StatsHandling.DistributeSP(slea.readInt(), c, c.getPlayer());
break;
case PLAYER_INTERACTION:
PlayerInteractionHandler.PlayerInteraction(slea, c, c.getPlayer());
break;
case GUILD_OPERATION:
GuildHandler.Guild(slea, c);
break;
case DENY_GUILD_REQUEST:
slea.skip(1);
GuildHandler.DenyGuildRequest(slea.readMapleAsciiString(), c);
break;
case ALLIANCE_OPERATION:
AllianceHandler.HandleAlliance(slea, c, false);
break;
case DENY_ALLIANCE_REQUEST:
AllianceHandler.HandleAlliance(slea, c, true);
break;
case PUBLIC_NPC:
NPCHandler.OpenPublicNpc(slea, c);
break;
case BBS_OPERATION:
BBSHandler.BBSOperation(slea, c);
break;
case PARTY_OPERATION:
PartyHandler.PartyOperation(slea, c);
break;
case DENY_PARTY_REQUEST:
PartyHandler.DenyPartyRequest(slea, c);
break;
case ALLOW_PARTY_INVITE:
PartyHandler.AllowPartyInvite(slea, c);
break;
case BUDDYLIST_MODIFY:
BuddyListHandler.BuddyOperation(slea, c);
break;
case CYGNUS_SUMMON:
UserInterfaceHandler.CygnusSummon_NPCRequest(c);
break;
case SHIP_OBJECT:
UserInterfaceHandler.ShipObjectRequest(slea.readInt(), c);
break;
case BUY_CS_ITEM:
CashShopOperation.BuyCashItem(slea, c, c.getPlayer());
break;
case COUPON_CODE:
//FileoutputUtil.log(FileoutputUtil.PacketEx_Log, "Coupon : \n" + slea.toString(true));
//System.out.println(slea.toString());
//CashShopOperation.CouponCode(slea.readMapleAsciiString(), c);
c.getSession().write(MTSCSPacket.showOneADayInfo(true, 10003055));
CashShopOperation.doCSPackets(c);
break;
case TWIN_DRAGON_EGG:
System.out.println("TWIN_DRAGON_EGG: " + slea.toString());
final CashItemInfo item = CashItemFactory.getInstance().getItem(10003055);
Item itemz = c.getPlayer().getCashInventory().toItem(item);
c.getSession().write(MTSCSPacket.sendTwinDragonEgg(true, true, 38, itemz, 1));
break;
case XMAS_SURPRISE:
System.out.println("XMAS_SURPRISE: " + slea.toString());
break;
case CS_UPDATE:
CashShopOperation.CSUpdate(c);
break;
case TOUCHING_MTS:
MTSOperation.MTSUpdate(MTSStorage.getInstance().getCart(c.getPlayer().getId()), c);
break;
case MTS_TAB:
MTSOperation.MTSOperation(slea, c);
break;
case USE_POT:
ItemMakerHandler.UsePot(slea, c);
break;
case CLEAR_POT:
ItemMakerHandler.ClearPot(slea, c);
break;
case FEED_POT:
ItemMakerHandler.FeedPot(slea, c);
break;
case CURE_POT:
ItemMakerHandler.CurePot(slea, c);
break;
case REWARD_POT:
ItemMakerHandler.RewardPot(slea, c);
break;
case DAMAGE_SUMMON:
slea.skip(4);
SummonHandler.DamageSummon(slea, c.getPlayer());
break;
case MOVE_SUMMON:
SummonHandler.MoveSummon(slea, c.getPlayer());
break;
case SUMMON_ATTACK:
SummonHandler.SummonAttack(slea, c, c.getPlayer());
break;
case MOVE_DRAGON:
SummonHandler.MoveDragon(slea, c.getPlayer());
break;
case SUB_SUMMON:
SummonHandler.SubSummon(slea, c.getPlayer());
break;
case REMOVE_SUMMON:
SummonHandler.RemoveSummon(slea, c);
break;
case SPAWN_PET:
PetHandler.SpawnPet(slea, c, c.getPlayer());
break;
case MOVE_PET:
PetHandler.MovePet(slea, c.getPlayer());
break;
case PET_CHAT:
//System.out.println("Pet chat: " + slea.toString());
if (slea.available() < 12) {
break;
}
final int petid = GameConstants.GMS ? c.getPlayer().getPetIndex((int) slea.readLong()) : slea.readInt();
c.getPlayer().updateTick(slea.readInt());
PetHandler.PetChat(petid, slea.readShort(), slea.readMapleAsciiString(), c.getPlayer());
break;
case PET_COMMAND:
MaplePet pet = null;
if (GameConstants.GMS) {
pet = c.getPlayer().getPet(c.getPlayer().getPetIndex((int) slea.readLong()));
} else {
pet = c.getPlayer().getPet((byte) slea.readInt());
}
slea.readByte(); //always 0?
if (pet == null) {
return;
}
PetHandler.PetCommand(pet, PetDataFactory.getPetCommand(pet.getPetItemId(), slea.readByte()), c, c.getPlayer());
break;
case PET_FOOD:
PetHandler.PetFood(slea, c, c.getPlayer());
break;
case PET_LOOT:
InventoryHandler.Pickup_Pet(slea, c, c.getPlayer());
break;
case PET_AUTO_POT:
PetHandler.Pet_AutoPotion(slea, c, c.getPlayer());
break;
case MONSTER_CARNIVAL:
MonsterCarnivalHandler.MonsterCarnival(slea, c);
break;
case DUEY_ACTION:
DueyHandler.DueyOperation(slea, c);
break;
case USE_HIRED_MERCHANT:
HiredMerchantHandler.UseHiredMerchant(c, true);
break;
case MERCH_ITEM_STORE:
HiredMerchantHandler.MerchantItemStore(slea, c);
break;
case CANCEL_DEBUFF:
// Ignore for now
break;
case MAPLETV:
break;
case LEFT_KNOCK_BACK:
PlayerHandler.leftKnockBack(slea, c);
break;
case SNOWBALL:
PlayerHandler.snowBall(slea, c);
break;
case COCONUT:
PlayersHandler.hitCoconut(slea, c);
break;
case REPAIR:
NPCHandler.repair(slea, c);
break;
case REPAIR_ALL:
NPCHandler.repairAll(c);
break;
case GAME_POLL:
UserInterfaceHandler.InGame_Poll(slea, c);
break;
case OWL:
InventoryHandler.Owl(slea, c);
break;
case OWL_WARP:
InventoryHandler.OwlWarp(slea, c);
break;
case USE_OWL_MINERVA:
InventoryHandler.OwlMinerva(slea, c);
break;
case RPS_GAME:
NPCHandler.RPSGame(slea, c);
break;
case UPDATE_QUEST:
NPCHandler.UpdateQuest(slea, c);
break;
case USE_ITEM_QUEST:
NPCHandler.UseItemQuest(slea, c);
break;
case FOLLOW_REQUEST:
PlayersHandler.FollowRequest(slea, c);
break;
case AUTO_FOLLOW_REPLY:
case FOLLOW_REPLY:
PlayersHandler.FollowReply(slea, c);
break;
case RING_ACTION:
PlayersHandler.RingAction(slea, c);
break;
case REQUEST_FAMILY:
FamilyHandler.RequestFamily(slea, c);
break;
case OPEN_FAMILY:
FamilyHandler.OpenFamily(slea, c);
break;
case FAMILY_OPERATION:
FamilyHandler.FamilyOperation(slea, c);
break;
case DELETE_JUNIOR:
FamilyHandler.DeleteJunior(slea, c);
break;
case DELETE_SENIOR:
FamilyHandler.DeleteSenior(slea, c);
break;
case USE_FAMILY:
FamilyHandler.UseFamily(slea, c);
break;
case FAMILY_PRECEPT:
FamilyHandler.FamilyPrecept(slea, c);
break;
case FAMILY_SUMMON:
FamilyHandler.FamilySummon(slea, c);
break;
case ACCEPT_FAMILY:
FamilyHandler.AcceptFamily(slea, c);
break;
case SOLOMON:
PlayersHandler.Solomon(slea, c);
break;
case GACH_EXP:
PlayersHandler.GachExp(slea, c);
break;
case PARTY_SEARCH_START:
PartyHandler.MemberSearch(slea, c);
break;
case PARTY_SEARCH_STOP:
PartyHandler.PartySearch(slea, c);
break;
case EXPEDITION_LISTING:
PartyHandler.PartyListing(slea, c);
break;
case EXPEDITION_OPERATION:
PartyHandler.Expedition(slea, c);
break;
case USE_TELE_ROCK:
InventoryHandler.TeleRock(slea, c);
break;
case PAM_SONG:
InventoryHandler.PamSong(slea, c);
break;
case REPORT:
PlayersHandler.Report(slea, c);
break;
case CANCEL_OUT_SWIPE:
slea.readInt();
break;
case VIEW_SKILLS:
PlayersHandler.viewSkills(slea, c);
break;
case SKILL_SWIPE:
PlayersHandler.updateStolenSkill(slea, c);
break;
case MAGIC_WHEEL:
System.out.println("[MAGIC_WHEEL] [" + slea.toString() + "]");
final byte mode = slea.readByte(); // 0 = open, 2 = start.
if (mode == 2) {
final int idk = slea.readInt(); // 4? o.o
final short toUseSlot = (short) slea.readInt();
final int tokenId = slea.readInt();
}
break;
default:
System.out.println("[UNHANDLED] Recv [" + header.toString() + "] found");
break;
}
}
}Channelserver.java
PHP:
/*
This file is part of the OdinMS Maple Story Server
Copyright (C) 2008 ~ 2010 Patrick Huy <patrick.huy@frz.cc>
Matthias Butz <matze@odinms.de>
Jan Christian Meyer <vimes@odinms.de>
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License version 3
as published by the Free Software Foundation. You may not use, modify
or distribute this program under any other version of the
GNU Affero General Public License.
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 Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package handling.channel;
import client.MapleCharacter;
import constants.GameConstants;
import constants.ServerConstants;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import handling.MapleServerHandler;
import handling.login.LoginServer;
import handling.mina.MapleCodecFactory;
import handling.world.CheaterData;
import java.util.concurrent.locks.ReentrantReadWriteLock;
import scripting.EventScriptManager;
import server.MapleSquad;
import server.MapleSquad.MapleSquadType;
import server.maps.MapleMapFactory;
import server.shops.HiredMerchant;
import server.life.PlayerNPC;
import org.apache.mina.common.ByteBuffer;
import org.apache.mina.common.SimpleByteBufferAllocator;
import org.apache.mina.common.IoAcceptor;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.transport.socket.nio.SocketAcceptorConfig;
import org.apache.mina.transport.socket.nio.SocketAcceptor;
import java.util.ArrayList;
import java.util.EnumMap;
import java.util.HashSet;
import java.util.Set;
import server.ServerProperties;
import server.events.*;
import server.maps.AramiaFireWorks;
import server.maps.MapleMapObject;
import tools.ConcurrentEnumMap;
import tools.packet.CWvsContext;
public class ChannelServer {
public static long serverStartTime;
public int eventMap = 0;
private int expRate, mesoRate, dropRate = 2, dropRate2 = 3, cashRate = 3, traitRate = 3;
private short port = 8585;
private static final short DEFAULT_PORT = 8585;
private int channel, running_MerchantID = 0, flags = 0;
private String serverMessage, ip, serverName;
private boolean shutdown = false, finishedShutdown = false, MegaphoneMuteState = false, adminOnly = false;
private PlayerStorage players;
private IoAcceptor acceptor;
private final MapleMapFactory mapFactory;
private EventScriptManager eventSM;
private AramiaFireWorks works = new AramiaFireWorks();
private static final Map<Integer, ChannelServer> instances = new HashMap<Integer, ChannelServer>();
private final Map<MapleSquadType, MapleSquad> mapleSquads = new ConcurrentEnumMap<MapleSquadType, MapleSquad>(MapleSquadType.class);
private final Map<Integer, HiredMerchant> merchants = new HashMap<Integer, HiredMerchant>();
private final List<PlayerNPC> playerNPCs = new LinkedList<PlayerNPC>();
private final ReentrantReadWriteLock merchLock = new ReentrantReadWriteLock(); //merchant
public boolean eventOn = false;
private int eventmap = -1;
private final Map<MapleEventType, MapleEvent> events = new EnumMap<MapleEventType, MapleEvent>(MapleEventType.class);
private ChannelServer(final int channel) {
this.channel = channel;
mapFactory = new MapleMapFactory(channel);
}
public static Set<Integer> getAllInstance() {
return new HashSet<Integer>(instances.keySet());
}
public final void loadEvents() {
if (events.size() != 0) {
return;
}
events.put(MapleEventType.CokePlay, new MapleCoconut(channel, MapleEventType.CokePlay)); //yep, coconut. same poop
events.put(MapleEventType.Coconut, new MapleCoconut(channel, MapleEventType.Coconut));
events.put(MapleEventType.Fitness, new MapleFitness(channel, MapleEventType.Fitness));
events.put(MapleEventType.OlaOla, new MapleOla(channel, MapleEventType.OlaOla));
events.put(MapleEventType.OxQuiz, new MapleOxQuiz(channel, MapleEventType.OxQuiz));
events.put(MapleEventType.Snowball, new MapleSnowball(channel, MapleEventType.Snowball));
events.put(MapleEventType.Survival, new MapleSurvival(channel, MapleEventType.Survival));
}
public final void run_startup_configurations() {
setChannel(channel); //instances.put
try {
expRate = Integer.parseInt(ServerProperties.getProperty("net.sf.odinms.world.exp"));
mesoRate = Integer.parseInt(ServerProperties.getProperty("net.sf.odinms.world.meso"));
serverMessage = ServerProperties.getProperty("net.sf.odinms.world.serverMessage");
serverName = ServerProperties.getProperty("net.sf.odinms.login.serverName");
flags = Integer.parseInt(ServerProperties.getProperty("net.sf.odinms.world.flags", "0"));
adminOnly = Boolean.parseBoolean(ServerProperties.getProperty("net.sf.odinms.world.admin", "false"));
eventSM = new EventScriptManager(this, ServerProperties.getProperty("net.sf.odinms.channel.events").split(","));
port = Short.parseShort(ServerProperties.getProperty("net.sf.odinms.channel.net.port" + channel, String.valueOf(DEFAULT_PORT + channel)));
} catch (Exception e) {
throw new RuntimeException(e);
}
ip = ServerProperties.getProperty("net.sf.odinms.channel.net.interface") + ":" + port;
ByteBuffer.setUseDirectBuffers(false);
ByteBuffer.setAllocator(new SimpleByteBufferAllocator());
acceptor = new SocketAcceptor();
final SocketAcceptorConfig acceptor_config = new SocketAcceptorConfig();
acceptor_config.getSessionConfig().setTcpNoDelay(true);
acceptor_config.setDisconnectOnUnbind(true);
acceptor_config.getFilterChain().addLast("codec", new ProtocolCodecFilter(new MapleCodecFactory()));
players = new PlayerStorage(channel);
loadEvents();
try {
acceptor.bind(new InetSocketAddress(port), new MapleServerHandler(channel, false), acceptor_config);
System.out.println("Channel " + channel + ": Listening on port " + port + "");
eventSM.init();
} catch (IOException e) {
System.out.println("Binding to port " + port + " failed (ch: " + getChannel() + ")" + e);
}
}
public final void shutdown() {
if (finishedShutdown) {
return;
}
broadcastPacket(CWvsContext.serverNotice(0, "This channel will now shut down."));
// dc all clients by hand so we get sessionClosed...
shutdown = true;
System.out.println("Channel " + channel + ", Saving characters...");
getPlayerStorage().disconnectAll();
System.out.println("Channel " + channel + ", Unbinding...");
acceptor.unbindAll();
acceptor = null;
//temporary while we dont have !addchannel
instances.remove(channel);
setFinishShutdown();
}
public final void unbind() {
acceptor.unbindAll();
}
public final boolean hasFinishedShutdown() {
return finishedShutdown;
}
public final MapleMapFactory getMapFactory() {
return mapFactory;
}
public static final ChannelServer newInstance(final int channel) {
return new ChannelServer(channel);
}
public static final ChannelServer getInstance(final int channel) {
return instances.get(channel);
}
public final void addPlayer(final MapleCharacter chr) {
getPlayerStorage().registerPlayer(chr);
}
public final PlayerStorage getPlayerStorage() {
if (players == null) { //wth
players = new PlayerStorage(channel); //wthhhh
}
return players;
}
public void setEventMap(int id){
this.eventMap = id;
}
public int getEventMap(){
return this.eventMap;
}
public final void removePlayer(final MapleCharacter chr) {
getPlayerStorage().deregisterPlayer(chr);
}
public final void removePlayer(final int idz, final String namez) {
getPlayerStorage().deregisterPlayer(idz, namez);
}
public final String getServerMessage() {
return serverMessage;
}
public final void setServerMessage(final String newMessage) {
serverMessage = newMessage;
broadcastPacket(CWvsContext.serverMessage(serverMessage));
}
public final void broadcastPacket(final byte[] data) {
getPlayerStorage().broadcastPacket(data);
}
public final void broadcastSmegaPacket(final byte[] data) {
getPlayerStorage().broadcastSmegaPacket(data);
}
public final void broadcastGMPacket(final byte[] data) {
getPlayerStorage().broadcastGMPacket(data);
}
public final int getExpRate() {
return expRate;
}
public final void setExpRate(final int expRate) {
this.expRate = expRate;
}
public final int getCashRate() {
return cashRate;
}
public final int getChannel() {
return channel;
}
public final void setChannel(final int channel) {
instances.put(channel, this);
LoginServer.addChannel(channel);
}
public static final ArrayList<ChannelServer> getAllInstances() {
return new ArrayList<ChannelServer>(instances.values());
}
public final String getIP() {
return ip;
}
public final boolean isShutdown() {
return shutdown;
}
public final int getLoadedMaps() {
return mapFactory.getLoadedMaps();
}
public final EventScriptManager getEventSM() {
return eventSM;
}
public final void reloadEvents() {
eventSM.cancel();
eventSM = new EventScriptManager(this, ServerProperties.getProperty("net.sf.odinms.channel.events").split(","));
eventSM.init();
}
public final int getMesoRate() {
return mesoRate;
}
public final void setMesoRate(final int mesoRate) {
this.mesoRate = mesoRate;
}
public final int getDropRate() {
return dropRate;
}
public final int getDropRate2() {
return dropRate2;
}
public static final void startChannel_Main() {
serverStartTime = System.currentTimeMillis();
for (int i = 0; i < Integer.parseInt(ServerProperties.getProperty("net.sf.odinms.channel.count", "0")); i++) {
newInstance(i + 1).run_startup_configurations();
}
}
public Map<MapleSquadType, MapleSquad> getAllSquads() {
return Collections.unmodifiableMap(mapleSquads);
}
public final MapleSquad getMapleSquad(final String type) {
return getMapleSquad(MapleSquadType.valueOf(type.toLowerCase()));
}
public final MapleSquad getMapleSquad(final MapleSquadType type) {
return mapleSquads.get(type);
}
public final boolean addMapleSquad(final MapleSquad squad, final String type) {
final MapleSquadType types = MapleSquadType.valueOf(type.toLowerCase());
if (types != null && !mapleSquads.containsKey(types)) {
mapleSquads.put(types, squad);
squad.scheduleRemoval();
return true;
}
return false;
}
public final boolean removeMapleSquad(final MapleSquadType types) {
if (types != null && mapleSquads.containsKey(types)) {
mapleSquads.remove(types);
return true;
}
return false;
}
public final int closeAllMerchant() {
int ret = 0;
merchLock.writeLock().lock();
try {
final Iterator<Entry<Integer, HiredMerchant>> merchants_ = merchants.entrySet().iterator();
while (merchants_.hasNext()) {
HiredMerchant hm = merchants_.next().getValue();
hm.closeShop(true, false);
//HiredMerchantSave.QueueShopForSave(hm);
hm.getMap().removeMapObject(hm);
merchants_.remove();
ret++;
}
} finally {
merchLock.writeLock().unlock();
}
//hacky
for (int i = 910000001; i <= 910000022; i++) {
for (MapleMapObject mmo : mapFactory.getMap(i).getAllHiredMerchantsThreadsafe()) {
((HiredMerchant) mmo).closeShop(true, false);
//HiredMerchantSave.QueueShopForSave((HiredMerchant) mmo);
ret++;
}
}
return ret;
}
public final int addMerchant(final HiredMerchant hMerchant) {
merchLock.writeLock().lock();
try {
running_MerchantID++;
merchants.put(running_MerchantID, hMerchant);
return running_MerchantID;
} finally {
merchLock.writeLock().unlock();
}
}
public final void removeMerchant(final HiredMerchant hMerchant) {
merchLock.writeLock().lock();
try {
merchants.remove(hMerchant.getStoreId());
} finally {
merchLock.writeLock().unlock();
}
}
public final boolean containsMerchant(final int accid, int cid) {
boolean contains = false;
merchLock.readLock().lock();
try {
final Iterator itr = merchants.values().iterator();
while (itr.hasNext()) {
HiredMerchant hm = (HiredMerchant) itr.next();
if (hm.getOwnerAccId() == accid || hm.getOwnerId() == cid) {
contains = true;
break;
}
}
} finally {
merchLock.readLock().unlock();
}
return contains;
}
public final List<HiredMerchant> searchMerchant(final int itemSearch) {
final List<HiredMerchant> list = new LinkedList<HiredMerchant>();
merchLock.readLock().lock();
try {
final Iterator itr = merchants.values().iterator();
while (itr.hasNext()) {
HiredMerchant hm = (HiredMerchant) itr.next();
if (hm.searchItem(itemSearch).size() > 0) {
list.add(hm);
}
}
} finally {
merchLock.readLock().unlock();
}
return list;
}
public final void toggleMegaphoneMuteState() {
this.MegaphoneMuteState = !this.MegaphoneMuteState;
}
public final boolean getMegaphoneMuteState() {
return MegaphoneMuteState;
}
public int getEvent() {
return eventmap;
}
public final void setEvent(final int ze) {
this.eventmap = ze;
}
public MapleEvent getEvent(final MapleEventType t) {
return events.get(t);
}
public final Collection<PlayerNPC> getAllPlayerNPC() {
return playerNPCs;
}
public final void addPlayerNPC(final PlayerNPC npc) {
if (playerNPCs.contains(npc)) {
return;
}
playerNPCs.add(npc);
getMapFactory().getMap(npc.getMapId()).addMapObject(npc);
}
public final void removePlayerNPC(final PlayerNPC npc) {
if (playerNPCs.contains(npc)) {
playerNPCs.remove(npc);
getMapFactory().getMap(npc.getMapId()).removeMapObject(npc);
}
}
public final String getServerName() {
return serverName;
}
public final void setServerName(final String sn) {
this.serverName = sn;
}
public final String getTrueServerName() {
return serverName.substring(0, serverName.length() - (GameConstants.GMS ? 2 : 3));
}
public final int getPort() {
return port;
}
public static final Set<Integer> getChannelServer() {
return new HashSet<Integer>(instances.keySet());
}
public final void setShutdown() {
this.shutdown = true;
System.out.println("Channel " + channel + " has set to shutdown and is closing Hired Merchants...");
}
public final void setFinishShutdown() {
this.finishedShutdown = true;
System.out.println("Channel " + channel + " has finished shutdown.");
}
public final boolean isAdminOnly() {
return adminOnly;
}
public final static int getChannelCount() {
return instances.size();
}
public final int getTempFlag() {
return flags;
}
public static Map<Integer, Integer> getChannelLoad() {
Map<Integer, Integer> ret = new HashMap<Integer, Integer>();
for (ChannelServer cs : instances.values()) {
ret.put(cs.getChannel(), cs.getConnectedClients());
}
return ret;
}
public int getConnectedClients() {
return getPlayerStorage().getConnectedClients();
}
public List<CheaterData> getCheaters() {
List<CheaterData> cheaters = getPlayerStorage().getCheaters();
Collections.sort(cheaters);
return cheaters;
}
public List<CheaterData> getReports() {
List<CheaterData> cheaters = getPlayerStorage().getReports();
Collections.sort(cheaters);
return cheaters;
}
public void broadcastMessage(byte[] message) {
broadcastPacket(message);
}
public void broadcastSmega(byte[] message) {
broadcastSmegaPacket(message);
}
public void broadcastGMMessage(byte[] message) {
broadcastGMPacket(message);
}
public AramiaFireWorks getFireWorks() {
return works;
}
public int getTraitRate() {
return traitRate;
}
}Cashshopserver.java
PHP:
/*
This file is part of the OdinMS Maple Story Server
Copyright (C) 2008 ~ 2010 Patrick Huy <patrick.huy@frz.cc>
Matthias Butz <matze@odinms.de>
Jan Christian Meyer <vimes@odinms.de>
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License version 3
as published by the Free Software Foundation. You may not use, modify
or distribute this program under any other version of the
GNU Affero General Public License.
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 Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package handling.cashshop;
import java.net.InetSocketAddress;
import handling.MapleServerHandler;
import handling.channel.PlayerStorage;
import handling.mina.MapleCodecFactory;
import org.apache.mina.common.ByteBuffer;
import org.apache.mina.common.SimpleByteBufferAllocator;
import org.apache.mina.common.IoAcceptor;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.transport.socket.nio.SocketAcceptorConfig;
import org.apache.mina.transport.socket.nio.SocketAcceptor;
import server.MTSStorage;
import server.ServerProperties;
public class CashShopServer {
private static String ip;
private static InetSocketAddress InetSocketadd;
private final static int PORT = 8600;
private static IoAcceptor acceptor;
private static PlayerStorage players, playersMTS;
private static boolean finishedShutdown = false;
public static final void run_startup_configurations() {
ip = ServerProperties.getProperty("net.sf.odinms.world.host") + ":" + PORT;
ByteBuffer.setUseDirectBuffers(false);
ByteBuffer.setAllocator(new SimpleByteBufferAllocator());
acceptor = new SocketAcceptor();
final SocketAcceptorConfig cfg = new SocketAcceptorConfig();
cfg.getSessionConfig().setTcpNoDelay(true);
cfg.setDisconnectOnUnbind(true);
cfg.getFilterChain().addLast("codec", new ProtocolCodecFilter(new MapleCodecFactory()));
players = new PlayerStorage(-10);
playersMTS = new PlayerStorage(-20);
try {
InetSocketadd = new InetSocketAddress(PORT);
acceptor.bind(InetSocketadd, new MapleServerHandler(-1, true), cfg);
System.out.println("Listening on port " + PORT + ".");
} catch (final Exception e) {
System.err.println("Binding to port " + PORT + " failed");
e.printStackTrace();
throw new RuntimeException("Binding failed.", e);
}
}
public static final String getIP() {
return ip;
}
public static final PlayerStorage getPlayerStorage() {
return players;
}
public static final PlayerStorage getPlayerStorageMTS() {
return playersMTS;
}
public static final void shutdown() {
if (finishedShutdown) {
return;
}
System.out.println("Saving all connected clients (CS)...");
players.disconnectAll();
playersMTS.disconnectAll();
MTSStorage.getInstance().saveBuyNow(true);
System.out.println("Shutting down CS...");
acceptor.unbindAll();
finishedShutdown = true;
}
public static boolean isShutdown() {
return finishedShutdown;
}
}And use the LIB files from Lithium source.
Have fun bye
Last edited:
Ja ik weet dat ze nu allemala gaan leechen. Mr vroeg of laat komt er toch altijd een release hoe je dit moet fixen. En bednakt voor de verbetering in mn topic heb t aangepast
