0ct0pu5/siyuan
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

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

Browse source
This commit is contained in:
Vanessa 2022-07-07 23:11:17 +08:00
commit 88bc3a150b
3 changed files with 20 additions and 24 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
kernel/filesys/tree.go
View file

@ -73,13 +73,13 @@ func LoadTree(boxID, p string, luteEngine *lute.Lute) (ret *parse.Tree, err erro
parentPath = filepath.Join(util.DataDir, boxID, parentPath) parentPath = filepath.Join(util.DataDir, boxID, parentPath)
parentData, readErr := filelock.LockFileRead(parentPath) parentData, readErr := filelock.LockFileRead(parentPath)
if nil != readErr { if nil != readErr {
util.LogWarnf("read tree data [%s] failed: %s", parentPath, err) util.LogWarnf("read tree data [%s] failed: %s", parentPath, readErr)
hPathBuilder.WriteString("Untitled/") hPathBuilder.WriteString("Untitled/")
continue continue
} }
parentTree, parseErr := protyle.ParseJSONWithoutFix(luteEngine, parentData) parentTree, parseErr := protyle.ParseJSONWithoutFix(luteEngine, parentData)
if nil != parseErr { if nil != parseErr {
util.LogWarnf("parse tree [%s] failed: %s", parentPath, err) util.LogWarnf("parse tree [%s] failed: %s", parentPath, parseErr)
hPathBuilder.WriteString("Untitled/") hPathBuilder.WriteString("Untitled/")
continue continue
} }

34
kernel/model/repository.go
View file

@ -512,7 +512,9 @@ func indexRepoBeforeCloudSync(repo *dejavu.Repo) (err error) {
dejavu.CtxPushMsg: dejavu.CtxPushMsgToStatusBar, dejavu.CtxPushMsg: dejavu.CtxPushMsgToStatusBar,
}) })
if nil != err { if nil != err {
util.PushStatusBar(fmt.Sprintf(Conf.Language(140), err)) msg := fmt.Sprintf(Conf.Language(140), err)
util.PushStatusBar(msg)
util.PushErrMsg(msg, 5000)
util.LogErrorf("index data repo before cloud sync failed: %s", err) util.LogErrorf("index data repo before cloud sync failed: %s", err)
return return
} }
@ -542,92 +544,92 @@ func newRepository() (ret *dejavu.Repo, err error) {
ignoreLines = append(ignoreLines, "/.siyuan/conf.json") // 忽略旧版同步配置 ignoreLines = append(ignoreLines, "/.siyuan/conf.json") // 忽略旧版同步配置
ret, err = dejavu.NewRepo(util.DataDir, util.RepoDir, util.HistoryDir, util.TempDir, Conf.Repo.Key, ignoreLines) ret, err = dejavu.NewRepo(util.DataDir, util.RepoDir, util.HistoryDir, util.TempDir, Conf.Repo.Key, ignoreLines)
if nil != err { if nil != err {
util.LogErrorf("init data repository failed: %s", err) util.LogErrorf("init data repo failed: %s", err)
} }
return return
} }
func subscribeEvents() { func subscribeEvents() {
eventbus.Subscribe(dejavu.EvtIndexWalkData, func(context map[string]interface{}, path string) { eventbus.Subscribe(dejavu.EvtIndexWalkData, func(context map[string]interface{}, path string) {
msg := "Indexing data repository [walk data " + path + "]" msg := "Indexing data repo [walk data " + path + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
}) })
eventbus.Subscribe(dejavu.EvtIndexGetLatestFile, func(context map[string]interface{}, path string) { eventbus.Subscribe(dejavu.EvtIndexGetLatestFile, func(context map[string]interface{}, path string) {
msg := "Indexing data repository [get latest file " + path + "]" msg := "Indexing data repo [get latest file " + path + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
}) })
eventbus.Subscribe(dejavu.EvtIndexUpsertFile, func(context map[string]interface{}, path string) { eventbus.Subscribe(dejavu.EvtIndexUpsertFile, func(context map[string]interface{}, path string) {
msg := "Indexing data repository [upsert file " + path + "]" msg := "Indexing data repo [upsert file " + path + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
}) })
eventbus.Subscribe(dejavu.EvtCheckoutWalkData, func(context map[string]interface{}, path string) { eventbus.Subscribe(dejavu.EvtCheckoutWalkData, func(context map[string]interface{}, path string) {
msg := "Checkout data repository [walk data " + path + "]" msg := "Checkout data repo [walk data " + path + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
}) })
eventbus.Subscribe(dejavu.EvtCheckoutUpsertFile, func(context map[string]interface{}, path string) { eventbus.Subscribe(dejavu.EvtCheckoutUpsertFile, func(context map[string]interface{}, path string) {
msg := "Checkout data repository [upsert file " + path + "]" msg := "Checkout data repo [upsert file " + path + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
}) })
eventbus.Subscribe(dejavu.EvtCheckoutRemoveFile, func(context map[string]interface{}, path string) { eventbus.Subscribe(dejavu.EvtCheckoutRemoveFile, func(context map[string]interface{}, path string) {
msg := "Checkout data repository [remove file " + path + "]" msg := "Checkout data repo [remove file " + path + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
}) })
eventbus.Subscribe(dejavu.EvtCloudBeforeDownloadIndex, func(context map[string]interface{}, id string) { eventbus.Subscribe(dejavu.EvtCloudBeforeDownloadIndex, func(context map[string]interface{}, id string) {
msg := "Downloading data repository index [" + id + "]" msg := "Downloading data repo index [" + id + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
}) })
eventbus.Subscribe(dejavu.EvtCloudBeforeDownloadFile, func(context map[string]interface{}, id string) { eventbus.Subscribe(dejavu.EvtCloudBeforeDownloadFile, func(context map[string]interface{}, id string) {
msg := "Downloading data repository file [" + id + "]" msg := "Downloading data repo file [" + id + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
//util.LogInfof("%s", msg) //util.LogInfof("%s", msg)
}) })
eventbus.Subscribe(dejavu.EvtCloudBeforeDownloadChunk, func(context map[string]interface{}, id string) { eventbus.Subscribe(dejavu.EvtCloudBeforeDownloadChunk, func(context map[string]interface{}, id string) {
msg := "Downloading data repository chunk [" + id + "]" msg := "Downloading data repo chunk [" + id + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
//util.LogInfof("%s", msg) //util.LogInfof("%s", msg)
}) })
eventbus.Subscribe(dejavu.EvtCloudBeforeDownloadRef, func(context map[string]interface{}, ref string) { eventbus.Subscribe(dejavu.EvtCloudBeforeDownloadRef, func(context map[string]interface{}, ref string) {
msg := "Downloading data repository ref [" + ref + "]" msg := "Downloading data repo ref [" + ref + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
}) })
eventbus.Subscribe(dejavu.EvtCloudBeforeUploadIndex, func(context map[string]interface{}, id string) { eventbus.Subscribe(dejavu.EvtCloudBeforeUploadIndex, func(context map[string]interface{}, id string) {
msg := "Uploading data repository index [" + id + "]" msg := "Uploading data repo index [" + id + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
}) })
eventbus.Subscribe(dejavu.EvtCloudBeforeUploadFile, func(context map[string]interface{}, id string) { eventbus.Subscribe(dejavu.EvtCloudBeforeUploadFile, func(context map[string]interface{}, id string) {
msg := "Uploading data repository file [" + id + "]" msg := "Uploading data repo file [" + id + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
//util.LogInfof("%s", msg) //util.LogInfof("%s", msg)
}) })
eventbus.Subscribe(dejavu.EvtCloudBeforeUploadChunk, func(context map[string]interface{}, id string) { eventbus.Subscribe(dejavu.EvtCloudBeforeUploadChunk, func(context map[string]interface{}, id string) {
msg := "Uploading data repository chunk [" + id + "]" msg := "Uploading data repo chunk [" + id + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
//util.LogInfof("%s", msg) //util.LogInfof("%s", msg)
}) })
eventbus.Subscribe(dejavu.EvtCloudBeforeUploadRef, func(context map[string]interface{}, ref string) { eventbus.Subscribe(dejavu.EvtCloudBeforeUploadRef, func(context map[string]interface{}, ref string) {
msg := "Uploading data repository ref [" + ref + "]" msg := "Uploading data repo ref [" + ref + "]"
util.SetBootDetails(msg) util.SetBootDetails(msg)
contextPushMsg(context, msg) contextPushMsg(context, msg)
}) })

6
kernel/util/websocket.go
View file

@ -21,7 +21,6 @@ import (
"time" "time"
"github.com/88250/gulu" "github.com/88250/gulu"
"github.com/88250/lute/html"
"github.com/88250/melody" "github.com/88250/melody"
) )
@ -126,33 +125,28 @@ func ReloadUI() {
} }
func PushTxErr(msg string, code int, data interface{}) { func PushTxErr(msg string, code int, data interface{}) {
msg = html.EscapeHTMLStr(msg)
BroadcastByType("main", "txerr", code, msg, data) BroadcastByType("main", "txerr", code, msg, data)
} }
func PushUpdateMsg(msgId string, msg string, timeout int) { func PushUpdateMsg(msgId string, msg string, timeout int) {
msg = html.EscapeHTMLStr(msg)
BroadcastByType("main", "msg", 0, msg, map[string]interface{}{"id": msgId, "closeTimeout": timeout}) BroadcastByType("main", "msg", 0, msg, map[string]interface{}{"id": msgId, "closeTimeout": timeout})
return return
} }
func PushMsg(msg string, timeout int) (msgId string) { func PushMsg(msg string, timeout int) (msgId string) {
msgId = gulu.Rand.String(7) msgId = gulu.Rand.String(7)
msg = html.EscapeHTMLStr(msg)
BroadcastByType("main", "msg", 0, msg, map[string]interface{}{"id": msgId, "closeTimeout": timeout}) BroadcastByType("main", "msg", 0, msg, map[string]interface{}{"id": msgId, "closeTimeout": timeout})
return return
} }
func PushErrMsg(msg string, timeout int) (msgId string) { func PushErrMsg(msg string, timeout int) (msgId string) {
msgId = gulu.Rand.String(7) msgId = gulu.Rand.String(7)
msg = html.EscapeHTMLStr(msg)
BroadcastByType("main", "msg", -1, msg, map[string]interface{}{"id": msgId, "closeTimeout": timeout}) BroadcastByType("main", "msg", -1, msg, map[string]interface{}{"id": msgId, "closeTimeout": timeout})
return return
} }
func PushStatusBar(msg string) { func PushStatusBar(msg string) {
msg += " (" + time.Now().Format("2006-01-02 15:04:05") + ")" msg += " (" + time.Now().Format("2006-01-02 15:04:05") + ")"
msg = html.EscapeHTMLStr(msg)
BroadcastByType("main", "statusbar", 0, msg, nil) BroadcastByType("main", "statusbar", 0, msg, nil)
} }