Implemented trace isolate
Einige Prüfungen sind fehlgeschlagen
SteamWarCI Build failed

Dieser Commit ist enthalten in:
D4rkr34lm 2024-03-21 14:03:20 +01:00
Ursprung 5a59578a66
Commit a94f5747a0
8 geänderte Dateien mit 211 neuen und 42 gelöschten Zeilen

Datei anzeigen

@ -63,16 +63,16 @@ public class Recorder implements Listener {
*/ */
private final Set<Trace> noExplosionRecorded = new HashSet<>(); private final Set<Trace> noExplosionRecorded = new HashSet<>();
/**
* A map for records that have been taken in the same tick and now have to be added to the traces
*/
private final Map<Trace, List<TNTRecord>> recordsToAddMap = new HashMap<>();
/** /**
* Maps a tracked tnt entity to its entire recording history * Maps a tracked tnt entity to its entire recording history
*/ */
private final Map<TNTPrimed, List<TNTRecord>> historyMap = new HashMap<>(); private final Map<TNTPrimed, List<TNTRecord>> historyMap = new HashMap<>();
/**
* Maps Traces to their next open unique TNTRecord id
*/
private final Map<Trace, Integer> nextOpenTNTRecordIdMap = new HashMap<>();
/** /**
* Regions where auto-trace is enabled * Regions where auto-trace is enabled
*/ */
@ -116,7 +116,6 @@ public class Recorder implements Listener {
Trace trace = new Trace(region); Trace trace = new Trace(region);
noExplosionRecorded.add(trace); noExplosionRecorded.add(trace);
activeTraces.put(region, trace); activeTraces.put(region, trace);
nextOpenTNTRecordIdMap.put(trace, 0);
return manager.add(trace); return manager.add(trace);
} }
@ -147,7 +146,8 @@ public class Recorder implements Listener {
for(TNTPrimed tnt : trackedTNT.getOrDefault(region, Collections.emptyList())){ for(TNTPrimed tnt : trackedTNT.getOrDefault(region, Collections.emptyList())){
record(tnt, trace, Collections.emptyList()); record(tnt, trace, Collections.emptyList());
} }
trace.commitAdd(); trace.addAll(recordsToAddMap.get(trace));
recordsToAddMap.get(trace).clear();
} }
} }
@ -162,8 +162,7 @@ public class Recorder implements Listener {
if(history.size() == 0){ if(history.size() == 0){
historyMap.put(tntPrimed, history); historyMap.put(tntPrimed, history);
tntID = nextOpenTNTRecordIdMap.get(trace); tntID = trace.getAndIncrementNextOpenRecordId();
nextOpenTNTRecordIdMap.put(trace, tntID + 1);
} }
else else
tntID = history.get(0).getTntId(); tntID = history.get(0).getTntId();
@ -176,7 +175,7 @@ public class Recorder implements Listener {
TNTRecord record = new TNTRecord(tntID, tntPrimed, isExplosion, afterFirstExplosion, TPSUtils.currentTick.get() - trace.getStartTime(), history, destroyedBlocks); TNTRecord record = new TNTRecord(tntID, tntPrimed, isExplosion, afterFirstExplosion, TPSUtils.currentTick.get() - trace.getStartTime(), history, destroyedBlocks);
history.add(record); history.add(record);
trace.add(record); recordsToAddMap.get(trace).add(record);
} }
/** Event for TNTs beeing spawn. /** Event for TNTs beeing spawn.

Datei anzeigen

@ -50,9 +50,10 @@ public class Trace {
private List<TNTRecord> records = new ArrayList<>(); private List<TNTRecord> records = new ArrayList<>();
/** /**
* Records to be added * ID that should be asigned to the next record of a unique tnt
*/ */
private List<TNTRecord> newRecords = new ArrayList<>(); @Getter
private int nextOpenRecordId = -1;
/** /**
* A map of players -> REntityServers for rendering traces to a player * A map of players -> REntityServers for rendering traces to a player
@ -73,28 +74,28 @@ public class Trace {
this.region = region; this.region = region;
} }
/** Methode to add a records to add staging /**
* * Gets and increments the next open record id
* @param records records to add * @return next open record id
*/ */
protected void add (TNTRecord records){ protected int getAndIncrementNextOpenRecordId(){
newRecords.add(records); nextOpenRecordId++;
return nextOpenRecordId;
} }
/** /**
* Commits the additions made to this trace and updates active renders of this trace * Adds the given records and updates potential trace renderings
*/ */
protected void commitAdd(){ protected void addAll(List<TNTRecord> records){
records.addAll(newRecords); this.records.addAll(records);
for(Player player: serverMap.keySet()){ for(Player player: serverMap.keySet()){
REntityServer server = serverMap.get(player); REntityServer server = serverMap.get(player);
BundleFilter bundleFilter = bundleFilterMap.get(player); BundleFilter bundleFilter = bundleFilterMap.get(player);
ViewFlag[] viewFlags = viewFlagMap.get(player); ViewFlag[] viewFlags = viewFlagMap.get(player);
render(server, newRecords, viewFlags, bundleFilter); render(server, records, viewFlags, bundleFilter);
} }
newRecords.clear();
} }
/** Internal methode to make records immutable after recording is finished /** Internal methode to make records immutable after recording is finished
@ -105,8 +106,9 @@ public class Trace {
this.records = records; this.records = records;
} }
/** /** Gets the historys of all tnts in this trace
* *
* @return the historys of this trace
*/ */
public Set<List<TNTRecord>> getHistories() { public Set<List<TNTRecord>> getHistories() {
Set<List<TNTRecord>> histories = new HashSet<>(); Set<List<TNTRecord>> histories = new HashSet<>();
@ -233,6 +235,13 @@ public class Trace {
server.close(); server.close();
} }
/** Returns the flags used by the given player to render the trace or null if not present
*
* @param player
* @return
*/
protected ViewFlag[] getViewFlags(Player player){return viewFlagMap.get(player);}
@Override @Override
public String toString() { public String toString() {
return "Trace{" + return "Trace{" +

Datei anzeigen

@ -21,20 +21,21 @@ package de.steamwar.bausystem.features.tracer;
import de.steamwar.bausystem.BauSystem; import de.steamwar.bausystem.BauSystem;
import de.steamwar.bausystem.features.tracer.rendering.BundleFilter; import de.steamwar.bausystem.features.tracer.rendering.BundleFilter;
import de.steamwar.bausystem.features.tracer.rendering.TraceEntity;
import de.steamwar.bausystem.features.tracer.rendering.ViewFlag; import de.steamwar.bausystem.features.tracer.rendering.ViewFlag;
import de.steamwar.bausystem.features.tracer.rendering.dynamicFlags.IsolateFlag;
import de.steamwar.bausystem.region.Region; import de.steamwar.bausystem.region.Region;
import de.steamwar.command.PreviousArguments; import de.steamwar.command.PreviousArguments;
import de.steamwar.command.SWCommand; import de.steamwar.command.SWCommand;
import de.steamwar.command.TypeMapper; import de.steamwar.command.TypeMapper;
import de.steamwar.command.TypeValidator;
import de.steamwar.entity.REntityServer;
import de.steamwar.linkage.Linked; import de.steamwar.linkage.Linked;
import de.steamwar.linkage.LinkedInstance; import de.steamwar.linkage.LinkedInstance;
import org.bukkit.command.CommandSender; import org.bukkit.command.CommandSender;
import org.bukkit.entity.Player; import org.bukkit.entity.Player;
import java.util.ArrayList; import java.util.*;
import java.util.Arrays;
import java.util.Collection;
import java.util.List;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@Linked @Linked
@ -83,12 +84,67 @@ public class TraceCommand extends SWCommand {
manager.clear(); manager.clear();
} }
//TODO Manage non exsistent trace
@Register(value = "delete", description = "TRACE_COMMAND_HELP_SHOW") @Register(value = "delete", description = "TRACE_COMMAND_HELP_SHOW")
public void delete(Player player, int id){ public void delete(Player player, int id){
manager.remove(id); manager.remove(id);
} }
@Register(value = "isolate", description = "TRACE_COMMAND_HELP_SHOW")
public void isolate(Player player, Trace trace, @ErrorMessage("test") TNTRecord... records){
IsolateFlag isolationFlag = null;
ViewFlag[] viewFlags = trace.getViewFlags(player);
if(viewFlags != null)
for(ViewFlag flag: viewFlags)
if(flag.name.equals("isolate"))
isolationFlag = (IsolateFlag) flag;
if(isolationFlag == null)
isolationFlag = new IsolateFlag();
for(TNTRecord record: records)
isolationFlag.toggleId(record.getTntId());
}
@ClassMapper(value = Trace.class, local = true)
public TypeMapper<Trace> traceClassMapper(){
return new TypeMapper<Trace>() {
@Override
public Trace map(CommandSender commandSender, String[] previousArguments, String s) {
int id = Integer.parseInt(s);
Optional<Trace> trace = manager.get(id);
return trace.orElse(null);
}
@Override
public Collection<String> tabCompletes(CommandSender sender, PreviousArguments previousArguments, String s) {
return manager.getAllIds().stream()
.map(id -> id.toString())
.collect(Collectors.toList());
}
};
}
@ClassMapper(value = TNTRecord.class, local = true)
public TypeMapper<TNTRecord> recordMapper() {
return new TypeMapper<TNTRecord>() {
@Override
public TNTRecord map(CommandSender commandSender, PreviousArguments previousArguments, String s) {
Trace trace = previousArguments.getFirst(Trace.class).orElse(null);
if(trace == null) return null;
int id = Integer.parseInt(s);
return trace.getRecords().stream()
.filter(record -> record.getTntId() == id)
.findFirst()
.orElse(null);
}
};
}
@ClassMapper(value = BundleFilter.class, local = true) @ClassMapper(value = BundleFilter.class, local = true)
public TypeMapper<BundleFilter> bundleFilterClassMapper() { public TypeMapper<BundleFilter> bundleFilterClassMapper() {
return new TypeMapper<BundleFilter>() { return new TypeMapper<BundleFilter>() {

Datei anzeigen

@ -72,6 +72,7 @@ public class TraceManager implements Listener {
*/ */
public boolean remove(int id){ public boolean remove(int id){
if(id >= nextOpenId) return false; if(id >= nextOpenId) return false;
if(traces.get(id) == null) return false;
for(Player player: viewFlagMap.keySet()) for(Player player: viewFlagMap.keySet())
traces.get(id).hide(player); traces.get(id).hide(player);
traces.remove(id); traces.remove(id);
@ -119,6 +120,11 @@ public class TraceManager implements Listener {
return new ArrayList<>(traces.values()); return new ArrayList<>(traces.values());
} }
/**
* @return all ids of active traces
*/
public Set<Integer> getAllIds(){return traces.keySet();}
/** Toggles trace show on for player /** Toggles trace show on for player
* *
* @param player * @param player

Datei anzeigen

@ -26,7 +26,7 @@ import java.util.function.BiFunction;
public enum BundleFilter { public enum BundleFilter {
//TODO chagne optional to true flase null
LOOSE((TNTRecord a, TNTRecord b) -> { LOOSE((TNTRecord a, TNTRecord b) -> {
if(a.isExplosion() != b.isExplosion()) return Optional.of(false); if(a.isExplosion() != b.isExplosion()) return Optional.of(false);
if(a.getLocation().distance(b.getLocation()) <= BundleFilter.pixelSize) return Optional.of(false); if(a.getLocation().distance(b.getLocation()) <= BundleFilter.pixelSize) return Optional.of(false);

Datei anzeigen

@ -19,12 +19,16 @@
package de.steamwar.bausystem.features.tracer.rendering; package de.steamwar.bausystem.features.tracer.rendering;
import de.steamwar.bausystem.BauSystem;
import de.steamwar.bausystem.features.tracer.TNTRecord; import de.steamwar.bausystem.features.tracer.TNTRecord;
import de.steamwar.entity.REntityServer; import de.steamwar.entity.REntityServer;
import de.steamwar.entity.RFallingBlockEntity; import de.steamwar.entity.RFallingBlockEntity;
import lombok.Getter; import lombok.Getter;
import org.bukkit.Location; import org.bukkit.Location;
import org.bukkit.Material; import org.bukkit.Material;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.entity.EntityInteractEvent;
import java.util.List; import java.util.List;
@ -40,5 +44,23 @@ public class TraceEntity extends RFallingBlockEntity {
super(server, location, isExplosion ? Material.RED_STAINED_GLASS : Material.TNT); super(server, location, isExplosion ? Material.RED_STAINED_GLASS : Material.TNT);
setNoGravity(true); setNoGravity(true);
this.records = records; this.records = records;
server.setCallback(((player, rEntity, entityAction) -> {
if (entityAction != REntityServer.EntityAction.INTERACT) return;
TNTRecord representative = records.get(0);
BauSystem.MESSAGE.sendPrefixless("TNT_CLICK_HEADER", player);
BauSystem.MESSAGE.sendPrefixless("TNT_CLICK_FUSE_TIME", player, representative.getFuse());
BauSystem.MESSAGE.sendPrefixless("TNT_CLICK_POSITION_X", player, representative.getLocation().getX() + "");
BauSystem.MESSAGE.sendPrefixless("TNT_CLICK_POSITION_Y", player, representative.getLocation().getY() + "");
BauSystem.MESSAGE.sendPrefixless("TNT_CLICK_POSITION_Z", player, representative.getLocation().getZ() + "");
BauSystem.MESSAGE.sendPrefixless("TNT_CLICK_VELOCITY_X", player, representative.getVelocity().getX() + "");
BauSystem.MESSAGE.sendPrefixless("TNT_CLICK_VELOCITY_Y", player, representative.getVelocity().getY() + "");
BauSystem.MESSAGE.sendPrefixless("TNT_CLICK_VELOCITY_Z", player, representative.getVelocity().getZ() + "");
}));
} }
} }

Datei anzeigen

@ -68,7 +68,7 @@ public abstract class ViewFlag {
public void modify(REntityServer server, List<TraceEntity> entities) {} public void modify(REntityServer server, List<TraceEntity> entities) {}
}; };
public static ViewFlag SOURCE = new ViewFlag(true, false, "source") { public static ViewFlag SOURCE = new ViewFlag(true, false, IGNITE, "source") {
@Override @Override
public List<TNTRecord> filter(List<TNTRecord> records) { public List<TNTRecord> filter(List<TNTRecord> records) {
return records.stream() return records.stream()
@ -107,7 +107,7 @@ public abstract class ViewFlag {
public static ViewFlag MICROMOTION = new ViewFlag(true, false, "micromotion") { public static ViewFlag MICROMOTION = new ViewFlag(true, false, "micromotion") {
@Override @Override
public List<TNTRecord> filter(List<TNTRecord> records) { public List<TNTRecord> filter(List<TNTRecord> records) {
Set<UUID> seen = new HashSet<>(); Set<Integer> seen = new HashSet<>();
Set<TNTRecord> toRemove = new HashSet<>(); Set<TNTRecord> toRemove = new HashSet<>();
for(TNTRecord uniqueRecord: records){ for(TNTRecord uniqueRecord: records){
@ -146,23 +146,25 @@ public abstract class ViewFlag {
@Override @Override
public void modify(REntityServer server, List<TraceEntity> entities) { public void modify(REntityServer server, List<TraceEntity> entities) {
for(TraceEntity entity: entities) { for(TraceEntity entity: entities) {
TNTRecord example = entity.getRecords().get(0); TNTRecord representaitv = entity.getRecords().get(0);
if(example.isExplosion()) continue; if(representaitv.isExplosion()) continue;
Location pos = example.getLocation(); Location pos = representaitv.getLocation();
Vector xVelocity = new Vector(example.getVelocity().getX(), 0, 0); double xVelocity = representaitv.getVelocity().getX();
Vector yVelocity = new Vector(0, example.getVelocity().getY(), 0); double yVelocity = representaitv.getVelocity().getY();
Vector zVelocity = new Vector(0, 0, example.getVelocity().getZ()); double zVelocity = representaitv.getVelocity().getZ();
Vector firstVelocity = xVelocity.getX() >= zVelocity.getZ() ? xVelocity : zVelocity; pos = pos.add(0,yVelocity,0);
pos = pos.add(yVelocity);
RFallingBlockEntity y = new RFallingBlockEntity(server, pos, Material.WHITE_STAINED_GLASS); RFallingBlockEntity y = new RFallingBlockEntity(server, pos, Material.WHITE_STAINED_GLASS);
y.setNoGravity(true); y.setNoGravity(true);
pos = pos.add(firstVelocity); if(xVelocity >= zVelocity)
pos.add(xVelocity, 0, 0);
else
pos.add(0,0,zVelocity);
RFallingBlockEntity secound = new RFallingBlockEntity(server, pos, Material.WHITE_STAINED_GLASS); RFallingBlockEntity secound = new RFallingBlockEntity(server, pos, Material.WHITE_STAINED_GLASS);
secound.setNoGravity(true); secound.setNoGravity(true);
} }
@ -215,6 +217,11 @@ public abstract class ViewFlag {
*/ */
public final String[] aliases; public final String[] aliases;
/**
* A flag that is used whenever this flag is used
*/
public final ViewFlag required;
public ViewFlag(boolean isStatic, boolean isInverse, String name, String... aliases) { public ViewFlag(boolean isStatic, boolean isInverse, String name, String... aliases) {
this.name = name; this.name = name;
this.aliases = aliases; this.aliases = aliases;
@ -222,7 +229,18 @@ public abstract class ViewFlag {
flags.add(this); flags.add(this);
if(isInverse) if(isInverse)
inverseFlags.add(this); inverseFlags.add(this);
} required = null;
}
public ViewFlag(boolean isStatic, boolean isInverse, ViewFlag required, String name, String... aliases){
this.name = name;
this.aliases = aliases;
if(isStatic)
flags.add(this);
if(isInverse)
inverseFlags.add(this);
this.required = required;
}
/** Filters the given records for a given condition /** Filters the given records for a given condition
* *

Datei anzeigen

@ -0,0 +1,59 @@
/*
* This file is a part of the SteamWar software.
*
* Copyright (C) 2024 SteamWar.de-Serverteam
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as published by
* the Free Software Foundation, either version 3 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 Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package de.steamwar.bausystem.features.tracer.rendering.dynamicFlags;
import de.steamwar.bausystem.features.tracer.TNTRecord;
import de.steamwar.bausystem.features.tracer.rendering.TraceEntity;
import de.steamwar.bausystem.features.tracer.rendering.ViewFlag;
import de.steamwar.entity.REntityServer;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
public class IsolateFlag extends ViewFlag {
private final List<Integer> tntToIsolate = new ArrayList<>();
public IsolateFlag(){
super(false, false, ViewFlag.IGNITE, "isolate");
}
/**
* Toggles the given id to be or not to be rendered
* @param id
*/
public void toggleId(int id){
if(tntToIsolate.contains(id))
tntToIsolate.remove(id);
else
tntToIsolate.add(id);
}
@Override
public List<TNTRecord> filter(List<TNTRecord> records) {
return records.stream()
.filter(record -> tntToIsolate.contains(record.getTntId()))
.collect(Collectors.toList());
}
@Override
public void modify(REntityServer server, List<TraceEntity> entities) {}
}