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 ++++++++++++++++++++++++++-----------------------
 1 file changed, 26 insertions(+), 23 deletions(-)

(limited to 'CacheDatabase.go')

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 
 	}
 }
 
-- 
cgit v1.2.3