mirror of
https://gitlab.com/kupfer/kupferbootstrap.git
synced 2025-02-23 05:35:44 -05:00
111 lines
3.5 KiB
Python
111 lines
3.5 KiB
Python
import logging
|
|
import os
|
|
import pathlib
|
|
import subprocess
|
|
import sys
|
|
|
|
from config.state import config
|
|
from exec.file import makedir
|
|
|
|
from .wrapper import BaseWrapper, WRAPPER_PATHS
|
|
|
|
DOCKER_PATHS = WRAPPER_PATHS.copy()
|
|
|
|
|
|
def docker_volumes_args(volume_mappings: dict[str, str]) -> list[str]:
|
|
result = []
|
|
for source, destination in volume_mappings.items():
|
|
result += ['-v', f'{source}:{destination}:z']
|
|
return result
|
|
|
|
|
|
class DockerWrapper(BaseWrapper):
|
|
type: str = 'docker'
|
|
|
|
def wrap(self):
|
|
script_path = config.runtime.script_source_dir
|
|
assert script_path
|
|
with open(os.path.join(script_path, 'version.txt')) as version_file:
|
|
version = version_file.read().replace('\n', '')
|
|
tag = f'registry.gitlab.com/kupfer/kupferbootstrap:{version}'
|
|
if version == 'dev':
|
|
logging.info(f'Building docker image "{tag}"')
|
|
cmd = [
|
|
'docker',
|
|
'build',
|
|
'.',
|
|
'-t',
|
|
tag,
|
|
] + (['-q'] if not config.runtime.verbose else [])
|
|
logging.debug('Running docker cmd: ' + ' '.join(cmd))
|
|
result = subprocess.run(cmd, cwd=script_path, capture_output=True)
|
|
if result.returncode != 0:
|
|
logging.fatal('Failed to build docker image:\n' + result.stderr.decode())
|
|
exit(1)
|
|
else:
|
|
# Check if the image for the version already exists
|
|
result = subprocess.run(
|
|
[
|
|
'docker',
|
|
'images',
|
|
'-q',
|
|
tag,
|
|
],
|
|
capture_output=True,
|
|
)
|
|
if result.stdout == b'':
|
|
logging.info(f'Pulling kupferbootstrap docker image version \'{version}\'')
|
|
subprocess.run([
|
|
'docker',
|
|
'pull',
|
|
tag,
|
|
])
|
|
container_name = f'kupferbootstrap-{self.uuid}'
|
|
|
|
wrapped_config = self.generate_wrapper_config()
|
|
|
|
target_user = 'root' if config.runtime.uid == 0 else 'kupfer'
|
|
target_home = '/root' if target_user == 'root' else f'/home/{target_user}'
|
|
|
|
ssh_dir = os.path.join(pathlib.Path.home(), '.ssh')
|
|
if not os.path.exists(ssh_dir):
|
|
os.makedirs(ssh_dir, mode=0o700)
|
|
volumes = self.get_bind_mounts_default(wrapped_config, ssh_dir=ssh_dir, target_home=target_home)
|
|
for vol_name, vol_dest in DOCKER_PATHS.items():
|
|
vol_src = config.get_path(vol_name)
|
|
makedir(vol_src)
|
|
volumes[vol_src] = vol_dest
|
|
docker_cmd = [
|
|
'docker',
|
|
'run',
|
|
'--name',
|
|
container_name,
|
|
'--rm',
|
|
'--interactive',
|
|
'--tty',
|
|
'--privileged',
|
|
] + docker_volumes_args(volumes) + [tag]
|
|
|
|
kupfer_cmd = ['kupferbootstrap', '--config', volumes[wrapped_config]] + self.filter_args_wrapper(sys.argv[1:])
|
|
if config.runtime.uid:
|
|
kupfer_cmd = ['wrapper_su_helper', '--uid', str(config.runtime.uid), '--username', 'kupfer', '--'] + kupfer_cmd
|
|
|
|
cmd = docker_cmd + kupfer_cmd
|
|
logging.debug('Wrapping in docker:' + repr(cmd))
|
|
result = subprocess.run(cmd)
|
|
|
|
exit(result.returncode)
|
|
|
|
def stop(self):
|
|
subprocess.run(
|
|
[
|
|
'docker',
|
|
'kill',
|
|
self.identifier,
|
|
],
|
|
stdout=subprocess.DEVNULL,
|
|
stderr=subprocess.DEVNULL,
|
|
)
|
|
|
|
|
|
wrapper = DockerWrapper()
|