miniflux/internal/integration/apprise/apprise.go

// SPDX-FileCopyrightText: Copyright The Miniflux Authors. All rights reserved.
// SPDX-License-Identifier: Apache-2.0

package apprise

import (
	"fmt"
	"net"
	"strings"
	"time"

	"miniflux.app/v2/internal/http/client"
	"miniflux.app/v2/internal/model"
	"miniflux.app/v2/internal/urllib"
)

const defaultClientTimeout = 1 * time.Second

// 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 base URL or service URL")
	}
	_, err := net.DialTimeout("tcp", c.baseURL, defaultClientTimeout)
	if err != nil {
		apiEndpoint, err := urllib.JoinBaseURLAndPath(c.baseURL, "/notify")
		if err != nil {
			return fmt.Errorf(`apprise: invalid API endpoint: %v`, err)
		}

		clt := client.New(apiEndpoint)
		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
}