rework xonk saving to avoid crawling threads we won't ever save

This commit is contained in:
Ted Unangst 2019-04-29 14:06:34 -04:00
parent a6335e7d36
commit ef7880cadc
2 changed files with 12 additions and 11 deletions

View File

@ -240,9 +240,6 @@ func savedonk(url string, name, media string) *Donk {
} }
func needxonk(user *WhatAbout, x *Honk) bool { func needxonk(user *WhatAbout, x *Honk) bool {
if x == nil {
return false
}
if x.What == "eradicate" { if x.What == "eradicate" {
return true return true
} }
@ -386,7 +383,7 @@ func peeppeep() {
for _, item := range items { for _, item := range items {
xonk := xonkxonk(user, item) xonk := xonkxonk(user, item)
if needxonk(user, xonk) { if xonk != nil {
savexonk(user, xonk) savexonk(user, xonk)
} }
} }
@ -442,8 +439,7 @@ func xonkxonk(user *WhatAbout, item interface{}) *Honk {
} }
depth++ depth++
xonk := xonkxonkfn(obj) xonk := xonkxonkfn(obj)
if needxonk(user, xonk) { if xonk != nil {
xonk.UserID = user.ID
savexonk(user, xonk) savexonk(user, xonk)
} }
depth-- depth--
@ -516,9 +512,6 @@ func xonkxonk(user *WhatAbout, item interface{}) *Honk {
} }
if what == "honk" && rid != "" { if what == "honk" && rid != "" {
what = "tonk" what = "tonk"
if needxonkid(user, rid) {
saveoneup(rid)
}
} }
} }
if ot == "Tombstone" { if ot == "Tombstone" {
@ -581,8 +574,16 @@ func xonkxonk(user *WhatAbout, item interface{}) *Honk {
xonk.Audience = audience xonk.Audience = audience
xonk.Convoy = convoy xonk.Convoy = convoy
if needxonk(user, &xonk) {
if what == "tonk" {
if needxonkid(user, rid) {
saveoneup(rid)
}
}
return &xonk return &xonk
} }
return nil
}
return xonkxonkfn(item) return xonkxonkfn(item)
} }

View File

@ -372,7 +372,7 @@ func inbox(w http.ResponseWriter, r *http.Request) {
} }
default: default:
xonk := xonkxonk(user, j) xonk := xonkxonk(user, j)
if needxonk(user, xonk) { if xonk != nil {
savexonk(user, xonk) savexonk(user, xonk)
} }
} }