beenull/sftpgo-mirror
1
0
Fork 0
mirror of https://github.com/drakkan/sftpgo.git synced 2024-11-25 00:50:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Improve http action notification

Browse source 
Send the notification using a goroutine and set the request timeout to 15 seconds
This commit is contained in:
Nicola Murino 2019-07-27 19:29:33 +02:00
parent c4fbca9ea2
commit 4a46b84dd5
1 changed files with 19 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
sftpd/sftpd.go
View file

@ -3,6 +3,7 @@ package sftpd
import (
"fmt"
"net/http"
"net/url"
"os"
"os/exec"
"path/filepath"
@ -304,24 +305,31 @@ func executeAction(operation string, username string, path string, target string
}
}
if len(actions.HTTPNotificationURL) > 0 {
var req *http.Request
req, err = http.NewRequest(http.MethodGet, actions.HTTPNotificationURL, nil)
var url *url.URL
url, err = url.Parse(actions.HTTPNotificationURL)
if err == nil {
q := req.URL.Query()
q := url.Query()
q.Add("action", operation)
q.Add("username", username)
q.Add("path", path)
if len(target) > 0 {
q.Add("target_path", target)
}
req.URL.RawQuery = q.Encode()
resp, err := http.DefaultClient.Do(req)
respCode := 0
if err == nil {
respCode = resp.StatusCode
resp.Body.Close()
}
logger.Debug(logSender, "notified action to URL: %v status code: %v err: %v", req.URL.RequestURI(), respCode, err)
url.RawQuery = q.Encode()
go func() {
startTime := time.Now()
httpClient := &http.Client{
Timeout: 15 * time.Second,
}
resp, err := httpClient.Get(url.String())
respCode := 0
if err == nil {
respCode = resp.StatusCode
resp.Body.Close()
}
logger.Debug(logSender, "notified action to URL: %v status code: %v, elapsed: %v err: %v",
url.String(), respCode, time.Since(startTime), err)
}()
} else {
logger.Warn(logSender, "Invalid http_notification_url \"%v\" : %v", actions.HTTPNotificationURL, err)
}