back round 4 view raw

appview/indexer: handle `NewIssueClosed` #695

merged

opened by

boltless.me 1 month ago targeting master from boltless.me/core: feat/search

Doesn't suport issue reopen yet

Signed-off-by: Seongmin Lee git@boltless.me

options

unified split

Changed files

+17

appview

indexer

notifier.go

issues

issues.go

appview/indexer/notifier.go

···

       19
        
       	}

     

       20
        
       }

     

       21
        
       

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       22
        
       func (ix *Indexer) DeleteIssue(ctx context.Context, issue *models.Issue) {

     

       23
        
       	l := log.FromContext(ctx).With("notifier", "indexer.DeleteIssue", "issue", issue)

     

       24
        
       	l.Debug("deleting an issue")

···

       19
        
       	}

     

       20
        
       }

     

       21
        
       

     

       22
       +
       func (ix *Indexer) NewIssueClosed(ctx context.Context, issue *models.Issue) {

     

       23
       +
       	l := log.FromContext(ctx).With("notifier", "indexer.NewIssueClosed", "issue", issue)

     

       24
       +
       	l.Debug("updating an issue")

     

       25
       +
       	err := ix.Issues.Index(ctx, *issue)

     

       26
       +
       	if err != nil {

     

       27
       +
       		l.Error("failed to index an issue", "err", err)

     

       28
       +
       	}

     

       29
       +
       }

     

       30
       +
       

     

       31
        
       func (ix *Indexer) DeleteIssue(ctx context.Context, issue *models.Issue) {

     

       32
        
       	l := log.FromContext(ctx).With("notifier", "indexer.DeleteIssue", "issue", issue)

     

       33
        
       	l.Debug("deleting an issue")

appview/issues/issues.go

···

       305
        
       			rp.pages.Notice(w, "issue-action", "Failed to close issue. Try again later.")

     

       306
        
       			return

     

       307
        
       		}

     

       0
        
       
     

       0
        
       
     

       308
        
       

     

       309
        
       		// notify about the issue closure

     

       310
        
       		rp.notifier.NewIssueClosed(r.Context(), issue)

     
···

       353
        
       			rp.pages.Notice(w, "issue-action", "Failed to reopen issue. Try again later.")

     

       354
        
       			return

     

       355
        
       		}

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       356
        
       		rp.pages.HxLocation(w, fmt.Sprintf("/%s/issues/%d", f.OwnerSlashRepo(), issue.IssueId))

     

       357
        
       		return

     

       358
        
       	} else {

···

       305
        
       			rp.pages.Notice(w, "issue-action", "Failed to close issue. Try again later.")

     

       306
        
       			return

     

       307
        
       		}

     

       308
       +
       		// change the issue state (this will pass down to the notifiers)

     

       309
       +
       		issue.Open = false

     

       310
        
       

     

       311
        
       		// notify about the issue closure

     

       312
        
       		rp.notifier.NewIssueClosed(r.Context(), issue)

     
···

       355
        
       			rp.pages.Notice(w, "issue-action", "Failed to reopen issue. Try again later.")

     

       356
        
       			return

     

       357
        
       		}

     

       358
       +
       		// change the issue state (this will pass down to the notifiers)

     

       359
       +
       		issue.Open = true

     

       360
       +
       

     

       361
       +
       		// // notify about the issue reopen

     

       362
       +
       		// rp.notifier.NewIssueReopen(r.Context(), issue)

     

       363
       +
       

     

       364
        
       		rp.pages.HxLocation(w, fmt.Sprintf("/%s/issues/%d", f.OwnerSlashRepo(), issue.IssueId))

     

       365
        
       		return

     

       366
        
       	} else {