TBD/reforger_crawler_main
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

blocked edits

Browse Source
This commit is contained in:
Sotirios Pupakis
2025-09-09 01:32:38 +02:00
parent 597db14bc5
commit ca169f5e7e
2 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
controllers/indexerController.go
View File

@@ -27,7 +27,7 @@ func GetNextToBeIndexed(c *gin.Context) {
} }
var addon models.Addon var addon models.Addon
ret := initializers.DB.Where("to_be_indexed = ?", true).Where("is_being_indexed = ?", false).Where("priority_indexing = ?", true).Where("current_version_size <= ?", maxSize).Order("updated_at asc").First(&addon) ret := initializers.DB.Where("to_be_indexed = ?", true).Where("is_being_indexed = ?", false).Where("priority_indexing = ?", true).Where("blocked = ?", false).Where("current_version_size <= ?", maxSize).Order("updated_at asc").First(&addon)
if ret.Error == nil { if ret.Error == nil {
addon.IsBeingIndexed = true addon.IsBeingIndexed = true
@@ -43,7 +43,7 @@ func GetNextToBeIndexed(c *gin.Context) {
return return
} }
ret = initializers.DB.Where("to_be_indexed = ?", true).Where("is_being_indexed = ?", false).Where("current_version_size <= ?", maxSize).Order("updated_at asc").First(&addon) ret = initializers.DB.Where("to_be_indexed = ?", true).Where("is_being_indexed = ?", false).Where("blocked = ?", false).Where("current_version_size <= ?", maxSize).Order("updated_at asc").First(&addon)
if ret.Error != nil && ret.Error != gorm.ErrRecordNotFound { if ret.Error != nil && ret.Error != gorm.ErrRecordNotFound {
c.JSON(500, gin.H{"error": ret.Error.Error()}) c.JSON(500, gin.H{"error": ret.Error.Error()})
return return

9
controllers/scraperController.go
View File

@@ -31,9 +31,18 @@ func CreateAddon(c *gin.Context) {
} else { } else {
// addon exists, check version, update it and queue for reindexing if needed // addon exists, check version, update it and queue for reindexing if needed
if addon.CurrentVersionNumber != addonR.CurrentVersionNumber { if addon.CurrentVersionNumber != addonR.CurrentVersionNumber {
addon.Name = addonR.Name
addon.Type = addonR.Type
addon.Summary = addonR.Summary
addon.Unlisted = addonR.Unlisted
addon.Private = addonR.Private
addon.SubscriberCount = addonR.SubscriberCount
addon.Author = addonR.Author
addon.Preview = addonR.Preview
addon.CurrentVersionNumber = addonR.CurrentVersionNumber addon.CurrentVersionNumber = addonR.CurrentVersionNumber
addon.CurrentVersionID = addonR.CurrentVersionID addon.CurrentVersionID = addonR.CurrentVersionID
addon.CurrentVersionSize = addonR.CurrentVersionSize addon.CurrentVersionSize = addonR.CurrentVersionSize
addon.Blocked = addonR.Blocked
addon.ToBeIndexed = true addon.ToBeIndexed = true
initializers.DB.Save(&addon) initializers.DB.Save(&addon)
} }