ScriptManager.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.scripts;

import com.realtime.crossfire.jxclient.items.FloorView;
import com.realtime.crossfire.jxclient.items.ItemSet;
import com.realtime.crossfire.jxclient.map.MapUpdaterState;
import com.realtime.crossfire.jxclient.queue.CommandQueue;
import com.realtime.crossfire.jxclient.server.crossfire.CrossfireDrawinfoListener;
import com.realtime.crossfire.jxclient.server.crossfire.CrossfireServerConnection;
import com.realtime.crossfire.jxclient.skills.SkillSet;
import com.realtime.crossfire.jxclient.spells.Spell;
import com.realtime.crossfire.jxclient.stats.Stats;
import java.io.IOException;
import java.util.Collection;
import java.util.HashSet;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;
import java.util.stream.Collectors;
import org.jetbrains.annotations.NotNull;

public class ScriptManager {

    @NotNull
    private final CommandQueue commandQueue;

    @NotNull
    private final CrossfireServerConnection crossfireServerConnection;

    @NotNull
    private final Stats stats;

    @NotNull
    private final FloorView floorView;

    @NotNull
    private final ItemSet itemSet;

    @NotNull
    private final Iterable<Spell> spellsManager;

    @NotNull
    private final MapUpdaterState mapUpdaterState;

    @NotNull
    private final SkillSet skillSet;

    @NotNull
    private final Collection<ScriptProcess> scriptProcesses = new CopyOnWriteArraySet<>();

    private int nextScriptId = 1;

    public ScriptManager(@NotNull final CommandQueue commandQueue, @NotNull final CrossfireServerConnection crossfireServerConnection, @NotNull final Stats stats, @NotNull final FloorView floorView, @NotNull final ItemSet itemSet, @NotNull final Iterable<Spell> spellsManager, @NotNull final MapUpdaterState mapUpdaterState, @NotNull final SkillSet skillSet) {
        this.commandQueue = commandQueue;
        this.crossfireServerConnection = crossfireServerConnection;
        this.stats = stats;
        this.floorView = floorView;
        this.itemSet = itemSet;
        this.spellsManager = spellsManager;
        this.mapUpdaterState = mapUpdaterState;
        this.skillSet = skillSet;
    }

    public void newScript(@NotNull final String command) {
        final DefaultScriptProcess scriptProcess;
        try {
            scriptProcess = new DefaultScriptProcess(nextScriptId, command, commandQueue, crossfireServerConnection, stats, floorView, itemSet, spellsManager, mapUpdaterState, skillSet);
        } catch (final IOException ex) {
            crossfireServerConnection.drawInfo("Unable to run script: "+ex.getMessage(), CrossfireDrawinfoListener.NDI_RED);
            return;
        }
        nextScriptId++;
        scriptProcesses.add(scriptProcess);
        scriptProcess.addScriptProcessListener(result -> {
            scriptProcesses.remove(scriptProcess);
            if (result == null) {
                crossfireServerConnection.drawInfo("Script '"+scriptProcess+"' finished.", CrossfireDrawinfoListener.NDI_BLACK);
            } else {
                crossfireServerConnection.drawInfo("Script '"+scriptProcess+"' failed: "+result, CrossfireDrawinfoListener.NDI_RED);
            }
        });
        crossfireServerConnection.drawInfo("Script '"+scriptProcess+"' started.", CrossfireDrawinfoListener.NDI_BLACK);
        new Thread(scriptProcess, "JXClient:ScriptProcess:"+scriptProcess).start();
    }

    @NotNull
    public Set<ScriptProcess> getScripts(@NotNull final String partialScriptName) {
        try {
            return getScriptByScriptId(Integer.parseInt(partialScriptName));
        } catch (final NumberFormatException ignored) {
            return getScriptsByName(partialScriptName);
        }
    }

    @NotNull
    private Set<ScriptProcess> getScriptByScriptId(final int scriptId) {
        final Set<ScriptProcess> result = new HashSet<>();
        for (final ScriptProcess scriptProcess : scriptProcesses) {
            if (scriptProcess.getScriptId() == scriptId) {
                result.add(scriptProcess);
                break;
            }
        }
        return result;
    }

    @NotNull
    private Set<ScriptProcess> getScriptsByName(@NotNull final CharSequence partialScriptName) {
        return scriptProcesses.stream().filter(scriptProcess -> scriptProcess.getFilename().contains(partialScriptName)).collect(Collectors.toSet());
    }

    public boolean hasScripts() {
        return !scriptProcesses.isEmpty();
    }

}