Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
cfd68bb45e
|
|||
|
97d6ef8b47
|
|||
|
6441ddb3a5
|
|||
|
45f780f194
|
@@ -1,3 +1,3 @@
|
||||
projectGroup=ghast
|
||||
projectName=ghast-tools
|
||||
projectVersion=1.1
|
||||
projectVersion=1.4
|
||||
@@ -3,13 +3,13 @@ package ghast;
|
||||
import lombok.experimental.UtilityClass;
|
||||
import org.bukkit.plugin.Plugin;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
import java.io.OutputStream;
|
||||
import java.io.*;
|
||||
import java.net.URL;
|
||||
import java.nio.charset.Charset;
|
||||
import java.nio.charset.StandardCharsets;
|
||||
import java.nio.file.Files;
|
||||
import java.nio.file.Path;
|
||||
import java.util.Scanner;
|
||||
|
||||
import static java.text.MessageFormat.format;
|
||||
|
||||
@@ -18,25 +18,10 @@ import static java.text.MessageFormat.format;
|
||||
public class AssetsManager {
|
||||
|
||||
private static final String ERROR_NOT_FOUND = "Asset \"{0}\" not found";
|
||||
private static final String ERROR_OPEN = "Error open asset \"{0}\": {1}";
|
||||
|
||||
public void saveTo(String resourceName, Path targetPath) {
|
||||
URL resourceUrl = getResourceUrl(resourceName);
|
||||
|
||||
Path saveToPath;
|
||||
if (Files.isDirectory(targetPath)) {
|
||||
saveToPath = targetPath.resolve(resourceName);
|
||||
} else {
|
||||
saveToPath = targetPath;
|
||||
}
|
||||
|
||||
doSaveTo(resourceUrl, saveToPath);
|
||||
}
|
||||
|
||||
public void saveTo(String resourceName, File targetPath) {
|
||||
saveTo(resourceName, targetPath.toPath());
|
||||
}
|
||||
|
||||
public InputStream loadResource(String resourceName, String defaultResourceName, boolean saveDefault) {
|
||||
//region getAsInputStream methods
|
||||
public InputStream getAsInputStream(String resourceName, String defaultResourceName, boolean saveDefault) {
|
||||
Plugin plugin = GhastTools.getPlugin();
|
||||
InputStream inputStream;
|
||||
|
||||
@@ -59,17 +44,76 @@ public class AssetsManager {
|
||||
return inputStream;
|
||||
}
|
||||
|
||||
public InputStream loadResource(String resourceName, String defaultResourceName) {
|
||||
return loadResource(resourceName, defaultResourceName, true);
|
||||
public InputStream getAsInputStream(String resourceName, String defaultResourceName) {
|
||||
return getAsInputStream(resourceName, defaultResourceName, true);
|
||||
}
|
||||
|
||||
public InputStream loadResource(String resourceName, boolean saveDefault) {
|
||||
return loadResource(resourceName, resourceName, saveDefault);
|
||||
public InputStream getAsInputStream(String resourceName, boolean saveDefault) {
|
||||
return getAsInputStream(resourceName, resourceName, saveDefault);
|
||||
}
|
||||
|
||||
public InputStream loadResource(String resourceName) {
|
||||
return loadResource(resourceName, resourceName, true);
|
||||
public InputStream getAsInputStream(String resourceName) {
|
||||
return getAsInputStream(resourceName, resourceName, true);
|
||||
}
|
||||
//endregion
|
||||
|
||||
//region getAsReader methods
|
||||
public Reader getAsReader(String resourceName, String defaultResourceName, boolean saveDefault) {
|
||||
return new InputStreamReader(getAsInputStream(resourceName, defaultResourceName, saveDefault));
|
||||
}
|
||||
|
||||
public Reader getAsReader(String resourceName, String defaultResourceName) {
|
||||
return new InputStreamReader(getAsInputStream(resourceName, defaultResourceName, true));
|
||||
}
|
||||
|
||||
public Reader getAsReader(String resourceName, boolean saveDefault) {
|
||||
return new InputStreamReader(getAsInputStream(resourceName, resourceName, saveDefault));
|
||||
}
|
||||
|
||||
public Reader getAsReader(String resourceName) {
|
||||
return new InputStreamReader(getAsInputStream(resourceName, resourceName, true));
|
||||
}
|
||||
//endregion
|
||||
|
||||
//region getAsString methods
|
||||
public String getAsString(String resourceName, String defaultResourceName, Charset charset, boolean saveDefault) {
|
||||
try (InputStream inputStream = getAsInputStream(resourceName, defaultResourceName, saveDefault);
|
||||
Scanner scanner = new Scanner(inputStream, charset.name()).useDelimiter("\\A")) {
|
||||
|
||||
return scanner.next();
|
||||
} catch (IOException e) {
|
||||
throw new AssetsException(format(ERROR_OPEN, resourceName, e.getMessage()), e);
|
||||
}
|
||||
}
|
||||
|
||||
public String getAsString(String resourceName, String defaultResourceName, Charset charset) {
|
||||
return getAsString(resourceName, defaultResourceName, charset, true);
|
||||
}
|
||||
|
||||
public String getAsString(String resourceName, String defaultResourceName, boolean saveDefault) {
|
||||
return getAsString(resourceName, defaultResourceName, StandardCharsets.UTF_8, saveDefault);
|
||||
}
|
||||
|
||||
public String getAsString(String resourceName, String defaultResourceName) {
|
||||
return getAsString(resourceName, defaultResourceName, StandardCharsets.UTF_8, true);
|
||||
}
|
||||
|
||||
public String getAsString(String resourceName, Charset charset, boolean saveDefault) {
|
||||
return getAsString(resourceName, resourceName, charset, saveDefault);
|
||||
}
|
||||
|
||||
public String getAsString(String resourceName, Charset charset) {
|
||||
return getAsString(resourceName, resourceName, charset, true);
|
||||
}
|
||||
|
||||
public String getAsString(String resourceName, boolean saveDefault) {
|
||||
return getAsString(resourceName, resourceName, StandardCharsets.UTF_8, saveDefault);
|
||||
}
|
||||
|
||||
public String getAsString(String resourceName) {
|
||||
return getAsString(resourceName, resourceName, StandardCharsets.UTF_8, true);
|
||||
}
|
||||
//endregion
|
||||
|
||||
private URL getResourceUrl(String resourceName) {
|
||||
URL resourceUrl = AssetsManager.class.getClassLoader().getResource(resourceName);
|
||||
@@ -81,6 +125,9 @@ public class AssetsManager {
|
||||
}
|
||||
|
||||
private void doSaveTo(URL resourceUrl, Path saveToPath) {
|
||||
try {
|
||||
Files.createDirectories(saveToPath.getParent());
|
||||
|
||||
try (InputStream inputStream = resourceUrl.openStream();
|
||||
OutputStream outputStream = Files.newOutputStream(saveToPath)) {
|
||||
|
||||
@@ -89,6 +136,8 @@ public class AssetsManager {
|
||||
while ((count = inputStream.read(buffer)) != -1) {
|
||||
outputStream.write(buffer, 0, count);
|
||||
}
|
||||
outputStream.flush();
|
||||
}
|
||||
} catch (IOException e) {
|
||||
throw new AssetsException(format("Error save asset \"{0}\" to \"{1}\": {2}",
|
||||
resourceUrl, saveToPath, e.getMessage()), e);
|
||||
@@ -99,7 +148,7 @@ public class AssetsManager {
|
||||
try {
|
||||
return Files.newInputStream(pathToResource);
|
||||
} catch (IOException e) {
|
||||
throw new AssetsException(format("Error open asset \"{0}\": {1}", pathToResource, e.getMessage()), e);
|
||||
throw new AssetsException(format(ERROR_OPEN, pathToResource, e.getMessage()), e);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -107,7 +156,7 @@ public class AssetsManager {
|
||||
try {
|
||||
return resourceUrl.openStream();
|
||||
} catch (IOException e) {
|
||||
throw new AssetsException(format("Error open asset \"{0}\": {1}", resourceUrl, e.getMessage()), e);
|
||||
throw new AssetsException(format(ERROR_OPEN, resourceUrl, e.getMessage()), e);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
55
src/main/java/ghast/EventContext.java
Normal file
55
src/main/java/ghast/EventContext.java
Normal file
@@ -0,0 +1,55 @@
|
||||
package ghast;
|
||||
|
||||
import lombok.AccessLevel;
|
||||
import lombok.NoArgsConstructor;
|
||||
import org.bukkit.Bukkit;
|
||||
import org.bukkit.event.Event;
|
||||
import org.bukkit.event.EventPriority;
|
||||
import org.bukkit.event.Listener;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import java.util.function.BooleanSupplier;
|
||||
import java.util.function.Consumer;
|
||||
|
||||
@NoArgsConstructor(access = AccessLevel.PRIVATE)
|
||||
@SuppressWarnings("unused")
|
||||
public class EventContext implements Listener {
|
||||
|
||||
private static final BooleanSupplier EMPTY_FILTER = () -> true;
|
||||
|
||||
private final Map<Class<? extends Event>, Consumer<?>> eventMap = new HashMap<>();
|
||||
private BooleanSupplier filter = EMPTY_FILTER;
|
||||
|
||||
public EventContext filter(BooleanSupplier filter) {
|
||||
this.filter = (filter != null ? filter : EMPTY_FILTER);
|
||||
return this;
|
||||
}
|
||||
|
||||
public <T extends Event> EventContext onEvent(Class<T> eventType, EventPriority eventPriority, Consumer<T> consumer) {
|
||||
if (consumer == null) {
|
||||
eventMap.remove(eventType);
|
||||
} else {
|
||||
eventMap.put(eventType, consumer);
|
||||
Bukkit.getPluginManager().registerEvent(eventType, this, eventPriority,
|
||||
this::eventExecute, GhastTools.getPlugin());
|
||||
}
|
||||
return this;
|
||||
}
|
||||
|
||||
public <T extends Event> EventContext onEvent(Class<T> eventType, Consumer<T> consumer) {
|
||||
return onEvent(eventType, EventPriority.NORMAL, consumer);
|
||||
}
|
||||
|
||||
@SuppressWarnings({ "unchecked", "rawtypes" })
|
||||
private void eventExecute(Listener listener, Event event) {
|
||||
Consumer consumer = eventMap.get(event.getClass());
|
||||
if (consumer != null && filter.getAsBoolean()) {
|
||||
consumer.accept(event);
|
||||
}
|
||||
}
|
||||
|
||||
public static EventContext create() {
|
||||
return new EventContext();
|
||||
}
|
||||
}
|
||||
@@ -1,66 +0,0 @@
|
||||
package ghast;
|
||||
|
||||
import lombok.AccessLevel;
|
||||
import lombok.Getter;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.Setter;
|
||||
import lombok.experimental.UtilityClass;
|
||||
import org.bukkit.Bukkit;
|
||||
import org.bukkit.event.Event;
|
||||
import org.bukkit.event.EventPriority;
|
||||
import org.bukkit.event.Listener;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import java.util.function.BooleanSupplier;
|
||||
import java.util.function.Consumer;
|
||||
|
||||
@UtilityClass
|
||||
@SuppressWarnings("unused")
|
||||
public class EventManager {
|
||||
|
||||
public Builder createContext() {
|
||||
return new Builder();
|
||||
}
|
||||
|
||||
@RequiredArgsConstructor(access = AccessLevel.PRIVATE)
|
||||
public static class Builder {
|
||||
|
||||
private static final BooleanSupplier EMPTY_FILTER = () -> true;
|
||||
|
||||
private final EventContext eventContext = new EventContext();
|
||||
|
||||
public Builder filter(BooleanSupplier filter) {
|
||||
eventContext.setFilter(filter != null ? filter : EMPTY_FILTER);
|
||||
return this;
|
||||
}
|
||||
|
||||
public <T extends Event> Builder onEvent(Class<T> eventType, EventPriority eventPriority, Consumer<T> consumer) {
|
||||
eventContext.getEventMap().put(eventType, consumer);
|
||||
Bukkit.getPluginManager().registerEvent(eventType, eventContext, eventPriority,
|
||||
eventContext::eventExecute, GhastTools.getPlugin());
|
||||
return this;
|
||||
}
|
||||
|
||||
public <T extends Event> Builder onEvent(Class<T> eventType, Consumer<T> consumer) {
|
||||
return onEvent(eventType, EventPriority.NORMAL, consumer);
|
||||
}
|
||||
}
|
||||
|
||||
@RequiredArgsConstructor(access = AccessLevel.PRIVATE)
|
||||
@Getter(AccessLevel.PRIVATE)
|
||||
@Setter(AccessLevel.PRIVATE)
|
||||
private static class EventContext implements Listener {
|
||||
|
||||
private final Map<Class<? extends Event>, Consumer<?>> eventMap = new HashMap<>();
|
||||
private BooleanSupplier filter;
|
||||
|
||||
@SuppressWarnings({ "unchecked", "rawtypes" })
|
||||
private void eventExecute(Listener listener, Event event) {
|
||||
Consumer consumer = eventMap.get(event.getClass());
|
||||
if (consumer != null && filter.getAsBoolean()) {
|
||||
consumer.accept(event);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -5,8 +5,7 @@ import org.bukkit.configuration.file.YamlConfiguration;
|
||||
import org.bukkit.plugin.Plugin;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
import java.io.InputStreamReader;
|
||||
import java.io.Reader;
|
||||
import java.lang.ref.WeakReference;
|
||||
|
||||
@UtilityClass
|
||||
@@ -30,8 +29,8 @@ public class GhastTools {
|
||||
getPlugin().saveDefaultConfig();
|
||||
}
|
||||
|
||||
try (InputStream inputStream = AssetsManager.loadResource("config.yml", saveDefault)) {
|
||||
return YamlConfiguration.loadConfiguration(new InputStreamReader(inputStream));
|
||||
try (Reader reader = AssetsManager.getAsReader("config.yml", saveDefault)) {
|
||||
return YamlConfiguration.loadConfiguration(reader);
|
||||
} catch (IOException e) {
|
||||
throw new RuntimeException("Error load config: " + e.getMessage(), e);
|
||||
}
|
||||
|
||||
76
src/main/java/ghast/XLog.java
Normal file
76
src/main/java/ghast/XLog.java
Normal file
@@ -0,0 +1,76 @@
|
||||
package ghast;
|
||||
|
||||
import lombok.experimental.UtilityClass;
|
||||
|
||||
import java.util.logging.Level;
|
||||
|
||||
import static java.text.MessageFormat.format;
|
||||
|
||||
@UtilityClass
|
||||
public class XLog {
|
||||
|
||||
//region Debug
|
||||
public void debug(String pattern, Object... objects) {
|
||||
if (objects.length > 1 && objects[objects.length - 1] instanceof Throwable) {
|
||||
Throwable throwable = (Throwable) objects[objects.length - 1];
|
||||
Object[] values = new Object[objects.length - 1];
|
||||
System.arraycopy(objects, 0, values, 0, values.length);
|
||||
|
||||
debug(format(pattern, values), throwable);
|
||||
} else {
|
||||
debug(format(pattern, objects));
|
||||
}
|
||||
}
|
||||
|
||||
public void debug(String message, Throwable throwable) {
|
||||
GhastTools.getPlugin().getLogger().log(Level.FINE, message, throwable);
|
||||
}
|
||||
|
||||
public void debug(String message) {
|
||||
GhastTools.getPlugin().getLogger().fine(message);
|
||||
}
|
||||
//endregion
|
||||
|
||||
//region Info
|
||||
public void info(String pattern, Object... objects) {
|
||||
info(format(pattern, objects));
|
||||
}
|
||||
|
||||
public void info(String message) {
|
||||
GhastTools.getPlugin().getLogger().info(message);
|
||||
}
|
||||
//endregion
|
||||
|
||||
//region Warning
|
||||
public void warn(String pattern, Object... objects) {
|
||||
warn(format(pattern, objects));
|
||||
}
|
||||
|
||||
public void warn(String message) {
|
||||
GhastTools.getPlugin().getLogger().warning(message);
|
||||
}
|
||||
//endregion
|
||||
|
||||
//region Error
|
||||
public void error(String pattern, Object... objects) {
|
||||
if (objects.length > 1 && objects[objects.length - 1] instanceof Throwable) {
|
||||
Throwable throwable = (Throwable) objects[objects.length - 1];
|
||||
Object[] values = new Object[objects.length - 1];
|
||||
System.arraycopy(objects, 0, values, 0, values.length);
|
||||
|
||||
error(format(pattern, values), throwable);
|
||||
} else {
|
||||
error(format(pattern, objects));
|
||||
}
|
||||
}
|
||||
|
||||
public void error(String message) {
|
||||
GhastTools.getPlugin().getLogger().severe(message);
|
||||
}
|
||||
|
||||
public void error(String message, Throwable throwable) {
|
||||
GhastTools.getPlugin().getLogger().log(Level.SEVERE, message, throwable);
|
||||
}
|
||||
//endregion
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user