Add some debug messages

This commit is contained in:
Jan-Lukas Else 2021-11-19 17:57:38 +01:00
parent 974892e3e5
commit e0728e2ba0
1 changed files with 16 additions and 2 deletions

View File

@ -74,7 +74,12 @@ func (a *goBlog) verifyMention(m *mention) error {
} }
// Check if target has a valid status code // Check if target has a valid status code
if targetResp.StatusCode != http.StatusOK { if targetResp.StatusCode != http.StatusOK {
return a.db.deleteWebmention(m) // Ignore for now
// TODO: Reject if target is not found
// return a.db.deleteWebmention(m)
if a.cfg.Debug {
log.Printf("Webmention for unknown path: %s\n", m.Target)
}
} }
// Check if target has a redirect // Check if target has a redirect
if respReq := targetResp.Request; respReq != nil { if respReq := targetResp.Request; respReq != nil {
@ -102,6 +107,9 @@ func (a *goBlog) verifyMention(m *mention) error {
} }
// Check if source has a valid status code // Check if source has a valid status code
if sourceResp.StatusCode != http.StatusOK { if sourceResp.StatusCode != http.StatusOK {
if a.cfg.Debug {
log.Printf("Delete webmention because source doesn't have valid status code: %s\n", m.Source)
}
return a.db.deleteWebmention(m) return a.db.deleteWebmention(m)
} }
// Check if source has a redirect // Check if source has a redirect
@ -114,6 +122,9 @@ func (a *goBlog) verifyMention(m *mention) error {
err = m.verifyReader(sourceResp.Body) err = m.verifyReader(sourceResp.Body)
_ = sourceResp.Body.Close() _ = sourceResp.Body.Close()
if err != nil { if err != nil {
if a.cfg.Debug {
log.Printf("Delete webmention because verifying %s threw error: %s\n", m.Source, err.Error())
}
return a.db.deleteWebmention(m) return a.db.deleteWebmention(m)
} }
if cr := []rune(m.Content); len(cr) > 500 { if cr := []rune(m.Content); len(cr) > 500 {
@ -125,6 +136,9 @@ func (a *goBlog) verifyMention(m *mention) error {
newStatus := webmentionStatusVerified newStatus := webmentionStatusVerified
// Update or insert webmention // Update or insert webmention
if a.db.webmentionExists(m) { if a.db.webmentionExists(m) {
if a.cfg.Debug {
log.Printf("Update webmention: %s => %s\n", m.Source, m.Target)
}
// Update webmention // Update webmention
err = a.db.updateWebmention(m, newStatus) err = a.db.updateWebmention(m, newStatus)
if err != nil { if err != nil {
@ -157,7 +171,7 @@ func (m *mention) verifyReader(body io.Reader) error {
return err return err
} }
if _, hasLink := funk.FindString(links, func(s string) bool { if _, hasLink := funk.FindString(links, func(s string) bool {
return unescapedPath(s) == unescapedPath(m.Target) || unescapedPath(s) == unescapedPath(m.NewTarget) return unescapedPath(s) == unescapedPath(m.Target) || unescapedPath(s) == unescapedPath(defaultIfEmpty(m.NewTarget, m.Target))
}); !hasLink { }); !hasLink {
return errors.New("target not found in source") return errors.New("target not found in source")
} }