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
|
#!/usr/bin/env python
from binascii import b2a_base64
from glob import glob
from os import rename, stat, system
from socket import gethostbyname
from string import strip
from syslog import syslog, LOG_INFO
from Bcfg2.Server.Types import ConfigFile
from Bcfg2.Server.Generator import Generator, DirectoryBacked
from elementtree.ElementTree import Element
class sshbase(Generator):
"The sshbase generator manages ssh host keys (both v1 and v2) for hosts. It also manages
the ssh_known_hosts file. It can integrate host keys from other management domains and
similarly export its keys. The repository contains files in the following formats:
ssh_host_key.H_(hostname) -> the v1 host private key for (hostname)
ssh_host_key.pub.H_(hostname) -> the v1 host public key for (hostname)
ssh_host_(dr)sa_key.H_(hostname) -> the v2 ssh host private key for (hostname)
ssh_host_(dr)sa_key.pub.H_(hostname) -> the v2 ssh host public key for (hostname)
ssh_known_hosts -> the current known hosts file. this is regenerated each time a new key is generated.
"
__name__ = 'sshbase'
__version__ = '$Id$'
__author__ = 'bcfg-dev@mcs.anl.gov'
def __setup__(self):
self.repository = DirectoryBacked(self.data, self.core.fam)
self.__provides__ = {'ConfigFile':{'/etc/ssh/ssh_known_hosts':self.build_skn,
'/etc/ssh/ssh_host_dsa_key':self.build_hk,
'/etc/ssh/ssh_host_rsa_key':self.build_hk,
'/etc/ssh/ssh_host_dsa_key.pub':self.build_hk,
'/etc/ssh/ssh_host_rsa_key.pub':self.build_hk,
'/etc/ssh/ssh_host_key':self.build_hk,
'/etc/ssh/ssh_host_key.pub':self.build_hk}}
def build_skn(self,entry,metadata):
client = metadata.hostname
filedata = self.repository.entries['ssh_known_hosts'].data
ip=gethostbyname(client)
keylist = map(lambda x:x%(client), ["ssh_host_dsa_key.pub.H_%s","ssh_host_rsa_key.pub.H_%s","ssh_host_key.pub.H_%s"])
for hostkey in keylist:
filedata += "%s,%s,%s %s"%(client,"%s.mcs.anl.gov"%(client),ip,self.repository.entries[hostkey].data)
entry.attrib.update({'owner':'root', 'group':'root', 'perms':'0644'})
entry.text = filedata
def build_hk(self,entry,metadata):
client = metadata.hostname
filename = "%s.H_%s"%(entry.attrib['name'].split('/')[-1],client)
if filename not in self.repository.entries.keys():
self.GenerateHostKeys(client)
self.GenerateKnownHosts()
keydata = self.repository.entries[filename].data
entry.attrib.update({'owner':'root', 'group':'root', 'perms':'0600'})
entry.text = keydata
if "ssh_host_key.H_" in filename:
entry.attrib['encoding'] = 'base64'
entry.text = b2a_base64(keydata)
def GenerateKnownHosts(self):
output = ''
for f in self.repository.entries.keys():
if ".pub.H_" in f:
h = f.split('_')[-1]
output += "%s,%s.mcs.anl.gov,%s %s"%(h, h, gethostbyname(h), self.repository.entries[f].data)
self.repository.entries['ssh_known_hosts'].data = output
def GenerateHostKeys(self,client):
keylist = map(lambda x:x%client, ["ssh_host_dsa_key.H_%s","ssh_host_rsa_key.H_%s","ssh_host_key.H_%s"])
for hostkey in keylist:
if 'ssh_host_rsa_key.H_' in hostkey:
keytype = 'rsa'
elif 'ssh_host_dsa_key.H_' in hostkey:
keytype = 'dsa'
else:
keytype = 'rsa1'
if hostkey not in self.repository.entries.keys():
system('ssh-keygen -f %s/%s -N "" -t %s -C root@%s'%(self.data,hostkey,keytype,client))
rename("%s/%s.pub"%(self.data,hostkey),"%s/"%(self.data)+".".join(hostkey.split('.')[:-1]+['pub']+hostkey.split('.')[-1]))
# call the notifier for global
def GetProbes(self, metadata):
p = Element("probe", name='hostname', interpreter='/bin/sh', source='sshbase')
p.text = 'hostname'
return [p]
def AcceptProbeData(self, client, probedata):
p = strip(probedata.text)
#syslog(LOG_INFO, "Got hostname %s for client %s"%(p, client))
|
