Ahmed Mze

package dispatcher

import (
    "context"
    "net/http"
)

// Notifier is implemented by every output channel
// (Telegram, Discord, Email, Webhook...).
type Notifier interface {
    Notify(ctx context.Context, e Event) error
}

type Dispatcher struct {
    notifiers []Notifier
}

func New(notifiers ...Notifier) *Dispatcher {
    return &Dispatcher{notifiers: notifiers}
}

// ServeHTTP receives an event, then fans it out
// to every registered notifier concurrently.
func (d *Dispatcher) ServeHTTP(w http.ResponseWriter, r *http.Request) {
    e, err := ParseEvent(r)
    if err != nil {
        http.Error(w, err.Error(), http.StatusBadRequest)
        return
    }

    for _, notifier := range d.notifiers {
        go notifier.Notify(r.Context(), e)
    }

    w.WriteHeader(http.StatusAccepted)
}