From 4ced69bd3c4c0e2e0c59b2890fe1647875680727 Mon Sep 17 00:00:00 2001
From: Steve Manuel <nilslice@gmail.com>
Date: Thu, 12 Jan 2017 12:28:05 -0800
Subject: move expensive work outside store.Update in Sort

---
 system/db/content.go | 25 ++++++++++++++++++-------
 1 file changed, 18 insertions(+), 7 deletions(-)

(limited to 'system')

diff --git a/system/db/content.go b/system/db/content.go
index 5ddf0a7..cec29fd 100644
--- a/system/db/content.go
+++ b/system/db/content.go
@@ -432,29 +432,40 @@ func SortContent(namespace string) {
 	// sort posts
 	sort.Sort(posts)
 
+	// marshal posts to json
+	var bb [][]byte
+	for i := range posts {
+		j, err := json.Marshal(posts[i])
+		if err != nil {
+			// log error and kill sort so __sorted is not in invalid state
+			log.Println("Error marshal post to json in SortContent:", err)
+			return
+		}
+
+		bb = append(bb, j)
+	}
+
 	// store in <namespace>_sorted bucket, first delete existing
 	err := store.Update(func(tx *bolt.Tx) error {
 		bname := []byte(namespace + "__sorted")
 		err := tx.DeleteBucket(bname)
 		if err != nil || err != bolt.ErrBucketNotFound {
+			fmt.Println("Error in DeleteBucket")
 			return err
 		}
 
 		b, err := tx.CreateBucketIfNotExists(bname)
 		if err != nil {
+			fmt.Println("Error in CreateBucketIfNotExists")
 			return err
 		}
 
 		// encode to json and store as 'i:post.Time()':post
-		for i := range posts {
-			j, err := json.Marshal(posts[i])
-			if err != nil {
-				return err
-			}
-
+		for i := range bb {
 			cid := fmt.Sprintf("%d:%d", i, posts[i].Time())
-			err = b.Put([]byte(cid), j)
+			err = b.Put([]byte(cid), bb[i])
 			if err != nil {
+				fmt.Println("Error in Put")
 				return err
 			}
 		}
-- 
cgit v1.2.3