back round 0 view raw

appview/{notify,strings}: notify on string create/edit/delete ops #572

merged

opened by

anirudh.fi 3 months ago targeting master from push-zwoymssunvsp

Signed-off-by: Anirudh Oppiliappan did:plc:hwevmowznbiukdf6uk5dwrrq

options

unified split

Changed files

+34

appview

notify

merged_notifier.go

notifier.go

strings

strings.go

+18

appview/notify/merged_notifier.go

···

       66
       66
        
       		notifier.UpdateProfile(ctx, profile)

     

       67
       67
        
       	}

     

       68
       68
        
       }

     

       69
       69
       +
       

     

       70
       70
       +
       func (m *mergedNotifier) NewString(ctx context.Context, string *db.String) {

     

       71
       71
       +
       	for _, notifier := range m.notifiers {

     

       72
       72
       +
       		notifier.NewString(ctx, string)

     

       73
       73
       +
       	}

     

       74
       74
       +
       }

     

       75
       75
       +
       

     

       76
       76
       +
       func (m *mergedNotifier) EditString(ctx context.Context, string *db.String) {

     

       77
       77
       +
       	for _, notifier := range m.notifiers {

     

       78
       78
       +
       		notifier.EditString(ctx, string)

     

       79
       79
       +
       	}

     

       80
       80
       +
       }

     

       81
       81
       +
       

     

       82
       82
       +
       func (m *mergedNotifier) DeleteString(ctx context.Context, did, rkey string) {

     

       83
       83
       +
       	for _, notifier := range m.notifiers {

     

       84
       84
       +
       		notifier.DeleteString(ctx, did, rkey)

     

       85
       85
       +
       	}

     

       86
       86
       +
       }

appview/notify/notifier.go

···

       21
       21
        
       	NewPullComment(ctx context.Context, comment *db.PullComment)

     

       22
       22
        
       

     

       23
       23
        
       	UpdateProfile(ctx context.Context, profile *db.Profile)

     

       24
       24
       +
       

     

       25
       25
       +
       	NewString(ctx context.Context, s *db.String)

     

       26
       26
       +
       	EditString(ctx context.Context, s *db.String)

     

       27
       27
       +
       	DeleteString(ctx context.Context, did, rkey string)

     

       24
       28
        
       }

     

       25
       29
        
       

     

       26
       30
        
       // BaseNotifier is a listener that does nothing

     
···

       42
       46
        
       func (m *BaseNotifier) NewPullComment(ctx context.Context, comment *db.PullComment) {}

     

       43
       47
        
       

     

       44
       48
        
       func (m *BaseNotifier) UpdateProfile(ctx context.Context, profile *db.Profile) {}

     

       49
       49
       +
       

     

       50
       50
       +
       func (m *BaseNotifier) NewString(ctx context.Context, s *db.String)        {}

     

       51
       51
       +
       func (m *BaseNotifier) EditString(ctx context.Context, s *db.String)       {}

     

       52
       52
       +
       func (m *BaseNotifier) DeleteString(ctx context.Context, did, rkey string) {}

appview/strings/strings.go

···

       12
       12
        
       	"tangled.sh/tangled.sh/core/appview/config"

     

       13
       13
        
       	"tangled.sh/tangled.sh/core/appview/db"

     

       14
       14
        
       	"tangled.sh/tangled.sh/core/appview/middleware"

     

       15
       15
       +
       	"tangled.sh/tangled.sh/core/appview/notify"

     

       15
       16
        
       	"tangled.sh/tangled.sh/core/appview/oauth"

     

       16
       17
        
       	"tangled.sh/tangled.sh/core/appview/pages"

     

       17
       18
        
       	"tangled.sh/tangled.sh/core/appview/pages/markup"

     
···

       36
       37
        
       	IdResolver *idresolver.Resolver

     

       37
       38
        
       	Logger     *slog.Logger

     

       38
       39
        
       	Knotstream *eventconsumer.Consumer

     

       40
       40
       +
       	Notifier   notify.Notifier

     

       39
       41
        
       }

     

       40
       42
        
       

     

       41
       43
        
       func (s *Strings) Router(mw *middleware.Middleware) http.Handler {

     
···

       284
       286
        
       			return

     

       285
       287
        
       		}

     

       286
       288
        
       

     

       289
       289
       +
       		s.Notifier.EditString(r.Context(), &entry)

     

       290
       290
       +
       

     

       287
       291
        
       		// if that went okay, redir to the string

     

       288
       292
        
       		s.Pages.HxRedirect(w, "/strings/"+user.Handle+"/"+entry.Rkey)

     

       289
       293
        
       	}

     
···

       358
       362
        
       			return

     

       359
       363
        
       		}

     

       360
       364
        
       

     

       365
       365
       +
       		s.Notifier.NewString(r.Context(), &string)

     

       366
       366
       +
       

     

       361
       367
        
       		// successful

     

       362
       368
        
       		s.Pages.HxRedirect(w, "/strings/"+user.Handle+"/"+string.Rkey)

     

       363
       369
        
       	}

     
···

       400
       406
        
       		return

     

       401
       407
        
       	}

     

       402
       408
        
       

     

       409
       409
       +
       	s.Notifier.DeleteString(r.Context(), user.Did, rkey)

     

       410
       410
       +
       

     

       403
       411
        
       	s.Pages.HxRedirect(w, "/strings/"+user.Handle)

     

       404
       412
        
       }

     

       405
       413