mirror of
https://github.com/kristoferssolo/telescope-frecency.nvim.git
synced 2025-10-21 20:10:38 +00:00
ada91ca486
* feat!: remove code for SQLite ref [Introduce revised telescope-frecency.nvim : neovim](https://www.reddit.com/r/neovim/comments/174m8zu/introduce_revised_telescopefrecencynvim/) I have deprecated SQLite features 4 months ago. It is the time to remove code for them. * test: fix test to load telescope validly * test: remove sqlite.lua from CI settings * test: test database as native * fix: add lacked type from old database/sqlite.lua * docs: remove description for SQLite3 logic * chore: fix types * chore: add types for Database:raw_table
88 lines
2.2 KiB
Lua
88 lines
2.2 KiB
Lua
local async = require "plenary.async" --[[@as PlenaryAsync]]
|
|
local log = require "plenary.log"
|
|
local uv = vim.loop or vim.uv
|
|
|
|
---@class FrecencyNativeWatcherMtime
|
|
---@field sec integer
|
|
---@field nsec integer
|
|
local Mtime = {}
|
|
|
|
---@param mtime FsStatMtime
|
|
---@return FrecencyNativeWatcherMtime
|
|
Mtime.new = function(mtime)
|
|
return setmetatable({ sec = mtime.sec, nsec = mtime.nsec }, Mtime)
|
|
end
|
|
|
|
---@param other FrecencyNativeWatcherMtime
|
|
---@return boolean
|
|
function Mtime:__eq(other)
|
|
return self.sec == other.sec and self.nsec == other.nsec
|
|
end
|
|
|
|
---@return string
|
|
function Mtime:__tostring()
|
|
return string.format("%d.%d", self.sec, self.nsec)
|
|
end
|
|
|
|
---@class FrecencyNativeWatcher
|
|
---@field handler UvFsEventHandle
|
|
---@field path string
|
|
---@field mtime FrecencyNativeWatcherMtime
|
|
local Watcher = {}
|
|
|
|
---@return FrecencyNativeWatcher
|
|
Watcher.new = function()
|
|
return setmetatable({ path = "", mtime = Mtime.new { sec = 0, nsec = 0 } }, { __index = Watcher })
|
|
end
|
|
|
|
---@param path string
|
|
---@param tx PlenaryAsyncControlChannelTx
|
|
function Watcher:watch(path, tx)
|
|
if self.handler then
|
|
self.handler:stop()
|
|
end
|
|
self.handler = assert(uv.new_fs_event()) --[[@as UvFsEventHandle]]
|
|
self.handler:start(path, { recursive = true }, function(err, _, _)
|
|
if err then
|
|
log.debug("failed to watch path: " .. err)
|
|
return
|
|
end
|
|
async.void(function()
|
|
-- NOTE: wait for updating mtime
|
|
async.util.sleep(50)
|
|
local stat
|
|
err, stat = async.uv.fs_stat(path)
|
|
if err then
|
|
log.debug("failed to stat path: " .. err)
|
|
return
|
|
end
|
|
local mtime = Mtime.new(stat.mtime)
|
|
if self.mtime ~= mtime then
|
|
log.debug(("mtime changed: %s -> %s"):format(self.mtime, mtime))
|
|
self.mtime = mtime
|
|
tx.send()
|
|
end
|
|
end)()
|
|
end)
|
|
end
|
|
|
|
local watcher = Watcher.new()
|
|
|
|
return {
|
|
---@param path string
|
|
---@param tx PlenaryAsyncControlChannelTx
|
|
---@return nil
|
|
watch = function(path, tx)
|
|
log.debug("watch path: " .. path)
|
|
watcher:watch(path, tx)
|
|
end,
|
|
|
|
---@param stat FsStat
|
|
---@return nil
|
|
update = function(stat)
|
|
local mtime = Mtime.new(stat.mtime)
|
|
log.debug(("update mtime: %s -> %s"):format(watcher.mtime, mtime))
|
|
watcher.mtime = mtime
|
|
end,
|
|
}
|