Something went wrong. Try again.
A privacy-first, self-hosted, fully open source personal knowledge management software, written in typescript and golang. (PERSONAL FORK)
Something went wrong. Try again.
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114// SiYuan - Refactor your thinking// Copyright (c) 2020-present, b3log.org//// This program is free software: you can redistribute it and/or modify// it under the terms of the GNU Affero General Public License as published by// the Free Software Foundation, either version 3 of the License, or// (at your option) any later version.//// This program is distributed in the hope that it will be useful,// but WITHOUT ANY WARRANTY; without even the implied warranty of// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the// GNU Affero General Public License for more details.//// You should have received a copy of the GNU Affero General Public License// along with this program. If not, see <https://www.gnu.org/licenses/>.
//go:build !darwin
package model
import ( "os" "path/filepath" "time"
"github.com/88250/gulu" "github.com/fsnotify/fsnotify" "github.com/siyuan-note/logging" "github.com/siyuan-note/siyuan/kernel/cache" "github.com/siyuan-note/siyuan/kernel/util")
var assetsWatcher *fsnotify.Watcher
func WatchAssets() { if !isFileWatcherAvailable() { return }
go func() { watchAssets() }()}
func watchAssets() { assetsDir := filepath.Join(util.DataDir, "assets") if nil != assetsWatcher { assetsWatcher.Close() }
var err error if assetsWatcher, err = fsnotify.NewWatcher(); err != nil { logging.LogErrorf("add assets watcher for folder [%s] failed: %s", assetsDir, err) return }
go func() { defer logging.Recover()
var ( timer *time.Timer lastEvent fsnotify.Event ) timer = time.NewTimer(100 * time.Millisecond) <-timer.C // timer should be expired at first
for { select { case event, ok := <-assetsWatcher.Events: if !ok { return }
lastEvent = event timer.Reset(time.Millisecond * 100) case err, ok := <-assetsWatcher.Errors: if !ok { return } logging.LogErrorf("watch assets failed: %s", err) case <-timer.C: //logging.LogInfof("assets changed: %s", lastEvent) if lastEvent.Op&fsnotify.Write == fsnotify.Write { IncSync() }
// 重新缓存资源文件，以便使用 /资源 搜索 go cache.LoadAssets()
if lastEvent.Op&fsnotify.Remove == fsnotify.Remove { HandleAssetsRemoveEvent(lastEvent.Name) } else { HandleAssetsChangeEvent(lastEvent.Name) } } } }()
if !gulu.File.IsDir(assetsDir) { os.MkdirAll(assetsDir, 0755) }
if err = assetsWatcher.Add(assetsDir); err != nil { logging.LogErrorf("add assets watcher for folder [%s] failed: %s", assetsDir, err) } //logging.LogInfof("added file watcher [%s]", assetsDir)}
func CloseWatchAssets() { if nil != assetsWatcher { assetsWatcher.Close() }}