diff --git a/fedilogue/retrieve.go b/fedilogue/retrieve.go index a6fe17f..52883cf 100644 --- a/fedilogue/retrieve.go +++ b/fedilogue/retrieve.go @@ -96,11 +96,12 @@ func check_activity(uri string) { o.Recentactivities.Mu.Lock() i, _ := o.Recentactivities.Contains(uri) if i != -1 { - logDebug("Ignoring recent request: ", uri) + logDebug("Ignoring cached recent request: ", uri) o.Recentactivities.Mu.Unlock() return } + o.Recentactivities.Add(uri, "") // Added blank entry o.Recentactivities.Mu.Unlock() var jsondocument string @@ -149,6 +150,7 @@ func check_activity(uri string) { // If AttributedTo is blank, this is likely an authentication failure // For now, skip it... if activityjson.AttributedTo == "" { + logDebug("AttributedTo field is blank, dropping for ", uri) return } @@ -208,6 +210,7 @@ func check_actor(uri string) *ActorJson { // Check if there were any recent requests on this o, _ := GetRunner(actorjson.instance) if o.Banned { + logDebug("Banned actor: ", uri) return nil // Banned actor } o.Recentactors.Mu.Lock() @@ -248,6 +251,7 @@ func check_actor(uri string) *ActorJson { body, err := ioutil.ReadAll(resp.Body) if err != nil { + logWarn("Unable to read body from ", uri) return nil // Unable to read body of message } resp.Body.Close() @@ -256,8 +260,10 @@ func check_actor(uri string) *ActorJson { err = json.Unmarshal(body, &actorjson) if err != nil { + logWarn("Unable to unmarshal body from ", uri) return nil // Unable to unmarshal body of message } + o.Recentactors.Add(uri, actorjson) var bot bool if actorjson.Type == "Service" {