~azzar1/unity/add-show-desktop-key

« back to all changes in this revision

Viewing changes to lib/common/makeuser.py

  • Committer: mattgiuca
  • Date: 2008-02-05 01:51:26 UTC
  • Revision ID: svn-v3-trunk0:2b9c9e99-6f39-0410-b283-7f802c844ae2:trunk:411
Renamed lib/fileservice to lib/fileservice_lib (naming conflict).
Added new app: fileservice. This app replaces the old one that was deleted -
it simply calls fileservice_lib.handle, and that's it (so it functions exactly
the same).

Show diffs side-by-side

added added

removed removed

Lines of Context:
31
31
 
32
32
# TODO: When creating a new home directory, chown it to its owner
33
33
 
34
 
# TODO: In chown_to_webserver:
35
 
# Do not call os.system("chown www-data") - use Python lib
36
 
# and use the web server uid given in conf. (Several places).
37
 
 
38
 
import md5
39
34
import os
40
 
import stat
41
35
import shutil
42
 
import time
43
 
import uuid
44
36
import warnings
45
 
import filecmp
46
 
import logging
 
37
 
47
38
import conf
48
39
import db
49
 
import pulldown_subj
50
 
 
51
 
def chown_to_webserver(filename):
52
 
    """
53
 
    Chowns a file so the web server user owns it.
54
 
    (This is useful in setting up Subversion conf files).
55
 
    Assumes root.
56
 
    """
57
 
    try:
58
 
        os.system("chown -R www-data:www-data %s" % filename)
59
 
    except:
60
 
        pass
61
 
 
62
 
def make_svn_repo(path, throw_on_error=True):
63
 
    """Create a Subversion repository at the given path.
64
 
    """
65
 
    try:
66
 
        res = os.system("svnadmin create '%s'" % path)
67
 
        if res != 0 and throw_on_error:
68
 
            raise Exception("Cannot create repository: %s" % path)
69
 
    except Exception, exc:
70
 
        print repr(exc)
71
 
        if throw_on_error:
72
 
            raise
73
 
 
74
 
    chown_to_webserver(path)
75
 
 
76
 
def rebuild_svn_config():
77
 
    """Build the complete SVN configuration file.
78
 
    """
79
 
    conn = db.DB()
80
 
    users = conn.get_users()
81
 
    groups = {}
82
 
    for u in users:
83
 
        role = str(u.role)
84
 
        if role not in groups:
85
 
            groups[role] = []
86
 
        groups[role].append(u.login)
87
 
    f = open(conf.svn_conf + ".new", "w")
88
 
    f.write("# IVLE SVN Repositories Configuration\n")
89
 
    f.write("# Auto-generated on %s\n" % time.asctime())
90
 
    f.write("\n")
91
 
    f.write("[groups]\n")
92
 
    for (g,ls) in groups.iteritems():
93
 
        f.write("%s = %s\n" % (g, ",".join(ls)))
94
 
    f.write("\n")
95
 
    for u in users:
96
 
        f.write("[%s:/]\n" % u.login)
97
 
        f.write("%s = rw\n" % u.login)
98
 
        #f.write("@tutor = r\n")
99
 
        #f.write("@lecturer = rw\n")
100
 
        #f.write("@admin = rw\n")
101
 
        f.write("\n")
102
 
    f.close()
103
 
    os.rename(conf.svn_conf + ".new", conf.svn_conf)
104
 
    chown_to_webserver(conf.svn_conf)
105
 
 
106
 
def rebuild_svn_group_config():
107
 
    """Build the complete SVN configuration file for groups
108
 
    """
109
 
    conn = db.DB()
110
 
    groups = conn.get_all('project_group',
111
 
        ['groupid', 'groupnm', 'projectsetid'])
112
 
    f = open(conf.svn_group_conf + ".new", "w")
113
 
    f.write("# IVLE SVN Group Repositories Configuration\n")
114
 
    f.write("# Auto-generated on %s\n" % time.asctime())
115
 
    f.write("\n")
