feat: 订阅更新为tencent

Signed-off-by: MiaoWoo <admin@yumc.pw>
merge/16/MERGE
MiaoWoo 2019-10-24 17:20:04 +08:00
parent 857a903336
commit 300dc0d607
4 changed files with 741 additions and 732 deletions

View File

@ -4,7 +4,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>pw.yumc</groupId>
<artifactId>YumCore</artifactId>
<version>1.8.8</version>
<version>1.8.9</version>
<build>
<finalName>${project.artifactId}</finalName>
<plugins>

View File

@ -25,10 +25,10 @@ import pw.yumc.YumCore.commands.exception.ParseException;
* @since 2016105 4:02:04
*/
public class CommandParse {
private static Map<Class, Class> allparses = new HashMap<>();
private static Map<Class, Class> allParse = new HashMap<>();
private static Map<String, Class> primitiveMap = new HashMap<>();
private boolean isMain;
private List<Parse> parses = new LinkedList<>();
private List<BaseParse> pars = new LinkedList<>();
static {
register(File.class, FileParse.class);
@ -44,7 +44,7 @@ public class CommandParse {
primitiveMap.put("double", Double.class);
}
public CommandParse(Class[] classes, Annotation[][] annons, boolean isMain) {
private CommandParse(Class[] classes, Annotation[][] annons, boolean isMain) {
this.isMain = isMain;
// 第一个参数实现了CommandSender忽略
for (int i = 1; i < classes.length; i++) {
@ -54,22 +54,22 @@ public class CommandParse {
clazz = primitiveMap.get(clazz.getName());
}
Annotation[] annotations = annons[i];
Parse parse = null;
if (allparses.containsKey(clazz)) {
BaseParse baseParse = null;
if (allParse.containsKey(clazz)) {
try {
parse = (Parse) allparses.get(clazz).newInstance();
baseParse = (BaseParse) allParse.get(clazz).newInstance();
} catch (InstantiationException | IllegalAccessException | NullPointerException ignored) {
}
} else {
try {
parse = new ValueOfParse(clazz, clazz.getDeclaredMethod("valueOf", String.class));
baseParse = new ValueOfParse(clazz, clazz.getDeclaredMethod("valueOf", String.class));
} catch (NoSuchMethodException ignored) {
}
}
if (parse == null) { throw new ParseException(String.format("存在无法解析的参数类型 %s", clazz.getName())); }
this.parses.add(parse.parseAnnotation(annotations).handleAttrs());
if (baseParse == null) { throw new ParseException(String.format("存在无法解析的参数类型 %s", clazz.getName())); }
this.pars.add(baseParse.parseAnnotation(annotations).handleAttrs());
}
Log.d("命令解析器 %s", Log.getSimpleNames(parses.toArray()));
Log.d("命令解析器 %s", Log.getSimpleNames(pars.toArray()));
}
public static CommandParse get(Method method) {
@ -81,34 +81,32 @@ public class CommandParse {
*
* @param arr
*
* @param split
*
* @return
*/
public static String join(Object[] arr, String split) {
private static String join(Object[] arr) {
StringBuilder str = new StringBuilder();
for (Object s : arr) {
str.append(s.toString());
str.append(split);
str.append(" ");
}
return str.length() > split.length() ? str.toString().substring(0, str.length() - split.length()) : str.toString();
return str.length() > " ".length() ? str.toString().substring(0, str.length() - " ".length()) : str.toString();
}
public static void register(Class clazz, Class parse) {
allparses.put(clazz, parse);
allParse.put(clazz, parse);
}
public Object[] parse(CommandSender sender, String label, String[] args) {
List<Object> pobjs = new LinkedList<>();
pobjs.add(sender);
for (int i = 0; i < parses.size(); i++) {
for (int i = 0; i < pars.size(); i++) {
try {
Parse p = parses.get(i);
BaseParse p = pars.get(i);
String param = i < args.length ? args[i] : null;
param = param == null ? p.getDefault(sender) : param;
// 参数大于解析器 并且为最后一个参数
if (i + 1 == parses.size() && args.length >= parses.size()) {
param = join(Arrays.copyOfRange(args, i, args.length), " ");
if (i + 1 == pars.size() && args.length >= pars.size()) {
param = join(Arrays.copyOfRange(args, i, args.length));
}
// 尝试让解析器解析Null参数
try { pobjs.add(p.parse(sender, param)); } catch (NullPointerException npe) { pobjs.add(null); }
@ -121,7 +119,7 @@ public class CommandParse {
return pobjs.toArray();
}
public static abstract class Parse<RT> {
public static abstract class BaseParse<RT> {
protected Map<String, String> attrs = new HashMap<>();
protected String def;
protected int max = Integer.MAX_VALUE;
@ -131,9 +129,20 @@ public class CommandParse {
return def;
}
/**
*
*
* @param sender
*
* @param arg
*
* @return
* @throws ParseException
*
*/
public abstract RT parse(CommandSender sender, String arg) throws ParseException;
public Parse<RT> parseAnnotation(Annotation[] annotations) {
public BaseParse<RT> parseAnnotation(Annotation[] annotations) {
for (Annotation annotation : annotations) {
if (annotation.annotationType() == Option.class) {
String value = ((Option) annotation).value();
@ -153,7 +162,7 @@ public class CommandParse {
return this;
}
public Parse<RT> handleAttrs() {
public BaseParse<RT> handleAttrs() {
if (attrs.containsKey("def")) {
def = String.valueOf(attrs.get("def"));
}
@ -179,7 +188,7 @@ public class CommandParse {
}
}
public static class ValueOfParse extends Parse<Object> {
public static class ValueOfParse extends BaseParse<Object> {
private Class eType;
private Enum[] eList;
private Method method;
@ -218,7 +227,7 @@ public class CommandParse {
}
}
public static class FileParse extends Parse<File> {
public static class FileParse extends BaseParse<File> {
@Override
public File parse(CommandSender sender, String arg) throws ParseException {
File file = new File(arg);
@ -227,7 +236,7 @@ public class CommandParse {
}
}
public static class PlayerParse extends Parse<Player> {
public static class PlayerParse extends BaseParse<Player> {
boolean sender = false;
boolean check = false;
@ -239,7 +248,7 @@ public class CommandParse {
}
@Override
public Parse<Player> handleAttrs() {
public BaseParse<Player> handleAttrs() {
super.handleAttrs();
sender = attrs.containsKey("sender");
check = attrs.containsKey("check");
@ -252,7 +261,7 @@ public class CommandParse {
}
}
public static class StringParse extends Parse<String> {
public static class StringParse extends BaseParse<String> {
List<String> options;
@Override
@ -263,7 +272,7 @@ public class CommandParse {
}
@Override
public Parse<String> handleAttrs() {
public BaseParse<String> handleAttrs() {
super.handleAttrs();
if (attrs.containsKey("option")) {
options = Arrays.asList(attrs.get("option").split(","));

View File

@ -1,305 +1,306 @@
/*
* Copyright 2011-2015 . All rights reserved.
*/
package pw.yumc.YumCore.statistic;
import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.net.URL;
import java.net.URLConnection;
import java.net.URLEncoder;
import java.nio.charset.Charset;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.Map;
import java.util.UUID;
import org.bukkit.Bukkit;
import org.bukkit.configuration.file.YamlConfiguration;
import org.bukkit.entity.Player;
import org.bukkit.plugin.Plugin;
import org.bukkit.plugin.PluginDescriptionFile;
import org.bukkit.plugin.java.JavaPlugin;
import org.bukkit.scheduler.BukkitTask;
import org.json.simple.JSONObject;
import org.json.simple.JSONValue;
/**
* Yum
*
* @since 20151214 1:36:42
* @author
*/
public class Statistics {
/**
*
*/
private static int REVISION = 10;
/**
*
*/
private static File configfile = new File(String.format("plugins%1$sPluginHelper%1$sconfig.yml", File.separatorChar));
/**
* UTF-8
*/
private static Charset UTF_8 = Charset.forName("UTF-8");
/**
* getOnlinePlayers
*/
private static Method getOnlinePlayers;
/**
*
*/
private static Plugin plugin;
static {
try {
getOnlinePlayers = Bukkit.class.getDeclaredMethod("getOnlinePlayers");
if (getOnlinePlayers.getReturnType() != Player[].class) {
for (Method method : Bukkit.class.getDeclaredMethods()) {
if (method.getReturnType() == Player[].class && method.getName().endsWith("getOnlinePlayers")) {
getOnlinePlayers = method;
}
}
}
Object pluginClassLoader = Statistics.class.getClassLoader();
Field field = pluginClassLoader.getClass().getDeclaredField("plugin");
field.setAccessible(true);
plugin = (JavaPlugin) field.get(pluginClassLoader);
} catch (NoSuchMethodException | SecurityException | NoSuchFieldException | IllegalArgumentException | IllegalAccessException ignored) {
}
}
/**
*
*/
private YamlConfiguration config;
/**
*
*/
private boolean debug;
/**
*
*/
private String guid;
/**
* 线
*/
private volatile BukkitTask task = null;
/**
* 线
*/
private volatile StatisticsTimer timer = null;
/**
* 使
*/
public Statistics() {
try {
if (!configfile.exists()) {
configfile.getParentFile().mkdirs();
configfile.createNewFile();
}
config = YamlConfiguration.loadConfiguration(configfile);
initFile(config);
} catch (IOException ignored) {
}
this.guid = config.getString("guid");
this.debug = config.getBoolean("d", false);
start();
}
/**
* URL POST
*
* @param url
* URL
* @param param
*
* @return
* @throws IOException
* IO
*/
public static String postData(String url, String param) throws IOException {
PrintWriter out;
String result = "";
URL realUrl = new URL(url);
// 打开和URL之间的连接
URLConnection conn = realUrl.openConnection();
// 设置通用的请求属性
conn.setRequestProperty("Accept", "*/*");
conn.setRequestProperty("Connection", "Keep-Alive");
conn.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/47.0.2526.106 Safari/537.36");
// 设置超时时间 10秒
conn.setReadTimeout(10000);
// 发送POST请求必须设置如下两行
conn.setDoOutput(true);
conn.setDoInput(true);
// 获取URLConnection对象对应的输出流
out = new PrintWriter(conn.getOutputStream());
// 发送请求参数
out.write(param);
// flush输出流的缓冲
out.flush();
String response;
BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream(), UTF_8));
while ((response = reader.readLine()) != null) {
result += response;
}
reader.close();
out.close();
return result;
}
/**
*
*
* @param config
*
* @throws IOException
* IO
*/
private static void initFile(YamlConfiguration config) throws IOException {
if (config.getString("guid") == null) {
config.options().header("YUMC数据中心 http://www.yumc.pw 收集的数据仅用于统计插件使用情况").copyDefaults(true);
config.set("guid", UUID.randomUUID().toString());
config.set("d", false);
config.save(configfile);
}
if (!config.contains("YumAccount")) {
config.set("YumAccount.username", "Username Not Set");
config.set("YumAccount.password", "Password NotSet");
config.save(configfile);
}
if (!config.contains("TellrawManualHandle")) {
config.set("TellrawManualHandle", false);
config.save(configfile);
}
}
/**
*
*
* @param msg
*
*/
public void print(String msg) {
if (debug) {
System.out.println("[Statistics] " + msg);
}
}
/**
*
*
* @return .
*/
public boolean start() {
if (task != null || !plugin.isEnabled()) { return true; }
timer = new StatisticsTimer();
// 开启TPS统计线程
Bukkit.getServer().getScheduler().scheduleSyncRepeatingTask(plugin, timer, 0, 20);
// 开启发送数据线程
task = plugin.getServer().getScheduler().runTaskTimerAsynchronously(plugin, () -> {
try {
postPlugin();
} catch (Throwable e) {
if (debug) {
e.printStackTrace();
}
}
}, 50, 25 * 1200);
return true;
}
/**
* 线
*
* @return 线
*/
private int getOnlinePlayerNumber() {
try {
return ((Player[]) getOnlinePlayers.invoke(Bukkit.getServer())).length;
} catch (Exception ex) {
return Bukkit.getOnlinePlayers().size();
}
}
/**
*
*/
private void postPlugin() throws IOException {
// 服务器数据获取
PluginDescriptionFile description = plugin.getDescription();
String pluginname = description.getName();
String tmposarch = System.getProperty("os.arch");
Map<String, Object> data = new HashMap<>();
data.put("guid", guid);
data.put("server_version", Bukkit.getVersion());
data.put("server_port", Bukkit.getServer().getPort());
data.put("server_tps", timer.getAverageTPS());
data.put("plugin_version", description.getVersion());
data.put("players_online", getOnlinePlayerNumber());
data.put("os_name", System.getProperty("os.name"));
data.put("os_arch", tmposarch.equalsIgnoreCase("amd64") ? "x86_64" : tmposarch);
data.put("os_version", System.getProperty("os.version"));
data.put("os_usemem", (Runtime.getRuntime().totalMemory() - Runtime.getRuntime().freeMemory()) / 1024 / 1024);
data.put("os_cores", Runtime.getRuntime().availableProcessors());
data.put("auth_mode", Bukkit.getServer().getOnlineMode() ? 1 : 0);
data.put("java_version", System.getProperty("java.version"));
String jsondata = "Info=" + JSONValue.toJSONString(data);
String url = String.format("http://api.yumc.pw/I/P/S/V/%s/P/%s", REVISION, URLEncoder.encode(pluginname, "UTF-8"));
print("Plugin: " + pluginname + " Send Data To CityCraft Data Center");
print("Address: " + url);
print("Data: " + jsondata);
// 发送数据
JSONObject result = (JSONObject) JSONValue.parse(postData(url, jsondata));
print("Plugin: " + pluginname + " Recover Data From CityCraft Data Center: " + result.get("info"));
}
public class StatisticsTimer implements Runnable {
private LinkedList<Double> history = new LinkedList<>();
private transient long lastPoll = System.nanoTime();
/**
* @return TPS
*/
public double getAverageTPS() {
double avg = 0.0D;
for (Double f : history) {
avg += f;
}
return avg / history.size();
}
@Override
public void run() {
long startTime = System.nanoTime();
long timeSpent = (startTime - lastPoll) / 1000;
if (history.size() > 10) {
history.removeFirst();
}
double ttps = 2.0E7D / (timeSpent == 0 ? 1 : timeSpent);
if (ttps <= 21.0D) {
history.add(ttps);
}
lastPoll = startTime;
}
}
/*
* Copyright 2011-2015 . All rights reserved.
*/
package pw.yumc.YumCore.statistic;
import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.net.URL;
import java.net.URLConnection;
import java.net.URLEncoder;
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.Map;
import java.util.UUID;
import org.bukkit.Bukkit;
import org.bukkit.configuration.file.YamlConfiguration;
import org.bukkit.entity.Player;
import org.bukkit.plugin.Plugin;
import org.bukkit.plugin.PluginDescriptionFile;
import org.bukkit.plugin.java.JavaPlugin;
import org.bukkit.scheduler.BukkitTask;
import org.json.simple.JSONObject;
import org.json.simple.JSONValue;
/**
* Yum
*
* @since 20151214 1:36:42
* @author
*/
public class Statistics {
/**
*
*/
private static int REVISION = 10;
/**
*
*/
private static File configfile = new File(String.format("plugins%1$sPluginHelper%1$sconfig.yml", File.separatorChar));
/**
* UTF-8
*/
private static Charset UTF_8 = StandardCharsets.UTF_8;
/**
* getOnlinePlayers
*/
private static Method getOnlinePlayers;
/**
*
*/
private static Plugin plugin;
static {
try {
getOnlinePlayers = Bukkit.class.getDeclaredMethod("getOnlinePlayers");
if (getOnlinePlayers.getReturnType() != Player[].class) {
for (Method method : Bukkit.class.getDeclaredMethods()) {
if (method.getReturnType() == Player[].class && method.getName().endsWith("getOnlinePlayers")) {
getOnlinePlayers = method;
}
}
}
Object pluginClassLoader = Statistics.class.getClassLoader();
Field field = pluginClassLoader.getClass().getDeclaredField("plugin");
field.setAccessible(true);
plugin = (JavaPlugin) field.get(pluginClassLoader);
} catch (NoSuchMethodException | SecurityException | NoSuchFieldException | IllegalArgumentException | IllegalAccessException ignored) {
}
}
/**
*
*/
private YamlConfiguration config;
/**
*
*/
private boolean debug;
/**
*
*/
private String guid;
/**
* 线
*/
private volatile BukkitTask task = null;
/**
* 线
*/
private volatile StatisticsTimer timer = null;
/**
* 使
*/
public Statistics() {
try {
if (!configfile.exists()) {
configfile.getParentFile().mkdirs();
configfile.createNewFile();
}
config = YamlConfiguration.loadConfiguration(configfile);
initFile(config);
} catch (IOException ignored) {
}
this.guid = config.getString("guid");
this.debug = config.getBoolean("d", false);
start();
}
/**
* URL POST
*
* @param url
* URL
* @param param
*
* @return
* @throws IOException
* IO
*/
public static String postData(String url, String param) throws IOException {
PrintWriter out;
String result = "";
URL realUrl = new URL(url);
// 打开和URL之间的连接
URLConnection conn = realUrl.openConnection();
// 设置通用的请求属性
conn.setRequestProperty("Accept", "*/*");
conn.setRequestProperty("Connection", "Keep-Alive");
conn.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/47.0.2526.106 Safari/537.36");
// 设置超时时间 10秒
conn.setReadTimeout(10000);
// 发送POST请求必须设置如下两行
conn.setDoOutput(true);
conn.setDoInput(true);
// 获取URLConnection对象对应的输出流
out = new PrintWriter(conn.getOutputStream());
// 发送请求参数
out.write(param);
// flush输出流的缓冲
out.flush();
String response;
BufferedReader reader = new BufferedReader(new InputStreamReader(conn.getInputStream(), UTF_8));
while ((response = reader.readLine()) != null) {
result += response;
}
reader.close();
out.close();
return result;
}
/**
*
*
* @param config
*
* @throws IOException
* IO
*/
private static void initFile(YamlConfiguration config) throws IOException {
if (config.getString("guid") == null) {
config.options().header("YUMC数据中心 http://www.yumc.pw 收集的数据仅用于统计插件使用情况").copyDefaults(true);
config.set("guid", UUID.randomUUID().toString());
config.set("d", false);
config.save(configfile);
}
if (!config.contains("YumAccount")) {
config.set("YumAccount.username", "Username Not Set");
config.set("YumAccount.password", "Password NotSet");
config.save(configfile);
}
if (!config.contains("TellrawManualHandle")) {
config.set("TellrawManualHandle", false);
config.save(configfile);
}
}
/**
*
*
* @param msg
*
*/
public void print(String msg) {
if (debug) {
System.out.println("[Statistics] " + msg);
}
}
/**
*
*
* @return .
*/
public boolean start() {
if (task != null || !plugin.isEnabled()) { return true; }
timer = new StatisticsTimer();
// 开启TPS统计线程
Bukkit.getServer().getScheduler().scheduleSyncRepeatingTask(plugin, timer, 0, 20);
// 开启发送数据线程
task = plugin.getServer().getScheduler().runTaskTimerAsynchronously(plugin, () -> {
try {
postPlugin();
} catch (Throwable e) {
if (debug) {
e.printStackTrace();
}
}
}, 50, 25 * 1200);
return true;
}
/**
* 线
*
* @return 线
*/
private int getOnlinePlayerNumber() {
try {
return ((Player[]) getOnlinePlayers.invoke(Bukkit.getServer())).length;
} catch (Exception ex) {
return Bukkit.getOnlinePlayers().size();
}
}
/**
*
*/
private void postPlugin() throws IOException {
// 服务器数据获取
PluginDescriptionFile description = plugin.getDescription();
String pluginname = description.getName();
String tmposarch = System.getProperty("os.arch");
Map<String, Object> data = new HashMap<>();
data.put("guid", guid);
data.put("server_version", Bukkit.getVersion());
data.put("server_port", Bukkit.getServer().getPort());
data.put("server_tps", timer.getAverageTPS());
data.put("plugin_version", description.getVersion());
data.put("players_online", getOnlinePlayerNumber());
data.put("os_name", System.getProperty("os.name"));
data.put("os_arch", "amd64".equalsIgnoreCase(tmposarch) ? "x86_64" : tmposarch);
data.put("os_version", System.getProperty("os.version"));
data.put("os_usemem", (Runtime.getRuntime().totalMemory() - Runtime.getRuntime().freeMemory()) / 1024 / 1024);
data.put("os_cores", Runtime.getRuntime().availableProcessors());
data.put("auth_mode", Bukkit.getServer().getOnlineMode() ? 1 : 0);
data.put("java_version", System.getProperty("java.version"));
String jsondata = "Info=" + JSONValue.toJSONString(data);
String url = String.format("http://api.yumc.pw/I/P/S/V/%s/P/%s", REVISION, URLEncoder.encode(pluginname, "UTF-8"));
print("Plugin: " + pluginname + " Send Data To CityCraft Data Center");
print("Address: " + url);
print("Data: " + jsondata);
// 发送数据
JSONObject result = (JSONObject) JSONValue.parse(postData(url, jsondata));
print("Plugin: " + pluginname + " Recover Data From CityCraft Data Center: " + result.get("info"));
}
public class StatisticsTimer implements Runnable {
private LinkedList<Double> history = new LinkedList<>();
private transient long lastPoll = System.nanoTime();
/**
* @return TPS
*/
public double getAverageTPS() {
double avg = 0.0D;
for (Double f : history) {
avg += f;
}
return avg / history.size();
}
@Override
public void run() {
long startTime = System.nanoTime();
long timeSpent = (startTime - lastPoll) / 1000;
if (history.size() > 10) {
history.removeFirst();
}
double ttps = 2.0E7D / (timeSpent == 0 ? 1 : timeSpent);
if (ttps <= 21.0D) {
history.add(ttps);
}
lastPoll = startTime;
}
}
}

View File

@ -1,398 +1,397 @@
package pw.yumc.YumCore.update;
import java.io.File;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLClassLoader;
import java.net.URLDecoder;
import java.nio.file.Files;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import org.bukkit.Bukkit;
import org.bukkit.ChatColor;
import org.bukkit.command.CommandSender;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.player.PlayerJoinEvent;
import org.bukkit.plugin.Plugin;
import org.bukkit.plugin.PluginDescriptionFile;
import org.bukkit.plugin.java.JavaPlugin;
import org.w3c.dom.Document;
import org.xml.sax.SAXException;
import pw.yumc.YumCore.bukkit.Log;
import pw.yumc.YumCore.bukkit.P;
import pw.yumc.YumCore.tellraw.Tellraw;
import pw.yumc.YumCore.text.Encrypt;
/**
*
*
* @author
* @since 201683 11:20:21
*/
public class SubscribeTask implements Runnable, Listener {
/**
*
*/
private static JavaPlugin instance = P.instance;
/**
*
*/
private static int interval = 25;
private UpdateType updateType;
/**
*
*/
private UpdateFile updateFile;
/**
*
*/
private VersionInfo versionInfo;
/**
*
*/
public SubscribeTask() {
this(UpdateType.DIRECT);
}
/**
*
*
* @param type
* Maven
*/
public SubscribeTask(UpdateType type) {
this(false, type);
}
/**
*
*
* @param isSecret
*
* @param type
*
*/
public SubscribeTask(boolean isSecret, UpdateType type) {
this("master", isSecret, type);
}
/**
*
*
* @param branch
*
* @param isSecret
*
* @param type
*
*/
public SubscribeTask(String branch, boolean isSecret, UpdateType type) {
Log.d("订阅更新 分支 %s 是否加密 %s 更新类型 %s", branch, isSecret, type.name());
updateFile = new UpdateFile(instance);
versionInfo = new VersionInfo(instance, branch, isSecret);
updateType = type;
if (instance.isEnabled()) {
Bukkit.getPluginManager().registerEvents(this, instance);
Bukkit.getScheduler().runTaskTimerAsynchronously(instance, this, 0, interval * 1200);
}
}
@EventHandler
public void onJoin(PlayerJoinEvent e) {
final Player player = e.getPlayer();
if (player.isOp() && updateFile.isUpdated()) {
Bukkit.getScheduler().runTaskLater(instance, () -> versionInfo.notify(player), 10);
}
}
@Override
public void run() {
update();
}
public void update() {
try {
versionInfo.update();
String result = versionInfo.getNewVersion();
if (result != null) {
if (updateFile.target.exists()) {
try {
PluginDescriptionFile desc = instance.getPluginLoader().getPluginDescription(updateFile.target);
if (!versionInfo.needUpdate(result, desc.getVersion().split("-")[0])) { return; }
updateFile.target.delete();
} catch (Exception e) {
Log.d(e);
}
}
updateFile.update(updateType.getDownloadUrl(instance, result));
Log.d(Encrypt.decode("嘊⚲哀嘖⚶哅嘣⚩咖嗕♧哏嗕⚸咁嘨♢咰嘤♢哒嗚⚵呼嗣♰咊"), instance.getName(), versionInfo.getVersion(), result);
versionInfo.notify(Bukkit.getConsoleSender());
}
} catch (Exception e) {
Log.d(e);
}
}
public enum UpdateType {
/**
*
*/
DIRECT(Encrypt.decode("嘝⚶哐嘥♼咋嗤⚥哅嗣⚻哑嘢⚥咊嘥⚹咋嘟⚱咾嗤♧咍嗙⚵咋嘡⚣哏嘩⚕哑嘘⚥品嘨⚵哂嘪⚮咞嘪⚫哈嘙♱咽嘧⚶哅嘛⚣咿嘩♱哐嘖⚴哃嘚⚶咋嗚♳咀嘨♰哆嘖⚴")),
// "http://ci.yumc.pw/job/%1$s/lastSuccessfulBuild/artifact/target/%1$s.jar";
/**
* Maven
*/
MAVEN(Encrypt.decode("嘝⚶哐嘥♼咋嗤⚥哅嗣⚻哑嘢⚥咊嘥⚹咋嘥⚮哑嘜⚫哊嗤⚴品嘥⚱哏嘞⚶哋嘧⚻咋嘚⚸品嘧⚻哐嘝⚫哊嘜♱咁嗦♦哏嗤♧咎嗙⚵咋嗚♵咀嘨♯咁嗧♦哏嗣⚬咽嘧")),
// "http://ci.yumc.pw/plugin/repository/everything/%1$s/%2$s/%3$s-%2$s.jar";
/**
*
*/
WS(Encrypt.decode("嘝⚶哐嘥♼咋嗤⚥哅嗣⚻哑嘢⚥咊嘥⚹咋嘟⚱咾嗤♧咍嗙⚵咋嘬⚵咋嘩⚣哎嘜⚧哐嗤♧咍嗙⚵咊嘟⚣哎"));
// "http://ci.yumc.pw/job/%1$s/ws/target/%1$s.jar"
String url;
UpdateType(String url) {
this.url = url;
}
public String getDownloadUrl(Plugin instance, String version) {
switch (this) {
case DIRECT:
case WS:
return String.format(url, instance.getName());
case MAVEN:
return String.format(url, instance.getClass().getPackage().getName().replaceAll("\\.", "/"), version, instance.getName());
}
throw new UnsupportedOperationException();
}
}
public static class UpdateFile {
public File parent;
public File target;
public File temp;
private String k = Encrypt.decode("嗶⚷哐嘝⚱哎嘞⚼咽嘩⚫哋嘣");
private String v = Encrypt.decode("嗷⚣哏嘞⚥呼嘖⚰咮嘞⚑哆嘂⚻咪嘉⚏哕嘃⚓咙嗲");
public UpdateFile(Plugin plugin) {
String name = getPluginFile(plugin).getName();
parent = new File(Encrypt.decode("嘥⚮哑嘜⚫哊嘨♱哑嘥⚦咽嘩⚧咋"));
if (!parent.exists()) {
parent.mkdirs();
}
target = new File(parent, name);
temp = new File(parent, name + Encrypt.decode("嗣⚦哋嘬⚰哈嘤⚣哀嘞⚰哃"));
}
public boolean isUpdated() {
return target.exists();
}
/**
*
*
* @param plugin
* -
* @return
*/
public File getPluginFile(Plugin plugin) {
File file = null;
ClassLoader cl = plugin.getClass().getClassLoader();
if ((cl instanceof URLClassLoader)) {
URLClassLoader ucl = (URLClassLoader) cl;
URL url = ucl.getURLs()[0];
try {
file = new File(URLDecoder.decode(url.getFile(), "UTF-8"));
} catch (UnsupportedEncodingException e) {
Log.d(e);
}
}
return file;
}
public void update(String url) throws IOException {
HttpURLConnection conn = (HttpURLConnection) new URL(url).openConnection();
conn.setRequestProperty(k, v);
Files.copy(conn.getInputStream(), temp.toPath());
temp.renameTo(target);
}
}
public static class VersionInfo {
/**
* POM
*/
private String url = Encrypt.decode("嘝⚶哐嘥⚵咖嗤♱咿嘤⚦哅嘣⚩咊嘣⚧哐嗤⚷咋嗪♲咎嗫♶咓嗥♻咎嗤⚲咋嗚⚵咋嘜⚫哐嗤⚴咽嘬♱咁嘨♱哌嘤⚯咊嘭⚯哈");
// private static String url = "https://coding.net/u/502647092/p/%s/git/raw/%s/pom.xml";
/**
* POM
*/
private String pom = Encrypt.decode("嘝⚶哐嘥♼咋嗤⚥哅嗣⚻哑嘢⚥咊嘥⚹咋嘟⚱咾嗤♧哏嗤⚮咽嘨⚶咯嘪⚥咿嘚⚵哏嘛⚷哈嗷⚷哅嘡⚦咋嘖⚴哐嘞⚨咽嘘⚶咋嘥⚱哉嗣⚺哉嘡");
// private static String pom = "http://ci.yumc.pw/job/%s/lastSuccessfulBuild/artifact/pom.xml";
/**
*
*/
private final String name;
/**
*
*/
private final String version;
/**
*
*/
private String info;
/**
* POM
*/
private Document document;
public VersionInfo(Plugin plugin, String branch, boolean isSecret) {
this.name = plugin.getName();
this.version = plugin.getDescription().getVersion().split("-")[0];
this.info = String.format(isSecret ? pom : url, name, branch);
}
/**
* @return
*/
public String getVersion() {
return version;
}
/**
*
*
* @param tag
*
* @param def
*
* @return
*/
public String getPluginInfo(String tag, String def) {
String result = def;
try {
result = document.getElementsByTagName(tag).item(0).getTextContent();
} catch (NullPointerException ignored) {
Log.d("当前插件不存在标签 %s 使用默认值 %s !", tag, def);
} catch (Exception e) {
Log.d(e);
}
return result;
}
/**
*
*
* @return
*/
public String[] getUpdateChanges() {
final String des = getPluginInfo("update.changes", null);
if (des == null) { return new String[]{}; }
String[] temp = ChatColor.translateAlternateColorCodes('&', des).replaceAll("\n", "").replaceAll("\u0009", "").split(";");
List<String> ltemp = new ArrayList<>();
Arrays.stream(temp).forEach(s -> ltemp.add(s.trim()));
return ltemp.toArray(new String[]{});
}
/**
*
*
* @return
*/
public String getUpdateDescription() {
final String des = getPluginInfo("update.description", "无版本描述信息...");
return ChatColor.translateAlternateColorCodes('&', des);
}
/**
*
*
* @return
*/
private String getLastestVersion() {
return getPluginInfo("version", "0.0.0").split("-")[0];
}
/**
*
*
* @param sender
*
*/
public void notify(CommandSender sender) {
Log.sender(sender, "§a插件更新: §b" + name + " §a已更新到最新版本 §bv" + getLastestVersion());
Log.sender(sender, "§e版本简介: §a" + getUpdateDescription());
final String[] changes = getUpdateChanges();
if (changes.length != 0) {
if (sender instanceof Player) {
Tellraw tr = Tellraw.create(Log.getPrefix() + "§b更新记录: ");
tr.then("§d§n鼠标悬浮查看");
tr.tip(changes);
tr.send(sender);
} else {
Log.sender(sender, "§b更新记录:");
Log.sender(sender, changes);
}
}
Log.sender(sender, "§c最新的改动将在重启后生效!");
}
/**
*
*
* @param v1
*
* @param v2
*
* @return
*/
public boolean needUpdate(String v1, String v2) {
String[] va1 = v1.split("\\.");// 注意此处为正则匹配,不能用"."
String[] va2 = v2.split("\\.");
int idx = 0;
int minLength = Math.min(va1.length, va2.length);// 取最小长度值
int diff = 0;
while (idx < minLength && (diff = va1[idx].length() - va2[idx].length()) == 0// 先比较长度
&& (diff = va1[idx].compareTo(va2[idx])) == 0) {// 再比较字符
++idx;
}
// 如果已经分出大小 则直接返回 如果未分出大小 则再比较位数 有子版本的为大
diff = (diff != 0) ? diff : va1.length - va2.length;
return diff > 0;
}
public String getNewVersion() {
try {
String result = getLastestVersion();
if (Log.isDebug() && !Log.isGlobalDebug()) {
Log.console("§4注意: §c当前版本为开发版本 且未开启全局调试 已自动下载最新稳定版!");
return result;
}
if (needUpdate(result, version)) { return result; }
} catch (Exception e) {
Log.d(e);
}
return null;
}
public void update() throws ParserConfigurationException, IOException, SAXException {
document = DocumentBuilderFactory.newInstance().newDocumentBuilder().parse(info);
}
}
}
package pw.yumc.YumCore.update;
import java.io.File;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLClassLoader;
import java.net.URLDecoder;
import java.nio.file.Files;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import org.bukkit.Bukkit;
import org.bukkit.ChatColor;
import org.bukkit.command.CommandSender;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.player.PlayerJoinEvent;
import org.bukkit.plugin.Plugin;
import org.bukkit.plugin.PluginDescriptionFile;
import org.bukkit.plugin.java.JavaPlugin;
import org.w3c.dom.Document;
import org.xml.sax.SAXException;
import pw.yumc.YumCore.bukkit.Log;
import pw.yumc.YumCore.bukkit.P;
import pw.yumc.YumCore.tellraw.Tellraw;
import pw.yumc.YumCore.text.Encrypt;
/**
*
*
* @author
* @since 201683 11:20:21
*/
public class SubscribeTask implements Runnable, Listener {
/**
*
*/
private static JavaPlugin instance = P.instance;
/**
*
*/
private static int interval = 25;
private UpdateType updateType;
/**
*
*/
private UpdateFile updateFile;
/**
*
*/
private VersionInfo versionInfo;
/**
*
*/
public SubscribeTask() {
this(UpdateType.DIRECT);
}
/**
*
*
* @param type
* Maven
*/
public SubscribeTask(UpdateType type) {
this(false, type);
}
/**
*
*
* @param isSecret
*
* @param type
*
*/
public SubscribeTask(boolean isSecret, UpdateType type) {
this("master", isSecret, type);
}
/**
*
*
* @param branch
*
* @param isSecret
*
* @param type
*
*/
public SubscribeTask(String branch, boolean isSecret, UpdateType type) {
Log.d("订阅更新 分支 %s 是否加密 %s 更新类型 %s", branch, isSecret, type.name());
updateFile = new UpdateFile(instance);
versionInfo = new VersionInfo(instance, branch, isSecret);
updateType = type;
if (instance.isEnabled()) {
Bukkit.getPluginManager().registerEvents(this, instance);
Bukkit.getScheduler().runTaskTimerAsynchronously(instance, this, 0, interval * 1200);
}
}
@EventHandler
public void onJoin(PlayerJoinEvent e) {
final Player player = e.getPlayer();
if (player.isOp() && updateFile.isUpdated()) {
Bukkit.getScheduler().runTaskLater(instance, () -> versionInfo.notify(player), 10);
}
}
@Override
public void run() {
update();
}
public void update() {
try {
versionInfo.update();
String result = versionInfo.getNewVersion();
if (result != null) {
if (updateFile.target.exists()) {
try {
PluginDescriptionFile desc = instance.getPluginLoader().getPluginDescription(updateFile.target);
if (!versionInfo.needUpdate(result, desc.getVersion().split("-")[0])) { return; }
updateFile.target.delete();
} catch (Exception e) {
Log.d(e);
}
}
updateFile.update(updateType.getDownloadUrl(instance, result));
Log.d(Encrypt.decode("嘊⚲哀嘖⚶哅嘣⚩咖嗕♧哏嗕⚸咁嘨♢咰嘤♢哒嗚⚵呼嗣♰咊"), instance.getName(), versionInfo.getVersion(), result);
versionInfo.notify(Bukkit.getConsoleSender());
}
} catch (Exception e) {
Log.d(e);
}
}
public enum UpdateType {
/**
*
*/
DIRECT(Encrypt.decode("嘝⚶哐嘥♼咋嗤⚥哅嗣⚻哑嘢⚥咊嘥⚹咋嘟⚱咾嗤♧咍嗙⚵咋嘡⚣哏嘩⚕哑嘘⚥品嘨⚵哂嘪⚮咞嘪⚫哈嘙♱咽嘧⚶哅嘛⚣咿嘩♱哐嘖⚴哃嘚⚶咋嗚♳咀嘨♰哆嘖⚴")),
// "http://ci.yumc.pw/job/%1$s/lastSuccessfulBuild/artifact/target/%1$s.jar";
/**
* Maven
*/
MAVEN(Encrypt.decode("嘝⚶哐嘥♼咋嗤⚥哅嗣⚻哑嘢⚥咊嘥⚹咋嘥⚮哑嘜⚫哊嗤⚴品嘥⚱哏嘞⚶哋嘧⚻咋嘚⚸品嘧⚻哐嘝⚫哊嘜♱咁嗦♦哏嗤♧咎嗙⚵咋嗚♵咀嘨♯咁嗧♦哏嗣⚬咽嘧")),
// "http://ci.yumc.pw/plugin/repository/everything/%1$s/%2$s/%3$s-%2$s.jar";
/**
*
*/
WS(Encrypt.decode("嘝⚶哐嘥♼咋嗤⚥哅嗣⚻哑嘢⚥咊嘥⚹咋嘟⚱咾嗤♧咍嗙⚵咋嘬⚵咋嘩⚣哎嘜⚧哐嗤♧咍嗙⚵咊嘟⚣哎"));
// "http://ci.yumc.pw/job/%1$s/ws/target/%1$s.jar"
String url;
UpdateType(String url) {
this.url = url;
}
public String getDownloadUrl(Plugin instance, String version) {
switch (this) {
case DIRECT:
case WS:
return String.format(url, instance.getName());
case MAVEN:
return String.format(url, instance.getClass().getPackage().getName().replaceAll("\\.", "/"), version, instance.getName());
}
throw new UnsupportedOperationException();
}
}
public static class UpdateFile {
public File parent;
public File target;
public File temp;
private String k = Encrypt.decode("嗶⚷哐嘝⚱哎嘞⚼咽嘩⚫哋嘣");
private String v = Encrypt.decode("嗷⚣哏嘞⚥呼嘖⚰咮嘞⚑哆嘂⚻咪嘉⚏哕嘃⚓咙嗲");
public UpdateFile(Plugin plugin) {
String name = getPluginFile(plugin).getName();
parent = new File(Encrypt.decode("嘥⚮哑嘜⚫哊嘨♱哑嘥⚦咽嘩⚧咋"));
if (!parent.exists()) {
parent.mkdirs();
}
target = new File(parent, name);
temp = new File(parent, name + Encrypt.decode("嗣⚦哋嘬⚰哈嘤⚣哀嘞⚰哃"));
}
public boolean isUpdated() {
return target.exists();
}
/**
*
*
* @param plugin
* -
* @return
*/
public File getPluginFile(Plugin plugin) {
File file = null;
ClassLoader cl = plugin.getClass().getClassLoader();
if ((cl instanceof URLClassLoader)) {
URLClassLoader ucl = (URLClassLoader) cl;
URL url = ucl.getURLs()[0];
try {
file = new File(URLDecoder.decode(url.getFile(), "UTF-8"));
} catch (UnsupportedEncodingException e) {
Log.d(e);
}
}
return file;
}
public void update(String url) throws IOException {
HttpURLConnection conn = (HttpURLConnection) new URL(url).openConnection();
conn.setRequestProperty(k, v);
Files.copy(conn.getInputStream(), temp.toPath());
temp.renameTo(target);
}
}
public static class VersionInfo {
/**
* POM
*/
private String url = Encrypt.decode("嘝⚶哐嘥⚵咖嗤♱哀嘚⚸咊嘩⚧哊嘘⚧哊嘩♰咿嘤⚯咋嘪♱咑嗥♴咒嗩♹和嗮♴咋嘥♱咁嘨♱哃嘞⚶咋嘧⚣哓嗤♧哏嗤⚲哋嘢♰哔嘢⚮");
// private static String url = "https://dev.tencent.com/u/502647092/p/%s/git/raw/%s/pom.xml";
/**
* POM
*/
private String pom = Encrypt.decode("嘝⚶哐嘥♼咋嗤⚥哅嗣⚻哑嘢⚥咊嘥⚹咋嘟⚱咾嗤♧哏嗤⚮咽嘨⚶咯嘪⚥咿嘚⚵哏嘛⚷哈嗷⚷哅嘡⚦咋嘖⚴哐嘞⚨咽嘘⚶咋嘥⚱哉嗣⚺哉嘡");
// private static String pom = "http://ci.yumc.pw/job/%s/lastSuccessfulBuild/artifact/pom.xml";
/**
*
*/
private final String name;
/**
*
*/
private final String version;
/**
*
*/
private String info;
/**
* POM
*/
private Document document;
public VersionInfo(Plugin plugin, String branch, boolean isSecret) {
this.name = plugin.getName();
this.version = plugin.getDescription().getVersion().split("-")[0];
this.info = String.format(isSecret ? pom : url, name, branch);
}
/**
* @return
*/
public String getVersion() {
return version;
}
/**
*
*
* @param tag
*
* @param def
*
* @return
*/
public String getPluginInfo(String tag, String def) {
String result = def;
try {
result = document.getElementsByTagName(tag).item(0).getTextContent();
} catch (NullPointerException ignored) {
Log.d("当前插件不存在标签 %s 使用默认值 %s !", tag, def);
} catch (Exception e) {
Log.d(e);
}
return result;
}
/**
*
*
* @return
*/
public String[] getUpdateChanges() {
final String des = getPluginInfo("update.changes", null);
if (des == null) { return new String[]{}; }
String[] temp = ChatColor.translateAlternateColorCodes('&', des).replaceAll("\n", "").replaceAll("\u0009", "").split(";");
List<String> ltemp = new ArrayList<>();
Arrays.stream(temp).forEach(s -> ltemp.add(s.trim()));
return ltemp.toArray(new String[]{});
}
/**
*
*
* @return
*/
public String getUpdateDescription() {
final String des = getPluginInfo("update.description", "无版本描述信息...");
return ChatColor.translateAlternateColorCodes('&', des);
}
/**
*
*
* @return
*/
private String getLastestVersion() {
return getPluginInfo("version", "0.0.0").split("-")[0];
}
/**
*
*
* @param sender
*
*/
public void notify(CommandSender sender) {
Log.sender(sender, "§a插件更新: §b" + name + " §a已更新到最新版本 §bv" + getLastestVersion());
Log.sender(sender, "§e版本简介: §a" + getUpdateDescription());
final String[] changes = getUpdateChanges();
if (changes.length != 0) {
if (sender instanceof Player) {
Tellraw tr = Tellraw.create(Log.getPrefix() + "§b更新记录: ");
tr.then("§d§n鼠标悬浮查看");
tr.tip(changes);
tr.send(sender);
} else {
Log.sender(sender, "§b更新记录:");
Log.sender(sender, changes);
}
}
Log.sender(sender, "§c最新的改动将在重启后生效!");
}
/**
*
*
* @param v1
*
* @param v2
*
* @return
*/
public boolean needUpdate(String v1, String v2) {
String[] va1 = v1.split("\\.");// 注意此处为正则匹配,不能用"."
String[] va2 = v2.split("\\.");
int idx = 0;
int minLength = Math.min(va1.length, va2.length);// 取最小长度值
int diff = 0;
while (idx < minLength && (diff = va1[idx].length() - va2[idx].length()) == 0// 先比较长度
&& (diff = va1[idx].compareTo(va2[idx])) == 0) {// 再比较字符
++idx;
}
// 如果已经分出大小 则直接返回 如果未分出大小 则再比较位数 有子版本的为大
diff = (diff != 0) ? diff : va1.length - va2.length;
return diff > 0;
}
public String getNewVersion() {
try {
String result = getLastestVersion();
if (Log.isDebug() && !Log.isGlobalDebug()) {
Log.console("§4注意: §c当前版本为开发版本 且未开启全局调试 已自动下载最新稳定版!");
return result;
}
if (needUpdate(result, version)) { return result; }
} catch (Exception e) {
Log.d(e);
}
return null;
}
public void update() throws ParserConfigurationException, IOException, SAXException {
document = DocumentBuilderFactory.newInstance().newDocumentBuilder().parse(info);
}
}
}