Messaging über self-hosted Ntfy-Server mit Authorisierung

[gredie]

Hallo,

ich habe einen eigenen Ntfy Server laufen und möchte den auch für evcc messaging verwenden.
In der Doku konnte ich nicht finden wie man die Autorisierung im Messager-Header zum ntfy-server in evcc definieren kann.

Wie lässt sich das in evcc.yaml einbauen?

[StefanSchoof]

Wenn ich mir https://github.com/evcc-io/evcc/blob/master/push/ntfy.go anschaue, denke ich nicht das das implement ist.

[gredie]

Schade, es wären sicher nur einige Zeilen Code notwendig die Funktion einzubauen.

Dann werde ich alternativ ein Shell Script für den passenden ntfy-Aufruf verwenden müssen. Werden dafür im messaging die title/msg von der event definition übergeben? Ich konnte dazu in der Doku leider nichts finden.

[andig]

Was für Header brauchst Du denn? Analog HTTP Plugin könnte man die ja nachrüsten.

[gredie]

Heute werden ja schon neben title & msg auch uri, priority und tags verwendet.
Bei uri kann ich meinen privaten ntfy-url angeben, für die Authentication wäre noch ein zusätzlicher Header notwendig

lt ntfy doku wäre das
req.Header.Set("Authorization", "Basic base64(username:password)")

im evcc config.yaml

• type: ntfy
  uri: https://ntfy.privateserver.com/evcctestalerts
  priority: default
  tags: electric_plug,blue_car
  authorization: "Basic base64(username:password)"

Es wäre super wenn sich das realisieren lässt :-)

BTW: Kann man die events im evcc irgendwie testweise anstoßen um die api und das Messageformat auszutesten?

[andig]

@gredie in der ntfy.go müsste einfach Authentifierung analog HTTP Plugin ergänzt werden. Ist eigentlich kein großes Hexenwerk.

[fabwal]

Kann man das nicht vielleicht über den Query Parameter machen?
https://docs.ntfy.sh/publish/#query-param

Ich habe es mal implementiert, klappt aber bisher noch nicht, was aber auch locker an mir liegen kann :)

[steffenahrens]

Kenne mich nicht aus, aber es ist doch bestimmt möglich die "Bearer" und/oder "Basic" Access Tokens als weiteren optionalen Parameter einzubinden.
Habe mir die ntfy.go mal angesehen, könnte es sein das es ungefähr in diese Richtung gehen muss:

import (
	"errors"
	"net/http"
	"strings"

	"github.com/evcc-io/evcc/util"
	"github.com/evcc-io/evcc/util/request"
)

func init() {
	registry.Add("ntfy", NewNtfyFromConfig)
}

// Ntfy implements the ntfy messaging aggregator
type Ntfy struct {
	log      *util.Logger
	uri      string
	priority string
	tags     string
	bearer string
}

// NewNtfyFromConfig creates new Ntfy messenger
func NewNtfyFromConfig(other map[string]interface{}) (Messenger, error) {
	var cc struct {
		URI      string
		Priority string
		Tags     string
		Bearer string
	}

	if err := util.DecodeOther(other, &cc); err != nil {
		return nil, err
	}

	if cc.URI == "" {
		return nil, errors.New("missing uri")
	}

	log := util.NewLogger("ntfy")
	if token, ok := strings.CutPrefix(cc.URI, "https://ntfy.sh/"); ok {
		log = log.Redact(token)
	}

	m := &Ntfy{
		log:      log,
		uri:      cc.URI,
		priority: cc.Priority,
		tags:     cc.Tags,
		bearer:	  cc.Bearer,
	}

	return m, nil
}

// Send sends to all receivers
func (m *Ntfy) Send(title, msg string) {
	req, err := request.New("POST", m.uri, strings.NewReader(msg), map[string]string{
		"Priority": m.priority,
		"Title":    title,
		"Tags":     m.tags,		
	})
	if(bearer != "" || bearer != nil){
		req.Header.Set("Authorization", "Bearer %bearer")
	}
	if err != nil {
		m.log.ERROR.Printf("ntfy: %v", err)
	}

	if _, err := http.DefaultClient.Do(req); err != nil {
		m.log.ERROR.Printf("ntfy: %v", err)
	}
}

[andig]