116
 
    for g in groups:
117
 
        projectsetid = g['projectsetid']
118
 
        offeringinfo = conn.get_offering_info(projectsetid)
119
 
        subj_short_name = offeringinfo['subj_short_name']
120
 
        year = offeringinfo['year']
121
 
        semester = offeringinfo['semester']
122
 
        reponame = "_".join([subj_short_name, year, semester, g['groupnm']])
123
 
        f.write("[%s:/]\n"%reponame)
124
 
        users = conn.get_projectgroup_members(g['groupid'])
125
 
        for u in users:
126
 
            f.write("%s = rw\n"%u['login'])
127
 
        f.write("\n")
128
 
    f.close()
129
 
    os.rename(conf.svn_group_conf + ".new", conf.svn_group_conf)
130
 
    chown_to_webserver(conf.svn_group_conf)
131
 
 
132
 
def make_svn_auth(login, throw_on_error=True):
133
 
    """Setup svn authentication for the given user.
134
 
       FIXME: create local.auth entry
135
 
    """
136
 
    passwd = md5.new(uuid.uuid4().bytes).digest().encode('hex')
137
 
    if os.path.exists(conf.svn_auth_ivle):
138
 
        create = ""
139
 
    else:
140
 
        create = "c"
141
 
 
142
 
    db.DB().update_user(login, svn_pass=passwd)
143
 
 
144
 
    res = os.system("htpasswd -%smb %s %s %s" % (create,
145
 
                                              conf.svn_auth_ivle,
146
 
                                              login, passwd))
147
 
    if res != 0 and throw_on_error:
148
 
        raise Exception("Unable to create ivle-auth for %s" % login)
149
 
 
150
 
    # Make sure the file is owned by the web server
151
 
    if create == "c":
152
 
        chown_to_webserver(conf.svn_auth_ivle)
153
 
 
154
 
    return passwd
155
 
 
156
 
def generate_manifest(basedir, targetdir, parent=''):
157
 
    """ From a basedir and a targetdir work out which files are missing or out 
158
 
    of date and need to be added/updated and which files are redundant and need 
159
 
    to be removed.
160
 
    
161
 
    parent: This is used for the recursive call to track the relative paths 
162
 
    that we have decended.
163
 
    """
164
 
    
165
 
    cmp = filecmp.dircmp(basedir, targetdir)
166
 
 
167
 
    # Add all new files and files that have changed
168
 
    to_add = [os.path.join(parent,x) for x in (cmp.left_only + cmp.diff_files)]
169
 
 
170
 
    # Remove files that are redundant
171
 
    to_remove = [os.path.join(parent,x) for x in cmp.right_only]
172
 
    
173
 
    # Recurse
174
 
    for d in cmp.common_dirs:
175
 
        newbasedir = os.path.join(basedir, d)
176
 
        newtargetdir = os.path.join(targetdir, d)
177
 
        newparent = os.path.join(parent, d)
178
 
        (sadd,sremove) = generate_manifest(newbasedir, newtargetdir, newparent)
179
 
        to_add += sadd
180
 
        to_remove += sremove
181
 
 
182
 
    return (to_add, to_remove)
183
 
 
184
 
 
185
 
def make_jail(username, uid, force=True, svn_pass=None):
 
40
 
 
41
def makeuser(username, password, nick, fullname, rolenm, studentid):
 
42
    """Creates a new user on a pre-installed system.
 
43
    Sets up the following:
 
44
    * User's jail and home directory within the jail.
 
45
    * Subversion repository
 
46
    * Check out Subversion workspace into jail
 
47
    * Database details for user
 
48
    * Unix user account
 
49
    """
 
50
    homedir = make_jail(username)
 
51
    make_user_db(username, password, nick, fullname, rolenm, studentid)
 
52
    # TODO: -p password (need to use crypt)
 
53
    #if os.system("useradd -d %s '%s'" % (homedir, username)) != 0:
 
54
    #    raise Exception("Failed to add Unix user account")
 
