From b61203eec3ae81ea23b89dde279bafd17bfd9d17 Mon Sep 17 00:00:00 2001 From: oppiliappan Date: Wed, 10 Dec 2025 07:16:54 +0000 Subject: [PATCH] appview: rename refresolver module to mentions Change-Id: ozkxlrlnrmmqxpvtoqzvrwqztqpklyoz usage of the resolver is now mentionsResolver. Signed-off-by: oppiliappan --- appview/issues/issues.go | 60 +++++++++---------- appview/{refresolver => mentions}/resolver.go | 4 +- appview/pulls/pulls.go | 58 +++++++++--------- appview/state/router.go | 4 +- appview/state/state.go | 38 ++++++------ 5 files changed, 83 insertions(+), 81 deletions(-) rename appview/{refresolver => mentions}/resolver.go (98%) diff --git a/appview/issues/issues.go b/appview/issues/issues.go index 3f5dc796..2dc809ae 100644 --- a/appview/issues/issues.go +++ b/appview/issues/issues.go @@ -19,13 +19,13 @@ import ( "tangled.org/core/appview/config" "tangled.org/core/appview/db" issues_indexer "tangled.org/core/appview/indexer/issues" + "tangled.org/core/appview/mentions" "tangled.org/core/appview/models" "tangled.org/core/appview/notify" "tangled.org/core/appview/oauth" "tangled.org/core/appview/pages" "tangled.org/core/appview/pages/repoinfo" "tangled.org/core/appview/pagination" - "tangled.org/core/appview/refresolver" "tangled.org/core/appview/reporesolver" "tangled.org/core/appview/validator" "tangled.org/core/idresolver" @@ -34,18 +34,18 @@ import ( ) type Issues struct { - oauth *oauth.OAuth - repoResolver *reporesolver.RepoResolver - enforcer *rbac.Enforcer - pages *pages.Pages - idResolver *idresolver.Resolver - refResolver *refresolver.Resolver - db *db.DB - config *config.Config - notifier notify.Notifier - logger *slog.Logger - validator *validator.Validator - indexer *issues_indexer.Indexer + oauth *oauth.OAuth + repoResolver *reporesolver.RepoResolver + enforcer *rbac.Enforcer + pages *pages.Pages + idResolver *idresolver.Resolver + mentionsResolver *mentions.Resolver + db *db.DB + config *config.Config + notifier notify.Notifier + logger *slog.Logger + validator *validator.Validator + indexer *issues_indexer.Indexer } func New( @@ -54,7 +54,7 @@ func New( enforcer *rbac.Enforcer, pages *pages.Pages, idResolver *idresolver.Resolver, - refResolver *refresolver.Resolver, + mentionsResolver *mentions.Resolver, db *db.DB, config *config.Config, notifier notify.Notifier, @@ -63,18 +63,18 @@ func New( logger *slog.Logger, ) *Issues { return &Issues{ - oauth: oauth, - repoResolver: repoResolver, - enforcer: enforcer, - pages: pages, - idResolver: idResolver, - refResolver: refResolver, - db: db, - config: config, - notifier: notifier, - logger: logger, - validator: validator, - indexer: indexer, + oauth: oauth, + repoResolver: repoResolver, + enforcer: enforcer, + pages: pages, + idResolver: idResolver, + mentionsResolver: mentionsResolver, + db: db, + config: config, + notifier: notifier, + logger: logger, + validator: validator, + indexer: indexer, } } @@ -163,7 +163,7 @@ func (rp *Issues) EditIssue(w http.ResponseWriter, r *http.Request) { newIssue := issue newIssue.Title = r.FormValue("title") newIssue.Body = r.FormValue("body") - newIssue.Mentions, newIssue.References = rp.refResolver.Resolve(r.Context(), newIssue.Body) + newIssue.Mentions, newIssue.References = rp.mentionsResolver.Resolve(r.Context(), newIssue.Body) if err := rp.validator.ValidateIssue(newIssue); err != nil { l.Error("validation error", "err", err) @@ -412,7 +412,7 @@ func (rp *Issues) NewIssueComment(w http.ResponseWriter, r *http.Request) { replyTo = &replyToUri } - mentions, references := rp.refResolver.Resolve(r.Context(), body) + mentions, references := rp.mentionsResolver.Resolve(r.Context(), body) comment := models.IssueComment{ Did: user.Did, @@ -584,7 +584,7 @@ func (rp *Issues) EditIssueComment(w http.ResponseWriter, r *http.Request) { newComment := comment newComment.Body = newBody newComment.Edited = &now - newComment.Mentions, newComment.References = rp.refResolver.Resolve(r.Context(), newBody) + newComment.Mentions, newComment.References = rp.mentionsResolver.Resolve(r.Context(), newBody) record := newComment.AsRecord() @@ -912,7 +912,7 @@ func (rp *Issues) NewIssue(w http.ResponseWriter, r *http.Request) { }) case http.MethodPost: body := r.FormValue("body") - mentions, references := rp.refResolver.Resolve(r.Context(), body) + mentions, references := rp.mentionsResolver.Resolve(r.Context(), body) issue := &models.Issue{ RepoAt: f.RepoAt(), diff --git a/appview/refresolver/resolver.go b/appview/mentions/resolver.go similarity index 98% rename from appview/refresolver/resolver.go rename to appview/mentions/resolver.go index 9d569a30..3ac375c5 100644 --- a/appview/refresolver/resolver.go +++ b/appview/mentions/resolver.go @@ -1,4 +1,4 @@ -package refresolver +package mentions import ( "context" @@ -35,8 +35,10 @@ func New( func (r *Resolver) Resolve(ctx context.Context, source string) ([]syntax.DID, []syntax.ATURI) { l := r.logger.With("method", "Resolve") + rawMentions, rawRefs := markup.FindReferences(r.config.Core.AppviewHost, source) l.Debug("found possible references", "mentions", rawMentions, "refs", rawRefs) + idents := r.idResolver.ResolveIdents(ctx, rawMentions) var mentions []syntax.DID for _, ident := range idents { diff --git a/appview/pulls/pulls.go b/appview/pulls/pulls.go index 40864603..1f9ef88b 100644 --- a/appview/pulls/pulls.go +++ b/appview/pulls/pulls.go @@ -19,13 +19,13 @@ import ( "tangled.org/core/appview/config" "tangled.org/core/appview/db" pulls_indexer "tangled.org/core/appview/indexer/pulls" + "tangled.org/core/appview/mentions" "tangled.org/core/appview/models" "tangled.org/core/appview/notify" "tangled.org/core/appview/oauth" "tangled.org/core/appview/pages" "tangled.org/core/appview/pages/markup" "tangled.org/core/appview/pages/repoinfo" - "tangled.org/core/appview/refresolver" "tangled.org/core/appview/reporesolver" "tangled.org/core/appview/validator" "tangled.org/core/appview/xrpcclient" @@ -44,18 +44,18 @@ import ( ) type Pulls struct { - oauth *oauth.OAuth - repoResolver *reporesolver.RepoResolver - pages *pages.Pages - idResolver *idresolver.Resolver - refResolver *refresolver.Resolver - db *db.DB - config *config.Config - notifier notify.Notifier - enforcer *rbac.Enforcer - logger *slog.Logger - validator *validator.Validator - indexer *pulls_indexer.Indexer + oauth *oauth.OAuth + repoResolver *reporesolver.RepoResolver + pages *pages.Pages + idResolver *idresolver.Resolver + mentionsResolver *mentions.Resolver + db *db.DB + config *config.Config + notifier notify.Notifier + enforcer *rbac.Enforcer + logger *slog.Logger + validator *validator.Validator + indexer *pulls_indexer.Indexer } func New( @@ -63,7 +63,7 @@ func New( repoResolver *reporesolver.RepoResolver, pages *pages.Pages, resolver *idresolver.Resolver, - refResolver *refresolver.Resolver, + mentionsResolver *mentions.Resolver, db *db.DB, config *config.Config, notifier notify.Notifier, @@ -73,18 +73,18 @@ func New( logger *slog.Logger, ) *Pulls { return &Pulls{ - oauth: oauth, - repoResolver: repoResolver, - pages: pages, - idResolver: resolver, - refResolver: refResolver, - db: db, - config: config, - notifier: notifier, - enforcer: enforcer, - logger: logger, - validator: validator, - indexer: indexer, + oauth: oauth, + repoResolver: repoResolver, + pages: pages, + idResolver: resolver, + mentionsResolver: mentionsResolver, + db: db, + config: config, + notifier: notifier, + enforcer: enforcer, + logger: logger, + validator: validator, + indexer: indexer, } } @@ -729,7 +729,7 @@ func (s *Pulls) PullComment(w http.ResponseWriter, r *http.Request) { return } - mentions, references := s.refResolver.Resolve(r.Context(), body) + mentions, references := s.mentionsResolver.Resolve(r.Context(), body) // Start a transaction tx, err := s.db.BeginTx(r.Context(), nil) @@ -1205,7 +1205,7 @@ func (s *Pulls) createPullRequest( } } - mentions, references := s.refResolver.Resolve(r.Context(), body) + mentions, references := s.mentionsResolver.Resolve(r.Context(), body) rkey := tid.TID() initialSubmission := models.PullSubmission{ @@ -2397,7 +2397,7 @@ func (s *Pulls) newStack(ctx context.Context, repo *models.Repo, user *oauth.Use body := fp.Body rkey := tid.TID() - mentions, references := s.refResolver.Resolve(ctx, body) + mentions, references := s.mentionsResolver.Resolve(ctx, body) initialSubmission := models.PullSubmission{ Patch: fp.Raw, diff --git a/appview/state/router.go b/appview/state/router.go index 968ed403..df7e258e 100644 --- a/appview/state/router.go +++ b/appview/state/router.go @@ -266,7 +266,7 @@ func (s *State) IssuesRouter(mw *middleware.Middleware) http.Handler { s.enforcer, s.pages, s.idResolver, - s.refResolver, + s.mentionsResolver, s.db, s.config, s.notifier, @@ -283,7 +283,7 @@ func (s *State) PullsRouter(mw *middleware.Middleware) http.Handler { s.repoResolver, s.pages, s.idResolver, - s.refResolver, + s.mentionsResolver, s.db, s.config, s.notifier, diff --git a/appview/state/state.go b/appview/state/state.go index aeef9f78..2d0cf176 100644 --- a/appview/state/state.go +++ b/appview/state/state.go @@ -15,13 +15,13 @@ import ( "tangled.org/core/appview/config" "tangled.org/core/appview/db" "tangled.org/core/appview/indexer" + "tangled.org/core/appview/mentions" "tangled.org/core/appview/models" "tangled.org/core/appview/notify" dbnotify "tangled.org/core/appview/notify/db" phnotify "tangled.org/core/appview/notify/posthog" "tangled.org/core/appview/oauth" "tangled.org/core/appview/pages" - "tangled.org/core/appview/refresolver" "tangled.org/core/appview/reporesolver" "tangled.org/core/appview/validator" xrpcclient "tangled.org/core/appview/xrpcclient" @@ -43,22 +43,22 @@ import ( ) type State struct { - db *db.DB - notifier notify.Notifier - indexer *indexer.Indexer - oauth *oauth.OAuth - enforcer *rbac.Enforcer - pages *pages.Pages - idResolver *idresolver.Resolver - refResolver *refresolver.Resolver - posthog posthog.Client - jc *jetstream.JetstreamClient - config *config.Config - repoResolver *reporesolver.RepoResolver - knotstream *eventconsumer.Consumer - spindlestream *eventconsumer.Consumer - logger *slog.Logger - validator *validator.Validator + db *db.DB + notifier notify.Notifier + indexer *indexer.Indexer + oauth *oauth.OAuth + enforcer *rbac.Enforcer + pages *pages.Pages + idResolver *idresolver.Resolver + mentionsResolver *mentions.Resolver + posthog posthog.Client + jc *jetstream.JetstreamClient + config *config.Config + repoResolver *reporesolver.RepoResolver + knotstream *eventconsumer.Consumer + spindlestream *eventconsumer.Consumer + logger *slog.Logger + validator *validator.Validator } func Make(ctx context.Context, config *config.Config) (*State, error) { @@ -100,7 +100,7 @@ func Make(ctx context.Context, config *config.Config) (*State, error) { repoResolver := reporesolver.New(config, enforcer, d) - refResolver := refresolver.New(config, res, d, log.SubLogger(logger, "refResolver")) + mentionsResolver := mentions.New(config, res, d, log.SubLogger(logger, "mentionsResolver")) wrapper := db.DbWrapper{Execer: d} jc, err := jetstream.NewJetstreamClient( @@ -182,7 +182,7 @@ func Make(ctx context.Context, config *config.Config) (*State, error) { enforcer, pages, res, - refResolver, + mentionsResolver, posthog, jc, config, -- 2.43.0