gitea-image-forge/build.py
2023-02-03 02:01:01 +03:00

444 lines
13 KiB
Python
Executable File

#!/usr/bin/python3
import argparse
import json
import os
import re
import subprocess
import textwrap
from graphlib import TopologicalSorter
from pathlib import Path
from jinja2 import Template
ORG_DIR = Path("org")
class Tasks:
def __init__(self, tasks):
if tasks is None:
self._tasks = None
else:
self._tasks = json.loads(Path(tasks).read_text())
def get(self, branch, image):
if self._tasks is None:
return []
else:
if branch_tasks := self._tasks.get(branch):
return [n for n, i in branch_tasks.items() if image in i or len(i) == 0]
class Tags:
def __init__(self, tags_file, latest):
if tags_file is None:
self._tags = None
else:
tags_file = Path(tags_file)
self._tags = json.loads(tags_file.read_text())
self._latest = latest
def tags(self, branch, image):
if self._tags is None:
tags = [branch]
else:
tags = self._tags[image][branch]
if branch == self._latest:
tags.append("latest")
return tags
class DockerBuilder:
def make_from_re(self):
registry = r"(?P<registry>[\w.:]+)"
organization = r"(?P<organization>\w+)"
name = r"(?P<name>\w+)"
tag = r"(?P<tag>[\w.]+)"
return f"^FROM (:?{registry}/)?(:?{organization}/)?{name}(:?:{tag})?$"
def __init__(
self,
registry,
organization,
overwrite_organization,
latest,
dry_run,
images_info,
tasks: Tasks,
tags: Tags,
):
self.from_re = re.compile(self.make_from_re())
self.org_dir = ORG_DIR
self.images_dir = ORG_DIR / organization
self.registry = registry
self.organization = organization
if overwrite_organization:
self.overwrite_organization = overwrite_organization
else:
self.overwrite_organization = organization
self.latest = latest
self.dry_run = dry_run
self.images_info = images_info
self.tasks = tasks
self.tags = tags
def full_image(self, image):
return f"{self.organization}/{image}"
def forall_images(consume_result):
def forall_images_decorator(f):
def wrapped(self, *args, **kwargs):
for image in self.images_dir.iterdir():
image_name = "/".join(image.parts[1:])
local_kwargs = {
"image_name": image_name,
"image": image,
"dockerfile": image / "Dockerfile",
"dockerfile_template": image / "Dockerfile.template",
}
new_kwargs = kwargs | local_kwargs
yield f(self, *args, **new_kwargs)
def consumer(*args, **kwargs):
for _ in wrapped(*args, **kwargs):
pass
if consume_result:
return consumer
else:
return wrapped
return forall_images_decorator
@forall_images(consume_result=True)
def remove_dockerfiles(self, **kwargs):
if kwargs["dockerfile"].exists():
kwargs["dockerfile"].unlink()
def render_template(self, template: str, branch: str, install_pakages=None) -> str:
if self.registry:
registry = self.registry.rstrip("/") + "/"
alt_image = "alt/alt"
else:
registry = ""
alt_image = "alt"
rendered = Template(template).render(
alt_image=alt_image,
branch=branch,
install_pakages=install_pakages,
organization=self.overwrite_organization,
registry=registry,
)
return rendered
@forall_images(consume_result=True)
def render_dockerfiles(self, branch, **kwargs):
def install_pakages(*names):
tasks = self.tasks.get(branch, kwargs["image_name"])
linux32 = '$([ "$(rpm --eval %_host_cpu)" = i586 ] && echo linux32)'
if tasks:
apt_repo = "\\\n apt-get install apt-repo -y && \\"
for task in tasks:
apt_repo += f"\n {linux32} apt-repo add {task} && \\"
apt_repo += "\n apt-get update && \\"
else:
apt_repo = "\\"
update_command = f"""RUN apt-get update && {apt_repo}"""
install_command = f"""
{linux32} apt-get install -y {' '.join(names)} && \\
rm -f /var/cache/apt/archives/*.rpm \\
/var/cache/apt/*.bin \\
/var/lib/apt/lists/*.*
"""
install_command = textwrap.dedent(install_command).rstrip("\n")
install_command = textwrap.indent(install_command, " " * 4)
return update_command + install_command
dockerfile_template = kwargs["dockerfile_template"]
if dockerfile_template.exists():
rendered = self.render_template(
dockerfile_template.read_text(), branch, install_pakages
)
kwargs["dockerfile"].write_text(rendered + "\n")
@forall_images(consume_result=False)
def get_requires(self, **kwargs):
requires = set()
for line in kwargs["dockerfile"].read_text().splitlines():
if match := re.match(self.from_re, line):
from_image = match.groupdict()
if from_image["organization"] == self.organization:
requires.add(from_image["name"])
return (kwargs["image"].name, requires)
def get_build_order(self):
requires = {}
for image, image_requires in self.get_requires():
requires[image] = image_requires
ts = TopologicalSorter(requires)
return ts.static_order()
def render_full_tag(self, image, tag):
if self.registry:
registry = self.registry.rstrip("/") + "/"
else:
registry = ""
if tag:
tag = f":{tag}"
return f"{registry}{self.overwrite_organization}/{image}{tag}"
def run(self, cmd, *args, **kwargs):
if "check" not in kwargs:
kwargs["check"] = True
if self.dry_run:
pre_cmd = ["echo"]
else:
pre_cmd = []
subprocess.run(pre_cmd + cmd, *args, **kwargs)
def podman_build(self, image, arches, branch):
full_image = self.full_image(image)
if self.images_info.skip_branch(full_image, branch):
return
msg = "Building image {} for branch {} and {} arches".format(
self.full_image(image),
branch,
arches,
)
print(msg)
build_arches = set(arches) - set(self.images_info.skip_arches(full_image))
platforms = ",".join([f"linux/{a}" for a in build_arches])
tags = self.tags.tags(branch, full_image)
full_name = self.render_full_tag(image, tags[0])
rm_manifest_cmd = [
"podman",
"manifest",
"rm",
full_name,
]
self.run(rm_manifest_cmd, check=False)
build_cmd = [
"podman",
"build",
f"--manifest={full_name}",
f"--platform={platforms}",
".",
]
self.run(build_cmd, cwd=self.images_dir / image)
for tag in tags[1:]:
other_full_name = self.render_full_tag(image, tag)
tag_cmd = ["podman", "tag", full_name, other_full_name]
self.run(tag_cmd)
def podman_push(self, image, branch, sign=None):
full_image = self.full_image(image)
if self.images_info.skip_branch(full_image, branch):
return
tags = self.tags.tags(branch, full_image)
manifests = [self.render_full_tag(image, t) for t in tags]
for manifest in manifests:
print(f"Push manifest {manifest}")
cmd = [
"podman",
"manifest",
"push",
manifest,
f"docker://{manifest}",
]
if sign is not None:
cmd.append(f"--sign-by={sign}")
self.run(cmd)
class ImagesInfo:
def __init__(self):
info = {}
images_info = Path("images-info.json")
if images_info.exists():
info = json.loads(images_info.read_text())
self._info = info
def skip_arch(self, image, arch):
info = self._info.get(image, {})
return arch in info.get("skip-arches", [])
def skip_arches(self, image):
info = self._info.get(image, {})
return info.get("skip-arches", [])
def skip_branch(self, image, branch):
info = self._info.get(image, {})
return branch in info.get("skip-branches", [])
def skip_branches(self, image):
info = self._info.get(image, {})
return info.get("skip-branches", [])
def parse_args():
stages = ["build", "remove_dockerfiles", "render_dockerfiles", "push"]
arches = ["amd64", "386", "arm64", "arm", "ppc64le"]
branches = ["p9", "p10", "sisyphus"]
organizations = list(ORG_DIR.iterdir())
images = [f"{o.name}/{i.name}" for o in organizations for i in o.iterdir()]
organizations = [o.name for o in organizations]
parser = argparse.ArgumentParser(
formatter_class=argparse.ArgumentDefaultsHelpFormatter,
)
images_group = parser.add_mutually_exclusive_group(required=True)
images_group.add_argument(
"-i",
"--images",
nargs="+",
default=images,
choices=images,
help="list of branches",
)
images_group.add_argument(
"-o",
"--organizations",
nargs="+",
default=organizations,
choices=organizations,
help="build all images from these organizations",
)
parser.add_argument(
"-r",
"--registry",
default="registry.altlinux.org",
)
parser.add_argument(
"--overwrite-organization",
)
parser.add_argument(
"-l",
"--latest",
default="p10",
)
parser.add_argument(
"--tasks",
type=Tasks,
default=Tasks(None),
)
parser.add_argument(
"--tags",
help="use tags from TAGS file",
)
parser.add_argument(
"--dry-run",
action="store_true",
help="print instead of running docker commands",
)
parser.add_argument(
"--sign",
)
parser.add_argument(
"--skip-images",
nargs="+",
default=[],
choices=images,
help="list of skipping images",
)
parser.add_argument(
"-a",
"--arches",
nargs="+",
default=arches,
choices=arches,
help="list of arches",
)
parser.add_argument(
"--skip-arches",
nargs="+",
default=[],
choices=arches,
help="list of skipping arches",
)
parser.add_argument(
"-b",
"--branches",
nargs="+",
default=branches,
choices=branches,
help="list of branches",
)
parser.add_argument(
"--skip-branches",
nargs="+",
default=[],
choices=branches,
help="list of skipping branches",
)
parser.add_argument(
"--stages",
nargs="+",
default=stages,
choices=stages,
help="list of stages",
)
parser.add_argument(
"--skip-stages",
nargs="+",
default=[],
choices=stages,
help="list of skipping stages",
)
args = parser.parse_args()
args.stages = set(args.stages) - set(args.skip_stages)
args.branches = set(args.branches) - set(args.skip_branches)
args.images = set(args.images) - set(args.skip_images)
return args
def main():
args = parse_args()
images_info = ImagesInfo()
tags = Tags(args.tags, args.latest)
for organization in args.organizations:
for branch in args.branches:
db = DockerBuilder(
args.registry,
organization,
args.overwrite_organization,
args.latest,
args.dry_run,
images_info,
args.tasks,
tags,
)
if "remove_dockerfiles" in args.stages:
db.remove_dockerfiles()
if "render_dockerfiles" in args.stages:
db.render_dockerfiles(branch)
for image in db.get_build_order():
if f"{organization}/{image}" not in args.images:
continue
if "build" in args.stages:
db.podman_build(image, args.arches, branch)
if "push" in args.stages:
db.podman_push(image, branch, args.sign)
if __name__ == "__main__":
main()
# vim: colorcolumn=89