upstream/webhookd
1
0
Fork 0
mirror of https://github.com/ncarlier/webhookd.git synced 2025-04-09 18:43:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: Add basic auth to http notifier.

Browse Source
This commit is contained in:
Nicolas Carlier 2014-09-25 15:16:19 +00:00
parent 2d27bea493
commit 759126cbc6
1 changed files with 13 additions and 1 deletions

14
src/notification/http_notifier.go
View File

@ -9,12 +9,14 @@ import (
"net/url"
"os"
"path/filepath"
"strings"
)
type HttpNotifier struct {
URL string
From string
To string
User []string
}
func NewHttpNotifier() *HttpNotifier {
@ -24,6 +26,10 @@ func NewHttpNotifier() *HttpNotifier {
log.Println("Unable to create HTTP notifier. APP_HTTP_NOTIFIER_URL not set.")
return nil
}
user := os.Getenv("APP_HTTP_NOTIFIER_USER")
if user != "" {
notifier.User = strings.Split(user, ":")
}
notifier.From = os.Getenv("APP_NOTIFIER_FROM")
if notifier.From == "" {
notifier.From = "webhookd <noreply@nunux.org>"
@ -35,7 +41,7 @@ func NewHttpNotifier() *HttpNotifier {
return notifier
}
func (n HttpNotifier) Notify(subject string, text string, attachfile string) {
func (n *HttpNotifier) Notify(subject string, text string, attachfile string) {
log.Println("Sending notification '" + subject + "' to " + n.URL + " ...")
data := make(url.Values)
data.Set("from", n.From)
@ -75,6 +81,11 @@ func (n HttpNotifier) Notify(subject string, text string, attachfile string) {
}
defer req.Body.Close()
req.Header.Set("Content-Type", writer.FormDataContentType())
if len(n.User) == 2 {
req.SetBasicAuth(n.User[0], n.User[1])
}
// Submit the request
client := &http.Client{}
res, err := client.Do(req)
@ -86,6 +97,7 @@ func (n HttpNotifier) Notify(subject string, text string, attachfile string) {
// Check the response
if res.StatusCode != http.StatusOK {
log.Println("bad status: %s", res.Status)
log.Println(res.Body)
return
}
log.Println("HTTP notification sended with attachment: ", attachfile)