9c484efd36
* add public func to lookup a ChatClient by its clientId * add facility to send a system message directly to a user * add clientId field to UserEvent * implement simple http endpoint to send a message to a user * let mux handle new directSystemMessageToUser endpoint * add ClientId to UserEvents across the codebase * render body of system-message to client * add clientId to Chat-Message * add tests showing how url-parsing should work * add simple rest endpoint helpers for parameter-parsing and easy routing * use newly added rest-endpoint helper to rout to Client-Messaging controller * use safe "ReadRestUrlParameter" to parse ClientId * remove empty HandleFunc in router * set Header directly to prevent built-in (platform-dependent) canonicalization to kick in * fix typo in "Parameter" message * remove debug-logging of HTTP headers in REST-helpers * convert to uint32 to prevent overruns when converting to wraptype uint later on * resolve linter-ouchies * resolve linter potential nil-deref warning * document the SendSystemMessageToClient endpoint in swaggerdoc * remove clientId assignment causing potential nil dereference in userDisabledEvent-case as the clientId isn't relevant here anyway * make findClientById private, so its not accessible outside of core/chat * remove redundant string type hint * Update PR based on linter requirements Co-authored-by: Raffael Rehberger <raffael@rtrace.io> Co-authored-by: Gabe Kangas <gabek@real-ity.com>
74 lines
1.8 KiB
Go
74 lines
1.8 KiB
Go
package webhooks
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"net/http"
|
|
"time"
|
|
|
|
log "github.com/sirupsen/logrus"
|
|
|
|
"github.com/owncast/owncast/core/user"
|
|
|
|
"github.com/owncast/owncast/core/data"
|
|
"github.com/owncast/owncast/models"
|
|
)
|
|
|
|
// WebhookEvent represents an event sent as a webhook.
|
|
type WebhookEvent struct {
|
|
Type models.EventType `json:"type"` // messageSent | userJoined | userNameChange
|
|
EventData interface{} `json:"eventData,omitempty"`
|
|
}
|
|
|
|
// WebhookChatMessage represents a single chat message sent as a webhook payload.
|
|
type WebhookChatMessage struct {
|
|
User *user.User `json:"user,omitempty"`
|
|
ClientID uint `json:"clientId,omitempty"`
|
|
Body string `json:"body,omitempty"`
|
|
RawBody string `json:"rawBody,omitempty"`
|
|
ID string `json:"id,omitempty"`
|
|
Visible bool `json:"visible"`
|
|
Timestamp *time.Time `json:"timestamp,omitempty"`
|
|
}
|
|
|
|
// SendEventToWebhooks will send a single webhook event to all webhook destinations.
|
|
func SendEventToWebhooks(payload WebhookEvent) {
|
|
webhooks := data.GetWebhooksForEvent(payload.Type)
|
|
|
|
for _, webhook := range webhooks {
|
|
log.Debugf("Event %s sent to Webhook %s", payload.Type, webhook.URL)
|
|
if err := sendWebhook(webhook.URL, payload); err != nil {
|
|
log.Errorf("Event: %s failed to send to webhook: %s Error: %s", payload.Type, webhook.URL, err)
|
|
}
|
|
}
|
|
}
|
|
|
|
func sendWebhook(url string, payload WebhookEvent) error {
|
|
jsonText, err := json.Marshal(payload)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
req, err := http.NewRequest("POST", url, bytes.NewReader(jsonText))
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
req.Header.Set("Content-Type", "application/json")
|
|
|
|
client := &http.Client{}
|
|
|
|
resp, err := client.Do(req)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
defer resp.Body.Close()
|
|
|
|
if err := data.SetWebhookAsUsed(url); err != nil {
|
|
log.Warnln(err)
|
|
}
|
|
|
|
return nil
|
|
}
|