Merge remote-tracking branch 'origin/dev' into dev

kernel/model/repository.go

@@ -563,33 +563,41 @@ func subscribeEvents() {
 		util.SetBootDetails(msg)
 		contextPushMsg(context, msg)
 	})
+
+	count := 0
 	eventbus.Subscribe(dejavu.EvtIndexWalkData, func(context map[string]interface{}, path string) {
 		msg := fmt.Sprintf(Conf.Language(158), path)
+		count++
+		if 0 == count%32 {
 			util.SetBootDetails(msg)
 			contextPushMsg(context, msg)
+		}
 	})
 	eventbus.Subscribe(dejavu.EvtIndexBeforeGetLatestFiles, func(context map[string]interface{}, files []string) {
 		msg := fmt.Sprintf(Conf.Language(159), len(files))
 		util.SetBootDetails(msg)
 		contextPushMsg(context, msg)
-
 	})
 	eventbus.Subscribe(dejavu.EvtIndexGetLatestFile, func(context map[string]interface{}, path string) {
 		msg := fmt.Sprintf(Conf.Language(159), path)
+		count++
+		if 0 == count%32 {
 			util.SetBootDetails(msg)
 			contextPushMsg(context, msg)
-
+		}
 	})
 	eventbus.Subscribe(dejavu.EvtIndexUpsertFiles, func(context map[string]interface{}, files []*entity.File) {
 		msg := fmt.Sprintf(Conf.Language(160), len(files))
 		util.SetBootDetails(msg)
 		contextPushMsg(context, msg)
-
 	})
 	eventbus.Subscribe(dejavu.EvtIndexUpsertFile, func(context map[string]interface{}, path string) {
 		msg := fmt.Sprintf(Conf.Language(160), path)
+		count++
+		if 0 == count%32 {
 			util.SetBootDetails(msg)
 			contextPushMsg(context, msg)
+		}
 	})
 
 	eventbus.Subscribe(dejavu.EvtCheckoutBeforeWalkData, func(context map[string]interface{}, path string) {
@@ -599,18 +607,27 @@ func subscribeEvents() {
 	})
 	eventbus.Subscribe(dejavu.EvtCheckoutWalkData, func(context map[string]interface{}, path string) {
 		msg := fmt.Sprintf(Conf.Language(161), path)
+		count++
+		if 0 == count%32 {
 			util.SetBootDetails(msg)
 			contextPushMsg(context, msg)
+		}
 	})
 	eventbus.Subscribe(dejavu.EvtCheckoutUpsertFile, func(context map[string]interface{}, path string) {
 		msg := fmt.Sprintf(Conf.Language(162), path)
+		count++
+		if 0 == count%32 {
 			util.SetBootDetails(msg)
 			contextPushMsg(context, msg)
+		}
 	})
 	eventbus.Subscribe(dejavu.EvtCheckoutRemoveFile, func(context map[string]interface{}, path string) {
 		msg := fmt.Sprintf(Conf.Language(163), path)
+		count++
+		if 0 == count%32 {
 			util.SetBootDetails(msg)
 			contextPushMsg(context, msg)
+		}
 	})
 
 	eventbus.Subscribe(dejavu.EvtCloudBeforeDownloadIndex, func(context map[string]interface{}, id string) {
@@ -626,8 +643,11 @@ func subscribeEvents() {
 	})
 	eventbus.Subscribe(dejavu.EvtCloudBeforeDownloadFile, func(context map[string]interface{}, id string) {
 		msg := fmt.Sprintf(Conf.Language(165), id[:7])
+		count++
+		if 0 == count%32 {
 			util.SetBootDetails(msg)
 			contextPushMsg(context, msg)
+		}
 	})
 	eventbus.Subscribe(dejavu.EvtCloudBeforeDownloadChunks, func(context map[string]interface{}, ids []string) {
 		msg := fmt.Sprintf(Conf.Language(166), len(ids))
@@ -636,8 +656,11 @@ func subscribeEvents() {
 	})
 	eventbus.Subscribe(dejavu.EvtCloudBeforeDownloadChunk, func(context map[string]interface{}, id string) {
 		msg := fmt.Sprintf(Conf.Language(166), id[:7])
+		count++
+		if 0 == count%32 {
 			util.SetBootDetails(msg)
 			contextPushMsg(context, msg)
+		}
 	})
 	eventbus.Subscribe(dejavu.EvtCloudBeforeDownloadRef, func(context map[string]interface{}, ref string) {
 		msg := fmt.Sprintf(Conf.Language(167), ref)
@@ -656,8 +679,11 @@ func subscribeEvents() {
 	})
 	eventbus.Subscribe(dejavu.EvtCloudBeforeUploadFile, func(context map[string]interface{}, id string) {
 		msg := fmt.Sprintf(Conf.Language(169), id[:7])
+		count++
+		if 0 == count%32 {
 			util.SetBootDetails(msg)
 			contextPushMsg(context, msg)
+		}
 	})
 	eventbus.Subscribe(dejavu.EvtCloudBeforeUploadChunks, func(context map[string]interface{}, ids []string) {
 		msg := fmt.Sprintf(Conf.Language(170), len(ids))
@@ -666,8 +692,11 @@ func subscribeEvents() {
 	})
 	eventbus.Subscribe(dejavu.EvtCloudBeforeUploadChunk, func(context map[string]interface{}, id string) {
 		msg := fmt.Sprintf(Conf.Language(170), id[:7])
+		count++
+		if 0 == count%32 {
 			util.SetBootDetails(msg)
 			contextPushMsg(context, msg)
+		}
 	})
 	eventbus.Subscribe(dejavu.EvtCloudBeforeUploadRef, func(context map[string]interface{}, ref string) {
 		msg := fmt.Sprintf(Conf.Language(171), ref)