TestScriptProcess.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-2017,2019-2023 Andreas Kirschbaum
 * Copyright (C) 2010-2012,2014-2018,2020-2023 Nicolas Weeger
 */
 
package com.realtime.crossfire.jxclient.scripts;
 
import com.realtime.crossfire.jxclient.animations.Animations;
import com.realtime.crossfire.jxclient.faces.AbstractFacesManager;
import com.realtime.crossfire.jxclient.faces.FaceCache;
import com.realtime.crossfire.jxclient.faces.FaceImages;
import com.realtime.crossfire.jxclient.faces.FacesManager;
import com.realtime.crossfire.jxclient.guistate.GuiStateManager;
import com.realtime.crossfire.jxclient.guistate.TestGuiStateManager;
import com.realtime.crossfire.jxclient.items.FloorView;
import com.realtime.crossfire.jxclient.items.ItemSet;
import com.realtime.crossfire.jxclient.map.CfAnimations;
import com.realtime.crossfire.jxclient.map.MapUpdaterState;
import com.realtime.crossfire.jxclient.map.PendingDirections;
import com.realtime.crossfire.jxclient.queue.CommandQueue;
import com.realtime.crossfire.jxclient.server.crossfire.CrossfireServerConnection;
import com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServerConnection;
import com.realtime.crossfire.jxclient.skills.SkillSet;
import com.realtime.crossfire.jxclient.spells.SpellsManager;
import com.realtime.crossfire.jxclient.stats.ExperienceTable;
import com.realtime.crossfire.jxclient.stats.Stats;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.StringReader;
import java.util.concurrent.Semaphore;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;
import org.junit.Assert;
 
public class TestScriptProcess extends AbstractScriptProcess {
 
    @NotNull
    private static final Pattern PATTERN_MAP_SCROLL = Pattern.compile("@map_scroll (-?[0-9]+) (-?[0-9]+)");
 
    @NotNull
    private final StringBuilder sb = new StringBuilder();
 
    @NotNull
    private final MapUpdaterState mapUpdaterState;
 
    @NotNull
    private final BufferedReader br;
 
    @NotNull
    private final Semaphore sem = new Semaphore(0);
 
    @NotNull
    public static TestScriptProcess newTestScriptProcess(@NotNull final String scriptCommands) {
        return newTestScriptProcess(scriptCommands, new TestCrossfireServerConnection());
    }
 
    @NotNull
    public static TestScriptProcess newTestScriptProcess(@NotNull final String scriptCommands, @NotNull final CrossfireServerConnection crossfireServerConnection) {
        final GuiStateManager guiStateManager = new TestGuiStateManager();
        final CommandQueue commandQueue = new CommandQueue(crossfireServerConnection, guiStateManager, new PendingDirections());
        final SkillSet skillSet = new SkillSet(guiStateManager);
        final ExperienceTable experienceTable = new ExperienceTable();
        final Stats stats = new Stats(experienceTable, skillSet, guiStateManager);
        final ItemSet itemSet = new ItemSet();
        final FloorView floorView = new FloorView(itemSet);
        final FaceCache faceCache = new FaceCache();
        final FacesManager facesManager = new AbstractFacesManager(faceCache) {
 
            @NotNull
            @Override
            protected FaceImages getFaceImages(final int faceNum, @Nullable final AtomicBoolean returnIsUnknownImage) {
                throw new AssertionError("not implemented");
            }
 
        };
        final MapUpdaterState mapUpdaterState = new MapUpdaterState(facesManager, new Animations(guiStateManager), new CfAnimations(itemSet, facesManager, new Animations(null)));
        mapUpdaterState.newMap(25, 17);
        final SpellsManager spellsManager = new SpellsManager(guiStateManager, skillSet, stats);
        return new TestScriptProcess(0, "", commandQueue, crossfireServerConnection, stats, floorView, itemSet, spellsManager, mapUpdaterState, skillSet, scriptCommands);
    }
 
    private TestScriptProcess(final int scriptId, @NotNull final String filename, @NotNull final CommandQueue commandQueue, @NotNull final CrossfireServerConnection crossfireServerConnection, @NotNull final Stats stats, @NotNull final FloorView floorView, @NotNull final ItemSet itemSet, @NotNull final SpellsManager spellsManager, @NotNull final MapUpdaterState mapUpdaterState, @NotNull final SkillSet skillSet, @NotNull final String scriptCommands) {
        super(scriptId, filename, commandQueue, crossfireServerConnection, stats, floorView, itemSet, spellsManager, mapUpdaterState, skillSet);
        this.mapUpdaterState = mapUpdaterState;
        br = new BufferedReader(new StringReader(scriptCommands));
    }
 
    @Override
    public void killScript() {
        sb.append("killScript\n");
    }
 
    @Nullable
    @Override
    protected String readFromScript() throws IOException {
        while (true) {
            final String line = br.readLine();
            if (line == null) {
                sb.append("readFromScript: EOF\n");
                sem.release();
                return null;
            }
 
            sb.append("readFromScript: ").append(line).append("\n");
            final Matcher matcherMapScroll = PATTERN_MAP_SCROLL.matcher(line);
            if (matcherMapScroll.matches()) {
                final int dx = Integer.parseInt(matcherMapScroll.group(1));
                final int dy = Integer.parseInt(matcherMapScroll.group(2));
                synchronized (mapUpdaterState.mapBegin()) {
                    mapUpdaterState.mapScroll(dx, dy);
                    mapUpdaterState.mapEnd();
                }
                continue;
            }
 
            if (line.equals("@map_new")) {
                synchronized (mapUpdaterState.mapBegin()) {
                    mapUpdaterState.newMap(25, 17);
                    mapUpdaterState.mapEnd();
                }
                continue;
            }
 
            if (line.startsWith("@")) {
                Assert.fail("unrecognized command: "+line);
            }
 
            return line;
        }
    }
 
    @Nullable
    @Override
    protected String waitForTermination() {
        try {
            sem.acquire();
        } catch (final InterruptedException ignored) {
            return "current thread has been interrupted";
        }
        return null;
    }
 
    @Override
    protected void writeToScript(@NotNull final String data) {
        sb.append("writeToScript: ").append(data);
    }
 
    @NotNull
    public String getAndClearEvents() {
        final String result = sb.toString();
        sb.setLength(0);
        return result;
    }
 
}