mirror of
https://github.com/owncast/owncast.git
synced 2024-11-24 13:50:06 +03:00
2ccd3aad87
* It builds with the new user repository * fix(test): fix broken test * fix(api): fix registration endpoint that was broken after the change * fix(test): update test to reflect new user repository * fix: use interface type instead of concrete type * fix: restore commented out code
43 lines
1.2 KiB
Go
43 lines
1.2 KiB
Go
package webhooks
|
|
|
|
import (
|
|
"sync"
|
|
"time"
|
|
|
|
"github.com/owncast/owncast/core/data"
|
|
"github.com/owncast/owncast/models"
|
|
)
|
|
|
|
// WebhookEvent represents an event sent as a webhook.
|
|
type WebhookEvent struct {
|
|
EventData interface{} `json:"eventData,omitempty"`
|
|
Type models.EventType `json:"type"` // messageSent | userJoined | userNameChange
|
|
}
|
|
|
|
// WebhookChatMessage represents a single chat message sent as a webhook payload.
|
|
type WebhookChatMessage struct {
|
|
User *models.User `json:"user,omitempty"`
|
|
Timestamp *time.Time `json:"timestamp,omitempty"`
|
|
Body string `json:"body,omitempty"`
|
|
RawBody string `json:"rawBody,omitempty"`
|
|
ID string `json:"id,omitempty"`
|
|
ClientID uint `json:"clientId,omitempty"`
|
|
Visible bool `json:"visible"`
|
|
}
|
|
|
|
// SendEventToWebhooks will send a single webhook event to all webhook destinations.
|
|
func SendEventToWebhooks(payload WebhookEvent) {
|
|
sendEventToWebhooks(payload, nil)
|
|
}
|
|
|
|
func sendEventToWebhooks(payload WebhookEvent, wg *sync.WaitGroup) {
|
|
webhooks := data.GetWebhooksForEvent(payload.Type)
|
|
|
|
for _, webhook := range webhooks {
|
|
// Use wg to track the number of notifications to be sent.
|
|
if wg != nil {
|
|
wg.Add(1)
|
|
}
|
|
addToQueue(webhook, payload, wg)
|
|
}
|
|
}
|