jlelse
/
GoBlog
mirror of https://github.com/jlelse/GoBlog
1
Fork 0
Code Packages Releases Activity

Fix hooks

This commit is contained in:
Jan-Lukas Else 2021-05-24 12:54:43 +02:00
parent b5faa6bbb2
commit a4c145e68c
5 changed files with 18 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activityPub.go
View File

@ -34,17 +34,17 @@ func initActivityPub() error {
return nil return nil
} }
// Add hooks // Add hooks
postHooks[postPostHook] = append(postHooks[postPostHook], func(p *post) { postPostHooks = append(postPostHooks, func(p *post) {
if p.isPublishedSectionPost() { if p.isPublishedSectionPost() {
p.apPost() p.apPost()
} }
}) })
postHooks[postUpdateHook] = append(postHooks[postUpdateHook], func(p *post) { postUpdateHooks = append(postUpdateHooks, func(p *post) {
if p.isPublishedSectionPost() { if p.isPublishedSectionPost() {
p.apUpdate() p.apUpdate()
} }
}) })
postHooks[postDeleteHook] = append(postHooks[postDeleteHook], func(p *post) { postDeleteHooks = append(postDeleteHooks, func(p *post) {
p.apDelete() p.apDelete()
}) })
// Prepare webfinger // Prepare webfinger

6
blogstats.go
View File

@ -13,9 +13,9 @@ func initBlogStats() {
f := func(p *post) { f := func(p *post) {
resetBlogStats(p.Blog) resetBlogStats(p.Blog)
} }
postHooks[postPostHook] = append(postHooks[postPostHook], f) postPostHooks = append(postPostHooks, f)
postHooks[postUpdateHook] = append(postHooks[postPostHook], f) postUpdateHooks = append(postUpdateHooks, f)
postHooks[postDeleteHook] = append(postHooks[postPostHook], f) postDeleteHooks = append(postDeleteHooks, f)
} }
func serveBlogStats(w http.ResponseWriter, r *http.Request) { func serveBlogStats(w http.ResponseWriter, r *http.Request) {

18
hooks.go
View File

@ -17,16 +17,14 @@ func preStartHooks() {
} }
} }
type postHookType string type postHookFunc func(*post)
const ( var (
postPostHook postHookType = "post" postPostHooks []postHookFunc
postUpdateHook postHookType = "update" postUpdateHooks []postHookFunc
postDeleteHook postHookType = "delete" postDeleteHooks []postHookFunc
) )
var postHooks = map[postHookType][]func(*post){}
func (p *post) postPostHooks() { func (p *post) postPostHooks() {
// Hooks after post published // Hooks after post published
for _, cmdTmplString := range appConfig.Hooks.PostPost { for _, cmdTmplString := range appConfig.Hooks.PostPost {
@ -37,7 +35,7 @@ func (p *post) postPostHooks() {
}) })
}(p, cmdTmplString) }(p, cmdTmplString)
} }
for _, f := range postHooks[postPostHook] { for _, f := range postPostHooks {
go f(p) go f(p)
} }
} }
@ -52,7 +50,7 @@ func (p *post) postUpdateHooks() {
}) })
}(p, cmdTmplString) }(p, cmdTmplString)
} }
for _, f := range postHooks[postUpdateHook] { for _, f := range postUpdateHooks {
go f(p) go f(p)
} }
} }
@ -66,7 +64,7 @@ func (p *post) postDeleteHooks() {
}) })
}(p, cmdTmplString) }(p, cmdTmplString)
} }
for _, f := range postHooks[postDeleteHook] { for _, f := range postDeleteHooks {
go f(p) go f(p)
} }
} }

2
telegram.go
View File

@ -21,7 +21,7 @@ func initTelegram() {
} }
} }
if enable { if enable {
postHooks[postPostHook] = append(postHooks[postPostHook], func(p *post) { postPostHooks = append(postPostHooks, func(p *post) {
if p.isPublishedSectionPost() { if p.isPublishedSectionPost() {
p.tgPost() p.tgPost()
} }

6
webmention.go
View File

@ -37,9 +37,9 @@ func initWebmention() {
_ = p.sendWebmentions() _ = p.sendWebmentions()
} }
} }
postHooks[postPostHook] = append(postHooks[postPostHook], hookFunc) postPostHooks = append(postPostHooks, hookFunc)
postHooks[postUpdateHook] = append(postHooks[postUpdateHook], hookFunc) postUpdateHooks = append(postUpdateHooks, hookFunc)
postHooks[postDeleteHook] = append(postHooks[postDeleteHook], hookFunc) postDeleteHooks = append(postDeleteHooks, hookFunc)
// Start verifier // Start verifier
initWebmentionQueue() initWebmentionQueue()
} }