Add Apprise integration

integration/apprise/apprise.go

@@ -0,0 +1,54 @@
+// SPDX-FileCopyrightText: Copyright The Miniflux Authors. All rights reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+package apprise
+
+import (
+	"fmt"
+	"net"
+	"strings"
+	"time"
+
+	"miniflux.app/http/client"
+	"miniflux.app/model"
+)
+
+// Client represents a Apprise client.
+type Client struct {
+	servicesURL string
+	baseURL     string
+}
+
+// NewClient returns a new Apprise client.
+func NewClient(serviceURL, baseURL string) *Client {
+	return &Client{serviceURL, baseURL}
+}
+
+// PushEntry pushes entry to apprise
+func (c *Client) PushEntry(entry *model.Entry) error {
+	if c.baseURL == "" || c.servicesURL == "" {
+		return fmt.Errorf("apprise: missing credentials")
+	}
+	timeout := time.Duration(1 * time.Second)
+	_, err := net.DialTimeout("tcp", c.baseURL, timeout)
+	if err != nil {
+		clt := client.New(c.baseURL + "/notify")
+		message := "[" + entry.Title + "]" + "(" + entry.URL + ")" + "\n\n"
+		data := &Data{
+			Urls: c.servicesURL,
+			Body: message,
+		}
+		response, error := clt.PostJSON(data)
+		if error != nil {
+			return fmt.Errorf("apprise: ending message failed: %v", error)
+		}
+
+		if response.HasServerFailure() {
+			return fmt.Errorf("apprise: request failed, status=%d", response.StatusCode)
+		}
+	} else {
+		return fmt.Errorf("%s %s %s", c.baseURL, "responding on port:", strings.Split(c.baseURL, ":")[1])
+	}
+
+	return nil
+}

integration/apprise/wrapper.go

@@ -0,0 +1,9 @@
+// SPDX-FileCopyrightText: Copyright The Miniflux Authors. All rights reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+package apprise
+
+type Data struct {
+	Urls string `json:"urls"`
+	Body string `json:"body"`
+}

integration/integration.go

@@ -5,6 +5,7 @@ package integration // import "miniflux.app/integration"
 
 import (
 	"miniflux.app/config"
+	"miniflux.app/integration/apprise"
 	"miniflux.app/integration/espial"
 	"miniflux.app/integration/instapaper"
 	"miniflux.app/integration/linkding"
@@ -160,4 +161,16 @@ func PushEntry(entry *model.Entry, integration *model.Integration) {
 			logger.Error("[Integration] push entry to telegram bot failed: %v", err)
 		}
 	}
+	if integration.AppriseEnabled {
+		logger.Debug("[Integration] Sending Entry %q for User #%d to apprise", entry.URL, integration.UserID)
+
+		client := apprise.NewClient(
+			integration.AppriseServicesURL,
+			integration.AppriseURL,
+		)
+		err := client.PushEntry(entry)
+		if err != nil {
+			logger.Error("[Integration] push entry to apprise failed: %v", err)
+		}
+	}
 }