55
 
 
56
def make_jail(username, force=True):
186
57
    """Creates a new user's jail space, in the jail directory as configured in
187
58
    conf.py.
188
59
 
189
 
    This only creates things within /home - everything else is expected to be
190
 
    part of another UnionFS branch.
 
60
    This expects there to be a "template" directory within the jail root which
 
61
    contains all the files for a sample student jail. It creates the student's
 
62
    directory in the jail root, by making a hard-link copy of every file in the
 
63
    template directory, recursively.
191
64
 
192
65
    Returns the path to the user's home directory.
193
66
 
194
 
    Chowns the user's directory within the jail to the given UID.
195
 
 
196
 
    Note: This takes separate username and uid arguments. The UID need not
197
 
    *necessarily* correspond to a Unix username at all, if all you are
198
 
    planning to do is setuid to it. This allows the caller the freedom of
199
 
    deciding the binding between username and uid, if any.
200
 
 
201
67
    force: If false, exception if jail already exists for this user.
202
68
    If true (default), overwrites it, but preserves home directory.
203
 
 
204
 
    svn_pass: If provided this will be a string, the randomly-generated
205
 
    Subversion password for this user (if you happen to already have it).
206
 
    If not provided, it will be read from the database.
207
69
    """
208
70
    # MUST run as root or some of this may fail
209
71
    if os.getuid() != 0:
210
72
        raise Exception("Must run make_jail as root")
211
73
    
 
74
    templatedir = os.path.join(conf.jail_base, 'template')
 
75
    if not os.path.isdir(templatedir):
 
76
        raise Exception("Template jail directory does not exist: " +
 
77
            templatedir)
212
78
    # tempdir is for putting backup homes in
213
 
    tempdir = os.path.join(conf.jail_base, '__temp__')
 
79
    tempdir = os.path.join(conf.jail_base, 'temp')
214
80
    if not os.path.exists(tempdir):
215
81
        os.makedirs(tempdir)
216
82
    elif not os.path.isdir(tempdir):
217
83
        os.unlink(tempdir)
218
84
        os.mkdir(tempdir)
219
 
    userdir = os.path.join(conf.jail_src_base, username)
 
85
    userdir = os.path.join(conf.jail_base, username)
220
86
    homedir = os.path.join(userdir, 'home')
221
 
    userhomedir = os.path.join(homedir, username)   # Return value
222
87
 
223
88
    if os.path.exists(userdir):
224
89
        if not force:
225
90
            raise Exception("User's jail already exists")
226
91
        # User jail already exists. Blow it away but preserve their home
227
 
        # directory. It should be all that is there anyway, but you never
228
 
        # know!
 
92
        # directory.
229
93
        # Ignore warnings about the use of tmpnam
230
94
        warnings.simplefilter('ignore')
231
95
        homebackup = os.tempnam(tempdir)
234
98
        # into a directory if it already exists, just fails. Therefore it is
235
99
        # not susceptible to tmpnam symlink attack.
236
100
        shutil.move(homedir, homebackup)
237
 
        shutil.rmtree(userdir)
238
 
        os.makedirs(homedir)
239
 
        shutil.move(homebackup, homedir)
240
 
        # Change the ownership of all the files to the right unixid
241
 
        logging.debug("chown %s's home directory files to uid %d"
242
 
            %(username, uid))
243
 
        os.chown(userhomedir, uid, uid)
244
 
        for root, dirs, files in os.walk(userhomedir):
245
 
            for fsobj in dirs + files:
246
 
                os.chown(os.path.join(root, fsobj), uid, uid)
 
101
        try:
 
102
            # Any errors that occur after making the backup will be caught and
 
103
            # the backup will be un-made.
 
104
            # XXX This will still leave the user's jail in an unusable state,
 
105
            # but at least they won't lose their files.
 
106
            shutil.rmtree(userdir)
 
107
 
 
108
            # Hard-link (copy aliasing) the entire tree over
 
109
            linktree(templatedir, userdir)
 
110
        finally:
 
111
            # Set up the user's home directory (restore backup)
 