@steffenahrens willst Du mal einen entsprechenden PR versuchen? Siehe http.go ;)

[steffenahrens]

Hi, ich verstehe leider nicht genau was ich testen soll :D Wenn du es mir etwas genauer sagen/beschreiben könntest, würde ich gerne mit helfen...

[svn2208]

Ich hab es mal versuchsweise gebaut. Ich bekomme diesen Fehler:
[main ] FATAL 2024/12/09 20:23:19 failed configuring push service ntfy: cannot create messenger type 'ntfy': decoding failed due to the following error(s): '' has invalid keys: auth

ich habe es statt bearer auth genannt. Muss man irgendwo den neuen cfg Parameter bekannt geben?

[andig]

Das wird wohl nicht funktionieren wenn niemand die Funktionalität einbaut.

[svn2208]

Hab ich lokal eingebaut:

❯ cat push/ntfy.go
package push

import (
"errors"
"net/http"
"strings"
"github.com/evcc-io/evcc/util"
"github.com/evcc-io/evcc/util/request"
)

func init() {
registry.Add("ntfy", NewNtfyFromConfig)
}

// Ntfy implements the ntfy messaging aggregator
type Ntfy struct {
log *util.Logger
uri string
priority string
tags string
auth string
}

// NewNtfyFromConfig creates new Ntfy messenger
func NewNtfyFromConfig(other map[string]interface{}) (Messenger, error) {
var cc struct {
URI string
Priority string
Tags string
Auth string
}

    if err := util.DecodeOther(other, &cc); err != nil {
            return nil, err
    }

    if cc.URI == "" {
            return nil, errors.New("missing uri")
    }

    log := util.NewLogger("ntfy")
    if token, ok := strings.CutPrefix(cc.URI, "https://ntfy.sh/"); ok {
            log = log.Redact(token)
    }

    m := &Ntfy{
            log:      log,
            uri:      cc.URI,
            priority: cc.Priority,
            tags:     cc.Tags,
            auth:    cc.Auth,
    }

    return m, nil

}

// Send sends to all receivers
func (m *Ntfy) Send(title, msg string) {
req, err := request.New("POST", m.uri, strings.NewReader(msg), map[string]string{
"Priority": m.priority,
"Title": title,
"Tags": m.tags,
})
if (m.auth != "") {
req.Header.Set("Authorization", "Bearer " + m.auth)
}
if err != nil {
m.log.ERROR.Printf("ntfy: %v", err)
}

    if _, err := http.DefaultClient.Do(req); err != nil {
            m.log.ERROR.Printf("ntfy: %v", err)
    }

}

[beyertom]

Als Übergangslösung funktioniert es auch mit dem Shoutrrr Service:

messaging:
  events:
    start:
      title: Charge started
      msg: Started charging in "${mode}" mode
    stop:
      title: Charge finished
      msg: Finished charging ${chargedEnergy:%.1fk}kWh in ${chargeDuration}.
    connect:
      title: Car connected
      msg: "Car connected at ${pvPower:%.1fk}kW PV"
    disconnect:
      title: Car disconnected
      msg: Car disconnected after ${connectedDuration}
    soc:
      title: Soc updated
      msg: Battery charged to ${vehicleSoc:%.0f}%
    guest:
      title: Unknown vehicle
      msg: Unknown vehicle, guest connected?

  services:
  - type: shout
    uri: ntfy://user:[email protected]/evcc

[steffenahrens]

Hatte die letzten tage viel zu tun, deswegen konnte ich das gestern erst testen. Funktioniert...

[m0nn3]

Gibt es hier schon etwas neues?
Bekomme es mit Auth (username + PW) oder Token nicht hin via ntfy Nachrichten zu senden.

[steffenahrens]

Hi. Ich nutze es tatsächlich jetzt noch über den shout Service so wie beyertom es vorgeschlagen hat und das funktioniert stabil.

[svn2208]

Ich hab auf Pushover umgestellt. Läuft einfach besser auf iOS Geräten

[m0nn3]

Ich bekomme immer eine Fehlermeldung:

failed configuring push service shout: cannot create messenger type 'shout': error initializing router services: parse "ntfy://m0nn3:Password": invalid port ":Password" after host

PS: Es lag an meinem Passwort, da ich einfach meinen Passwort Manager genommen habe und dieser hat ein # Zeichen benutzt.

Danke :)