/home/leaf/crossfire/jxclient/trunk/network/src/main/java/com/realtime/crossfire/jxclient/server/crossfire/DefaultCrossfireServerConnection.java

Go to the documentation of this file.

/*
 * This file is part of JXClient, the Fullscreen Java Crossfire Client.
 *
 * JXClient 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 2 of the License, or
 * (at your option) any later version.
 *
 * JXClient 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 JXClient; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 *
 * Copyright (C) 2005-2008 Yann Chachkoff.
 * Copyright (C) 2006-2011 Andreas Kirschbaum.
 */

package com.realtime.crossfire.jxclient.server.crossfire;

import com.realtime.crossfire.jxclient.guistate.ClientSocketState;
import com.realtime.crossfire.jxclient.map.Location;
import com.realtime.crossfire.jxclient.server.crossfire.messages.Map2;
import com.realtime.crossfire.jxclient.server.crossfire.messages.UpdItem;
import com.realtime.crossfire.jxclient.server.server.DefaultServerConnection;
import com.realtime.crossfire.jxclient.server.socket.ClientSocketListener;
import com.realtime.crossfire.jxclient.server.socket.UnknownCommandException;
import com.realtime.crossfire.jxclient.spells.SpellsManager;
import com.realtime.crossfire.jxclient.stats.Stats;
import com.realtime.crossfire.jxclient.util.DebugWriter;
import com.realtime.crossfire.jxclient.util.HexCodec;
import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.nio.BufferUnderflowException;
import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.regex.Pattern;
import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;

public class DefaultCrossfireServerConnection extends AbstractCrossfireServerConnection {

    private static final int DEFAULT_MAP_WIDTH = 11;

    private static final int DEFAULT_MAP_HEIGHT = 11;

    private static final int DEFAULT_NUM_LOOK_OBJECTS = 50;

    @NotNull
    private static final Pattern PATTERN_DOT = Pattern.compile(":");

    private static final int ACL_NAME = 1;

    private static final int ACL_CLASS = 2;

    private static final int ACL_RACE = 3;

    private static final int ACL_LEVEL = 4;

    private static final int ACL_FACE = 5;

    private static final int ACL_PARTY = 6;

    private static final int ACL_MAP = 7;

    private static final int ACL_FACE_NUM = 8;

    @NotNull
    private final Model model;

    @NotNull
    private final DefaultServerConnection defaultServerConnection;

    private int preferredMapWidth = 17;

    private int preferredMapHeight = 13;

    private int pendingMapWidth = 0;

    private int pendingMapHeight = 0;

    private int currentMapWidth = DEFAULT_MAP_WIDTH;

    private int currentMapHeight = DEFAULT_MAP_HEIGHT;

    private int preferredNumLookObjects = DEFAULT_NUM_LOOK_OBJECTS;

    private int pendingNumLookObjects = 0;

    private int currentNumLookObjects = 0;

    @NotNull
    private final byte[] writeBuffer = new byte[65536];

    @NotNull
    private final ByteBuffer byteBuffer = ByteBuffer.wrap(writeBuffer);

    private int packet = 1;

    @NotNull
    private static final byte[] ACCOUNT_LOGIN_PREFIX = {
        'a',
        'c',
        'c',
        'o',
        'u',
        'n',
        't',
        'l',
        'o',
        'g',
        'i',
        'n',
        ' ',
    };

    @NotNull
    private static final byte[] ACCOUNT_PLAY_PREFIX = {
        'a',
        'c',
        'c',
        'o',
        'u',
        'n',
        't',
        'p',
        'l',
        'a',
        'y',
        ' ',
    };

    @NotNull
    private static final byte[] ACCOUNT_ADD_PLAYER_PREFIX = {
        'a',
        'c',
        'c',
        'o',
        'u',
        'n',
        't',
        'a',
        'd',
        'd',
        'p',
        'l',
        'a',
        'y',
        'e',
        'r',
        ' ',
    };

    @NotNull
    private static final byte[] ACCOUNT_NEW_PREFIX = {
        'a',
        'c',
        'c',
        'o',
        'u',
        'n',
        't',
        'n',
        'e',
        'w',
        ' ',
    };

    @NotNull
    private static final byte[] ACCOUNT_PASSWORD_PREFIX = {
        'a',
        'c',
        'c',
        'o',
        'u',
        'n',
        't',
        'p',
        'w',
        ' ',
    };

    @NotNull
    private static final byte[] CREATE_PLAYER_PREFIX = {
        'c',
        'r',
        'e',
        'a',
        't',
        'e',
        'p',
        'l',
        'a',
        'y',
        'e',
        'r',
        ' ',
    };

    @NotNull
    private static final byte[] ADDME_PREFIX = {
        'a',
        'd',
        'd',
        'm',
        'e',
        ' ',
    };

    @NotNull
    private static final byte[] APPLY_PREFIX = {
        'a',
        'p',
        'p',
        'l',
        'y',
        ' ',
    };

    @NotNull
    private static final byte[] ASKFACE_PREFIX = {
        'a',
        's',
        'k',
        'f',
        'a',
        'c',
        'e',
        ' ',
    };

    @NotNull
    private static final byte[] EXAMINE_PREFIX = {
        'e',
        'x',
        'a',
        'm',
        'i',
        'n',
        'e',
        ' ',
    };

    @NotNull
    private static final byte[] LOCK_PREFIX = {
        'l',
        'o',
        'c',
        'k',
        ' ',
    };

    @NotNull
    private static final byte[] LOOKAT_PREFIX = {
        'l',
        'o',
        'o',
        'k',
        'a',
        't',
        ' ',
    };

    @NotNull
    private static final byte[] MARK_PREFIX = {
        'm',
        'a',
        'r',
        'k',
        ' ',
    };

    @NotNull
    private static final byte[] MOVE_PREFIX = {
        'm',
        'o',
        'v',
        'e',
        ' ',
    };

    @NotNull
    private static final byte[] NCOM_PREFIX = {
        'n',
        'c',
        'o',
        'm',
        ' ',
    };

    @NotNull
    private static final byte[] REPLY_PREFIX = {
        'r',
        'e',
        'p',
        'l',
        'y',
        ' ',
    };

    @NotNull
    private static final byte[] REQUESTINFO_PREFIX = {
        'r',
        'e',
        'q',
        'u',
        'e',
        's',
        't',
        'i',
        'n',
        'f',
        'o',
        ' ',
    };

    @NotNull
    private static final byte[] SETUP_PREFIX = {
        's',
        'e',
        't',
        'u',
        'p',
    }; // note that this command does not have a trailing space

    @NotNull
    private static final byte[] TOGGLEEXTENDEDTEXT_PREFIX = {
        't',
        'o',
        'g',
        'g',
        'l',
        'e',
        'e',
        'x',
        't',
        'e',
        'n',
        'd',
        'e',
        'd',
        't',
        'e',
        'x',
        't',
    }; // note that this command does not have a trailing space

    @NotNull
    private static final byte[] VERSION_PREFIX = {
        'v',
        'e',
        'r',
        's',
        'i',
        'o',
        'n',
        ' ',
    };

    @NotNull
    private final String version;

    @Nullable
    private final DebugWriter debugProtocol;

    @NotNull
    private ClientSocketState clientSocketState = ClientSocketState.CONNECTING;

    @Nullable
    private String accountName = null;

    @NotNull
    private final ClientSocketListener clientSocketListener = new ClientSocketListener() {

        @Override
        public void connecting() {
            // ignore
        }

        @Override
        public void connected() {
            DefaultCrossfireServerConnection.this.connected();
        }

        @Override
        public void packetReceived(@NotNull final ByteBuffer packet) throws UnknownCommandException {
            processPacket(packet);
        }

        @Override
        public void packetSent(@NotNull final byte[] buf, final int len) {
            // ignore
        }

        @Override
        public void disconnecting(@NotNull final String reason, final boolean isError) {
            // ignore
        }

        @Override
        public void disconnected(@NotNull final String reason) {
            // ignore
        }

    };

    private int loginMethod = 0;

    public DefaultCrossfireServerConnection(@NotNull final Model model, @Nullable final DebugWriter debugProtocol, @NotNull final String version) throws IOException {
        super(model);
        this.model = model;
        defaultServerConnection = new DefaultServerConnection(model, debugProtocol);
        this.version = version;
        byteBuffer.order(ByteOrder.BIG_ENDIAN);
        this.debugProtocol = debugProtocol;
        addClientSocketListener(clientSocketListener);
    }

    @Override
    public void start() {
        defaultServerConnection.start();
    }

    @Override
    public void stop() throws InterruptedException {
        defaultServerConnection.stop();
    }