112
            # First make sure the directory is empty and its parent exists
 
113
            try:
 
114
                shutil.rmtree(homedir)
 
115
            except:
 
116
                pass
 
117
            # XXX If this fails the user's directory will be lost (in the temp
 
118
            # directory). But it shouldn't fail as homedir should not exist.
 
119
            os.makedirs(homedir)
 
120
            shutil.move(homebackup, homedir)
 
121
        return os.path.join(homedir, username)
247
122
    else:
248
123
        # No user jail exists
 
124
        # Hard-link (copy aliasing) the entire tree over
 
125
        linktree(templatedir, userdir)
 
126
 
249
127
        # Set up the user's home directory
250
 
        os.makedirs(userhomedir)
251
 
        # Chown (and set the GID to the same as the UID).
252
 
        os.chown(userhomedir, uid, uid)
253
 
        # Chmod to rwxr-xr-x (755)
254
 
        os.chmod(userhomedir, 0755)
255
 
 
256
 
    # There are 2 special files which need to be generated specific to this
257
 
    # user: /opt/ivle/lib/conf/conf.py and /etc/passwd.
258
 
    # "__" username "__" users are exempt (special)
259
 
    if not (username.startswith("__") and username.endswith("__")):
260
 
        make_conf_py(username, userdir, conf.jail_system, svn_pass)
261
 
        make_etc_passwd(username, userdir, conf.jail_system, uid)
262
 
 
263
 
    return userhomedir
264
 
 
265
 
def make_conf_py(username, user_jail_dir, staging_dir, svn_pass=None):
266
 
    """
267
 
    Creates (overwriting any existing file, and creating directories) a
268
 
    file /opt/ivle/lib/conf/conf.py in a given user's jail.
269
 
    username: Username.
270
 
    user_jail_dir: User's jail dir, ie. conf.jail_base + username
271
 
    staging_dir: The dir with the staging copy of the jail. (With the
272
 
        template conf.py file).
273
 
    svn_pass: As with make_jail. User's SVN password, but if not supplied,
274
 
        will look up in the DB.
275
 
    """
276
 
    template_conf_path = os.path.join(staging_dir,"opt/ivle/lib/conf/conf.py")
277
 
    conf_path = os.path.join(user_jail_dir, "opt/ivle/lib/conf/conf.py")
278
 
    os.makedirs(os.path.dirname(conf_path))
279
 
 
280
 
    # If svn_pass isn't supplied, grab it from the DB
281
 
    if svn_pass is None:
282
 
        dbconn = db.DB()
283
 
        svn_pass = dbconn.get_user(username).svn_pass
284
 
        dbconn.close()
285
 
 
286
 
    # Read the contents of the template conf file
287
 
    try:
288
 
        template_conf_file = open(template_conf_path, "r")
289
 
        template_conf_data = template_conf_file.read()
290
 
        template_conf_file.close()
291
 
    except:
292
 
        # Couldn't open template conf.py for some reason
293
 
        # Just treat it as empty file
294
 
        template_conf_data = ("# Warning: Problem building config script.\n"
295
 
                              "# Could not find template conf.py file.\n")
296
 
 
297
 
    conf_file = open(conf_path, "w")
298
 
    conf_file.write(template_conf_data)
299
 
    conf_file.write("\n# The login name for the owner of the jail\n")
300
 
    conf_file.write("login = %s\n" % repr(username))
301
 
    conf_file.write("\n")
302
 
    conf_file.write("# The subversion-only password for the owner of "
303
 
        "the jail\n")
304
 
    conf_file.write("svn_pass = %s\n" % repr(svn_pass))
305
 
    conf_file.close()
306
 
 
307
 
    # Make this file world-readable
308
 
    # (chmod 644 conf_path)
309
 
    os.chmod(conf_path, stat.S_IRUSR | stat.S_IWUSR | stat.S_IRGRP
310
 
                        | stat.S_IROTH)
311
 
 
312
 
