1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
-- function borrowed from chmod.yazi plugin
local selected_or_hovered = ya.sync(function()
local tab = cx.active
local paths = {}
-- count up selected files
for _, url in pairs(tab.selected) do
paths[#paths + 1] = tostring(url)
end
-- if no files are selected use the hovered file
-- a tab has folders which have files which have urls
if #paths == 0 and tab.current.hovered then
-- lua so we are 1 indexed
paths[1] = tostring(tab.current.hovered.url)
end
return paths
end)
-- Helper function to expand tilde (~) in a path
local function expand_tilde(path)
if not path then
return nil
end
if path:sub(1, 1) == "~" then
local home = os.getenv("HOME") -- Get HOME environment variable
if not home then
-- Fallback for Windows-specific environment variables
home = os.getenv("USERPROFILE") -- Primary user profile directory on Windows
end
if home then
return home .. path:sub(2) -- Concatenate home path with the rest of the path
else
-- Fallback if HOME is not set
ya.notify({
title = "Rsync Plugin",
content = "Could not expand '~': HOME environment variable not set.",
level = "warn",
timeout = 5,
})
return path -- Return original path if home cannot be determined
end
end
return path -- Return original path if no tilde
end
return {
entry = function(_, job)
ya.mgr_emit("escape", { visual = true })
local remote_target = job.args and #job.args >= 1 and job.args[1] or nil
local remember = job.args and job.args.remember
local cache_file = os.getenv("HOME") .. "/.config/yazi/plugins/rsync.yazi/.last_target"
local cached_target = ""
if remember then
local f = io.open(cache_file, "r")
if f then
cached_target = f:read("*a"):match("^%s*(.-)%s*$")
f:close()
end
end
local files = selected_or_hovered()
if #files == 0 then
return ya.notify({ title = "Rsync", content = "No files selected", level = "warn", timeout = 3 })
end
local default_dest = remote_target or cached_target
if #files == 1 and remote_target ~= nil then
local base_name = files[1]:match("([^/]+)$")
default_dest = remote_target .. ":" .. base_name
ya.err({ default_dest = default_dest })
end
local dest, ok = ya.input({
title = "Rsync - [user]@[remote]:<destination>",
value = default_dest or nil,
pos = { "top-center", y = 3, w = 45 },
})
if ok ~= 1 then
return
end
-- Only expand tilde if it's a local path (doesn't contain ':')
if not dest:match(":") then
dest = expand_tilde(dest)
if not dest then
return
end -- If expand_tilde failed and returned nil
end
-- local cmd, err = Command("rsync"):args(files):arg(dest):stderr(Command.PIPED):output()
local cmd, err = Command("rsync")
:arg({ "-ahP", "--no-motd" })
:arg(files)
:arg(dest)
:stdout(Command.PIPED)
:stderr(Command.PIPED)
:output()
local stderr = cmd.stderr
local stdout = cmd.stdout
local return_code = cmd.status.code
ya.err({
stderr = stderr,
stdout = stdout,
err = err,
res = cmd.status.success,
return_code = return_code,
default_dest = default_dest,
})
if return_code ~= 0 then
ya.notify({
title = "Rsync Plugin",
content = string.format("stderr below, exit code %s\n\n%s", cmd.status.code, stderr),
level = "error",
timeout = 10,
})
else
ya.notify({
title = "Rsync Plugin",
content = "Rsync Completed!",
timeout = 3,
})
if remember and dest and dest ~= "" then
local f = io.open(cache_file, "w")
if f then
f:write(dest)
f:close()
end
end
end
end,
}
|
