AtrinikServerActions.java

Go to the documentation of this file.

/*
 * Gridarta MMORPG map editor for Crossfire, Daimonin and similar games.
 * Copyright (C) 2000-2015 The Gridarta Developers.
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along
 * with this program; if not, write to the Free Software Foundation, Inc.,
 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */

package net.sf.gridarta.var.atrinik.actions;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import net.sf.gridarta.actions.AbstractServerActions;
import net.sf.gridarta.model.mapmanager.FileControl;
import net.sf.gridarta.var.atrinik.model.archetype.Archetype;
import net.sf.gridarta.var.atrinik.model.gameobject.GameObject;
import net.sf.gridarta.var.atrinik.model.maparchobject.MapArchObject;
import org.jetbrains.annotations.NotNull;

public class AtrinikServerActions extends AbstractServerActions<GameObject, MapArchObject, Archetype> {

    private static final int SERVER_CMD_CONTROL = 0;

    @NotNull
    private static final String APPLICATION_NAME_IDENTIFIER = "gridarta";

    @NotNull
    private static final String CHARSET_NAME = "US-ASCII";

    private static final int CMD_CONTROL_MAP = 1;

    private static final int CMD_CONTROL_PLAYER = 2;

    private static final int CMD_CONTROL_MAP_RESET = 1;

    private static final int CMD_CONTROL_PLAYER_TELEPORT = 1;

    public AtrinikServerActions(@NotNull final FileControl<GameObject, MapArchObject, Archetype> fileControl) {
        super(fileControl);
    }

    private void sendPacket(@NotNull final ByteArrayOutputStream stream) throws IOException {
        final byte[] packet = stream.toByteArray();
        packet[0] = (byte) ((packet.length - 2) >> 8);
        packet[1] = (byte) (packet.length - 2);
        try {
            try (Socket socket = new Socket("127.0.0.1", 13327)) {
                final OutputStream outputStream = socket.getOutputStream();
                outputStream.write(packet);
                socket.shutdownOutput();
            }
        } catch (final IOException ex) {
            throw new IOException("127.0.0.1:13327: " + ex.getMessage(), ex);
        }
    }

    @Override
    protected void resetMap(@NotNull final String mapPath) throws IOException {
        final ByteArrayOutputStream tmp = new ByteArrayOutputStream();
        tmp.write(0);
        tmp.write(0);
        tmp.write(SERVER_CMD_CONTROL);
        tmp.write(APPLICATION_NAME_IDENTIFIER.getBytes(CHARSET_NAME));
        tmp.write(0); // termination of application name identifier
        tmp.write(CMD_CONTROL_MAP);
        tmp.write(CMD_CONTROL_MAP_RESET);
        tmp.write(mapPath.getBytes(CHARSET_NAME));
        tmp.write(0);
        sendPacket(tmp);
    }

    @Override
    protected void teleportCharacterToMap(@NotNull final String mapPath, final int mapX, final int mapY) throws IOException {
        final ByteArrayOutputStream tmp = new ByteArrayOutputStream();
        tmp.write(0);
        tmp.write(0);
        tmp.write(SERVER_CMD_CONTROL);
        tmp.write(APPLICATION_NAME_IDENTIFIER.getBytes(CHARSET_NAME));
        tmp.write(0); // termination of application name identifier
        tmp.write(CMD_CONTROL_PLAYER);
        tmp.write(CMD_CONTROL_PLAYER_TELEPORT);
        tmp.write(0); // empty player name
        tmp.write(mapPath.getBytes(CHARSET_NAME));
        tmp.write(0);
        tmp.write(mapX >> 8);
        tmp.write(mapX);
        tmp.write(mapY >> 8);
        tmp.write(mapY);
        sendPacket(tmp);
    }

}