def make_etc_passwd(username, user_jail_dir, template_dir, unixid):
313
 
    """
314
 
    Creates /etc/passwd in the given user's jail. This will be identical to
315
 
    that in the template jail, except for the added entry for this user.
316
 
    """
317
 
    template_passwd_path = os.path.join(template_dir, "etc/passwd")
318
 
    passwd_path = os.path.join(user_jail_dir, "etc/passwd")
319
 
    passwd_dir = os.path.dirname(passwd_path)
320
 
    if not os.path.exists(passwd_dir):
321
 
        os.makedirs(passwd_dir)
322
 
    shutil.copy(template_passwd_path, passwd_path)
323
 
    passwd_file = open(passwd_path, 'a')
324
 
    passwd_file.write('%s:x:%d:%d::/home/%s:/bin/bash'
325
 
                      % (username, unixid, unixid, username))
326
 
    passwd_file.close()
 
128
        userhomedir = os.path.join(homedir, username)
 
129
        os.mkdir(userhomedir)
 
130
        return userhomedir
327
131
 
328
132
def linktree(src, dst):
329
133
    """Recursively hard-link a directory tree using os.link().
364
168
    if errors:
365
169
        raise Exception, errors
366
170
 
367
 
def make_user_db(throw_on_error = True, **kwargs):
 
171
def make_user_db(login, password, nick, fullname, rolenm, studentid,
 
172
    force=True):
368
173
    """Creates a user's entry in the database, filling in all the fields.
369
 
    All arguments must be keyword args. They are the fields in the table.
370
 
    However, instead of supplying a "passhash", you must supply a
371
 
    "password" argument, which will be hashed internally.
372
 
    Also do not supply a state. All users are created in the "no_agreement"
373
 
    state.
374
 
    Also pulls the user's subjects using the configured subject pulldown
375
 
    module, and adds enrolments to the DB.
376
 
    Throws an exception if the user already exists.
 
174
    If force is False, throws an exception if the user already exists.
 
175
    If True, overwrites the user's entry in the DB.
377
176
    """
378
177
    dbconn = db.DB()
379
 
    dbconn.create_user(**kwargs)
 
178
    if force:
 
179
        # Delete user if it exists
 
180
        try:
 
181
            dbconn.delete_user(login)
 
182
        except:
 
183
            pass
 
184
    dbconn.create_user(login, password, nick, fullname, rolenm, studentid)
380
185
    dbconn.close()
381
 
 
382
 
    if kwargs['password']:
383
 
        if os.path.exists(conf.svn_auth_local):
384
 
            create = ""
385
 
        else:
386
 
            create = "c"
387
 
        res = os.system("htpasswd -%smb %s %s %s" % (create,
388
 
                                                     conf.svn_auth_local,
389
 
                                                     kwargs['login'],
390
 
                                                     kwargs['password']))
391
 
        if res != 0 and throw_on_error:
392
 
            raise Exception("Unable to create local-auth for %s" % kwargs['login'])
393
 
 
394
 
    # Make sure the file is owned by the web server
395
 
    if create == "c":
396
 
        chown_to_webserver(conf.svn_auth_local)
397
 
 
398
 
    # Pulldown subjects and add enrolments
399
 
    pulldown_subj.enrol_user(kwargs['login'])
400
 
 
401
 
def mount_jail(login):
402
 
    # This is where we'll mount to...
403
 
    destdir = os.path.join(conf.jail_base, login)
404
 
    # ... and this is where we'll get the user bits.
405
 
    srcdir = os.path.join(conf.jail_src_base, login)
406
 
    try:
407
 
        if not os.path.exists(destdir):
408
 
            os.mkdir(destdir)
409
 
        if os.system('/bin/mount -t aufs -o dirs=%s:%s=ro none %s'
410
 
                     % (srcdir, conf.jail_system, destdir)) == 0:
411
 
            logging.info("mounted user %s's jail." % login)
412
 
        else:
413
 
            logging.error("failed to mount user %s's jail!" % login)
414
 
    except Exception, message:
415
 
        logging.warning(str(message))