82 lines
1.8 KiB
Go
82 lines
1.8 KiB
Go
|
package barertc
|
||
|
|
|
||
|
|
import (
|
||
|
|
"bytes"
|
||
|
|
"encoding/json"
|
||
|
|
"errors"
|
||
|
|
"io"
|
||
|
|
"net/http"
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"git.kirsle.net/apps/barertc/pkg/config"
|
||
|
|
"git.kirsle.net/apps/barertc/pkg/log"
|
||
|
|
)
|
||
|
|
|
||
|
|
// The available and supported webhook event names.
|
||
|
|
const (
|
||
|
|
WebhookReport = "report"
|
||
|
|
)
|
||
|
|
|
||
|
|
// WebhookEnabled checks if the named webhook is enabled.
|
||
|
|
func WebhookEnabled(name string) bool {
|
||
|
|
for _, webhook := range config.Current.WebhookURLs {
|
||
|
|
if webhook.Name == name && webhook.Enabled {
|
||
|
|
return true
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return false
|
||
|
|
}
|
||
|
|
|
||
|
|
// GetWebhook gets a configured webhook.
|
||
|
|
func GetWebhook(name string) (config.WebhookURL, bool) {
|
||
|
|
for _, webhook := range config.Current.WebhookURLs {
|
||
|
|
if webhook.Name == name {
|
||
|
|
return webhook, true
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
return config.WebhookURL{}, false
|
||
|
|
}
|
||
|
|
|
||
|
|
// PostWebhook submits a JSON body to one of the app's configured webhooks.
|
||
|
|
func PostWebhook(name string, payload any) error {
|
||
|
|
webhook, ok := GetWebhook(name)
|
||
|
|
if !ok {
|
||
|
|
return errors.New("PostWebhook(%s): webhook name %s is not configured")
|
||
|
|
} else if !webhook.Enabled {
|
||
|
|
return errors.New("PostWebhook(%s): webhook is not enabled")
|
||
|
|
}
|
||
|
|
|
||
|
|
// JSON request body.
|
||
|
|
jsonStr, err := json.Marshal(payload)
|
||
|
|
if err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
|
||
|
|
// Make the API request to BareRTC.
|
||
|
|
var url = webhook.URL
|
||
|
|
log.Debug("PostWebhook(%s): to %s we send: %s", name, url, jsonStr)
|
||
|
|
req, err := http.NewRequest("POST", url, bytes.NewBuffer(jsonStr))
|
||
|
|
if err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
req.Header.Set("Content-Type", "application/json")
|
||
|
|
|
||
|
|
client := &http.Client{
|
||
|
|
Timeout: 10 * time.Second,
|
||
|
|
}
|
||
|
|
resp, err := client.Do(req)
|
||
|
|
if err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
defer resp.Body.Close()
|
||
|
|
|
||
|
|
if resp.StatusCode != http.StatusOK {
|
||
|
|
body, _ := io.ReadAll(resp.Body)
|
||
|
|
log.Error("PostWebhook(%s): unexpected response from webhook URL %s (code %d): %s", name, url, resp.StatusCode, body)
|
||
|
|
return errors.New("unexpected error from webhook URL")
|
||
|
|
}
|
||
|
|
|
||
|
|
return nil
|
||
|
|
}
|