Monorepo for Tangled forked from tangled.org/core
Something went wrong. Try again.
Go
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758package indexer
import ( "context"
"github.com/bluesky-social/indigo/atproto/syntax" "tangled.org/core/appview/models" "tangled.org/core/appview/notify" "tangled.org/core/log")
var _ notify.Notifier = &Indexer{}
func (ix *Indexer) NewIssue(ctx context.Context, issue *models.Issue, mentions []syntax.DID) { l := log.FromContext(ctx).With("notifier", "indexer", "issue", issue) l.Debug("indexing new issue") err := ix.Issues.Index(ctx, *issue) if err != nil { l.Error("failed to index an issue", "err", err) }}
func (ix *Indexer) NewIssueState(ctx context.Context, actor syntax.DID, issue *models.Issue) { l := log.FromContext(ctx).With("notifier", "indexer", "issue", issue) l.Debug("updating an issue") err := ix.Issues.Index(ctx, *issue) if err != nil { l.Error("failed to index an issue", "err", err) }}
func (ix *Indexer) DeleteIssue(ctx context.Context, issue *models.Issue) { l := log.FromContext(ctx).With("notifier", "indexer", "issue", issue) l.Debug("deleting an issue") err := ix.Issues.Delete(ctx, issue.Id) if err != nil { l.Error("failed to delete an issue", "err", err) }}
func (ix *Indexer) NewPull(ctx context.Context, pull *models.Pull) { l := log.FromContext(ctx).With("notifier", "indexer", "pull", pull) l.Debug("indexing new pr") err := ix.Pulls.Index(ctx, pull) if err != nil { l.Error("failed to index a pr", "err", err) }}
func (ix *Indexer) NewPullState(ctx context.Context, actor syntax.DID, pull *models.Pull) { l := log.FromContext(ctx).With("notifier", "indexer", "pull", pull) l.Debug("updating a pr") err := ix.Pulls.Index(ctx, pull) if err != nil { l.Error("failed to index a pr", "err", err) }}