patch of appview/notify: notify users mentioned on PR comments · round #0 · pull #739 · tangled.org/core

+11 -1

appview/notify/db/db.go

···

       239
       239
        
       	)

     

       240
       240
        
       }

     

       241
       241
        
       

     

       242
       242
       -
       func (n *databaseNotifier) NewPullComment(ctx context.Context, comment *models.PullComment) {

     

       242
       242
       +
       func (n *databaseNotifier) NewPullComment(ctx context.Context, comment *models.PullComment, mentions []syntax.DID) {

     

       243
       243
        
       	pull, err := db.GetPull(n.db,

     

       244
       244
        
       		syntax.ATURI(comment.RepoAt),

     

       245
       245
        
       		comment.PullId,

     
···

       283
       283
        
       		issueId,

     

       284
       284
        
       		pullId,

     

       285
       285
        
       	)

     

       286
       286
       +
       	n.notifyEvent(

     

       287
       287
       +
       		actorDid,

     

       288
       288
       +
       		mentions,

     

       289
       289
       +
       		models.NotificationTypeUserMentioned,

     

       290
       290
       +
       		entityType,

     

       291
       291
       +
       		entityId,

     

       292
       292
       +
       		repoId,

     

       293
       293
       +
       		issueId,

     

       294
       294
       +
       		pullId,

     

       295
       295
       +
       	)

     

       286
       296
        
       }

     

       287
       297
        
       

     

       288
       298
        
       func (n *databaseNotifier) UpdateProfile(ctx context.Context, profile *models.Profile) {

+4 -4

appview/notify/notifier.go

···

       22
       22
        
       	DeleteFollow(ctx context.Context, follow *models.Follow)

     

       23
       23
        
       

     

       24
       24
        
       	NewPull(ctx context.Context, pull *models.Pull)

     

       25
       25
       -
       	NewPullComment(ctx context.Context, comment *models.PullComment)

     

       25
       25
       +
       	NewPullComment(ctx context.Context, comment *models.PullComment, mentions []syntax.DID)

     

       26
       26
        
       	NewPullState(ctx context.Context, pull *models.Pull)

     

       27
       27
        
       

     

       28
       28
        
       	UpdateProfile(ctx context.Context, profile *models.Profile)

     
···

       50
       50
        
       func (m *BaseNotifier) NewFollow(ctx context.Context, follow *models.Follow)    {}

     

       51
       51
        
       func (m *BaseNotifier) DeleteFollow(ctx context.Context, follow *models.Follow) {}

     

       52
       52
        
       

     

       53
       53
       -
       func (m *BaseNotifier) NewPull(ctx context.Context, pull *models.Pull)                 {}

     

       54
       54
       -
       func (m *BaseNotifier) NewPullComment(ctx context.Context, models *models.PullComment) {}

     

       55
       55
       -
       func (m *BaseNotifier) NewPullState(ctx context.Context, pull *models.Pull)            {}

     

       53
       53
       +
       func (m *BaseNotifier) NewPull(ctx context.Context, pull *models.Pull)                                        {}

     

       54
       54
       +
       func (m *BaseNotifier) NewPullComment(ctx context.Context, models *models.PullComment, mentions []syntax.DID) {}

     

       55
       55
       +
       func (m *BaseNotifier) NewPullState(ctx context.Context, pull *models.Pull)                                   {}

     

       56
       56
        
       

     

       57
       57
        
       func (m *BaseNotifier) UpdateProfile(ctx context.Context, profile *models.Profile) {}

     

       58
       58

+4 -3

appview/notify/posthog/notifier.go

···

       86
       86
        
       	}

     

       87
       87
        
       }

     

       88
       88
        
       

     

       89
       89
       -
       func (n *posthogNotifier) NewPullComment(ctx context.Context, comment *models.PullComment) {

     

       89
       89
       +
       func (n *posthogNotifier) NewPullComment(ctx context.Context, comment *models.PullComment, mentions []syntax.DID) {

     

       90
       90
        
       	err := n.client.Enqueue(posthog.Capture{

     

       91
       91
        
       		DistinctId: comment.OwnerDid,

     

       92
       92
        
       		Event:      "new_pull_comment",

     

       93
       93
        
       		Properties: posthog.Properties{

     

       94
       94
       -
       			"repo_at": comment.RepoAt,

     

       95
       95
       -
       			"pull_id": comment.PullId,

     

       94
       94
       +
       			"repo_at":  comment.RepoAt,

     

       95
       95
       +
       			"pull_id":  comment.PullId,

     

       96
       96
       +
       			"mentions": mentions,

     

       96
       97
        
       		},

     

       97
       98
        
       	})

     

       98
       99
        
       	if err != nil {

+12 -1

appview/pulls/pulls.go

···

       33
       33
        
       	"tangled.org/core/types"

     

       34
       34
        
       

     

       35
       35
        
       	comatproto "github.com/bluesky-social/indigo/api/atproto"

     

       36
       36
       +
       	"github.com/bluesky-social/indigo/atproto/syntax"

     

       36
       37
        
       	lexutil "github.com/bluesky-social/indigo/lex/util"

     

       37
       38
        
       	indigoxrpc "github.com/bluesky-social/indigo/xrpc"

     

       38
       39
        
       	"github.com/go-chi/chi/v5"

     
···

       690
       691
        
       }

     

       691
       692
        
       

     

       692
       693
        
       func (s *Pulls) PullComment(w http.ResponseWriter, r *http.Request) {

     

       694
       694
       +
       	l := s.logger.With("handler", "PullComment")

     

       693
       695
        
       	user := s.oauth.GetUser(r)

     

       694
       696
        
       	f, err := s.repoResolver.Resolve(r)

     

       695
       697
        
       	if err != nil {

     
···

       787
       789
        
       			return

     

       788
       790
        
       		}

     

       789
       791
        
       

     

       790
       790
       -
       		s.notifier.NewPullComment(r.Context(), comment)

     

       792
       792
       +
       		rawMentions := markup.FindUserMentions(comment.Body)

     

       793
       793
       +
       		idents := s.idResolver.ResolveIdents(r.Context(), rawMentions)

     

       794
       794
       +
       		l.Debug("parsed mentions", "raw", rawMentions, "idents", idents)

     

       795
       795
       +
       		var mentions []syntax.DID

     

       796
       796
       +
       		for _, ident := range idents {

     

       797
       797
       +
       			if ident != nil && !ident.Handle.IsInvalidHandle() {

     

       798
       798
       +
       				mentions = append(mentions, ident.DID)

     

       799
       799
       +
       			}

     

       800
       800
       +
       		}

     

       801
       801
       +
       		s.notifier.NewPullComment(r.Context(), comment, mentions)

     

       791
       802
        
       

     

       792
       803
        
       		s.pages.HxLocation(w, fmt.Sprintf("/%s/pulls/%d#comment-%d", f.OwnerSlashRepo(), pull.PullId, commentId))

     

       793
       804
        
       		return