    private void connected() {
        pendingMapWidth = 0;
        pendingMapHeight = 0;
        pendingNumLookObjects = 0;
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("connected: defaulting to pending_num_look_objects="+pendingNumLookObjects);
        }
        setCurrentMapSize(DEFAULT_MAP_WIDTH, DEFAULT_MAP_HEIGHT);
        currentNumLookObjects = DEFAULT_NUM_LOOK_OBJECTS;
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("connected: defaulting to num_look_objects="+currentNumLookObjects);
        }

        fireNewMap();

        setClientSocketState(ClientSocketState.CONNECTING, ClientSocketState.VERSION);
        sendVersion(1023, 1027, version);
    }

    private void processPacket(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        try {
            packet.mark();
            switch (packet.get()) {
            case 'a':
                switch (packet.get()) {
                case 'c':
                    //accountplayers
                    if (packet.get() != 'c') {
                        break;
                    }
                    if (packet.get() != 'o') {
                        break;
                    }
                    if (packet.get() != 'u') {
                        break;
                    }
                    if (packet.get() != 'n') {
                        break;
                    }
                    if (packet.get() != 't') {
                        break;
                    }
                    if (packet.get() != 'p') {
                        break;
                    }
                    if (packet.get() != 'l') {
                        break;
                    }
                    if (packet.get() != 'a') {
                        break;
                    }
                    if (packet.get() != 'y') {
                        break;
                    }
                    if (packet.get() != 'e') {
                        break;
                    }
                    if (packet.get() != 'r') {
                        break;
                    }
                    if (packet.get() != 's') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv accountplayers");
                    }
                    processAccountPlayers(packet);
                    return;

                case 'd':
                    if (packet.get() != 'd') {
                        break;
                    }
                    switch (packet.get()) {
                    case 'm':
                        if (packet.get() != 'e') {
                            break;
                        }
                        if (packet.get() != '_') {
                            break;
                        }
                        switch (packet.get()) {
                        case 'f':
                            if (packet.get() != 'a') {
                                break;
                            }
                            if (packet.get() != 'i') {
                                break;
                            }
                            if (packet.get() != 'l') {
                                break;
                            }
                            if (packet.get() != 'e') {
                                break;
                            }
                            if (packet.get() != 'd') {
                                break;
                            }
                            if (packet.hasRemaining()) {
                                break;
                            }
                            if (debugProtocol != null) {
                                debugProtocol.debugProtocolWrite("recv addme_failed");
                            }
                            processAddmeFailed(packet);
                            return;

                        case 's':
                            if (packet.get() != 'u') {
                                break;
                            }
                            if (packet.get() != 'c') {
                                break;
                            }
                            if (packet.get() != 'c') {
                                break;
                            }
                            if (packet.get() != 'e') {
                                break;
                            }
                            if (packet.get() != 's') {
                                break;
                            }
                            if (packet.get() != 's') {
                                break;
                            }
                            if (packet.hasRemaining()) {
                                break;
                            }
                            if (debugProtocol != null) {
                                debugProtocol.debugProtocolWrite("recv addme_success");
                            }
                            processAddmeSuccess(packet);
                            return;
                        }
                        break;

                    case 'q':
                        if (packet.get() != 'u') {
                            break;
                        }
                        if (packet.get() != 'e') {
                            break;
                        }
                        if (packet.get() != 's') {
                            break;
                        }
                        if (packet.get() != 't') {
                            break;
                        }
                        if (packet.get() != ' ') {
                            break;
                        }

                        processAddQuest(packet);
                        return;
                        
                    case 's':
                        if (packet.get() != 'p') {
                            break;
                        }
                        if (packet.get() != 'e') {
                            break;
                        }
                        if (packet.get() != 'l') {
                            break;
                        }
                        if (packet.get() != 'l') {
                            break;
                        }
                        if (packet.get() != ' ') {
                            break;
                        }
                        processAddSpell(packet);
                        return;
                    }
                    break;

                case 'n':
                    if (packet.get() != 'i') {
                        break;
                    }
                    if (packet.get() != 'm') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processAnim(packet);
                    return;
                }
                break;

            case 'c':
                if (packet.get() != 'o') {
                    break;
                }
                if (packet.get() != 'm') {
                    break;
                }
                if (packet.get() != 'c') {
                    break;
                }
                if (packet.get() != ' ') {
                    break;
                }
                processComc(packet);
                return;

            case 'd':
                switch (packet.get()) {
                case 'e':
                    if (packet.get() != 'l') {
                        break;
                    }
                    switch (packet.get()) {
                    case 'i':
                        switch (packet.get()) {
                        case 'n':
                            if (packet.get() != 'v') {
                                break;
                            }
                            if (packet.get() != ' ') {
                                break;
                            }
                            processDelInv(packet);
                            return;

                        case 't':
                            if (packet.get() != 'e') {
                                break;
                            }
                            if (packet.get() != 'm') {
                                break;
                            }
                            if (packet.get() != ' ') {
                                break;
                            }
                            processDelItem(packet);
                            return;
                        }
                        break;

                    case 's':
                        if (packet.get() != 'p') {
                            break;
                        }
                        if (packet.get() != 'e') {
                            break;
                        }
                        if (packet.get() != 'l') {
                            break;
                        }
                        if (packet.get() != 'l') {
                            break;
                        }
                        if (packet.get() != ' ') {
                            break;
                        }
                        processDelSpell(packet);
                        return;
                    }
                    break;

                case 'r':
                    if (packet.get() != 'a') {
                        break;
                    }
                    if (packet.get() != 'w') {
                        break;
                    }
                    switch (packet.get()) {
                    case 'e':
                        if (packet.get() != 'x') {
                            break;
                        }
                        if (packet.get() != 't') {
                            break;
                        }
                        if (packet.get() != 'i') {
                            break;
                        }
                        if (packet.get() != 'n') {
                            break;
                        }
                        if (packet.get() != 'f') {
                            break;
                        }
                        if (packet.get() != 'o') {
                            break;
                        }
                        if (packet.get() != ' ') {
                            break;
                        }
                        processDrawExtInfo(packet);
                        return;

                    case 'i':
                        if (packet.get() != 'n') {
                            break;
                        }
                        if (packet.get() != 'f') {
                            break;
                        }
                        if (packet.get() != 'o') {
                            break;
                        }
                        if (packet.get() != ' ') {
                            break;
                        }
                        processDrawInfo(packet);
                        return;
                    }
                    break;
                }
                break;

            case 'E':
                if (packet.get() != 'x') {
                    break;
                }
                if (packet.get() != 't') {
                    break;
                }
                if (packet.get() != 'e') {
                    break;
                }
                if (packet.get() != 'n') {
                    break;
                }
                if (packet.get() != 'd') {
                    break;
                }
                if (packet.get() != 'e') {
                    break;
                }
                if (packet.get() != 'd') {
                    break;
                }
                switch (packet.get()) {
                case 'I':
                    if (packet.get() != 'n') {
                        break;
                    }
                    if (packet.get() != 'f') {
                        break;
                    }
                    if (packet.get() != 'o') {
                        break;
                    }
                    if (packet.get() != 'S') {
                        break;
                    }
                    if (packet.get() != 'e') {
                        break;
                    }
                    if (packet.get() != 't') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processExtendedInfoSet(packet);
                    return;

                case 'T':
                    if (packet.get() != 'e') {
                        break;
                    }
                    if (packet.get() != 'x') {
                        break;
                    }
                    if (packet.get() != 't') {
                        break;
                    }
                    if (packet.get() != 'S') {
                        break;
                    }
                    if (packet.get() != 'e') {
                        break;
                    }
                    if (packet.get() != 't') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processExtendedTextSet(packet);
                    return;
                }
                break;

            case 'f':
                if (packet.get() != 'a') {
                    break;
                }
                switch (packet.get()) {
                case 'c':
                    if (packet.get() != 'e') {
                        break;
                    }
                    if (packet.get() != '2') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processFace2(packet);
                    return;

                case 'i':
                    if (packet.get() != 'l') {
                        break;
                    }
                    if (packet.get() != 'u') {
                        break;
                    }
                    if (packet.get() != 'r') {
                        break;
                    }
                    if (packet.get() != 'e') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processFailure(packet);
                    return;
                }

            case 'g':
                if (packet.get() != 'o') {
                    break;
                }
                if (packet.get() != 'o') {
                    break;
                }
                if (packet.get() != 'd') {
                    break;
                }
                if (packet.get() != 'b') {
                    break;
                }
                if (packet.get() != 'y') {
                    break;
                }
                if (packet.get() != 'e') {
                    break;
                }
                if (packet.get() != ' ') {
                    break;
                }
                processGoodbye(packet);
                return;

            case 'i':
                switch (packet.get()) {
                case 'm':
                    if (packet.get() != 'a') {
                        break;
                    }
                    if (packet.get() != 'g') {
                        break;
                    }
                    if (packet.get() != 'e') {
                        break;
                    }
                    if (packet.get() != '2') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processImage2(packet);
                    return;

                case 't':
                    if (packet.get() != 'e') {
                        break;
                    }
                    if (packet.get() != 'm') {
                        break;
                    }
                    if (packet.get() != '2') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processItem2(packet);
                    return;
                }
                break;

            case 'm':
                switch (packet.get()) {
                case 'a':
                    switch (packet.get()) {
                    case 'g':
                        if (packet.get() != 'i') {
                            break;
                        }
                        if (packet.get() != 'c') {
                            break;
                        }
                        if (packet.get() != 'm') {
                            break;
                        }
                        if (packet.get() != 'a') {
                            break;
                        }
                        if (packet.get() != 'p') {
                            break;
                        }
                        if (packet.get() != ' ') {
                            break;
                        }
                        processMagicMap(packet);
                        return;

                    case 'p':
                        switch (packet.get()) {
                        case '2':
                            if (packet.get() != ' ') {
                                break;
                            }
                            processMap2(packet);
                            return;

                        case 'e':
                            if (packet.get() != 'x') {
                                break;
                            }
                            if (packet.get() != 't') {
                                break;
                            }
                            if (packet.get() != 'e') {
                                break;
                            }
                            if (packet.get() != 'n') {
                                break;
                            }
                            if (packet.get() != 'd') {
                                break;
                            }
                            if (packet.get() != 'e') {
                                break;
                            }
                            if (packet.get() != 'd') {
                                break;
                            }
                            if (packet.get() != ' ') {
                                break;
                            }
                            processMapExtended(packet);
                            return;
                        }
                        break;
                    }
                    break;

                case 'u':
                    if (packet.get() != 's') {
                        break;
                    }
                    if (packet.get() != 'i') {
                        break;
                    }
                    if (packet.get() != 'c') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processMusic(packet);
                    return;
                }
                break;

            case 'n':
                if (packet.get() != 'e') {
                    break;
                }
                if (packet.get() != 'w') {
                    break;
                }
                if (packet.get() != 'm') {
                    break;
                }
                if (packet.get() != 'a') {
                    break;
                }
                if (packet.get() != 'p') {
                    break;
                }
                processNewMap(packet);
                return;

            case 'p':
                switch (packet.get()) {
                case 'i':
                    if (packet.get() != 'c') {
                        break;
                    }
                    if (packet.get() != 'k') {
                        break;
                    }
                    if (packet.get() != 'u') {
                        break;
                    }
                    if (packet.get() != 'p') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processPickup(packet);
                    return;

                case 'l':
                    if (packet.get() != 'a') {
                        break;
                    }
                    if (packet.get() != 'y') {
                        break;
                    }
                    if (packet.get() != 'e') {
                        break;
                    }
                    if (packet.get() != 'r') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processPlayer(packet);
                    return;
                }
                break;

            case 'q':
                if (packet.get() != 'u') {
                    break;
                }
                if (packet.get() != 'e') {
                    break;
                }
                if (packet.get() != 'r') {
                    break;
                }
                if (packet.get() != 'y') {
                    break;
                }
                if (packet.get() != ' ') {
                    break;
                }
                processQuery(packet);
                return;

            case 'r':
                if (packet.get() != 'e') {
                    break;
                }
                if (packet.get() != 'p') {
                    break;
                }
                if (packet.get() != 'l') {
                    break;
                }
                if (packet.get() != 'y') {
                    break;
                }
                if (packet.get() != 'i') {
                    break;
                }
                if (packet.get() != 'n') {
                    break;
                }
                if (packet.get() != 'f') {
                    break;
                }
                if (packet.get() != 'o') {
                    break;
                }
                if (packet.get() != ' ') {
                    break;
                }
                processReplyInfo(packet);
                return;

            case 's':
                switch (packet.get()) {
                case 'e':
                    if (packet.get() != 't') {
                        break;
                    }
                    if (packet.get() != 'u') {
                        break;
                    }
                    if (packet.get() != 'p') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processSetup(packet);
                    return;

                case 'm':
                    if (packet.get() != 'o') {
                        break;
                    }
                    if (packet.get() != 'o') {
                        break;
                    }
                    if (packet.get() != 't') {
                        break;
                    }
                    if (packet.get() != 'h') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processSmooth(packet);
                    return;

                case 'o':
                    if (packet.get() != 'u') {
                        break;
                    }
                    if (packet.get() != 'n') {
                        break;
                    }
                    if (packet.get() != 'd') {
                        break;
                    }
                    switch (packet.get()) {
                    case ' ':
                        processSound(packet);
                        return;

                    case '2':
                        if (packet.get() != ' ') {
                            break;
                        }
                        processSound2(packet);
                        return;
                    }
                    break;

                case 't':
                    if (packet.get() != 'a') {
                        break;
                    }
                    if (packet.get() != 't') {
                        break;
                    }
                    if (packet.get() != 's') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processStats(packet);
                    return;
                }
                break;

            case 't':
                if (packet.get() != 'i') {
                    break;
                }
                if (packet.get() != 'c') {
                    break;
                }
                if (packet.get() != 'k') {
                    break;
                }
                if (packet.get() != ' ') {
                    break;
                }
                processTick(packet);
                return;

            case 'u':
                if (packet.get() != 'p') {
                    break;
                }
                if (packet.get() != 'd') {
                    break;
                }
                switch (packet.get()) {
                case 'i':
                    if (packet.get() != 't') {
                        break;
                    }
                    if (packet.get() != 'e') {
                        break;
                    }
                    if (packet.get() != 'm') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processUpdItem(packet);
                    return;

                case 'q':
                    if (packet.get() != 'u') {
                        break;
                    }
                    if (packet.get() != 'e') {
                        break;
                    }
                    if (packet.get() != 's') {
                        break;
                    }
                    if (packet.get() != 't') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processUpdQuest(packet);
                    return;

                case 's':
                    if (packet.get() != 'p') {
                        break;
                    }
                    if (packet.get() != 'e') {
                        break;
                    }
                    if (packet.get() != 'l') {
                        break;
                    }
                    if (packet.get() != 'l') {
                        break;
                    }
                    if (packet.get() != ' ') {
                        break;
                    }
                    processUpdSpell(packet);
                    return;
                }
                break;

            case 'v':
                if (packet.get() != 'e') {
                    break;
                }
                if (packet.get() != 'r') {
                    break;
                }
                if (packet.get() != 's') {
                    break;
                }
                if (packet.get() != 'i') {
                    break;
                }
                if (packet.get() != 'o') {
                    break;
                }
                if (packet.get() != 'n') {
                    break;
                }
                if (packet.get() != ' ') {
                    break;
                }
                processVersion(packet);
                return;
            }
        } catch (final IllegalArgumentException ex) {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("IllegalArgumentException while command parsing: "+ex+"\n"+hexDump(packet), ex);
            }
        } catch (final BufferUnderflowException ex) {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("BufferUnderflowException while command parsing: "+ex+"\n"+hexDump(packet), ex);
            }
        } catch (final ArrayIndexOutOfBoundsException ex) {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("ArrayIndexOutOfBoundsException while command parsing: "+ex+"\n"+hexDump(packet), ex);
            }
        } catch (final StringIndexOutOfBoundsException ex) {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("StringIndexOutOfBoundsException while command parsing: "+ex+"\n"+hexDump(packet), ex);
            }
        } catch (final UnknownCommandException ex) {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("UnknownCommandException while command parsing: "+ex+"\n"+hexDump(packet), ex);
            }
            throw ex;
        }

        packet.position(0);
        final String command = extractCommand(packet);
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv invalid command: "+command+"\n"+hexDump(packet));
        }
        throw new UnknownCommandException("Cannot parse command: "+command);
    }

    private void cmdMap2Coordinate(@NotNull final ByteBuffer packet, final int x, final int y) throws UnknownCommandException {
        while (true) {
            final int lenType = getInt1(packet);
            if (lenType == 0xFF) {
                break;
            }

            final int len = (lenType>>5)&7;
            final int type = lenType&31;
            switch (type) {
            case Map2.COORD_CLEAR_SPACE:
                cmdMap2CoordinateClearSpace(x, y, len);
                break;

            case Map2.COORD_DARKNESS:
                cmdMap2CoordinateDarkness(packet, x, y, len);
                break;

            case Map2.COORD_LAYER0:
            case Map2.COORD_LAYER1:
            case Map2.COORD_LAYER2:
            case Map2.COORD_LAYER3:
            case Map2.COORD_LAYER4:
            case Map2.COORD_LAYER5:
            case Map2.COORD_LAYER6:
            case Map2.COORD_LAYER7:
            case Map2.COORD_LAYER8:
            case Map2.COORD_LAYER9:
                cmdMap2CoordinateLayer(packet, x, y, len, type-Map2.COORD_LAYER0);
                break;
            }
        }
    }

    private void cmdMap2CoordinateClearSpace(final int x, final int y, final int len) throws UnknownCommandException {
        if (len != 0) {
            throw new UnknownCommandException("map2 command contains clear command with length "+len);
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv map2 "+x+"/"+y+" clear");
        }
        fireMapClear(x, y);
    }

    private void cmdMap2CoordinateDarkness(@NotNull final ByteBuffer packet, final int x, final int y, final int len) throws UnknownCommandException {
        if (len != 1) {
            throw new UnknownCommandException("map2 command contains darkness command with length "+len);
        }
        final int darkness = getInt1(packet);
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv map2 "+x+"/"+y+" darkness="+darkness);
        }
        fireMapDarkness(x, y, darkness);
    }

    private void cmdMap2CoordinateLayer(@NotNull final ByteBuffer packet, final int x, final int y, final int len, final int layer) throws UnknownCommandException {
        if (len < 2) {
            throw new UnknownCommandException("map2 command contains image command with length "+len);
        }
        final Location location = new Location(x, y, layer);
        final int face = getInt2(packet);
        if ((face&Map2.FACE_ANIMATION) == 0) {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("recv map2 "+location+" face="+face);
            }
            fireMapFace(location, face);
        } else {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("recv map2 "+location+" anim="+(face&Map2.ANIM_MASK)+" type="+((face>>Map2.ANIM_TYPE_SHIFT)&Map2.ANIM_TYPE_MASK));
            }
            fireMapAnimation(location, face&Map2.ANIM_MASK, (face>>Map2.ANIM_TYPE_SHIFT)&Map2.ANIM_TYPE_MASK);
        }
        if (len == 3) {
            cmdMap2CoordinateLayer3(packet, location, face);
        } else if (len == 4) {
            cmdMap2CoordinateLayer4(packet, location, face);
        } else if (len != 2) {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("recv map2 "+x+"/"+y+"/"+layer+" <invalid>");
            }
            throw new UnknownCommandException("map2 command contains image command with length "+len);
        }
    }

    private void cmdMap2CoordinateLayer3(@NotNull final ByteBuffer packet, @NotNull final Location location, final int face) throws UnknownCommandException {
        if (face == 0) {
            throw new UnknownCommandException("map2 command contains smoothing or animation information for empty face");
        }

        if ((face&Map2.FACE_ANIMATION) == 0) {
            final int smooth = getInt1(packet);
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("recv map2 "+location+" smooth="+smooth);
            }
            fireMapSmooth(location, smooth);
        } else {
            final int animSpeed = getInt1(packet);
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("recv map2 "+location+" anim_speed="+animSpeed);
            }
            fireMapAnimationSpeed(location, animSpeed);
        }
    }

    private void cmdMap2CoordinateLayer4(@NotNull final ByteBuffer packet, @NotNull final Location location, final int face) throws UnknownCommandException {
        if (face == 0) {
            throw new UnknownCommandException("map2 command contains smoothing or animation information for empty face");
        }

        final int animSpeed = getInt1(packet);
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv map2 "+location+" anim_speed="+animSpeed);
        }
        fireMapAnimationSpeed(location, animSpeed);

        final int smooth = getInt1(packet);
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv map2 "+location+" smooth="+smooth);
        }
        fireMapSmooth(location, smooth);
    }

    private void negotiateMapSize(final int mapWidth, final int mapHeight) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("negotiateMapSize: "+mapWidth+"x"+mapHeight);
        }

        if (clientSocketState == ClientSocketState.CONNECTING || clientSocketState == ClientSocketState.VERSION || clientSocketState == ClientSocketState.CONNECT_FAILED) {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("negotiateMapSize: clientSocketState="+clientSocketState+", ignoring");
            }
            return;
        }
        if (pendingMapWidth != 0 || pendingMapHeight != 0) {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("negotiateMapSize: already negotiating, ignoring");
            }
            return;
        }
        if (currentMapWidth == mapWidth && currentMapHeight == mapHeight) {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("negotiateMapSize: same as current map size, ignoring");
            }
            return;
        }
        pendingMapWidth = mapWidth;
        pendingMapHeight = mapHeight;
        sendSetup("mapsize "+pendingMapWidth+"x"+pendingMapHeight);
    }

    private void negotiateNumLookObjects(final int numLookObjects) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("negotiateNumLookObjects: "+numLookObjects);
        }

        if (clientSocketState == ClientSocketState.CONNECTING || clientSocketState == ClientSocketState.VERSION || clientSocketState == ClientSocketState.CONNECT_FAILED) {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("negotiateNumLookObjects: clientSocketState="+clientSocketState+", ignoring");
            }
            return;
        }
        if (pendingNumLookObjects != 0) {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("negotiateNumLookObjects: already negotiating pending_num_look_objects="+pendingNumLookObjects+", ignoring");
            }
            return;
        }
        if (currentNumLookObjects == numLookObjects) {
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("negotiateNumLookObjects: unchanged from num_look_objects="+currentNumLookObjects+", ignoring");
            }
            return;
        }
        pendingNumLookObjects = numLookObjects;
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("negotateNumLookObjects: pending_num_look_objects="+pendingNumLookObjects+", sending setup command");
        }
        sendSetup("num_look_objects "+pendingNumLookObjects);
    }

    private void cmdReplyinfo(@NotNull final String infoType, final ByteBuffer packet) throws IOException {
        if (infoType.equals("image_info")) {
            processImageInfoReplyinfo(packet);
        } else if (infoType.equals("skill_info")) {
            processSkillInfoReplyinfo(packet);
        } else if (infoType.equals("exp_table")) {
            processExpTableReplyinfo(packet);
        } else {
            System.err.println("Ignoring unexpected replyinfo type '"+infoType+"'.");
        }
    }

    private static void processImageInfoReplyinfo(@NotNull final ByteBuffer packet) throws IOException {
        final byte[] data = new byte[packet.remaining()];
        packet.get(data);
        final ByteArrayInputStream is = new ByteArrayInputStream(data);
        try {
            final InputStreamReader isr = new InputStreamReader(is);
            try {
                final BufferedReader d = new BufferedReader(isr);
                try {
                    final String info = d.readLine();
                    if (info == null) {
                        throw new IOException("Truncated parameter in image_info");
                    }
                    //noinspection UnusedAssignment
                    final int nrPics = Integer.parseInt(info);
                    // XXX: replyinfo image_info not implemented
                } finally {
                    d.close();
                }
            } finally {
                isr.close();
            }
        } finally {
            is.close();
        }
    }

    private void processSkillInfoReplyinfo(@NotNull final ByteBuffer packet) throws IOException {
        model.getSkillSet().clearSkills();
        final byte[] data = new byte[packet.remaining()];
        packet.get(data);
        final ByteArrayInputStream is = new ByteArrayInputStream(data);
        try {
            final InputStreamReader isr = new InputStreamReader(is);
            try {
                final BufferedReader d = new BufferedReader(isr);
                try {
                    while (true) {
                        final String r = d.readLine();
                        if (r == null) {
                            break;
                        }

                        final String[] sk = PATTERN_DOT.split(r, 2);
                        if (sk.length != 2) {
                            System.err.println("Ignoring skill definition for invalid skill: "+r+".");
                            continue;
                        }

                        final int skillId;
                        try {
                            skillId = Integer.parseInt(sk[0]);
                        } catch (final NumberFormatException ignored) {
                            System.err.println("Ignoring skill definition for invalid skill: "+r+".");
                            continue;
                        }

                        if (skillId < Stats.CS_STAT_SKILLINFO || skillId >= Stats.CS_STAT_SKILLINFO+Stats.CS_NUM_SKILLS) {
                            System.err.println("Ignoring skill definition for invalid skill id "+skillId+": "+r+".");
                            continue;
                        }

                        model.getSkillSet().addSkill(skillId, sk[1]);
                    }
                } finally {
                    d.close();
                }
            } finally {
                isr.close();
            }
        } finally {
            is.close();
        }
    }

    private void processExpTableReplyinfo(@NotNull final ByteBuffer packet) {
        final int numLevels = getInt2(packet);
        final long[] expTable = new long[numLevels];
        for (int level = 1; level < numLevels; level++) {
            expTable[level] = getInt8(packet);
        }
        if (packet.hasRemaining()) {
            System.err.println("Ignoring excess data at end of exp_table");
        }

        model.getExperienceTable().setExpTable(expTable);

        if (loginMethod == 0) {
            setClientSocketState(ClientSocketState.REQUESTINFO, ClientSocketState.ADDME);
            sendAddme();
        } else {
            setClientSocketState(ClientSocketState.REQUESTINFO, ClientSocketState.ACCOUNT_INFO);
            fireManageAccount();
        }
    }

    private void processAccountPlayers(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        fireStartAccountList(accountName);

        // number of characters
        int count = getInt1(packet);
        while (count > 0) {
            String name = "";
            String cClass = "";
            String race = "";
            String face = "";
            String party = "";
            String map = "";
            int level = 0;
            int faceNumber = 0;

            while (packet.hasRemaining()) {
                final int len = getInt1(packet);

                if (len == 0) {
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv accountplayers entry");
                    }
                    // got all information on a character
                    count--;

                    fireAddAccount(name, cClass, race, face, party, map, level, faceNumber);
                    break;
                }

                final int type = getInt1(packet);

                switch (type) {
                case ACL_NAME:
                    name = getString(packet, len-1);
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv accountplayers name="+name);
                    }
                    break;

                case ACL_CLASS:
                    cClass = getString(packet, len-1);
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv accountplayers class="+cClass);
                    }
                    break;

                case ACL_RACE:
                    race = getString(packet, len-1);
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv accountplayers race="+race);
                    }
                    break;

                case ACL_LEVEL:
                    level = getInt2(packet);
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv accountplayers level="+level);
                    }
                    break;

                case ACL_FACE:
                    face = getString(packet, len-1);
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv accountplayers face="+face);
                    }
                    break;

                case ACL_PARTY:
                    party = getString(packet, len-1);
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv accountplayers party="+party);
                    }
                    break;

                case ACL_MAP:
                    map = getString(packet, len-1);
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv accountplayers map="+map);
                    }
                    break;

                case ACL_FACE_NUM:
                    faceNumber = getInt2(packet);
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv accountplayers face="+faceNumber);
                    }
                    break;

                default:
                    // ignore those values we don't understand
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv accountplayers unknown="+type);
                    }
                    packet.position(packet.position()+len-1);
                    break;
                }
            }
        }
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("invalid accountplayers reply, pos="+packet.position());
        }

        fireEndAccountList();

        packet.reset();
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processAddmeFailed(@NotNull final ByteBuffer packet) {
        final int args = packet.position();
        // XXX: addme_failed command not implemented
        notifyPacketWatcherListenersNoData(packet, args);
    }

    private void processAddmeSuccess(@NotNull final ByteBuffer packet) {
        final int args = packet.position();

        if (clientSocketState != ClientSocketState.CONNECTED) {
            if (clientSocketState == ClientSocketState.ADDME) {
                // servers without account support
                setClientSocketState(ClientSocketState.ADDME, ClientSocketState.CONNECTED);
            } else if (clientSocketState == ClientSocketState.ACCOUNT_INFO) {
                fireStartPlaying();
                setClientSocketState(ClientSocketState.ACCOUNT_INFO, ClientSocketState.CONNECTED);
                negotiateNumLookObjects(preferredNumLookObjects);
            }
            negotiateMapSize(preferredMapWidth, preferredMapHeight);
        }

        notifyPacketWatcherListenersNoData(packet, args);
    }

    private void processAddQuest(@NotNull final ByteBuffer packet) {
        final int args = packet.position();
        while (packet.hasRemaining()) {
            final int code = getInt4(packet);
            final int titleLength = getInt2(packet);
            final String title = getString(packet, titleLength);
            final int face = getInt4(packet);
            final int replay = getInt1(packet);
            final int parent = getInt4(packet);
            final int end = getInt1(packet);
            final int stepLength = getInt2(packet);
            final String step = stepLength > 0 ? getString(packet, stepLength) : "";

            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("recv addquest code="+code+" title="+title+" face="+face+"replay="+replay+" end="+end+" desc="+step);
            }
            model.getQuestsManager().addQuest(code, title, face, replay == 1, parent, end == 1, step);
        }
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processAddSpell(@NotNull final ByteBuffer packet) {
        final int args = packet.position();
        while (packet.hasRemaining()) {
            final int tag = getInt4(packet);
            final int level = getInt2(packet);
            final int castingTime = getInt2(packet);
            final int mana = getInt2(packet);
            final int grace = getInt2(packet);
            final int damage = getInt2(packet);
            final int skill = getInt1(packet);
            final int path = getInt4(packet);
            final int face = getInt4(packet);
            final int nameLength = getInt1(packet);
            final String name = getString(packet, nameLength);
            final int messageLength = getInt2(packet);
            final String message = getString(packet, messageLength);
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("recv addspell tag="+tag+" lvl="+level+" time="+castingTime+" sp="+mana+" gr="+grace+" dam="+damage+" skill="+skill+" path="+path+" face="+face+" name="+name+" msg="+message);
            }
            model.getSpellsManager().addSpell(tag, level, castingTime, mana, grace, damage, skill, path, face, name, message);
        }
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processAnim(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int num = getInt2(packet);
        final int flags = getInt2(packet);
        final int[] faces = new int[packet.remaining()/2];
        if (faces.length <= 0) {
            throw new UnknownCommandException("no faces in anim command");
        }
        for (int i = 0; i < faces.length; i++) {
            faces[i] = getInt2(packet);
        }
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of anim command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv anim num="+num+" flags="+flags+" faces="+Arrays.toString(faces));
        }
        if ((num&~0x1FFF) != 0) {
            throw new UnknownCommandException("invalid animation id "+num);
        }
        fireAddAnimation(num&0x1FFF, flags, faces);
        notifyPacketWatcherListenersShortArray(packet, args);
    }

    private void processComc(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int packetNo = getInt2(packet);
        final int time = getInt4(packet);
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of comc command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv comc no="+packetNo+" time="+time);
        }
        fireCommandComcReceived(packetNo, time);
        notifyPacketWatcherListenersShortInt(packet, args);
    }

    private void processDelInv(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        int tag = 0;
        do {
            tag = tag*10+parseDigit(packet.get());
        } while (packet.hasRemaining());
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of delinv command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv delinv tag="+tag);
        }
        fireDelinvReceived(tag);
        notifyPacketWatcherListenersAscii(packet, args);
    }

    private void processDelItem(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int[] tags = new int[packet.remaining()/4];
        for (int i = 0; i < tags.length; i++) {
            tags[i] = getInt4(packet);
        }
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of delitem command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv delitem tags="+Arrays.toString(tags));
        }
        fireDelitemReceived(tags);
        notifyPacketWatcherListenersIntArray(packet, args);
    }

    private void processDelSpell(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int tag = getInt4(packet);
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of delspell command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv delspell tag="+tag);
        }
        model.getSpellsManager().deleteSpell(tag);
        notifyPacketWatcherListenersIntArray(packet, args);
    }

    private void processDrawExtInfo(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        int color = 0;
        do {
            color = color*10+parseDigit(packet.get());
        } while (packet.get(packet.position()) != ' ');
        packet.get();

        int type = 0;
        do {
            type = type*10+parseDigit(packet.get());
        } while (packet.get(packet.position()) != ' ');
        packet.get();

        int subtype = 0;
        do {
            subtype = subtype*10+parseDigit(packet.get());
        } while (packet.get(packet.position()) != ' ');
        packet.get();

        final String message = getString(packet, packet.remaining());

        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv drawextinfo color="+color+" type="+type+"/"+subtype+" msg="+message);
        }

        drawextinfo(color, type, subtype, message);
        notifyPacketWatcherListenersAscii(packet, args);
    }

    private void processDrawInfo(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        int color = 0;
        do {
            color = color*10+parseDigit(packet.get());
        } while (packet.get(packet.position()) != ' ');
        packet.get();

        final String message = getString(packet, packet.remaining());

        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv drawinfo color="+color+" msg="+message);
        }

        drawInfo(message, color);
        notifyPacketWatcherListenersAscii(packet, args);
    }

    private void processExtendedInfoSet(@NotNull final ByteBuffer packet) {
        final int args = packet.position();
        do {
            final int startPos = packet.position();
            while (packet.hasRemaining() && packet.get(packet.position()) != ' ') {
                packet.get();
            }
            final String string = newString(packet, startPos, packet.position()-startPos);
            packet.get();
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("recv ExtendedInfoSet "+string);
            }
            // XXX: ExtendedInfoSet command not implemented
        } while (packet.hasRemaining());
        notifyPacketWatcherListenersNoData(packet, args);
    }

    private void processExtendedTextSet(@NotNull final ByteBuffer packet) {
        final int args = packet.position();
        while (true) {
            final int startPos = packet.position();
            while (packet.hasRemaining() && packet.get(packet.position()) != ' ') {
                packet.get();
            }
            final String type = newString(packet, startPos, packet.position()-startPos);
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("recv ExtendedTextSet "+type);
            }
            // XXX: ExtendedTextSet command not implemented
            if (!packet.hasRemaining()) {
                break;
            }
            packet.get();
        }
        notifyPacketWatcherListenersNoData(packet, args);
    }

    private void processFace2(@NotNull final ByteBuffer packet) {
        final int args = packet.position();
        final int faceNum = getInt2(packet);
        final int faceSetNum = getInt1(packet);
        final int faceChecksum = getInt4(packet);
        final String faceName = getString(packet, packet.remaining()).intern();
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv face2 num="+faceNum+" set="+faceSetNum+" checksum="+faceChecksum+" name="+faceName);
        }
        fireFaceReceived(faceNum, faceSetNum, faceChecksum, faceName);
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processFailure(@NotNull final ByteBuffer packet) {
        final String full = getString(packet, packet.remaining());
        final String command;
        final String message;
        final int idx = full.indexOf(' ');
        if (idx == -1) {
            command = full;
            message = "";
        } else {
            command = full.substring(0, idx);
            message = full.substring(idx+1);
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv failure command="+command+" message="+message);
        }

        fireFailure(command, message);
    }

    private void processGoodbye(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of goodbye command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv goodbye");
        }
        // XXX: goodbye command not implemented
        notifyPacketWatcherListenersNoData(packet, args);
    }

    private void processImage2(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int faceNum = getInt4(packet);
        final int faceSetNum = getInt1(packet);
        final int len = getInt4(packet);
        if (packet.remaining() != len) {
            throw new UnknownCommandException("excess data at end of image2 command");
        }
        final int faceDataPosition = packet.position();
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv image2 face="+faceNum+" set="+faceSetNum+" len="+len);
        }
        packet.position(faceDataPosition);
        model.getAskfaceFaceQueue().faceReceived(faceNum, faceSetNum, packet);
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processItem2(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int location = getInt4(packet);
        while (packet.hasRemaining()) {
            final int tag = getInt4(packet);
            final int flags = getInt4(packet);
            final int weight = getInt4(packet);
            final int faceNum = getInt4(packet);
            final int nameLength = getInt1(packet);
            final String[] names = getString(packet, nameLength).split("\0", 2);
            final String name = names[0].intern();
            final String namePl = names.length < 2 ? name : names[1].intern();
            final int anim = getInt2(packet);
            final int animSpeed = getInt1(packet);
            final int nrof = getInt4(packet);
            final int type = getInt2(packet);
            if (debugProtocol != null) {
                debugProtocol.debugProtocolWrite("recv item2 location="+location+" tag="+tag+" flags="+flags+" weight="+weight+" face="+faceNum+" name="+name+" name_pl="+namePl+" anim="+anim+" anim_speed="+animSpeed+" nrof="+nrof+" type="+type);
            }
            fireAddItemReceived(location, tag, flags, weight, faceNum, name, namePl, anim, animSpeed, nrof, type);
        }
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of item2 command");
        }
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processMagicMap(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();

        final boolean widthSign = packet.get(packet.position()) == '-';
        if (widthSign) {
            packet.get();
        }
        int width = 0;
        do {
            width = width*10+parseDigit(packet.get());
        } while (packet.get(packet.position()) != ' ');
        packet.get();
        if (widthSign) {
            width = -width;
        }

        final boolean heightSign = packet.get(packet.position()) == '-';
        if (heightSign) {
            packet.get();
        }
        int height = 0;
        do {
            height = height*10+parseDigit(packet.get());
        } while (packet.get(packet.position()) != ' ');
        packet.get();
        if (heightSign) {
            height = -height;
        }

        final boolean pxSign = packet.get(packet.position()) == '-';
        if (pxSign) {
            packet.get();
        }
        int px = 0;
        do {
            px = px*10+parseDigit(packet.get());
        } while (packet.get(packet.position()) != ' ');
        packet.get();
        if (pxSign) {
            px = -px;
        }

        final boolean pySign = packet.get(packet.position()) == '-';
        if (pySign) {
            packet.get();
        }
        int py = 0;
        do {
            py = py*10+parseDigit(packet.get());
        } while (packet.get(packet.position()) != ' ');
        packet.get();
        if (pySign) {
            py = -py;
        }

        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv magicmap size="+width+"x"+height+" player="+px+"/"+py+" len="+packet.remaining());
        }

        if (packet.remaining() != width*height) {
            throw new UnknownCommandException("invalid magicmap command");
        }

        final byte[][] data = new byte[height][width];
        for (int y = 0; y < height; y++) {
            packet.get(data[y]);
        }
        fireMagicMap(-px+(currentMapWidth-1)/2, -py+(currentMapHeight-1)/2, data);
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processMap2(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv map2 begin");
        }
        if (crossfireUpdateMapListener != null) {
            synchronized (crossfireUpdateMapListener.mapBegin()) {
                while (packet.hasRemaining()) {
                    final int coord = getInt2(packet);
                    final int x = ((coord>>10)&0x3F)-Map2.COORD_OFFSET;
                    final int y = ((coord>>4)&0x3F)-Map2.COORD_OFFSET;
                    final int coordType = coord&0xF;

                    switch (coordType) {
                    case Map2.TYPE_COORDINATE:
                        cmdMap2Coordinate(packet, x, y);
                        break;

                    case Map2.TYPE_SCROLL:
                        if (debugProtocol != null) {
                            debugProtocol.debugProtocolWrite("recv map2 "+x+"/"+y+" scroll");
                        }
                        assert crossfireUpdateMapListener != null;
                        crossfireUpdateMapListener.mapScroll(x, y);
                        break;

                    default:
                        if (debugProtocol != null) {
                            debugProtocol.debugProtocolWrite("recv map2 "+x+"/"+y+" <invalid>");
                        }
                        throw new UnknownCommandException("map2 command contains unexpected coordinate type "+coordType);
                    }
                }
                assert crossfireUpdateMapListener != null;
                crossfireUpdateMapListener.mapEnd();
            }
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv map2 end");
        }
        notifyPacketWatcherListenersShortArray(packet, args);
    }

    private void processMapExtended(@NotNull final ByteBuffer packet) {
        final int args = packet.position();
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv mapextended");
        }

        // XXX: "MapExtended" command not yet implemented

        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processMusic(@NotNull final ByteBuffer packet) {
        final int args = packet.position();
        final String music = getString(packet, packet.remaining());
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv music "+music);
        }

        fireMusicReceived(music);
        notifyPacketWatcherListenersAscii(packet, args);
    }

    private void processNewMap(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of newmap command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv newmap");
        }
        fireNewMap();
        notifyPacketWatcherListenersNoData(packet, args);
    }

    private void processPickup(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int pickupOptions = getInt4(packet);
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of pickup command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv pickup options="+pickupOptions);
        }
        firePickupChanged(pickupOptions);
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processPlayer(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int tag = getInt4(packet);
        final int weight = getInt4(packet);
        final int faceNum = getInt4(packet);
        final int nameLength = getInt1(packet);
        final String name = getString(packet, nameLength);
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of player command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv player tag="+tag+" weight="+weight+" face="+faceNum+" name="+name);
        }
        firePlayerReceived(tag, weight, faceNum, name);
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processQuery(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        int flags = 0;
        do {
            flags = flags*10+parseDigit(packet.get());
        } while (packet.get(packet.position()) != ' ');
        packet.get();

        final String text = getString(packet, packet.remaining());

        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv query flags="+flags+" text="+text);
        }

        // XXX: hack to process "What is your name?" prompt even before addme_success is received
        if (clientSocketState != ClientSocketState.CONNECTED) {
            setClientSocketState(ClientSocketState.ADDME, ClientSocketState.CONNECTED);
            negotiateMapSize(preferredMapWidth, preferredMapHeight);
            negotiateNumLookObjects(preferredNumLookObjects);
        }
        fireCommandQueryReceived(text, flags);
        notifyPacketWatcherListenersAscii(packet, args);
    }

    private void processReplyInfo(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int startPos = packet.position();
        while (packet.hasRemaining() && packet.get(packet.position()) != '\n' && packet.get(packet.position()) != ' ') {
            packet.get();
        }
        final String infoType = newString(packet, startPos, packet.position()-startPos);
        if (packet.hasRemaining()) {
            packet.get();
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv replyinfo type="+infoType+" len="+packet.remaining());
        }
        try {
            cmdReplyinfo(infoType, packet);
        } catch (final IOException ex) {
            throw new UnknownCommandException("invalid replyinfo command: "+ex.getMessage());
        }
        notifyPacketWatcherListenersAscii(packet, args);
    }

    private void processSetup(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final List<String> options = new ArrayList<String>();
        while (packet.hasRemaining()) {
            while (packet.get(packet.position()) == ' ') {
                packet.get();
            }
            final int startPos = packet.position();
            while (packet.hasRemaining() && packet.get(packet.position()) != ' ') {
                packet.get();
            }
            options.add(newString(packet, startPos, packet.position()-startPos));
            if (packet.hasRemaining()) {
                packet.get();
            }
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv setup "+options);
        }
        if (options.size()%2 != 0) {
            throw new UnknownCommandException("odd number of arguments in setup command");
        }
        for (int i = 0; i+1 < options.size(); i += 2) {
            final String option = options.get(i);
            final String value = options.get(i+1);
            if (option.equals("spellmon")) {
                if (!value.equals("1")) {
                    throw new UnknownCommandException("Error: the server is too old for this client since it does not support the spellmon=1 setup option.");
                }
            } else if (option.equals("sound2")) {
                // ignore: if the server sends sound info it is processed
            } else if (option.equals("exp64")) {
                // Ignored since it only enables additional/improved stat
                // commands but the old version is also supported.
            } else if (option.equals("newmapcmd")) {
                if (!value.equals("1")) {
                    throw new UnknownCommandException("Error: the server is too old for this client since it does not support the newmapcmd=1 setup option.");
                }
            } else if (option.equals("facecache")) {
                if (!value.equals("1")) {
                    throw new UnknownCommandException("the server is too old for this client since it does not support the facecache=1 setup option.");
                }
            } else if (option.equals("extendedTextInfos")) {
                if (!value.equals("1")) {
                    throw new UnknownCommandException("the server is too old for this client since it does not support the extendedTextInfos=1 setup option.");
                }
            } else if (option.equals("itemcmd")) {
                if (!value.equals("2")) {
                    throw new UnknownCommandException("the server is too old for this client since it does not support the itemcmd=2 setup option.");
                }
            } else if (option.equals("mapsize")) {
                final String[] tmp = value.split("x", 2);
                if (tmp.length != 2) {
                    throw new UnknownCommandException("the server returned 'setup mapsize "+value+"'.");
                }
                final int thisMapWidth;
                final int thisMapHeight;
                try {
                    thisMapWidth = Integer.parseInt(tmp[0]);
                    thisMapHeight = Integer.parseInt(tmp[1]);
                } catch (final NumberFormatException ignored) {
                    throw new UnknownCommandException("the server returned 'setup mapsize "+value+"'.");
                }
                if (pendingMapWidth == 0 || pendingMapHeight == 0) {
                    System.err.println("the server sent an unexpected 'setup mapsize "+value+"'.");
                } else if (pendingMapWidth == thisMapWidth && pendingMapHeight == thisMapHeight) {
                    pendingMapWidth = 0;
                    pendingMapHeight = 0;
                    setCurrentMapSize(thisMapWidth, thisMapHeight);
                    if (thisMapWidth != preferredMapWidth && thisMapHeight != preferredMapHeight) {
                        negotiateMapSize(preferredMapWidth, preferredMapHeight);
                    }
                } else if (pendingMapWidth > thisMapWidth && pendingMapHeight > thisMapHeight) {
                    pendingMapWidth = 0;
                    pendingMapHeight = 0;
                    negotiateMapSize(thisMapWidth, thisMapHeight);
                } else if (pendingMapWidth > thisMapWidth) {
                    final int tmpMapHeight = pendingMapHeight;
                    pendingMapWidth = 0;
                    pendingMapHeight = 0;
                    negotiateMapSize(thisMapWidth, tmpMapHeight);
                } else if (pendingMapHeight > thisMapHeight) {
                    final int tmpMapWidth = pendingMapWidth;
                    pendingMapWidth = 0;
                    pendingMapHeight = 0;
                    negotiateMapSize(tmpMapWidth, thisMapHeight);
                } else if (pendingMapWidth == thisMapWidth) {
                    final int tmpMapHeight = pendingMapHeight+2;
                    pendingMapWidth = 0;
                    pendingMapHeight = 0;
                    negotiateMapSize(thisMapWidth, tmpMapHeight);
                } else if (pendingMapHeight == thisMapHeight) {
                    final int tmpMapWidth = pendingMapWidth+2;
                    pendingMapWidth = 0;
                    pendingMapHeight = 0;
                    negotiateMapSize(tmpMapWidth, thisMapHeight);
                } else if (pendingMapWidth <= pendingMapHeight) {
                    final int tmpMapWidth = pendingMapWidth+2;
                    final int tmpMapHeight = pendingMapHeight;
                    pendingMapWidth = 0;
                    pendingMapHeight = 0;
                    negotiateMapSize(tmpMapWidth, tmpMapHeight);
                } else {
                    final int tmpMapWidth = pendingMapWidth;
                    final int tmpMapHeight = pendingMapHeight+2;
                    pendingMapWidth = 0;
                    pendingMapHeight = 0;
                    negotiateMapSize(tmpMapWidth, tmpMapHeight);
                }
            } else if (option.equals("map2cmd")) {
                if (!value.equals("1")) {
                    throw new UnknownCommandException("the server is too old for this client since it does not support the map2cmd=1 setup option.");
                }
            } else if (option.equals("darkness")) {
                // do not care
            } else if (option.equals("tick")) {
                if (!value.equals("1")) {
                    throw new UnknownCommandException("the server is too old for this client since it does not support the tick=1 setup option.");
                }
            } else if (option.equals("num_look_objects")) {
                if (value.equals("FALSE")) {
                    System.err.println("Warning: the server is too old for this client since it does not support the num_look_objects setup option.");
                    System.err.println("Expect issues with the ground view display.");
                    pendingNumLookObjects = 0;
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("processSetup: pending_num_look_objects="+pendingNumLookObjects+" [server didn't understand setup command]");
                    }
                } else {
                    final int thisNumLookObjects;
                    try {
                        thisNumLookObjects = Integer.parseInt(value);
                    } catch (final NumberFormatException ignored) {
                        throw new UnknownCommandException("the server returned 'setup num_look_objects "+value+"'.");
                    }
                    if (pendingNumLookObjects == 0) {
                        System.err.println("the server sent an unexpected 'setup num_look_objects "+value+"'.");
                    } else {
                        if (pendingNumLookObjects != thisNumLookObjects) {
                            System.err.println("Warning: the server didn't accept the num_look_objects setup option: requested "+pendingNumLookObjects+", returned "+thisNumLookObjects+".");
                            System.err.println("Expect issues with the ground view display.");
                        }
                        pendingNumLookObjects = 0;
                        if (debugProtocol != null) {
                            debugProtocol.debugProtocolWrite("processSetup: pending_num_look_objects="+pendingNumLookObjects+" [ok]");
                        }
                        currentNumLookObjects = thisNumLookObjects;
                        if (debugProtocol != null) {
                            debugProtocol.debugProtocolWrite("processSetup: num_look_objects="+currentNumLookObjects);
                        }
                        if (currentNumLookObjects != preferredNumLookObjects) {
                            negotiateNumLookObjects(preferredNumLookObjects);
                        }
                    }
                }
            } else if (option.equals("faceset")) {
                // ignore: we do not care about the face set
            } else if (option.equals("want_pickup")) {
                // ignore: we do not care whether this option has been ignored
            } else if (option.equals("extended_stats")) {
                // ignore: we do not care whether this option has been ignored
            } else if (option.equals("loginmethod")) {
                if (value.equals("FALSE")) {
                    loginMethod = 0;
                    continue;
                }

                final int method;
                try {
                    method = Integer.parseInt(value);
                } catch (final NumberFormatException ignored) {
                    throw new UnknownCommandException("the server returned 'setup loginmethod "+value+"'.");
                }
                loginMethod = method;
            } else if (option.equals("notifications")) {
                // ignore: we do not care whether this option has been ignored
            } else {
                System.err.println("Warning: ignoring unknown setup option from server: "+option+"="+value);
            }
        }

        if (options.size() != 2 || !options.get(0).equals("mapsize") && !options.get(0).equals("num_look_objects")) {
            setClientSocketState(ClientSocketState.SETUP, ClientSocketState.REQUESTINFO);
            sendRequestinfo("image_info");
            sendRequestinfo("skill_info");
            sendRequestinfo("exp_table");
            sendToggleextendedtext(MessageTypes.getAllTypes());
        }
        notifyPacketWatcherListenersAscii(packet, args);
    }

    private void processSmooth(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int faceNo = getInt2(packet);
        final int smoothPic = getInt2(packet);
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of smooth command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv smooth face="+faceNo+" smooth_pic="+smoothPic);
        }
        model.getSmoothFaces().updateSmoothFace(faceNo, smoothPic);
        notifyPacketWatcherListenersShortArray(packet, args);
    }

    private void processSound(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int x = packet.get();
        final int y = packet.get();
        final int num = getInt2(packet);
        final int type = getInt1(packet);
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of sound command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv sound pos="+x+"/"+y+" num="+num+" type="+type);
        }

        fireCommandSoundReceived(x, y, num, type);
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processSound2(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int x = packet.get();
        final int y = packet.get();
        final int dir = packet.get();
        final int volume = getInt1(packet);
        final int type = getInt1(packet);
        final int actionLength = getInt1(packet);
        final String action = getString(packet, actionLength);
        final int nameLength = getInt1(packet);
        final String name = getString(packet, nameLength);
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of sound2 command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv sound2 pos="+x+"/"+y+" dir="+dir+" volume="+volume+" type="+type+" action="+action+" name="+name);
        }

        fireCommandSound2Received(x, y, dir, volume, type, action, name);
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processStats(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        while (packet.hasRemaining()) {
            final int stat = getInt1(packet);
            switch (stat) {
            case Stats.CS_STAT_HP:
            case Stats.CS_STAT_MAXHP:
            case Stats.CS_STAT_SP:
            case Stats.CS_STAT_MAXSP:
            case Stats.CS_STAT_STR:
            case Stats.CS_STAT_INT:
            case Stats.CS_STAT_WIS:
            case Stats.CS_STAT_DEX:
            case Stats.CS_STAT_CON:
            case Stats.CS_STAT_CHA:
            case Stats.CS_STAT_LEVEL:
            case Stats.CS_STAT_WC:
            case Stats.CS_STAT_AC:
            case Stats.CS_STAT_DAM:
            case Stats.CS_STAT_ARMOUR:
            case Stats.CS_STAT_FOOD:
            case Stats.CS_STAT_POW:
            case Stats.CS_STAT_GRACE:
            case Stats.CS_STAT_MAXGRACE:
            case Stats.CS_STAT_FLAGS:
            case Stats.CS_STAT_RACE_STR:
            case Stats.CS_STAT_RACE_INT:
            case Stats.CS_STAT_RACE_WIS:
            case Stats.CS_STAT_RACE_DEX:
            case Stats.CS_STAT_RACE_CON:
            case Stats.CS_STAT_RACE_CHA:
            case Stats.CS_STAT_RACE_POW:
            case Stats.CS_STAT_BASE_STR:
            case Stats.CS_STAT_BASE_INT:
            case Stats.CS_STAT_BASE_WIS:
            case Stats.CS_STAT_BASE_DEX:
            case Stats.CS_STAT_BASE_CON:
            case Stats.CS_STAT_BASE_CHA:
            case Stats.CS_STAT_BASE_POW:
            case Stats.CS_STAT_APPLIED_STR:
            case Stats.CS_STAT_APPLIED_INT:
            case Stats.CS_STAT_APPLIED_WIS:
            case Stats.CS_STAT_APPLIED_DEX:
            case Stats.CS_STAT_APPLIED_CON:
            case Stats.CS_STAT_APPLIED_CHA:
            case Stats.CS_STAT_APPLIED_POW:
            case Stats.CS_STAT_GOLEM_HP:
            case Stats.CS_STAT_GOLEM_MAXHP:
                final short int2Param = (short)getInt2(packet);
                if (debugProtocol != null) {
                    debugProtocol.debugProtocolWrite("recv stats stat="+stat+" int2="+int2Param+"="+(int2Param&0xFFFF));
                }
                model.getStats().setStatInt2(stat, int2Param);
                notifyPacketWatcherListenersStats(stat, int2Param);
                break;

            case Stats.CS_STAT_EXP:
            case Stats.CS_STAT_SPEED:
            case Stats.CS_STAT_WEAP_SP:
            case Stats.CS_STAT_WEIGHT_LIM:
            case Stats.CS_STAT_SPELL_ATTUNE:
            case Stats.CS_STAT_SPELL_REPEL:
            case Stats.CS_STAT_SPELL_DENY:
                final int int4Param = getInt4(packet);
                if (debugProtocol != null) {
                    debugProtocol.debugProtocolWrite("recv stats stat="+stat+" int4="+int4Param);
                }
                model.getStats().setStatInt4(stat, int4Param);
                notifyPacketWatcherListenersStats(stat, int4Param);
                break;

            case Stats.CS_STAT_EXP64:
                final long int8Param = getInt8(packet);
                if (debugProtocol != null) {
                    debugProtocol.debugProtocolWrite("recv stats stat="+stat+" int8="+int8Param);
                }
                model.getStats().setStatInt8(stat, int8Param);
                notifyPacketWatcherListenersStats(stat, int8Param);
                break;

            case Stats.CS_STAT_RANGE:
            case Stats.CS_STAT_TITLE:
                final int length = getInt1(packet);
                final String strParam = getString(packet, length);
                if (debugProtocol != null) {
                    debugProtocol.debugProtocolWrite("recv stats stat="+stat+" str="+strParam);
                }
                model.getStats().setStatString(stat, strParam);
                notifyPacketWatcherListenersStats(stat, strParam);
                break;

            default:
                if (Stats.CS_STAT_RESIST_START <= stat && stat < Stats.CS_STAT_RESIST_START+Stats.RESIST_TYPES) {
                    final short int2Param2 = (short)getInt2(packet);
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv stats stat="+stat+" int2="+int2Param2);
                    }
                    model.getStats().setStatInt2(stat, int2Param2);
                    notifyPacketWatcherListenersStats(stat, int2Param2);
                } else if (Stats.CS_STAT_SKILLINFO <= stat && stat < Stats.CS_STAT_SKILLINFO+Stats.CS_NUM_SKILLS) {
                    final int level = getInt1(packet);
                    final long experience = getInt8(packet);
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv stats stat="+stat+" level="+level+" experience="+experience);
                    }
                    model.getStats().setStatSkill(stat, level, experience);
                    notifyPacketWatcherListenersStats(stat, level, experience);
                } else {
                    if (debugProtocol != null) {
                        debugProtocol.debugProtocolWrite("recv stats stat="+stat+" <unknown parameter>");
                    }
                    throw new UnknownCommandException("unknown stat value: "+stat);
                }
                break;
            }
        }
    }

    private void processTick(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int tickNo = getInt4(packet);
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of tick command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv tick "+tickNo);
        }
        fireTick(tickNo);
        notifyPacketWatcherListenersIntArray(packet, args);
    }

    private void processUpdItem(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int flags = getInt1(packet);
        final int tag = getInt4(packet);
        final int valLocation = (flags&UpdItem.UPD_LOCATION) == 0 ? 0 : getInt4(packet);
        final int valFlags = (flags&UpdItem.UPD_FLAGS) == 0 ? 0 : getInt4(packet);
        final int valWeight = (flags&UpdItem.UPD_WEIGHT) == 0 ? 0 : getInt4(packet);
        final int valFaceNum = (flags&UpdItem.UPD_FACE) == 0 ? 0 : getInt4(packet);
        final String valName;
        final String valNamePl;
        if ((flags&UpdItem.UPD_NAME) == 0) {
            valName = "";
            valNamePl = "";
        } else {
            final int nameLength = getInt1(packet);
            int namePlIndex = 0;
            while (namePlIndex < nameLength && packet.get(packet.position()+namePlIndex) != 0) {
                namePlIndex++;
            }
            valName = newString(packet, packet.position(), namePlIndex);
            valNamePl = namePlIndex+1 < nameLength ? newString(packet, packet.position()+namePlIndex+1, nameLength-(namePlIndex+1)) : valName;
            packet.position(packet.position()+nameLength);
        }
        final int valAnim = (flags&UpdItem.UPD_ANIM) == 0 ? 0 : getInt2(packet);
        final int valAnimSpeed = (flags&UpdItem.UPD_ANIMSPEED) == 0 ? 0 : getInt1(packet);
        final int valNrof = (flags&UpdItem.UPD_NROF) == 0 ? 0 : getInt4(packet);
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of upditem command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv upditem flags="+flags+" tag="+tag+" loc="+valLocation+" flags="+valFlags+" weight="+valWeight+" face="+valFaceNum+" name="+valName+" name_pl="+valNamePl+" anim="+valAnim+" anim_speed="+valAnimSpeed+" nrof="+valNrof);
        }
        fireUpditemReceived(flags, tag, valLocation, valFlags, valWeight, valFaceNum, valName, valNamePl, valAnim, valAnimSpeed, valNrof);
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processUpdQuest(@NotNull final ByteBuffer packet) {
        final int args = packet.position();
        final int code = getInt4(packet);
        final int end = getInt1(packet);
        final int stepLength = getInt2(packet);
        final String step = stepLength > 0 ? getString(packet, stepLength) : "";

        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv updquest code="+code+" end="+end+" description="+step);
        }
        model.getQuestsManager().updateQuest(code, end == 1, step);
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processUpdSpell(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        final int flags = getInt1(packet);
        final int tag = getInt4(packet);
        final int mana = (flags&SpellsManager.UPD_SP_MANA) == 0 ? 0 : getInt2(packet);
        final int grace = (flags&SpellsManager.UPD_SP_GRACE) == 0 ? 0 : getInt2(packet);
        final int damage = (flags&SpellsManager.UPD_SP_DAMAGE) == 0 ? 0 : getInt2(packet);
        if (packet.hasRemaining()) {
            throw new UnknownCommandException("excess data at end of updspell command");
        }
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv updspell flags="+flags+" tag="+tag+" sp="+mana+" gr="+grace+" dam="+damage);
        }
        model.getSpellsManager().updateSpell(flags, tag, mana, grace, damage);
        notifyPacketWatcherListenersMixed(packet, args);
    }

    private void processVersion(@NotNull final ByteBuffer packet) throws UnknownCommandException {
        final int args = packet.position();
        int csval = 0;
        do {
            csval = csval*10+parseDigit(packet.get());
        } while (packet.get(packet.position()) != ' ');
        packet.get();

        int scval = 0;
        do {
            scval = scval*10+parseDigit(packet.get());
        } while (packet.get(packet.position()) != ' ');
        packet.get();

        final String vinfo = getString(packet, packet.remaining());

        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("recv version cs="+csval+" sc="+scval+" info="+vinfo);
        }

        setClientSocketState(ClientSocketState.VERSION, ClientSocketState.SETUP);
        sendSetup("want_pickup 1", "faceset 0", "sound2 3", "exp64 1", "map2cmd 1", "darkness 1", "newmapcmd 1", "facecache 1", "extendedTextInfos 1", "itemcmd 2", "spellmon 1", "tick 1", "extended_stats 1", "loginmethod 1", "notifications 1");
        model.getStats().setSimpleWeaponSpeed(scval >= 1029);

        notifyPacketWatcherListenersAscii(packet, args);
    }

    @Override
    public void sendAccountLogin(@NotNull final String login, @NotNull final String password) {
        clearFailure();
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send accountlogin "+login);
        }
        accountName = login;
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(ACCOUNT_LOGIN_PREFIX);
            final byte[] loginBytes = login.getBytes(UTF8);
            byteBuffer.put((byte)loginBytes.length);
            byteBuffer.put(loginBytes);
            final byte[] passwordBytes = password.getBytes(UTF8);
            byteBuffer.put((byte)passwordBytes.length);
            byteBuffer.put(passwordBytes);
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }

    }

    @Override
    public void sendAddme() {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send addme");
        }
        defaultServerConnection.writePacket(ADDME_PREFIX, ADDME_PREFIX.length);
    }

    @Override
    public void sendApply(final int tag) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send apply tag="+tag);
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(APPLY_PREFIX);
            putDecimal(tag);
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    @Override
    public void sendAskface(final int num) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send askface face="+num);
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(ASKFACE_PREFIX);
            putDecimal(num);
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    @Override
    public void sendExamine(final int tag) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send examine tag="+tag);
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(EXAMINE_PREFIX);
            putDecimal(tag);
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    @Override
    public void sendLock(final boolean val, final int tag) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send lock tag="+tag+" val="+val);
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(LOCK_PREFIX);
            byteBuffer.put((byte)(val ? 1 : 0));
            byteBuffer.putInt(tag);
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    @Override
    public void sendLookat(final int dx, final int dy) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send lookat pos="+dx+"/"+dy);
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(LOOKAT_PREFIX);
            putDecimal(dx);
            byteBuffer.put((byte)' ');
            putDecimal(dy);
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    @Override
    public void sendMark(final int tag) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send mark tag="+tag);
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(MARK_PREFIX);
            byteBuffer.putInt(tag);
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    @Override
    public void sendMove(final int to, final int tag, final int nrof) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send move tag="+tag+" to="+to+" nrof="+nrof);
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(MOVE_PREFIX);
            putDecimal(to);
            byteBuffer.put((byte)' ');
            putDecimal(tag);
            byteBuffer.put((byte)' ');
            putDecimal(nrof);
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    @Override
    public int sendNcom(final int repeat, @NotNull final String command) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send ncom no="+packet+" repeat="+repeat+" cmd="+command);
        }
        final int thisPacket;
        synchronized (writeBuffer) {
            thisPacket = packet++&0x00FF;
            byteBuffer.clear();
            byteBuffer.put(NCOM_PREFIX);
            byteBuffer.putShort((short)thisPacket);
            byteBuffer.putInt(repeat);
            byteBuffer.put(command.getBytes(UTF8));
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
        return thisPacket;
    }

    @Override
    public void sendReply(@NotNull final String text) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send reply text="+text);
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(REPLY_PREFIX);
            byteBuffer.put(text.getBytes(UTF8));
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
        fireReplySent();
    }

    @Override
    public void sendRequestinfo(@NotNull final String infoType) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send requestinfo type="+infoType);
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(REQUESTINFO_PREFIX);
            byteBuffer.put(infoType.getBytes(UTF8));
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    @Override
    public void sendSetup(@NotNull final String... options) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send setup options="+Arrays.toString(options));
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(SETUP_PREFIX);
            if (options.length <= 0) {
                byteBuffer.put((byte)' ');
            } else {
                for (final String option : options) {
                    byteBuffer.put((byte)' ');
                    byteBuffer.put(option.getBytes(UTF8));
                }
            }
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    @Override
    public void sendToggleextendedtext(@NotNull final int... types) {
        if (types.length <= 0) {
            return;
        }

        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send toggleextendedtext types="+Arrays.toString(types));
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(TOGGLEEXTENDEDTEXT_PREFIX);
            for (final int type : types) {
                byteBuffer.put((byte)' ');
                putDecimal(type);
            }
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    @Override
    public void sendVersion(final int csval, final int scval, @NotNull final String vinfo) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send version cs="+csval+" sc="+scval+" info="+vinfo);
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(VERSION_PREFIX);
            putDecimal(csval);
            byteBuffer.put((byte)' ');
            putDecimal(scval);
            byteBuffer.put((byte)' ');
            byteBuffer.put(vinfo.getBytes(UTF8));
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    private void putDecimal(final int value) {
        if (value == 0) {
            byteBuffer.put((byte)'0');
        } else {
            final String str = Integer.toString(value);
            try {
                byteBuffer.put(str.getBytes("ISO-8859-1"));
            } catch (final UnsupportedEncodingException ex) {
                throw new AssertionError(ex); // every Java implementation must support UTF-8
            }
        }
    }

    private static int parseDigit(final byte ch) throws UnknownCommandException {
        final int digit = ch-'0';
        if (digit < 0 || digit > 9) {
            throw new UnknownCommandException("not a digit: "+ch);
        }
        return digit;
    }

    @Override
    public void setPreferredMapSize(final int preferredMapWidth, final int preferredMapHeight) {
        final int preferredMapWidth2 = Math.max(1, preferredMapWidth|1);
        final int preferredMapHeight2 = Math.max(1, preferredMapHeight|1);
        if (this.preferredMapWidth == preferredMapWidth2 && this.preferredMapHeight == preferredMapHeight2) {
            return;
        }

        this.preferredMapWidth = preferredMapWidth2;
        this.preferredMapHeight = preferredMapHeight2;

        negotiateMapSize(this.preferredMapWidth, this.preferredMapHeight);
    }

    private void setCurrentMapSize(final int currentMapWidth, final int currentMapHeight) {
        if (this.currentMapWidth == currentMapWidth && this.currentMapHeight == currentMapHeight) {
            return;
        }

        this.currentMapWidth = currentMapWidth;
        this.currentMapHeight = currentMapHeight;
        fireNewMap();
    }

    private void fireNewMap() {
        if (crossfireUpdateMapListener != null) {
            crossfireUpdateMapListener.newMap(currentMapWidth, currentMapHeight);
        }
    }

    @Override
    public void setPreferredNumLookObjects(final int preferredNumLookObjects) {
        final int preferredNumLookObjects2 = Math.max(3, preferredNumLookObjects);
        if (this.preferredNumLookObjects == preferredNumLookObjects2) {
            return;
        }

        this.preferredNumLookObjects = preferredNumLookObjects2;

        negotiateNumLookObjects(this.preferredNumLookObjects);
    }

    @Nullable
    @Override
    public String getAccountName() {
        return accountName;
    }

    @Override
    public void connect(@NotNull final String hostname, final int port) {
        accountName = null;
        clearFailure();
        clientSocketState = ClientSocketState.CONNECTING;
        setClientSocketState(ClientSocketState.CONNECTING, ClientSocketState.CONNECTING);
        defaultServerConnection.connect(hostname, port);
    }

    @Override
    public void disconnect(@NotNull final String reason) {
        defaultServerConnection.disconnect(reason);
    }

    @Override
    public void addClientSocketListener(@NotNull final ClientSocketListener clientSocketListener) {
        defaultServerConnection.addClientSocketListener(clientSocketListener);
    }

    @Override
    public void removeClientSocketListener(@NotNull final ClientSocketListener clientSocketListener) {
        defaultServerConnection.removeClientSocketListener(clientSocketListener);
    }

    private void setClientSocketState(@NotNull final ClientSocketState prevState, @NotNull final ClientSocketState nextState) {
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("connection state: "+nextState);
        }
        if (clientSocketState != prevState) {
            System.err.println("Warning: connection state is "+clientSocketState+" when switching to state "+nextState+", expecting state "+prevState);
        }
        clientSocketState = nextState;
        model.getGuiStateManager().setClientSocketState(nextState);
    }

    @Override
    public void sendAccountPlay(@NotNull final String name) {
        clearFailure();
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send accountplay "+name);
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(ACCOUNT_PLAY_PREFIX);
            byteBuffer.put(name.getBytes(UTF8));
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }

        final String tmpAccountName = accountName;
        if (tmpAccountName != null) {
            fireSelectCharacter(tmpAccountName, name);
        }
    }

    @Override
    public void sendAccountLink(final int force, @NotNull final String login, @NotNull final String password) {
        clearFailure();
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send accountaddplayer "+login);
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(ACCOUNT_ADD_PLAYER_PREFIX);
            byteBuffer.put((byte)force);
            final byte[] loginBytes = login.getBytes(UTF8);
            byteBuffer.put((byte)loginBytes.length);
            byteBuffer.put(loginBytes);
            final byte[] passwordBytes = password.getBytes(UTF8);
            byteBuffer.put((byte)passwordBytes.length);
            byteBuffer.put(passwordBytes);
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    @Override
    public void sendAccountCreate(@NotNull final String login, @NotNull final String password) {
        clearFailure();
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send accountnew "+login);
        }
        accountName = login;
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(ACCOUNT_NEW_PREFIX);
            final byte[] loginBytes = login.getBytes(UTF8);
            byteBuffer.put((byte)loginBytes.length);
            byteBuffer.put(loginBytes);
            final byte[] passwordBytes = password.getBytes(UTF8);
            byteBuffer.put((byte)passwordBytes.length);
            byteBuffer.put(passwordBytes);
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    @Override
    public void sendAccountCharacterCreate(@NotNull final String login, @NotNull final String password) {
        clearFailure();
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send createplayer "+login);
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(CREATE_PLAYER_PREFIX);
            final byte[] loginBytes = login.getBytes(UTF8);
            byteBuffer.put((byte)loginBytes.length);
            byteBuffer.put(loginBytes);
            final byte[] passwordBytes = password.getBytes(UTF8);
            byteBuffer.put((byte)passwordBytes.length);
            byteBuffer.put(passwordBytes);
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    @Override
    public void sendAccountPassword(@NotNull final String currentPassword, @NotNull final String newPassword) {
        clearFailure();
        if (debugProtocol != null) {
            debugProtocol.debugProtocolWrite("send accountpw");
        }
        synchronized (writeBuffer) {
            byteBuffer.clear();
            byteBuffer.put(ACCOUNT_PASSWORD_PREFIX);
            final byte[] currentPasswordBytes = currentPassword.getBytes(UTF8);
            byteBuffer.put((byte)currentPasswordBytes.length);
            byteBuffer.put(currentPasswordBytes);
            final byte[] newPasswordBytes = newPassword.getBytes(UTF8);
            byteBuffer.put((byte)newPasswordBytes.length);
            byteBuffer.put(newPasswordBytes);
            defaultServerConnection.writePacket(writeBuffer, byteBuffer.position());
        }
    }

    private static int getInt1(@NotNull final ByteBuffer byteBuffer) {
        return byteBuffer.get()&0xFF;
    }

    private static int getInt2(@NotNull final ByteBuffer byteBuffer) {
        return byteBuffer.getShort()&0xFFFF;
    }

    private static int getInt4(@NotNull final ByteBuffer byteBuffer) {
        return byteBuffer.getInt();
    }

    private static long getInt8(@NotNull final ByteBuffer byteBuffer) {
        return byteBuffer.getLong();
    }

    private static String getString(final ByteBuffer byteBuffer, final int len) {
        final byte[] tmp = new byte[len];
        byteBuffer.get(tmp);
        return new String(tmp, UTF8);
    }

    @NotNull
    private static String hexDump(@NotNull final ByteBuffer byteBuffer) {
        final int len = byteBuffer.limit();
        final byte[] data = new byte[len];
        for (int i = 0; i < len; i++) {
            data[i] = byteBuffer.get(i);
        }
        return HexCodec.hexDump(data, 0, len);
    }

    public int getCurrentNumLookObjects() {
        return currentNumLookObjects;
    }

}

---