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
|
local publish = require("mqtt.publish")
local json = require("cjson")
local hostname
local f = io.open("/proc/sys/kernel/hostname")
hostname = f:read()
f:close()
local m = {}
function shell_escape(args)
local ret = {}
for _,a in pairs(args) do
s = tostring(a)
if s:match("[^A-Za-z0-9_/:=-]") then
s = "'"..s:gsub("'", "'\\''").."'"
end
table.insert(ret,s)
end
return table.concat(ret, " ")
end
function run(args)
local h = io.popen(shell_escape(args))
local outstr = h:read("*a")
return h:close(), outstr
end
function m.postbuild(conf, aport, success)
-- upload log
local loghost,logdirprefix = (conf.logtarget or ""):match("(.*):(.*)")
if aport.logfile and loghost and logdirprefix then
local logdir = logdirprefix.."/"..hostname.."/"..aport:get_repo_name().."/"..aport.pkgname.."/"
run{"ssh", loghost, "mkdir", "-p", logdir}
run{"scp", aport.logfile, loghost..":"..logdir}
end
if not conf.mqttbroker then
return
end
local topic = ("build/%s/errors"):format(hostname)
local payload = nil
if not success then
payload = json.encode{
pkgname = aport.pkgname,
hostname = hostname,
reponame = aport:get_repo_name(),
logurl = ("%s/%s/%s/%s-%s-r%s.log"):format(
conf.logurlprefix or "https://build.alpinelinux.org/buildlogs",
hostname,
(string.match(aport.dir,"[^/]+/[^/]+$")),
aport.pkgname, aport.pkgver, aport.pkgrel),
status = success
}
end
publish.single(topic, payload, nil, true, conf.mqttbroker)
end
return m
|
