Make webhook more configurable

    * Add a new constructor to have more control over the URLNotifier
    * Add 'DropWhenFull' as param in 'URLNotifierParams'

webhook/notifier.go

@@ -16,10 +16,10 @@ package webhook
 
 import (
 	"context"
+	"github.com/livekit/protocol/logger"
 	"sync"
 
 	"github.com/livekit/protocol/livekit"
-	"github.com/livekit/protocol/logger"
 )
 
 type QueuedNotifier interface {
@@ -44,6 +44,19 @@ func NewDefaultNotifier(apiKey, apiSecret string, urls []string) QueuedNotifier
 	return n
 }
 
+func NewDefaultNotifierByParams(params []URLNotifierParams) QueuedNotifier {
+	n := &DefaultNotifier{}
+	for _, p := range params {
+		if p.Logger == nil {
+			p.Logger = logger.GetLogger().WithComponent("webhook")
+		}
+
+		u := NewURLNotifier(p)
+		n.urlNotifiers = append(n.urlNotifiers, u)
+	}
+	return n
+}
+
 func (n *DefaultNotifier) Stop(force bool) {
 	wg := sync.WaitGroup{}
 	for _, u := range n.urlNotifiers {

webhook/url_notifier.go

@@ -32,11 +32,12 @@ import (
 )
 
 type URLNotifierParams struct {
-	Logger    logger.Logger
-	QueueSize int
-	URL       string
-	APIKey    string
-	APISecret string
+	Logger       logger.Logger
+	QueueSize    int
+	DropWhenFull bool
+	URL          string
+	APIKey       string
+	APISecret    string
 }
 
 const defaultQueueSize = 100
@@ -66,7 +67,7 @@ func NewURLNotifier(params URLNotifierParams) *URLNotifier {
 	n.client.Logger = &logAdapter{}
 	n.worker = core.NewQueueWorker(core.QueueWorkerParams{
 		QueueSize:    params.QueueSize,
-		DropWhenFull: true,
+		DropWhenFull: params.DropWhenFull,
 		OnDropped:    func() { n.dropped.Inc() },
 	})
 	return n
@@ -102,6 +103,10 @@ func (n *URLNotifier) Stop(force bool) {
 func (n *URLNotifier) send(event *livekit.WebhookEvent) error {
 	// set dropped count
 	event.NumDropped = n.dropped.Swap(0)
+
+	// set the when event is dequeued and being sent
+	event.DequeuedAt = time.Now().Unix()
+
 	encoded, err := protojson.Marshal(event)
 	if err != nil {
 		return err