Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
4.9 kB · 131 lines
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132package logging
import ( "context" "log/slog"
"github.com/bluesky-social/indigo/atproto/syntax" "tangled.org/core/appview/models" "tangled.org/core/appview/notify" tlog "tangled.org/core/log")
type loggingNotifier struct { inner notify.Notifier logger *slog.Logger}
func NewLoggingNotifier(inner notify.Notifier, logger *slog.Logger) notify.Notifier { return &loggingNotifier{inner, logger}}
var _ notify.Notifier = &loggingNotifier{}
func (l *loggingNotifier) NewRepo(ctx context.Context, repo *models.Repo) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "NewRepo")) l.inner.NewRepo(ctx, repo)}
func (l *loggingNotifier) DeleteRepo(ctx context.Context, repo *models.Repo) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "DeleteRepo")) l.inner.DeleteRepo(ctx, repo)}
func (l *loggingNotifier) RenameRepo(ctx context.Context, actor syntax.DID, oldRepo, newRepo *models.Repo) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "RenameRepo")) l.inner.RenameRepo(ctx, actor, oldRepo, newRepo)}
func (l *loggingNotifier) NewStar(ctx context.Context, star *models.Star) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "NewStar")) l.inner.NewStar(ctx, star)}
func (l *loggingNotifier) DeleteStar(ctx context.Context, star *models.Star) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "DeleteStar")) l.inner.DeleteStar(ctx, star)}
func (l *loggingNotifier) NewComment(ctx context.Context, comment *models.Comment, mentions []syntax.DID) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "NewComment")) l.inner.NewComment(ctx, comment, mentions)}func (l *loggingNotifier) DeleteComment(ctx context.Context, comment *models.Comment) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "DeleteComment")) l.inner.DeleteComment(ctx, comment)}
func (l *loggingNotifier) NewIssue(ctx context.Context, issue *models.Issue, mentions []syntax.DID) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "NewIssue")) l.inner.NewIssue(ctx, issue, mentions)}
func (l *loggingNotifier) NewIssueState(ctx context.Context, actor syntax.DID, issue *models.Issue) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "NewIssueState")) l.inner.NewIssueState(ctx, actor, issue)}
func (l *loggingNotifier) DeleteIssue(ctx context.Context, issue *models.Issue) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "DeleteIssue")) l.inner.DeleteIssue(ctx, issue)}
func (l *loggingNotifier) NewIssueLabelOp(ctx context.Context, actor syntax.DID, issue *models.Issue, ops []models.LabelOp) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "NewIssueLabelOp")) l.inner.NewIssueLabelOp(ctx, actor, issue, ops)}
func (l *loggingNotifier) NewPullLabelOp(ctx context.Context, actor syntax.DID, pull *models.Pull, ops []models.LabelOp) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "NewPullLabelOp")) l.inner.NewPullLabelOp(ctx, actor, pull, ops)}
func (l *loggingNotifier) NewFollow(ctx context.Context, follow *models.Follow) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "NewFollow")) l.inner.NewFollow(ctx, follow)}
func (l *loggingNotifier) DeleteFollow(ctx context.Context, follow *models.Follow) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "DeleteFollow")) l.inner.DeleteFollow(ctx, follow)}
func (l *loggingNotifier) NewPull(ctx context.Context, pull *models.Pull) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "NewPull")) l.inner.NewPull(ctx, pull)}
func (l *loggingNotifier) NewPullState(ctx context.Context, actor syntax.DID, pull *models.Pull) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "NewPullState")) l.inner.NewPullState(ctx, actor, pull)}
func (l *loggingNotifier) UpdateProfile(ctx context.Context, profile *models.Profile) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "UpdateProfile")) l.inner.UpdateProfile(ctx, profile)}
func (l *loggingNotifier) NewString(ctx context.Context, s *models.String) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "NewString")) l.inner.NewString(ctx, s)}
func (l *loggingNotifier) EditString(ctx context.Context, s *models.String) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "EditString")) l.inner.EditString(ctx, s)}
func (l *loggingNotifier) DeleteString(ctx context.Context, did, rkey string) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "DeleteString")) l.inner.DeleteString(ctx, did, rkey)}
func (l *loggingNotifier) Push(ctx context.Context, repo *models.Repo, ref, oldSha, newSha, committerDid string) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "Push")) l.inner.Push(ctx, repo, ref, oldSha, newSha, committerDid)}
func (l *loggingNotifier) Clone(ctx context.Context, repo *models.Repo) { ctx = tlog.IntoContext(ctx, tlog.SubLogger(l.logger, "Clone")) l.inner.Clone(ctx, repo)}