155 lines
3.8 KiB
Lua
155 lines
3.8 KiB
Lua
|
#!/usr/bin/lua5.3
|
||
|
|
||
|
-- script to fetch and parse latest-releases.yaml from master site
|
||
|
-- and fetch the latest minirootfs images for all available branches
|
||
|
|
||
|
local request = require("http.request")
|
||
|
local cqueues = require("cqueues")
|
||
|
local yaml = require("lyaml")
|
||
|
local lfs = require("lfs")
|
||
|
|
||
|
local m = {}
|
||
|
m.mirror = os.getenv("MIRROR") or "https://cz.alpinelinux.org/alpine"
|
||
|
|
||
|
|
||
|
function m.fatal(...)
|
||
|
m.errormsg(...)
|
||
|
os.exit(1)
|
||
|
end
|
||
|
|
||
|
function m.fetch(url)
|
||
|
local headers, stream = request.new_from_uri(url):go()
|
||
|
if not headers then
|
||
|
m.fatal("Error: %s: %s", url, stream)
|
||
|
end
|
||
|
local body = stream:get_body_as_string()
|
||
|
return headers:get(":status"), body
|
||
|
end
|
||
|
|
||
|
function m.errormsg(...)
|
||
|
local msg = string.format(...)
|
||
|
io.stderr:write(string.format("%s\n", msg))
|
||
|
return nil, msg
|
||
|
end
|
||
|
|
||
|
function m.fetch_file(url, outfile)
|
||
|
local headers, stream = request.new_from_uri(url):go()
|
||
|
if not headers then
|
||
|
m.fatal("Error: %s: %s", url, stream)
|
||
|
end
|
||
|
if headers:get(":status") ~= "200" then
|
||
|
m.fatal("Error: HTTP %s: %s", headers:get(":status"), url)
|
||
|
end
|
||
|
|
||
|
local partfile = string.format("%s.part", outfile)
|
||
|
local f, errmsg = io.open(partfile, "w")
|
||
|
if not f then
|
||
|
return errormsg("Error: %s: %s:", file, errmsg)
|
||
|
end
|
||
|
local ok, errmsg, errnum = stream:save_body_to_file(f)
|
||
|
f:close()
|
||
|
if not ok then
|
||
|
return errormsg("Error: %s: %s", errmsg, url)
|
||
|
end
|
||
|
return os.rename(partfile, outfile)
|
||
|
end
|
||
|
|
||
|
function m.mkdockerfile(dir, rootfsfile)
|
||
|
local filename = string.format("%s/Dockerfile", dir)
|
||
|
local f, err = io.open(filename, "w")
|
||
|
if not f then
|
||
|
m.fatal("Error: %s: %s", filename, err)
|
||
|
end
|
||
|
f:write(string.format("FROM scratch\nADD %s /\nCMD [\"/bin/sh\"]\n", rootfsfile))
|
||
|
f:close()
|
||
|
end
|
||
|
|
||
|
function m.minirootfs_image(images)
|
||
|
for _,img in pairs(images) do
|
||
|
if img.flavor == "alpine-minirootfs" then
|
||
|
return img
|
||
|
end
|
||
|
end
|
||
|
return nil
|
||
|
end
|
||
|
|
||
|
function m.get_minirootfs(images, destdir)
|
||
|
local img = m.minirootfs_image(images)
|
||
|
if destdir then
|
||
|
local url = string.format("%s/%s/releases/%s/%s",
|
||
|
m.mirror, img.branch, img.arch, img.file)
|
||
|
local archdir = string.format("%s/%s", destdir, img.arch)
|
||
|
local ok, errmsg = lfs.mkdir(archdir)
|
||
|
m.fetch_file(url, string.format("%s/%s", archdir, img.file))
|
||
|
m.mkdockerfile(archdir, img.file)
|
||
|
print(img.file)
|
||
|
end
|
||
|
return { version=img.version, file=img.file, sha512=img.sha512 }
|
||
|
end
|
||
|
|
||
|
-- get array of minirootsfs releases --
|
||
|
function m.get_releases(branch, destdir)
|
||
|
local arches = { "aarch64", "armhf", "armv7", "ppc64le" , "riscv64", "s390x", "x86", "x86_64" }
|
||
|
local t = {}
|
||
|
local loop = cqueues.new()
|
||
|
for _, arch in pairs(arches) do
|
||
|
loop:wrap(function()
|
||
|
local url = string.format("%s/%s/releases/%s/latest-releases.yaml",
|
||
|
m.mirror, branch, arch)
|
||
|
local status, body = m.fetch(url)
|
||
|
if status == "200" then
|
||
|
t[arch] = m.get_minirootfs((yaml.load(body)), destdir)
|
||
|
end
|
||
|
end)
|
||
|
end
|
||
|
loop:loop()
|
||
|
return t
|
||
|
end
|
||
|
|
||
|
function m.equal_versions(releases)
|
||
|
local prev = nil
|
||
|
for arch, img in pairs(releases) do
|
||
|
if prev == nil then
|
||
|
prev = img.version
|
||
|
end
|
||
|
if prev ~= img.version then
|
||
|
return false, arch
|
||
|
end
|
||
|
prev = img.version
|
||
|
end
|
||
|
return true
|
||
|
end
|
||
|
|
||
|
-- return functions as module for unit testing
|
||
|
if not string.match(arg[0], "fetch%-latest%-releases") then
|
||
|
return m
|
||
|
end
|
||
|
|
||
|
local branch = arg[1] or "edge"
|
||
|
local destdir = arg[2] or "out"
|
||
|
|
||
|
lfs.mkdir(destdir)
|
||
|
|
||
|
local version
|
||
|
local releases = m.get_releases(branch, destdir)
|
||
|
|
||
|
if next(releases) == nil then
|
||
|
m.fatal("No releases found on %s/%s/releases", m.mirror, branch)
|
||
|
end
|
||
|
|
||
|
if not m.equal_versions(releases) then
|
||
|
m.fatal("not all versions are equal")
|
||
|
end
|
||
|
|
||
|
local f = io.open(string.format("%s/checksums.sha512", destdir), "w")
|
||
|
for arch,rel in pairs(releases) do
|
||
|
local line = string.format("%s %s/%s\n", rel.sha512, arch, rel.file)
|
||
|
f:write(line)
|
||
|
version=rel.version
|
||
|
end
|
||
|
f:close()
|
||
|
|
||
|
-- write version
|
||
|
f = io.open(string.format("%s/VERSION", destdir), "w")
|
||
|
f:write(version)
|
||
|
f:close()
|