<reponame>nailgun/seedbox<gh_stars>10-100
import itertools
import json

from flask import request

from seedbox import models


def render(node, indent=False):
    return IgnitionConfig(node).render(indent)


class IgnitionConfig(object):
    def __init__(self, node):
        self.node = node
        self.cluster = node.cluster

    def render(self, indent=False):
        content = self.get_content()
        if indent:
            return json.dumps(content, indent=2)
        else:
            return json.dumps(content, separators=(',', ':'))

    def get_content(self):
        packages = [P(self.node, request.url_root) for P in self.get_package_classes()]
        files = list(itertools.chain.from_iterable(p.get_files() for p in packages))
        units = list(itertools.chain.from_iterable(p.get_units() for p in packages))
        networkd_units = list(itertools.chain.from_iterable(p.get_networkd_units() for p in packages))
        ssh_keys = self.get_ssh_keys()

        return {
            'ignition': {
                'version': '2.0.0',
                'config': {},
            },
            'storage': self.get_storage_config(files),
            'networkd': {
                'units': networkd_units
            },
            'passwd': {
                'users': [{
                    'name': 'root',
                    'sshAuthorizedKeys': ssh_keys,
                }, {
                    'name': 'core',
                    'sshAuthorizedKeys': ssh_keys,
                }],
            },
            'systemd': {
                'units': units
            },
        }

    def get_package_classes(self):
        from .system import SystemPackage

        if self.node.maintenance_mode:
            return [SystemPackage]

        from .credentials import CredentialsPackage
        from .flannel import FlannelPackage

        packages = [
            SystemPackage,
            CredentialsPackage,
            FlannelPackage,
        ]

        if self.cluster.install_dnsmasq:
            from .dnsmasq import DnsmasqPackage
            packages += [
                DnsmasqPackage,
            ]

        if self.node.is_etcd_server:
            from .etcd_server import EtcdServerPackage
            packages += [
                EtcdServerPackage,
            ]

        if self.node.is_k8s_schedulable or self.node.is_k8s_master:
            from .kubeconfig import KubeconfigPackage
            from .kubelet import KubeletPackage
            from .kube_proxy import KubeProxyPackage
            packages += [
                KubeconfigPackage,
                KubeletPackage,
                KubeProxyPackage,
            ]

        if self.node.is_k8s_master:
            from .k8s_master_manifests import K8sMasterManifestsPackage
            packages += [
                K8sMasterManifestsPackage,
            ]

        return packages

    def get_storage_config(self, files):
        disks = []
        filesystems = []

        config = {
            'disks': disks,
            'filesystems': filesystems,
            'files': files,
        }

        if self.node.maintenance_mode:
            return config

        root_fs = False

        for disk in self.node.disks.filter_by(wipe_next_boot=True):
            partitions = []

            disks += [{
                'device': disk.device,
                'wipeTable': True,
                'partitions': partitions,
            }]

            for partition in disk.partitions.all():
                if partition.size_mibs:
                    size_sectors = partition.size_mibs * 1024 * 1024 // disk.sector_size_bytes
                else:
                    size_sectors = 0

                partitions += [{
                    'number': partition.number,
                    'start': 0,
                    'size': size_sectors,
                    'label': partition.label,
                }]

                filesystems += [partition2ignitionfs(partition)]

                if partition.is_root:
                    root_fs = True

        if not root_fs:
            filesystems += [partition2ignitionfs(self.node.root_partition)]

        return config

    def get_ssh_keys(self):
        return [user.ssh_key for user in self.cluster.users.filter(models.User.ssh_key != '')]


def partition2ignitionfs(partition):
    fs = {
        'mount': {
            'device': partition.device,
            'format': partition.format,
            'create': {
                'force': True,
                'options': ['-L{}'.format(partition.label)],
            },
        },
    }

    if partition.is_root:
        fs['name'] = 'root'

    return fs

import itertools
import json

from flask import request

from seedbox import models


def render(node, indent=False):
    return IgnitionConfig(node).render(indent)


class IgnitionConfig(object):
    def __init__(self, node):
        self.node = node
        self.cluster = node.cluster

    def render(self, indent=False):
        content = self.get_content()
        if indent:
            return json.dumps(content, indent=2)
        else:
            return json.dumps(content, separators=(',', ':'))

    def get_content(self):
        packages = [P(self.node, request.url_root) for P in self.get_package_classes()]
        files = list(itertools.chain.from_iterable(p.get_files() for p in packages))
        units = list(itertools.chain.from_iterable(p.get_units() for p in packages))
        networkd_units = list(itertools.chain.from_iterable(p.get_networkd_units() for p in packages))
        ssh_keys = self.get_ssh_keys()

        return {
            'ignition': {
                'version': '2.0.0',
                'config': {},
            },
            'storage': self.get_storage_config(files),
            'networkd': {
                'units': networkd_units
            },
            'passwd': {
                'users': [{
                    'name': 'root',
                    'sshAuthorizedKeys': ssh_keys,
                }, {
                    'name': 'core',
                    'sshAuthorizedKeys': ssh_keys,
                }],
            },
            'systemd': {
                'units': units
            },
        }

    def get_package_classes(self):
        from .system import SystemPackage

        if self.node.maintenance_mode:
            return [SystemPackage]

        from .credentials import CredentialsPackage
        from .flannel import FlannelPackage

        packages = [
            SystemPackage,
            CredentialsPackage,
            FlannelPackage,
        ]

        if self.cluster.install_dnsmasq:
            from .dnsmasq import DnsmasqPackage
            packages += [
                DnsmasqPackage,
            ]

        if self.node.is_etcd_server:
            from .etcd_server import EtcdServerPackage
            packages += [
                EtcdServerPackage,
            ]

        if self.node.is_k8s_schedulable or self.node.is_k8s_master:
            from .kubeconfig import KubeconfigPackage
            from .kubelet import KubeletPackage
            from .kube_proxy import KubeProxyPackage
            packages += [
                KubeconfigPackage,
                KubeletPackage,
                KubeProxyPackage,
            ]

        if self.node.is_k8s_master:
            from .k8s_master_manifests import K8sMasterManifestsPackage
            packages += [
                K8sMasterManifestsPackage,
            ]

        return packages

    def get_storage_config(self, files):
        disks = []
        filesystems = []

        config = {
            'disks': disks,
            'filesystems': filesystems,
            'files': files,
        }

        if self.node.maintenance_mode:
            return config

        root_fs = False

        for disk in self.node.disks.filter_by(wipe_next_boot=True):
            partitions = []

            disks += [{
                'device': disk.device,
                'wipeTable': True,
                'partitions': partitions,
            }]

            for partition in disk.partitions.all():
                if partition.size_mibs:
                    size_sectors = partition.size_mibs * 1024 * 1024 // disk.sector_size_bytes
                else:
                    size_sectors = 0

                partitions += [{
                    'number': partition.number,
                    'start': 0,
                    'size': size_sectors,
                    'label': partition.label,
                }]

                filesystems += [partition2ignitionfs(partition)]

                if partition.is_root:
                    root_fs = True

        if not root_fs:
            filesystems += [partition2ignitionfs(self.node.root_partition)]

        return config

    def get_ssh_keys(self):
        return [user.ssh_key for user in self.cluster.users.filter(models.User.ssh_key != '')]


def partition2ignitionfs(partition):
    fs = {
        'mount': {
            'device': partition.device,
            'format': partition.format,
            'create': {
                'force': True,
                'options': ['-L{}'.format(partition.label)],
            },
        },
    }

    if partition.is_root:
        fs['name'] = 'root'

    return fs