You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
44 lines
1.3 KiB
44 lines
1.3 KiB
package webhooks |
|
|
|
import ( |
|
"sync" |
|
"time" |
|
|
|
"github.com/owncast/owncast/core/data" |
|
"github.com/owncast/owncast/core/user" |
|
"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) { |
|
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) |
|
} |
|
}
|
|
|