feat: add serverchan notify client

db/notification.go

@@ -73,6 +73,8 @@ func toNotificationClient(cl *ent.NotificationClient) (*NotificationClient, erro
 		settings = notifier.TelegramConfig{}
 	case "bark":
 		settings = notifier.BarkConfig{}
+	case "serverchan":
+		settings = notifier.ServerChanConfig{}
 	}
 	err := json.Unmarshal([]byte(cl.Settings), &settings)
 	if err != nil {

pkg/notifier/clients_test.go

@@ -0,0 +1,15 @@
+package notifier
+
+import "testing"
+
+func TestServerChan(t *testing.T) {
+	s, err := NewServerChanClient(``)
+	if err != nil {
+		t.Error(err)
+		return
+	}
+	err = s.SendMsg("test")
+	if err != nil {
+		t.Error(err)
+	}
+}

pkg/notifier/doc.go

@@ -30,6 +30,7 @@ func init() {
 	handler.Store("dingtalk", NewDingTalkClient)
 	handler.Store("telegram", NewTelegramClient)
 	handler.Store("bark", NewbarkClient)
+	handler.Store("serverchan", NewServerChanClient)
 }
 
 func Gethandler(name string) (HandlerFunc, bool) {

pkg/notifier/serverchan.go

@@ -0,0 +1,89 @@
+package notifier
+
+import (
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+	"net/url"
+	"regexp"
+	"strings"
+
+	"github.com/pkg/errors"
+)
+
+type ServerChanConfig struct {
+	Key string `json:"key"`
+}
+
+func NewServerChanClient(s string) (NotificationClient, error) {
+	var cfg ServerChanConfig
+	if err := json.Unmarshal([]byte(s), &cfg); err != nil {
+		return nil, errors.Wrap(err, "json")
+	}
+
+	return &ServerChan{Key: cfg.Key}, nil
+}
+
+type ServerChan struct {
+	Key string
+}
+
+func (s *ServerChan) SendMsg(msg string) error {
+	return scSend("Polaris", msg, s.Key)
+}
+
+func scSend(text string, desp string, key string) error {
+	data := url.Values{}
+	data.Set("text", text)
+	data.Set("desp", desp)
+
+	// 根据 sendkey 是否以 "sctp" 开头决定 API 的 URL
+	var apiUrl string
+	if strings.HasPrefix(key, "sctp") {
+		// 使用正则表达式提取数字部分
+		re := regexp.MustCompile(`sctp(\d+)t`)
+		matches := re.FindStringSubmatch(key)
+		if len(matches) > 1 {
+			num := matches[1]
+			apiUrl = fmt.Sprintf("https://%s.push.ft07.com/send/%s.send", num, key)
+		} else {
+			return errors.New("invalid sendkey format for sctp")
+		}
+	} else {
+		apiUrl = fmt.Sprintf("https://sctapi.ftqq.com/%s.send", key)
+	}
+
+	client := &http.Client{}
+	req, err := http.NewRequest("POST", apiUrl, strings.NewReader(data.Encode()))
+	if err != nil {
+		return err
+	}
+
+	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
+
+	resp, err := client.Do(req)
+	if err != nil {
+		return err
+	}
+	defer resp.Body.Close()
+	d, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return err
+	}
+	var r response
+	if err := json.Unmarshal(d, &r); err != nil {
+		return err
+	}
+
+	if r.Code != 0 {
+		return errors.New(r.Message)
+	}
+
+	return nil
+}
+
+type response struct {
+	Code    int    `json:"code"`
+	Message string `json:"message"`
+}

ui/lib/settings/notifier.dart

@@ -84,6 +84,17 @@ class _NotifierState extends ConsumerState<NotifierSettings> {
                         showBarkNotifierDetails(NotifierData());
                       },
                     ),
+                  ),
+                  SettingsCard(
+                    child: InkWell(
+                      child: const Center(
+                        child: Text("Server酱"),
+                      ),
+                      onTap: () {
+                        Navigator.of(context).pop();
+                        showServerChanNotifierDetails(NotifierData());
+                      },
+                    ),
                   )
                 ],
               ),
@@ -98,10 +109,64 @@ class _NotifierState extends ConsumerState<NotifierSettings> {
         return showBarkNotifierDetails(notifier);
       case "pushover":
         return showPushoverNotifierDetails(notifier);
+      case "serverchan":
+        return showServerChanNotifierDetails(notifier);
     }
     return Future<void>.value();
   }
 
+  Future<void> showServerChanNotifierDetails(NotifierData notifier) {
+    final _formKey = GlobalKey<FormBuilderState>();
+
+    var body = FormBuilder(
+      key: _formKey,
+      initialValue: {
+        "name": notifier.name,
+        "enabled": notifier.enabled ?? true,
+        "key": notifier.settings != null ? notifier.settings!["key"] : "",
+      },
+      child: Column(
+        children: [
+          const Text("https://sct.ftqq.com/"),
+          FormBuilderTextField(
+            name: "name",
+            decoration: Commons.requiredTextFieldStyle(text: "名称"),
+            autovalidateMode: AutovalidateMode.onUserInteraction,
+            validator: FormBuilderValidators.required(),
+          ),
+          FormBuilderTextField(
+            name: "key",
+            decoration: Commons.requiredTextFieldStyle(text: "Key"),
+            autovalidateMode: AutovalidateMode.onUserInteraction,
+            validator: FormBuilderValidators.required(),
+          ),
+          FormBuilderSwitch(name: "enabled", title: const Text("启用"))
+        ],
+      ),
+    );
+    onDelete() async {
+      return ref.read(notifiersDataProvider.notifier).delete(notifier.id!);
+    }
+
+    onSubmit() async {
+      if (_formKey.currentState!.saveAndValidate()) {
+        var values = _formKey.currentState!.value;
+        return ref.read(notifiersDataProvider.notifier).add(NotifierData(
+                name: values["name"],
+                service: "serverchan",
+                enabled: values["enabled"],
+                settings: {
+                  "key": values["key"],
+                }));
+      } else {
+        throw "validation_error";
+      }
+    }
+
+    return showSettingDialog(
+        context, "Server酱", notifier.id != null, body, onSubmit, onDelete);
+  }
+
   Future<void> showBarkNotifierDetails(NotifierData notifier) {
     final _formKey = GlobalKey<FormBuilderState>();