新增 Webhook 通知渠道

src/main/java/com/ghostchu/peerbanhelper/alert/AlertManagerImpl.java

@@ -108,7 +108,7 @@ public void publishAlert(boolean push, @NotNull AlertLevel level, @NotNull Strin
             alertEntity.setCreateAt(OffsetDateTime.now());
             alertDao.saveOrUpdate(alertEntity);
             if (push) {
-                if (!pushManager.pushMessage("[PeerBanHelper/" + level.name() + "] " + tlUI(title), tlUI(content))) {
+                if (!pushManager.pushMessage("[PeerBanHelper/" + level.name() + "] " + tlUI(title), tlUI(content), level)) {
                     log.error(tlUI(Lang.UNABLE_TO_PUSH_ALERT_VIA_PROVIDERS));
                 }
             }

src/main/java/com/ghostchu/peerbanhelper/module/impl/webapi/PBHPushController.java

@@ -1,5 +1,6 @@
 package com.ghostchu.peerbanhelper.module.impl.webapi;
 
+import com.ghostchu.peerbanhelper.alert.AlertLevel;
 import com.ghostchu.peerbanhelper.module.AbstractFeatureModule;
 import com.ghostchu.peerbanhelper.module.impl.webapi.dto.PushWrapperDTO;
 import com.ghostchu.peerbanhelper.text.Lang;
@@ -135,7 +136,7 @@ private void handlePushProviderTest(Context ctx) {
             return;
         }
         try {
-            var testResult = pushProvider.push(tl(locale(ctx), Lang.PUSH_PROVIDER_TEST_TITLE), tl(locale(ctx), Lang.PUSH_PROVIDER_TEST_DESCRIPTION, name, pushProvider.getConfigType()));
+            var testResult = pushProvider.push(tl(locale(ctx), Lang.PUSH_PROVIDER_TEST_TITLE), tl(locale(ctx), Lang.PUSH_PROVIDER_TEST_DESCRIPTION, name, pushProvider.getConfigType()), AlertLevel.INFO);
             if (testResult) {
                 ctx.json(new StdResp(true, tl(locale(ctx), Lang.PUSH_PROVIDER_API_TEST_OK), null));
             } else {

src/main/java/com/ghostchu/peerbanhelper/util/push/PushManager.java

@@ -1,5 +1,6 @@
 package com.ghostchu.peerbanhelper.util.push;
 
+import com.ghostchu.peerbanhelper.alert.AlertLevel;
 import com.google.gson.JsonObject;
 import org.bspfsystems.yamlconfiguration.configuration.ConfigurationSection;
 
@@ -16,7 +17,7 @@ public interface PushManager {
 
     void savePushProviders() throws IOException;
 
-    boolean pushMessage(String title, String description);
+    boolean pushMessage(String title, String description, AlertLevel level);
 
     java.util.List<PushProvider> getProviderList();
 }

src/main/java/com/ghostchu/peerbanhelper/util/push/PushManagerImpl.java

@@ -1,6 +1,7 @@
 package com.ghostchu.peerbanhelper.util.push;
 
 import com.ghostchu.peerbanhelper.Main;
+import com.ghostchu.peerbanhelper.alert.AlertLevel;
 import com.ghostchu.peerbanhelper.text.Lang;
 import com.ghostchu.peerbanhelper.util.HTTPUtil;
 import com.ghostchu.peerbanhelper.util.push.impl.*;
@@ -47,6 +48,8 @@ public PushProvider createPushProvider(String name, String type, ConfigurationSe
             case "pushdeer" -> provider = PushDeerPushProvider.loadFromYaml(name, section, httpUtil);
             case "gotify" -> provider = GotifyPushProvider.loadFromYaml(name, section, httpUtil);
             case "ntfy" -> provider = NtfyPushProvider.loadFromYaml(name, section, httpUtil);
+            case "webhook" -> provider = WebhookPushProvider.loadFromYaml(name, section, httpUtil);
+            default -> provider = null;
         }
         return provider;
     }
@@ -63,6 +66,8 @@ public PushProvider createPushProvider(String name, String type, JsonObject json
             case "pushdeer" -> provider = PushDeerPushProvider.loadFromJson(name, jsonObject, httpUtil);
             case "gotify" -> provider = GotifyPushProvider.loadFromJson(name, jsonObject, httpUtil);
             case "ntfy" -> provider = NtfyPushProvider.loadFromJson(name, jsonObject, httpUtil);
+            case "webhook" -> provider = WebhookPushProvider.loadFromJson(name, jsonObject, httpUtil);
+            default -> provider = null;
         }
         return provider;
     }
@@ -104,11 +109,11 @@ public void savePushProviders() throws IOException {
     }
 
     @Override
-    public boolean pushMessage(String title, String description) {
+    public boolean pushMessage(String title, String description, AlertLevel level) {
         AtomicBoolean anySuccess = new AtomicBoolean(false);
         providerList.forEach(pushProvider -> {
             try {
-                if (pushProvider.push(title, description)) {
+                if (pushProvider.push(title, description, level)) {
                     anySuccess.set(true);
                 }
             } catch (Exception e) {

src/main/java/com/ghostchu/peerbanhelper/util/push/PushProvider.java

@@ -1,5 +1,6 @@
 package com.ghostchu.peerbanhelper.util.push;
 
+import com.ghostchu.peerbanhelper.alert.AlertLevel;
 import com.google.gson.JsonObject;
 import org.bspfsystems.yamlconfiguration.configuration.ConfigurationSection;
 
@@ -11,7 +12,7 @@ public interface PushProvider {
     JsonObject saveJson();
 
     ConfigurationSection saveYaml();
-
-    boolean push(String title, String content);
+    
+    boolean push(String title, String content, AlertLevel level);
 
 }

src/main/java/com/ghostchu/peerbanhelper/util/push/impl/BarkPushProvider.java

@@ -1,5 +1,6 @@
 package com.ghostchu.peerbanhelper.util.push.impl;
 
+import com.ghostchu.peerbanhelper.alert.AlertLevel;
 import com.ghostchu.peerbanhelper.util.HTTPUtil;
 import com.ghostchu.peerbanhelper.util.json.JsonUtil;
 import com.ghostchu.peerbanhelper.util.push.AbstractPushProvider;
@@ -67,7 +68,7 @@ public static BarkPushProvider loadFromYaml(String name, ConfigurationSection se
     }
 
     @Override
-    public boolean push(String title, String content) {
+    public boolean push(String title, String content, AlertLevel level) {
         Map<String, Object> map = new HashMap<>();
         map.put("title", title);
         map.put("body", content);

src/main/java/com/ghostchu/peerbanhelper/util/push/impl/GotifyPushProvider.java

@@ -1,5 +1,6 @@
 package com.ghostchu.peerbanhelper.util.push.impl;
 
+import com.ghostchu.peerbanhelper.alert.AlertLevel;
 import com.ghostchu.peerbanhelper.util.HTTPUtil;
 import com.ghostchu.peerbanhelper.util.json.JsonUtil;
 import com.ghostchu.peerbanhelper.util.push.AbstractPushProvider;
@@ -64,7 +65,7 @@ public static GotifyPushProvider loadFromYaml(String name, ConfigurationSection
     }
 
     @Override
-    public boolean push(String title, String content) {
+    public boolean push(String title, String content, AlertLevel level) {
         Map<String, Object> map = new HashMap<>();
         map.put("title", title);
         map.put("message", content);

src/main/java/com/ghostchu/peerbanhelper/util/push/impl/NtfyPushProvider.java

@@ -1,5 +1,6 @@
 package com.ghostchu.peerbanhelper.util.push.impl;
 
+import com.ghostchu.peerbanhelper.alert.AlertLevel;
 import com.ghostchu.peerbanhelper.util.HTTPUtil;
 import com.ghostchu.peerbanhelper.util.json.JsonUtil;
 import com.ghostchu.peerbanhelper.util.push.AbstractPushProvider;
@@ -22,6 +23,7 @@ public final class NtfyPushProvider extends AbstractPushProvider {
     private final Config config;
     private final String name;
     private final HTTPUtil httpUtil;
+    private static final String ICON_URL ="https://raw.githubusercontent.com/PBH-BTN/PeerBanHelper/refs/heads/master/src/main/resources/assets/icon.png";
 
     public NtfyPushProvider(String name, Config config, HTTPUtil httpUtil) {
         this.name = name;
@@ -71,7 +73,7 @@ public static NtfyPushProvider loadFromYaml(String name, ConfigurationSection se
     }
 
     @Override
-    public boolean push(String title, String content) {
+    public boolean push(String title, String content, AlertLevel level) {
 
         RequestBody requestBody = RequestBody.create(
                 content,
@@ -85,7 +87,7 @@ public boolean push(String title, String content) {
                 .post(requestBody)
                 .header("Title", encodedTitle)
                 .header("Priority", String.valueOf(config.getPriority()))
-                .header("Icon", "https://raw.githubusercontent.com/PBH-BTN/PeerBanHelper/refs/heads/master/src/main/resources/assets/icon.png");
+                .header("Icon", ICON_URL);
 
         if (config.getToken() != null && !config.getToken().isBlank()) {
             builder.header("Authorization", "Bearer " + config.getToken());
@@ -105,6 +107,16 @@ public boolean push(String title, String content) {
         return true;
     }
 
+    private int mapLevelToPriority(AlertLevel level) {
+        return switch (level) {
+            case TIP -> 1;
+            case INFO -> 2;
+            case WARN -> 3;
+            case ERROR -> 4;
+            case FATAL -> 5;
+        };
+    }
+
     @AllArgsConstructor
     @Data
     public static class Config {

src/main/java/com/ghostchu/peerbanhelper/util/push/impl/PushDeerPushProvider.java

@@ -1,5 +1,6 @@
 package com.ghostchu.peerbanhelper.util.push.impl;
 
+import com.ghostchu.peerbanhelper.alert.AlertLevel;
 import com.ghostchu.peerbanhelper.util.HTTPUtil;
 import com.ghostchu.peerbanhelper.util.json.JsonUtil;
 import com.ghostchu.peerbanhelper.util.push.AbstractPushProvider;
@@ -65,7 +66,7 @@ public static PushDeerPushProvider loadFromYaml(String name, ConfigurationSectio
     }
 
     @Override
-    public boolean push(String title, String content) {
+    public boolean push(String title, String content, AlertLevel level) {
         Map<String, Object> map = new HashMap<>();
         map.put("pushkey", config.getPushKey());
         map.put("text", title);

src/main/java/com/ghostchu/peerbanhelper/util/push/impl/PushPlusPushProvider.java

@@ -1,5 +1,6 @@
 package com.ghostchu.peerbanhelper.util.push.impl;
 
+import com.ghostchu.peerbanhelper.alert.AlertLevel;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.ghostchu.peerbanhelper.util.HTTPUtil;
 import com.ghostchu.peerbanhelper.util.json.JsonUtil;
@@ -76,7 +77,7 @@ public String getConfigType() {
     }
 
     @Override
-    public boolean push(String title, String content) {
+    public boolean push(String title, String content, AlertLevel level) {
         Map<String, Object> args = new HashMap<>() {{
             put("token", config.getToken());
             if (config.getTopic() != null) {

src/main/java/com/ghostchu/peerbanhelper/util/push/impl/ServerChanPushProvider.java

@@ -1,5 +1,6 @@
 package com.ghostchu.peerbanhelper.util.push.impl;
 
+import com.ghostchu.peerbanhelper.alert.AlertLevel;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.ghostchu.peerbanhelper.util.HTTPUtil;
 import com.ghostchu.peerbanhelper.util.json.JsonUtil;
@@ -74,7 +75,7 @@ public static ServerChanPushProvider loadFromYaml(String name, ConfigurationSect
     }
 
     @Override
-    public boolean push(String title, String content) {
+    public boolean push(String title, String content, AlertLevel level) {
         Map<String, Object> map = new HashMap<>();
         map.put("title", title);
         map.put("desp", content);

src/main/java/com/ghostchu/peerbanhelper/util/push/impl/SmtpPushProvider.java

@@ -1,5 +1,6 @@
 package com.ghostchu.peerbanhelper.util.push.impl;
 
+import com.ghostchu.peerbanhelper.alert.AlertLevel;
 import com.ghostchu.peerbanhelper.util.json.JsonUtil;
 import com.ghostchu.peerbanhelper.util.push.AbstractPushProvider;
 import com.google.gson.JsonObject;
@@ -142,7 +143,7 @@ public String getConfigType() {
     }
 
     @Override
-    public boolean push(String title, String content) {
+    public boolean push(String title, String content, AlertLevel level) {
         try {
             sendMail(config.getReceivers(), title, content);
             return true;

src/main/java/com/ghostchu/peerbanhelper/util/push/impl/TelegramPushProvider.java

@@ -1,5 +1,6 @@
 package com.ghostchu.peerbanhelper.util.push.impl;
 
+import com.ghostchu.peerbanhelper.alert.AlertLevel;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.ghostchu.peerbanhelper.util.HTTPUtil;
 import com.ghostchu.peerbanhelper.util.json.JsonUtil;
@@ -66,7 +67,7 @@ public ConfigurationSection saveYaml() {
     }
 
     @Override
-    public boolean push(String title, String content) {
+    public boolean push(String title, String content, AlertLevel level) {
         String markdown = "*" + title + "*\n" + content;
         Map<String, Object> map = new HashMap<>();
         map.put("chat_id", config.getChatId());