Something went wrong. Try again.
Monorepo for Tangled tangled.org
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124package notify
import ( "context" "sync"
"github.com/bluesky-social/indigo/atproto/syntax" "tangled.org/core/appview/models")
type mergedNotifier struct { notifiers []Notifier}
func NewMergedNotifier(notifiers []Notifier) Notifier { return &mergedNotifier{notifiers}}
var _ Notifier = &mergedNotifier{}
// fanout calls the same method on all notifiers concurrentlyfunc (m *mergedNotifier) fanout(callback func(Notifier)) { var wg sync.WaitGroup for _, n := range m.notifiers { wg.Add(1) go func(notifier Notifier) { defer wg.Done() callback(n) }(n) }}
func (m *mergedNotifier) NewRepo(ctx context.Context, repo *models.Repo) { m.fanout(func(n Notifier) { n.NewRepo(ctx, repo) })}
func (m *mergedNotifier) DeleteRepo(ctx context.Context, repo *models.Repo) { m.fanout(func(n Notifier) { n.DeleteRepo(ctx, repo) })}
func (m *mergedNotifier) RenameRepo(ctx context.Context, actor syntax.DID, oldRepo, newRepo *models.Repo) { m.fanout(func(n Notifier) { n.RenameRepo(ctx, actor, oldRepo, newRepo) })}
func (m *mergedNotifier) NewStar(ctx context.Context, star *models.Star) { m.fanout(func(n Notifier) { n.NewStar(ctx, star) })}
func (m *mergedNotifier) DeleteStar(ctx context.Context, star *models.Star) { m.fanout(func(n Notifier) { n.DeleteStar(ctx, star) })}
func (m *mergedNotifier) NewComment(ctx context.Context, comment *models.Comment, mentions []syntax.DID) { m.fanout(func(n Notifier) { n.NewComment(ctx, comment, mentions) })}
func (m *mergedNotifier) DeleteComment(ctx context.Context, comment *models.Comment) { m.fanout(func(n Notifier) { n.DeleteComment(ctx, comment) })}
func (m *mergedNotifier) NewIssue(ctx context.Context, issue *models.Issue, mentions []syntax.DID) { m.fanout(func(n Notifier) { n.NewIssue(ctx, issue, mentions) })}
func (m *mergedNotifier) NewIssueState(ctx context.Context, actor syntax.DID, issue *models.Issue) { m.fanout(func(n Notifier) { n.NewIssueState(ctx, actor, issue) })}
func (m *mergedNotifier) DeleteIssue(ctx context.Context, issue *models.Issue) { m.fanout(func(n Notifier) { n.DeleteIssue(ctx, issue) })}
func (m *mergedNotifier) NewIssueLabelOp(ctx context.Context, actor syntax.DID, issue *models.Issue, ops []models.LabelOp) { m.fanout(func(n Notifier) { n.NewIssueLabelOp(ctx, actor, issue, ops) })}
func (m *mergedNotifier) NewPullLabelOp(ctx context.Context, actor syntax.DID, pull *models.Pull, ops []models.LabelOp) { m.fanout(func(n Notifier) { n.NewPullLabelOp(ctx, actor, pull, ops) })}
func (m *mergedNotifier) NewFollow(ctx context.Context, follow *models.Follow) { m.fanout(func(n Notifier) { n.NewFollow(ctx, follow) })}
func (m *mergedNotifier) DeleteFollow(ctx context.Context, follow *models.Follow) { m.fanout(func(n Notifier) { n.DeleteFollow(ctx, follow) })}
func (m *mergedNotifier) NewPull(ctx context.Context, pull *models.Pull) { m.fanout(func(n Notifier) { n.NewPull(ctx, pull) })}
func (m *mergedNotifier) ResubmitPull(ctx context.Context, pull *models.Pull) { m.fanout(func(n Notifier) { n.ResubmitPull(ctx, pull) })}
func (m *mergedNotifier) NewPullState(ctx context.Context, actor syntax.DID, pull *models.Pull) { m.fanout(func(n Notifier) { n.NewPullState(ctx, actor, pull) })}
func (m *mergedNotifier) UpdateProfile(ctx context.Context, profile *models.Profile) { m.fanout(func(n Notifier) { n.UpdateProfile(ctx, profile) })}
func (m *mergedNotifier) NewString(ctx context.Context, s *models.String) { m.fanout(func(n Notifier) { n.NewString(ctx, s) })}
func (m *mergedNotifier) EditString(ctx context.Context, s *models.String) { m.fanout(func(n Notifier) { n.EditString(ctx, s) })}
func (m *mergedNotifier) DeleteString(ctx context.Context, did, rkey string) { m.fanout(func(n Notifier) { n.DeleteString(ctx, did, rkey) })}
func (m *mergedNotifier) Push(ctx context.Context, repo *models.Repo, ref, oldSha, newSha, committerDid string) { m.fanout(func(n Notifier) { n.Push(ctx, repo, ref, oldSha, newSha, committerDid) })}
func (m *mergedNotifier) Clone(ctx context.Context, repo *models.Repo) { m.fanout(func(n Notifier) { n.Clone(ctx, repo) })}