mirror of
				https://github.com/go-gitea/gitea
				synced 2025-11-03 21:08:25 +00:00 
			
		
		
		
	* Fix incorrect logging in oauth2.go Fix #11945 Signed-off-by: Andrew Thornton <art27@cantab.net> * Handle ErrAlreadyInQueue in stats indexer Fix #12380 Signed-off-by: Andrew Thornton <art27@cantab.net> * Fixes type in error message of indexer Add the missing character in the error message. Co-authored-by: techknowlogick <techknowlogick@gitea.io> Co-authored-by: Lieven Hollevoet <hollie@lika.be> Co-authored-by: zeripath <art27@cantab.net> Co-authored-by: Lieven Hollevoet <hollie@lika.be>
This commit is contained in:
		@@ -93,7 +93,7 @@ func (o *OAuth2) userIDFromToken(ctx *macaron.Context) int64 {
 | 
				
			|||||||
	}
 | 
						}
 | 
				
			||||||
	t, err := models.GetAccessTokenBySHA(tokenSHA)
 | 
						t, err := models.GetAccessTokenBySHA(tokenSHA)
 | 
				
			||||||
	if err != nil {
 | 
						if err != nil {
 | 
				
			||||||
		if models.IsErrAccessTokenNotExist(err) || models.IsErrAccessTokenEmpty(err) {
 | 
							if !models.IsErrAccessTokenNotExist(err) && !models.IsErrAccessTokenEmpty(err) {
 | 
				
			||||||
			log.Error("GetAccessTokenBySHA: %v", err)
 | 
								log.Error("GetAccessTokenBySHA: %v", err)
 | 
				
			||||||
		}
 | 
							}
 | 
				
			||||||
		return 0
 | 
							return 0
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -21,7 +21,7 @@ func handle(data ...queue.Data) {
 | 
				
			|||||||
	for _, datum := range data {
 | 
						for _, datum := range data {
 | 
				
			||||||
		opts := datum.(int64)
 | 
							opts := datum.(int64)
 | 
				
			||||||
		if err := indexer.Index(opts); err != nil {
 | 
							if err := indexer.Index(opts); err != nil {
 | 
				
			||||||
			log.Error("stats queue idexer.Index(%d) failed: %v", opts, err)
 | 
								log.Error("stats queue indexer.Index(%d) failed: %v", opts, err)
 | 
				
			||||||
		}
 | 
							}
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
@@ -39,5 +39,11 @@ func initStatsQueue() error {
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
// UpdateRepoIndexer update a repository's entries in the indexer
 | 
					// UpdateRepoIndexer update a repository's entries in the indexer
 | 
				
			||||||
func UpdateRepoIndexer(repo *models.Repository) error {
 | 
					func UpdateRepoIndexer(repo *models.Repository) error {
 | 
				
			||||||
	return statsQueue.Push(repo.ID)
 | 
						if err := statsQueue.Push(repo.ID); err != nil {
 | 
				
			||||||
 | 
							if err != queue.ErrAlreadyInQueue {
 | 
				
			||||||
 | 
								return err
 | 
				
			||||||
 | 
							}
 | 
				
			||||||
 | 
							log.Debug("Repo ID: %d already queued", repo.ID)
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						return nil
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user