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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
import platform
from cloudinit import distros
from cloudinit.distros import bsd_utils
from cloudinit import helpers
from cloudinit import log as logging
from cloudinit import net
from cloudinit import util
LOG = logging.getLogger(__name__)
class BSD(distros.Distro):
hostname_conf_fn = '/etc/rc.conf'
rc_conf_fn = "/etc/rc.conf"
# Set in BSD distro subclasses
group_add_cmd_prefix = []
pkg_cmd_install_prefix = []
pkg_cmd_remove_prefix = []
def __init__(self, name, cfg, paths):
super().__init__(name, cfg, paths)
# This will be used to restrict certain
# calls from repeatly happening (when they
# should only happen say once per instance...)
self._runner = helpers.Runners(paths)
cfg['ssh_svcname'] = 'sshd'
self.osfamily = platform.system().lower()
def _read_system_hostname(self):
sys_hostname = self._read_hostname(self.hostname_conf_fn)
return (self.hostname_conf_fn, sys_hostname)
def _read_hostname(self, filename, default=None):
return bsd_utils.get_rc_config_value('hostname')
def _get_add_member_to_group_cmd(self, member_name, group_name):
raise NotImplementedError('Return list cmd to add member to group')
def _write_hostname(self, hostname, filename):
bsd_utils.set_rc_config_value('hostname', hostname, fn='/etc/rc.conf')
def create_group(self, name, members=None):
if util.is_group(name):
LOG.warning("Skipping creation of existing group '%s'", name)
else:
group_add_cmd = self.group_add_cmd_prefix + [name]
try:
util.subp(group_add_cmd)
LOG.info("Created new group %s", name)
except Exception:
util.logexc(LOG, "Failed to create group %s", name)
if not members:
members = []
for member in members:
if not util.is_user(member):
LOG.warning("Unable to add group member '%s' to group '%s'"
"; user does not exist.", member, name)
continue
try:
util.subp(self._get_add_member_to_group_cmd(member, name))
LOG.info("Added user '%s' to group '%s'", member, name)
except Exception:
util.logexc(LOG, "Failed to add user '%s' to group '%s'",
member, name)
def generate_fallback_config(self):
nconf = {'config': [], 'version': 1}
for mac, name in net.get_interfaces_by_mac().items():
nconf['config'].append(
{'type': 'physical', 'name': name,
'mac_address': mac, 'subnets': [{'type': 'dhcp'}]})
return nconf
def install_packages(self, pkglist):
self.update_package_sources()
self.package_command('install', pkgs=pkglist)
def _get_pkg_cmd_environ(self):
"""Return environment vars used in *BSD package_command operations"""
raise NotImplementedError('BSD subclasses return a dict of env vars')
def package_command(self, command, args=None, pkgs=None):
if pkgs is None:
pkgs = []
# TODO neither freebsd nor netbsd handles a command 'upgrade'
# provided by cloudinit/config/cc_package_update_upgrade_install.py
if command == 'install':
cmd = self.pkg_cmd_install_prefix
elif command == 'remove':
cmd = self.pkg_cmd_remove_prefix
if args and isinstance(args, str):
cmd.append(args)
elif args and isinstance(args, list):
cmd.extend(args)
pkglist = util.expand_package_list('%s-%s', pkgs)
cmd.extend(pkglist)
# Allow the output of this to flow outwards (ie not be captured)
util.subp(cmd, env=self._get_pkg_cmd_environ(), capture=False)
def _write_network_config(self, netconfig):
return self._supported_write_network_config(netconfig)
def set_timezone(self, tz):
distros.set_etc_timezone(tz=tz, tz_file=self._find_tz_file(tz))
|
