From b62c79a0cff349ce475d67ed23bdd5d2e0470f76 Mon Sep 17 00:00:00 2001 From: FChannel <=> Date: Sun, 24 Jan 2021 12:38:29 -0800 Subject: local actibity check --- CacheDatabase.go | 49 ++++++++++++++++++++++++++----------------------- main.go | 2 +- 2 files changed, 27 insertions(+), 24 deletions(-) diff --git a/CacheDatabase.go b/CacheDatabase.go index 93b3443..29bd4a0 100644 --- a/CacheDatabase.go +++ b/CacheDatabase.go @@ -278,37 +278,40 @@ func WriteObjectReplyToCache(db *sql.DB, obj ObjectBase) { } func WriteObjectReplyCache(db *sql.DB, obj ObjectBase) { - - for _, e := range obj.Replies.OrderedItems { - query := `select inreplyto from cachereplies where id=$1` + if obj.Replies != nil { + for _, e := range obj.Replies.OrderedItems { - rows, err := db.Query(query, obj.Id) + query := `select inreplyto from cachereplies where id=$1` - CheckError(err, "error selecting obj id cache reply") + rows, err := db.Query(query, obj.Id) - var inreplyto string - defer rows.Close() - rows.Next() - rows.Scan(&inreplyto) + CheckError(err, "error selecting obj id cache reply") - if inreplyto != "" { - return - } - - query = `insert into cachereplies (id, inreplyto) values ($1, $2)` + var inreplyto string + defer rows.Close() + rows.Next() + rows.Scan(&inreplyto) - _, err = db.Exec(query, e.Id, obj.Id) - - if err != nil{ - fmt.Println("error inserting replies cache") - panic(err) - } + if inreplyto != "" { + return + } + + query = `insert into cachereplies (id, inreplyto) values ($1, $2)` - if !IsObjectLocal(db, e.Id) { - WriteObjectToCache(db, e) - } + _, err = db.Exec(query, e.Id, obj.Id) + + if err != nil{ + fmt.Println("error inserting replies cache") + panic(err) + } + if !IsObjectLocal(db, e.Id) { + WriteObjectToCache(db, e) + } + + } + return } } diff --git a/main.go b/main.go index 874dc4d..7887138 100644 --- a/main.go +++ b/main.go @@ -1586,7 +1586,7 @@ func GetCollectionFromID(id string) Collection { resp, err := http.DefaultClient.Do(req) if err != nil { - fmt.Println("could not get collection from " + id) + CheckError(err, "could not get collection from " + id) return nColl } -- cgit v1.2.3