Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154package indexer
import ( "context"
"github.com/bluesky-social/indigo/atproto/syntax" "tangled.org/core/appview/db" "tangled.org/core/appview/models" "tangled.org/core/appview/notify" "tangled.org/core/log" "tangled.org/core/orm")
var _ notify.Notifier = &Indexer{}
func (ix *Indexer) getAndReindexRepo(ctx context.Context, repoDid syntax.DID) { l := log.FromContext(ctx).With("notifier", "indexer", "repo_did", repoDid)
repo, err := db.GetRepo(ix.Db, orm.FilterEq("repo_did", string(repoDid))) if err != nil { l.Error("failed to get repo for reindexing", "err", err) return }
err = ix.Repos.Index(ctx, *repo) if err != nil { l.Error("failed to reindex repo", "err", err) }}
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) }
l.Debug("reindexing repo after new issue") ix.getAndReindexRepo(ctx, issue.RepoDid)}
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) }
l.Debug("reindexing repo after issue deletion") ix.getAndReindexRepo(ctx, issue.RepoDid)}
func (ix *Indexer) NewIssueLabelOp(ctx context.Context, _ syntax.DID, issue *models.Issue, _ []models.LabelOp) { l := log.FromContext(ctx).With("notifier", "indexer", "issue", issue) l.Debug("reindexing issue after label change") err := ix.Issues.Index(ctx, *issue) if err != nil { l.Error("failed to index an issue", "err", err) }}
func (ix *Indexer) NewPullLabelOp(ctx context.Context, _ syntax.DID, pull *models.Pull, _ []models.LabelOp) { l := log.FromContext(ctx).With("notifier", "indexer", "pull", pull) l.Debug("reindexing pull after label change") err := ix.Pulls.Index(ctx, pull) if err != nil { l.Error("failed to index a pr", "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) }
l.Debug("reindexing repo after new pull") ix.getAndReindexRepo(ctx, pull.RepoDid)}
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) }}
func (ix *Indexer) NewRepo(ctx context.Context, repo *models.Repo) { l := log.FromContext(ctx).With("notifier", "indexer", "repo", repo.RepoIdentifier(), "owner", repo.Did, "name", repo.Name) l.Debug("indexing new repo") err := ix.Repos.Index(ctx, *repo) if err != nil { l.Error("failed to index a repo", "err", err) }}
func (ix *Indexer) RenameRepo(ctx context.Context, actor syntax.DID, oldRepo, newRepo *models.Repo) { l := log.FromContext(ctx).With("notifier", "indexer", "repo", newRepo.RepoIdentifier(), "actor", actor, "old_name", oldRepo.Name, "new_name", newRepo.Name) l.Debug("reindexing repo after rename") err := ix.Repos.Index(ctx, *newRepo) if err != nil { l.Error("failed to reindex repo", "err", err) }}
func (ix *Indexer) DeleteRepo(ctx context.Context, repo *models.Repo) { l := log.FromContext(ctx).With("notifier", "indexer", "repo", repo) l.Debug("deleting repo from index") err := ix.Repos.Delete(ctx, repo.Id) if err != nil { l.Error("failed to index a repo", "err", err) }}
func (ix *Indexer) NewStar(ctx context.Context, star *models.Star) { l := log.FromContext(ctx).With("notifier", "indexer", "star", star)
if star.SubjectType != models.StarSubjectRepo { return }
l.Debug("reindexing repo after new star") ix.getAndReindexRepo(ctx, syntax.DID(star.Subject))}
func (ix *Indexer) DeleteStar(ctx context.Context, star *models.Star) { l := log.FromContext(ctx).With("notifier", "indexer", "star", star)
if star.SubjectType != models.StarSubjectRepo { return }
l.Debug("reindexing repo after star deletion") ix.getAndReindexRepo(ctx, syntax.DID(star.Subject))}