:art: Update av

kernel/api/transaction.go

@@ -78,6 +78,7 @@ func performTransactions(c *gin.Context) {
 func pushTransactions(app, session string, transactions []*model.Transaction) {
 	pushMode := util.PushModeBroadcastExcludeSelf
 	if 0 < len(transactions) && 0 < len(transactions[0].DoOperations) {
+		model.WaitForWritingFiles()
 		if strings.Contains(strings.ToLower(transactions[0].DoOperations[0].Action), "attrview") {
 			pushMode = util.PushModeBroadcast
 		}

kernel/sql/queue.go

@@ -200,17 +200,17 @@ func execOp(op *dbQueueOperation, tx *sql.Tx, context map[string]interface{}) (e
 }
 
 func RebuildAttributeViewQueue(av *av.AttributeView) {
-	dbQueueLock.Lock()
-	defer dbQueueLock.Unlock()
-
-	newOp := &dbQueueOperation{av: av, inQueueTime: time.Now(), action: "av_rebuild"}
-	for i, op := range operationQueue {
-		if "av_rebuild" == op.action && op.av.ID == av.ID {
-			operationQueue[i] = newOp
-			return
-		}
-	}
-	operationQueue = append(operationQueue, newOp)
+	//dbQueueLock.Lock()
+	//defer dbQueueLock.Unlock()
+	//
+	//newOp := &dbQueueOperation{av: av, inQueueTime: time.Now(), action: "av_rebuild"}
+	//for i, op := range operationQueue {
+	//	if "av_rebuild" == op.action && op.av.ID == av.ID {
+	//		operationQueue[i] = newOp
+	//		return
+	//	}
+	//}
+	//operationQueue = append(operationQueue, newOp)
 }
 
 func BatchRemoveAssetsQueue(hashes []string) {