feat: 👽️ refactor with new api

Author: AnzhiZhang

src/main/java/org/bsrserver/AltairGreeter.java

@@ -0,0 +1,73 @@
+package org.bsrserver;
+
+import java.nio.file.Path;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+
+import org.slf4j.Logger;
+import com.google.inject.Inject;
+import com.velocitypowered.api.event.proxy.ProxyInitializeEvent;
+import com.velocitypowered.api.plugin.Plugin;
+import com.velocitypowered.api.event.Subscribe;
+import com.velocitypowered.api.proxy.ProxyServer;
+import com.velocitypowered.api.plugin.annotation.DataDirectory;
+
+import org.bsrserver.config.Config;
+import org.bsrserver.data.hitokoto.QuotationsManager;
+import org.bsrserver.data.servers.ServersManager;
+import org.bsrserver.event.ServerConnectedEventEventListener;
+
+@Plugin(
+        id = "altairgreeter",
+        name = "Altair Greeter",
+        version = "1.4.0",
+        url = "https://www.bsrserver.org:8443",
+        description = "A greeter",
+        authors = {"Andy Zhang"}
+)
+public class AltairGreeter {
+    private final ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor();
+    private final ProxyServer proxyServer;
+    private final Logger logger;
+    private final QuotationsManager quotationsManager;
+    private final ServersManager serversManager;
+
+    @Inject
+    public AltairGreeter(ProxyServer proxyServer, Logger logger, @DataDirectory Path dataDirectory) {
+        this.proxyServer = proxyServer;
+        this.logger = logger;
+
+        // load config
+        Config.getInstance().loadConfig(dataDirectory);
+
+        // init data
+        this.quotationsManager = new QuotationsManager(this);
+        this.serversManager = new ServersManager(this);
+    }
+
+    @Subscribe
+    public void onInitialize(ProxyInitializeEvent event) {
+        // register command
+        proxyServer.getEventManager().register(this, new ServerConnectedEventEventListener(this));
+    }
+
+    public ScheduledExecutorService getScheduledExecutorService() {
+        return scheduledExecutorService;
+    }
+
+    public ProxyServer getProxyServer() {
+        return proxyServer;
+    }
+
+    public Logger getLogger() {
+        return logger;
+    }
+
+    public QuotationsManager getQuotationsManager() {
+        return quotationsManager;
+    }
+
+    public ServersManager getServersManager() {
+        return serversManager;
+    }
+}

src/main/java/org/bsrserver/Main.java

@@ -2,8 +2,8 @@
 
 import java.io.File;
 import java.io.IOException;
-import java.nio.file.Files;
 import java.nio.file.Path;
+import java.nio.file.Files;
 import java.util.Objects;
 
 import com.moandjiezana.toml.Toml;
@@ -30,31 +30,18 @@ public void loadConfig(Path dataDirectory) {
         if (!configFile.exists()) {
             try {
                 Files.copy(Objects.requireNonNull(getClass().getClassLoader().getResourceAsStream("config.toml")), configFile.toPath());
-            } catch (IOException e) {
-                e.printStackTrace();
+            } catch (IOException ignored) {
             }
         }
 
         configToml = new Toml().read(configFile);
     }
 
-    public String getDatabaseUrl() {
-        return configToml.getString("database.url");
-    }
-
-    public String getDatabaseUser() {
-        return configToml.getString("database.user");
-    }
-
-    public String getDatabasePassword() {
-        return configToml.getString("database.password");
-    }
-
-    public String getDatabaseTable() {
-        return configToml.getString("database.table");
+    public String getBackendBaseUrl() {
+        return configToml.getString("backend.baseurl");
     }
 
-    public String getSentencesUrl() {
-        return configToml.getString("sentences.url");
+    public String getBackendSecuredClientKey() {
+        return configToml.getString("backend.securedClientKey");
     }
 }

src/main/java/org/bsrserver/components/Sentences.java

@@ -0,0 +1,75 @@
+package org.bsrserver.data.hitokoto;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.concurrent.TimeUnit;
+
+import org.slf4j.Logger;
+import okhttp3.Request;
+import okhttp3.Response;
+import okhttp3.OkHttpClient;
+import com.alibaba.fastjson2.JSONArray;
+import com.alibaba.fastjson2.JSONObject;
+
+import org.bsrserver.AltairGreeter;
+import org.bsrserver.config.Config;
+
+public class QuotationsManager {
+    private final ArrayList<String> quotations = new ArrayList<>();
+    private final Logger logger;
+
+    public QuotationsManager(AltairGreeter altairGreeter) {
+        this.logger = altairGreeter.getLogger();
+        altairGreeter.getScheduledExecutorService().scheduleAtFixedRate(this::scheduledTask, 0, 30, TimeUnit.SECONDS);
+    }
+
+    private void scheduledTask() {
+        try {
+            updateQuotations();
+        } catch (Exception e) {
+            logger.error("Failed to get quotations", e);
+        }
+    }
+
+    private void updateQuotations() {
+        // clear
+        quotations.clear();
+
+        // request
+        String authorization = "KeySecuredClient " + Config.getInstance().getBackendSecuredClientKey();
+        OkHttpClient client = new OkHttpClient();
+        Request getRequest = new Request.Builder()
+                .url(Config.getInstance().getBackendBaseUrl() + "/v1/hitokoto/quotations")
+                .header("Authorization", authorization)
+                .build();
+
+        // get quotations
+        JSONArray quotationsJSONArray = null;
+        try {
+            Response response = client.newCall(getRequest).execute();
+            if (response.body() != null) {
+                quotationsJSONArray = JSONObject
+                        .parseObject(response.body().string())
+                        .getJSONObject("data")
+                        .getJSONArray("quotations");
+            }
+        } catch (IOException exception) {
+            logger.error("Failed to get quotations", exception);
+        }
+
+        // save quotations
+        if (quotationsJSONArray != null) {
+            for (JSONObject quotation : quotationsJSONArray.toArray(JSONObject.class)) {
+                quotations.add(quotation.getString("sourceName") + "：" + quotation.getString("content"));
+            }
+        }
+    }
+
+    public String getRandomQuotation() {
+        if (!quotations.isEmpty()) {
+            return quotations.get((int) (Math.random() * quotations.size()));
+        } else {
+            return "";
+        }
+    }
+}

src/main/java/org/bsrserver/config/Config.java

@@ -1,19 +1,19 @@
-package org.bsrserver.components;
+package org.bsrserver.data.servers;
 
 import java.time.LocalDate;
 
 public record ServerInfo(
         String serverName,
-        String namedName,
-        LocalDate foundationTime,
+        String givenName,
+        LocalDate foundationDate,
         int priority
 ) {
     @Override
     public String toString() {
         return "ServerInfo{" +
                 "serverName='" + serverName + '\'' +
-                ", namedName='" + namedName + '\'' +
-                ", foundationTime=" + foundationTime +
+                ", givenName='" + givenName + '\'' +
+                ", foundationDate=" + foundationDate +
                 ", priority=" + priority +
                 '}';
     }