diff --git a/kernel/model/repository.go b/kernel/model/repository.go index 821f91273..0c3b5a18c 100644 --- a/kernel/model/repository.go +++ b/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) - util.SetBootDetails(msg) - contextPushMsg(context, msg) + 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) - util.SetBootDetails(msg) - contextPushMsg(context, msg) - + 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) - util.SetBootDetails(msg) - contextPushMsg(context, msg) + 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) - util.SetBootDetails(msg) - contextPushMsg(context, msg) + 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) - util.SetBootDetails(msg) - contextPushMsg(context, msg) + 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) - util.SetBootDetails(msg) - contextPushMsg(context, msg) + 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]) - util.SetBootDetails(msg) - contextPushMsg(context, msg) + 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]) - util.SetBootDetails(msg) - contextPushMsg(context, msg) + 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]) - util.SetBootDetails(msg) - contextPushMsg(context, msg) + 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]) - util.SetBootDetails(msg) - contextPushMsg(context, msg) + 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)