oops
[invirt/packages/invirt-remote.git] / files / usr / sbin / sipb-xen-remconffs
1 #!/usr/bin/python
2
3 import fuse
4 from fuse import Fuse
5
6 from time import time
7
8 import stat     # for file properties
9 import os         # for filesystem modes (O_RDONLY, etc)
10 import errno   # for error number codes (ENOENT, etc)
11                            # - note: these must be returned as negatives
12
13 from syslog import *
14
15 import sipb_xen_database
16 from invirt.config import structs as config
17
18 fuse.fuse_python_api = (0, 2)
19
20 def getDepth(path):
21         """
22         Return the depth of a given path, zero-based from root ('/')
23         """
24         if path == '/':
25                 return 0
26         else:
27                 return path.count('/')
28
29 def getParts(path):
30         """
31         Return the slash-separated parts of a given path as a list
32         """
33         # [1:] to exclude leading empty element
34         split = path.split('/')
35         if split[-1]:
36                 return split[1:]
37         else:
38                 return split[1:-1]
39
40 def parse(path):
41         parts = getParts(path)
42         return parts, len(parts)
43
44 class MyStat:
45         def __init__(self):
46                 self.st_mode = 0
47                 self.st_ino = 0
48                 self.st_dev = 0
49                 self.st_nlink = 0
50                 self.st_uid = 0
51                 self.st_gid = 0
52                 self.st_size = 0
53                 self.st_atime = 0
54                 self.st_mtime = 0
55                 self.st_ctime = 0
56         
57         def toTuple(self):
58                 return (self.st_mode, self.st_ino, self.st_dev, self.st_nlink, self.st_uid, self.st_gid, self.st_size, self.st_atime, self.st_mtime, self.st_ctime)
59
60 class RemConfFS(Fuse):
61         """
62         RemConfFS creates a filesytem for configuring remctl, like this:
63         /
64         |-- acl
65         |   |-- machine1
66         |   ...
67         |   `-- machinen
68         `-- conf.d
69             |-- machine1
70             ...
71             `-- machinen
72
73         The machine list and the acls are drawn from a database.
74         
75         This filesystem only implements the getattr, getdir, read, and readlink
76         calls, because this is a read-only filesystem.
77         """
78         
79         def __init__(self, *args, **kw):
80                 """Initialize the filesystem and set it to allow_other access besides
81                 the user who mounts the filesystem (i.e. root)
82                 """
83                 Fuse.__init__(self, *args, **kw)
84                 self.lasttime = time()
85                 self.allow_other = 1
86                 
87                 openlog('sipb-xen-remconffs ', LOG_PID, LOG_DAEMON)
88                 
89                 syslog(LOG_DEBUG, 'Init complete.')
90
91         def getMachines(self):
92                 """Get the list of VMs in the database, clearing the cache if it's 
93                 older than 15 seconds"""
94                 if time() - self.lasttime > 15:
95                         self.lasttime = time()
96                         sipb_xen_database.clear_cache()
97                 return [machine.name for machine in sipb_xen_database.Machine.select()]
98                 
99         def getacl(self, machine_name):
100                 """Build the ACL file for a machine
101                 """
102                 machine = sipb_xen_database.Machine.get_by(name=machine_name)
103                 users = [acl.user for acl in machine.acl]
104                 return "\n".join(map(self.userToPrinc, users)
105                                  + ['include /etc/remctl/acl/web',
106                                     ''])
107                 
108         def getconf(self):
109                 """Build the master conf file, with all machines
110                 """
111                 return '\n'.join("control %s /usr/sbin/sipb-xen-remote-proxy-control"
112                                  " /etc/remctl/remconffs/acl/%s"
113                                  % (machine_name, machine_name)
114                                  for machine_name in self.getMachines())+'\n'
115         
116         def userToPrinc(self, user):
117                 """Convert Kerberos v4-style names to v5-style and append a default
118                 realm if none is specified
119                 """
120                 if '@' in user:
121                         (princ, realm) = user.split('@')
122                 else:
123                         princ = user
124                         realm = config.authn[0].realm
125                 
126                 return princ.replace('.', '/') + '@' + realm
127         
128         def getattr(self, path):
129                 """
130                 - st_mode (protection bits)
131                 - st_ino (inode number)
132                 - st_dev (device)
133                 - st_nlink (number of hard links)
134                 - st_uid (user ID of owner)
135                 - st_gid (group ID of owner)
136                 - st_size (size of file, in bytes)
137                 - st_atime (time of most recent access)
138                 - st_mtime (time of most recent content modification)
139                 - st_ctime (platform dependent; time of most recent metadata change on Unix,
140                                         or the time of creation on Windows).
141                 """
142                 
143                 syslog(LOG_DEBUG, "*** getattr: " + path)
144                 
145                 depth = getDepth(path)
146                 parts = getParts(path)
147                 
148                 st = MyStat()
149                 if path == '/':
150                         st.st_mode = stat.S_IFDIR | 0755
151                         st.st_nlink = 2
152                 elif depth == 1:
153                         if parts[0] == 'acl':
154                                 st.st_mode = stat.S_IFDIR | 0755
155                                 st.st_nlink = 2
156                         elif parts[0] == 'conf':
157                                 st.st_mode = stat.S_IFREG | 0444
158                                 st.st_nlink = 1
159                                 st.st_size = len(self.getconf())
160                         else:
161                                 return -errno.ENOENT
162                 elif depth == 2:
163                         if parts[0] != 'acl':
164                                 return -errno.ENOENT
165                         if parts[1] not in self.getMachines():
166                                 return -errno.ENOENT
167                         st.st_mode = stat.S_IFREG | 0444
168                         st.st_nlink = 1
169                         st.st_size = len(self.getacl(parts[1]))
170
171                 return st.toTuple()
172         
173         # This call isn't actually used in the version of Fuse on console, but we
174         # wanted to leave it implemented to ease the transition in the future
175         def readdir(self, path, offset):
176                 """Return a generator with the listing for a directory
177                 """
178                 syslog(LOG_DEBUG, '*** readdir %s %s' % (path, offset))
179                 for (value, zero) in self.getdir(path):
180                         yield fuse.Direntry(value)
181         
182         def getdir(self, path):
183                 """Return a list of tuples of the form (item, 0) with the contents of
184                 the directory path
185                 
186                 Fuse doesn't add '.' or '..' on its own, so we have to
187                 """
188                 syslog(LOG_DEBUG, '*** getdir %s' % path)
189                 
190                 parts, depth = parse(path)
191
192                 if depth == 0:
193                         contents = ('acl', 'conf')
194                 elif depth == 1:
195                         if parts[0] == 'acl':
196                                 contents = self.getMachines()
197                         else:
198                                 return -errno.ENOENT
199                 else:
200                         return -errno.ENOTDIR
201
202                 # Format the list the way that Fuse wants it - and don't forget to add
203                 # '.' and '..'
204                 return [(i, 0) for i in (list(contents) + ['.', '..'])]
205
206         def read(self, path, length, offset):
207                 """Read length bytes starting at offset of path. In most cases, this
208                 just gets passed on to the OS
209                 """
210                 syslog(LOG_DEBUG, '*** read %s %s %s' % (path, length, offset))
211                 
212                 parts, depth = parse(path)
213                 
214                 if depth == 0:
215                         return -errno.EISDIR
216                 elif parts[0] == 'conf':
217                         return self.getconf()[offset:offset+length]
218                 elif parts[0] == 'acl':
219                         if depth == 1:
220                                 return -errno.EISDIR
221                         if parts[1] in self.getMachines():
222                                 return self.getacl(parts[1])[offset:offset+length]
223                 return -errno.ENOENT
224         
225         def readlink(self, path):
226                 syslog(LOG_DEBUG, '*** readlink %s' % path)
227                 return -errno.ENOENT
228
229
230 if __name__ == '__main__':
231         sipb_xen_database.connect(config.db.uri)
232         usage="""
233 $0 [mount_path]
234 """
235         server = RemConfFS()
236         server.flags = 0
237         server.main()