refine delivery some more
This commit is contained in:
parent
5a435960be
commit
3d0cb6c737
22
activity.go
22
activity.go
|
@ -607,17 +607,23 @@ func jonkjonk(user *WhatAbout, h *Honk) (map[string]interface{}, map[string]inte
|
||||||
}
|
}
|
||||||
|
|
||||||
func honkworldwide(user *WhatAbout, honk *Honk) {
|
func honkworldwide(user *WhatAbout, honk *Honk) {
|
||||||
rcpts := make(map[string]bool)
|
|
||||||
for _, a := range honk.Audience {
|
|
||||||
if a != thewholeworld && a != user.URL {
|
|
||||||
rcpts[a] = true
|
|
||||||
}
|
|
||||||
}
|
|
||||||
jonk, _ := jonkjonk(user, honk)
|
jonk, _ := jonkjonk(user, honk)
|
||||||
jonk["@context"] = itiswhatitis
|
jonk["@context"] = itiswhatitis
|
||||||
var buf bytes.Buffer
|
var buf bytes.Buffer
|
||||||
WriteJunk(&buf, jonk)
|
WriteJunk(&buf, jonk)
|
||||||
msg := buf.Bytes()
|
msg := buf.Bytes()
|
||||||
|
|
||||||
|
rcpts := make(map[string]bool)
|
||||||
|
for _, a := range honk.Audience {
|
||||||
|
if a != thewholeworld && a != user.URL && !strings.HasSuffix(a, "/followers") {
|
||||||
|
box, _ := getboxes(a)
|
||||||
|
if box != nil && box.Shared != "" {
|
||||||
|
rcpts["%"+box.Shared] = true
|
||||||
|
} else {
|
||||||
|
rcpts[a] = true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
for _, f := range getdubs(user.ID) {
|
for _, f := range getdubs(user.ID) {
|
||||||
box, _ := getboxes(f.XID)
|
box, _ := getboxes(f.XID)
|
||||||
if box != nil && box.Shared != "" {
|
if box != nil && box.Shared != "" {
|
||||||
|
@ -627,9 +633,7 @@ func honkworldwide(user *WhatAbout, honk *Honk) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
for a := range rcpts {
|
for a := range rcpts {
|
||||||
if !strings.HasSuffix(a, "/followers") {
|
deliverate(0, user.Name, a, msg)
|
||||||
deliverate(0, user.Name, a, msg)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue