add MeoW Support

It looks like the Bark server

README.md

@@ -42,7 +42,7 @@ address: '127.0.0.1:14000'
 contact_bilibili: true
 ```
 
-### 需要Bark推送的
+### iOS用户，需要Bark推送的
 
 ```yaml
 Bark:
@@ -53,6 +53,13 @@ Bark:
   - url: "https://api.day.app/"
     device_key: "xCVBNMASDFGHJKLERTYUIO"
 ```
+### HarmonyOS用户，需要Bark推送的
+
+```yaml
+Meow:
+  - username: "a10000000"
+  - username: ""
+```
 
 ### 需要企业微信应用消息的
 

defaultConfig.yml

@@ -10,6 +10,10 @@ Bark:
   - url: "https://api.day.app/"
     device_key: ""
 
+Meow:
+  - username: ""
+  - username: ""
+
 WXWorkApp:
 #  - corpId: "ww123456789a01b2c3"
 #    appSecret: "0123456789abcdefghijklmnopqrstuvwxyzABCDEFG"

loadConfig.go

@@ -31,6 +31,7 @@ type ConfigLoader struct {
 	ContactBilibili bool                            `yaml:"contact_bilibili"`
 	Barks           []messageSender.BarkServer      `yaml:"Bark"`
 	WXWorkApps      []messageSender.WXWorkAppTarget `yaml:"WXWorkApp"`
+	Meow            []messageSender.MeowServer      `yaml:"Meow"`
 	Receivers       []Receiver                      `yaml:"Receivers"`
 }
 
@@ -87,6 +88,15 @@ func loadConfig() initStruct {
 			senderCount++
 		}
 	}
+	if len(configuration.Meow) > 0 {
+		for i := 0; i < len(configuration.Meow); i++ {
+			if configuration.Meow[i].Username == "" {
+				continue
+			}
+			configuration.Meow[i].RegisterServer()
+			senderCount++
+		}
+	}
 	if len(configuration.WXWorkApps) > 0 {
 		for i := 0; i < len(configuration.WXWorkApps); i++ {
 			if configuration.WXWorkApps[i].CorpId == "" || configuration.WXWorkApps[i].AppSecret == "" || configuration.WXWorkApps[i].AgentID == "" {

messageSender/sendMeowMessage.go

@@ -0,0 +1,56 @@
+package messageSender
+
+import (
+	"bytes"
+	"errors"
+	log "github.com/sirupsen/logrus"
+	"io"
+	"net/http"
+	"net/url"
+)
+
+const meowServerUrl = "http://api.chuckfang.com/"
+
+type MeowServer struct {
+	Username string `yaml:"username"`
+}
+
+func (m MeowServer) RegisterServer() {
+	RegisterMessageServer(m)
+}
+
+func (m MeowServer) SendMessage(message Message) {
+	err := m.sendMessage(message)
+	if err != nil {
+		log.Error("发送MeoW消息失败：", err)
+	}
+}
+
+func (m MeowServer) sendMessage(message Message) error {
+	if message == nil {
+		return errors.New("发送MeoW消息失败：消息为空")
+	}
+	target, err := url.JoinPath(meowServerUrl, m.Username, message.GetTitle(), message.GetContent())
+	if err != nil {
+		log.Error("发送MeoW消息失败：", err)
+		return err
+	}
+	resp, err := http.Get(target)
+	if err != nil {
+		log.Error("发送MeoW消息失败：", err)
+		return err
+	}
+	defer func(Body io.Closer) {
+		_ = Body.Close()
+	}(resp.Body)
+
+	if log.IsLevelEnabled(log.DebugLevel) {
+		buf := bytesBufferPool.Get().(*bytes.Buffer)
+		buf.Reset()                    // Reset the buffer for reuse
+		defer bytesBufferPool.Put(buf) // Return the buffer to the pool
+		_, _ = buf.ReadFrom(resp.Body)
+		log.Debug("发送MeoW消息响应：", buf.String())
+	}
+
+	return nil
+}

messageSender/sendMeowMessage_test.go

@@ -0,0 +1,19 @@
+package messageSender
+
+import (
+	"testing"
+	"time"
+)
+
+func TestMeowServer_sendMessage(t *testing.T) {
+	var target = MeowServer{Username: "xiaopangzi"}
+	var msg = GeneralPushMessage{
+		Title:   "测试标题" + time.Now().String(),
+		Content: "测试内容" + time.Now().GoString(),
+		IconURL: "",
+	}
+	err := target.sendMessage(&msg)
+	if err != nil {
+		t.Fail()
+	}
+}