55
74
chown_to_webserver(path)
57
def rebuild_svn_config(store, config):
76
def rebuild_svn_config():
58
77
"""Build the complete SVN configuration file.
60
@param config: An ivle.config.Config object.
62
users = store.find(User)
63
conf_name = config['paths']['svn']['conf']
64
temp_name = conf_name + ".new"
65
f = open(temp_name, "w")
67
# IVLE SVN repository authorisation configuration
69
""" % {'time': time.asctime()})
75
""" % {'login': u.login})
77
# Now we need to grant offering tutors and lecturers access to the latest
78
# submissions in their offerings. There are much prettier ways to do this,
79
# but a lot of browser requests call this function, so it needs to be
80
# fast. We can grab all of the paths needing authorisation directives with
81
# a single query, and we cache the list of viewers for each offering.
82
offering_viewers_cache = {}
83
for (login, psid, pspath, offeringid) in store.find(
84
(User.login, ProjectSubmission.id, ProjectSubmission.path,
86
Assessed.id == ProjectSubmission.assessed_id,
87
User.id == Assessed.user_id,
88
Project.id == Assessed.project_id,
89
ProjectSet.id == Project.project_set_id,
90
Offering.id == ProjectSet.id,
91
ProjectSubmission.date_submitted == Select(
92
Max(ProjectSubmission.date_submitted),
93
ProjectSubmission.assessed_id == Assessed.id,
94
tables=ProjectSubmission
98
# Do we already have the list of logins authorised for this offering
99
# cached? If not, get it.
100
if offeringid not in offering_viewers_cache:
101
offering_viewers_cache[offeringid] = list(store.find(
103
User.id == Enrolment.user_id,
104
Enrolment.offering_id == offeringid,
105
Enrolment.role.is_in((u'tutor', u'lecturer'))
112
""" % {'login': login, 'id': psid, 'path': pspath})
114
for viewer_login in offering_viewers_cache[offeringid]:
115
# We don't want to override the owner's write privilege,
116
# so we don't add them to the read-only ACL.
117
if login != viewer_login:
118
f.write("%s = r\n" % viewer_login)
80
users = conn.get_users()
84
if role not in groups:
86
groups[role].append(u.login)
87
f = open(ivle.conf.svn_conf + ".new", "w")
88
f.write("# IVLE SVN Repositories Configuration\n")
89
f.write("# Auto-generated on %s\n" % time.asctime())
92
for (g,ls) in groups.iteritems():
93
f.write("%s = %s\n" % (g, ",".join(ls)))
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")
121
os.rename(temp_name, conf_name)
122
chown_to_webserver(conf_name)
103
os.rename(ivle.conf.svn_conf + ".new", ivle.conf.svn_conf)
104
chown_to_webserver(ivle.conf.svn_conf)
124
def rebuild_svn_group_config(store, config):
106
def rebuild_svn_group_config():
125
107
"""Build the complete SVN configuration file for groups
127
@param config: An ivle.config.Config object.
129
conf_name = config['paths']['svn']['group_conf']
130
temp_name = conf_name + ".new"
131
f = open(temp_name, "w")
134
# IVLE SVN group repository authorisation configuration
135
# Generated: %(time)s
137
""" % {'time': time.asctime()})
139
group_members_cache = {}
140
for group in store.find(ProjectGroup):
141
offering = group.project_set.offering
142
reponame = "_".join([offering.subject.short_name,
143
offering.semester.year,
144
offering.semester.semester,
147
f.write("[%s:/]\n" % reponame)
148
if group.id not in group_members_cache:
149
group_members_cache[group.id] = set()
150
for user in group.members:
151
group_members_cache[group.id].add(user.login)
152
f.write("%s = rw\n" % user.login)
110
groups = conn.get_all('project_group',
111
['groupid', 'groupnm', 'projectsetid'])
112
f = open(ivle.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())
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'])
126
f.write("%s = rw\n"%u['login'])
155
# Now we need to grant offering tutors and lecturers access to the latest
156
# submissions in their offerings. There are much prettier ways to do this,
157
# but a lot of browser requests call this function, so it needs to be
158
# fast. We can grab all of the paths needing authorisation directives with
159
# a single query, and we cache the list of viewers for each offering.
160
offering_viewers_cache = {}
161
for (ssn, year, sem, name, psid, pspath, gid, offeringid) in store.find(
162
(Subject.short_name, Semester.year, Semester.semester,
163
ProjectGroup.name, ProjectSubmission.id, ProjectSubmission.path,
164
ProjectGroup.id, Offering.id),
165
Assessed.id == ProjectSubmission.assessed_id,
166
ProjectGroup.id == Assessed.project_group_id,
167
Project.id == Assessed.project_id,
168
ProjectSet.id == Project.project_set_id,
169
Offering.id == ProjectSet.offering_id,
170
Subject.id == Offering.subject_id,
171
Semester.id == Offering.semester_id,
172
ProjectSubmission.date_submitted == Select(
173
Max(ProjectSubmission.date_submitted),
174
ProjectSubmission.assessed_id == Assessed.id,
175
tables=ProjectSubmission
179
reponame = "_".join([ssn, year, sem, name])
181
# Do we already have the list of logins authorised for this offering
182
# cached? If not, get it.
183
if offeringid not in offering_viewers_cache:
184
offering_viewers_cache[offeringid] = list(store.find(
186
User.id == Enrolment.user_id,
187
Enrolment.offering_id == offeringid,
188
Enrolment.role.is_in((u'tutor', u'lecturer'))
195
""" % {'repo': reponame, 'id': psid, 'path': pspath})
197
for viewer_login in offering_viewers_cache[offeringid]:
198
# Skip existing group members, or they can't write to it any more.
199
if viewer_login not in group_members_cache[gid]:
200
f.write("%s = r\n" % viewer_login)
203
os.rename(temp_name, conf_name)
204
chown_to_webserver(conf_name)
206
def make_svn_auth(store, login, config, throw_on_error=True):
207
"""Create a Subversion password for a user.
209
Generates a new random Subversion password, and assigns it to the user.
210
The password is added to Apache's Subversion authentication file.
129
os.rename(ivle.conf.svn_group_conf + ".new", ivle.conf.svn_group_conf)
130
chown_to_webserver(ivle.conf.svn_group_conf)
132
def make_svn_auth(store, login, throw_on_error=True):
133
"""Setup svn authentication for the given user.
134
Uses the given DB store object. Does not commit to the db.
135
FIXME: create local.auth entry
212
# filename is, eg, /var/lib/ivle/svn/ivle.auth
213
filename = config['paths']['svn']['auth_ivle']
214
if os.path.exists(filename):
137
passwd = md5.new(uuid.uuid4().bytes).digest().encode('hex')
138
if os.path.exists(ivle.conf.svn_auth_ivle):
219
user = User.get_by_login(store, login)
221
if user.svn_pass is None:
222
passwd = hashlib.md5(uuid.uuid4().bytes).hexdigest()
223
user.svn_pass = unicode(passwd)
225
res = subprocess.call(['htpasswd', '-%smb' % create,
226
filename, login, user.svn_pass])
143
user = ivle.database.User.get_by_login(store, login)
144
user.svn_pass = unicode(passwd)
146
res = os.system("htpasswd -%smb %s %s %s" % (create,
147
ivle.conf.svn_auth_ivle,
227
149
if res != 0 and throw_on_error:
228
150
raise Exception("Unable to create ivle-auth for %s" % login)
230
152
# Make sure the file is owned by the web server
231
153
if create == "c":
232
chown_to_webserver(filename)
236
def make_jail(user, config, force=True):
237
"""Create or update a user's jail.
239
Only the user-specific parts of the jail are created here - everything
240
else is expected to be part of another aufs branch.
154
chown_to_webserver(ivle.conf.svn_auth_ivle)
158
def generate_manifest(basedir, targetdir, parent=''):
159
""" From a basedir and a targetdir work out which files are missing or out
160
of date and need to be added/updated and which files are redundant and need
163
parent: This is used for the recursive call to track the relative paths
164
that we have decended.
167
cmp = filecmp.dircmp(basedir, targetdir)
169
# Add all new files and files that have changed
170
to_add = [os.path.join(parent,x) for x in (cmp.left_only + cmp.diff_files)]
172
# Remove files that are redundant
173
to_remove = [os.path.join(parent,x) for x in cmp.right_only]
176
for d in cmp.common_dirs:
177
newbasedir = os.path.join(basedir, d)
178
newtargetdir = os.path.join(targetdir, d)
179
newparent = os.path.join(parent, d)
180
(sadd,sremove) = generate_manifest(newbasedir, newtargetdir, newparent)
184
return (to_add, to_remove)
187
def make_jail(username, uid, force=True, svn_pass=None):
188
"""Creates a new user's jail space, in the jail directory as configured in
191
This only creates things within /home - everything else is expected to be
192
part of another UnionFS branch.
242
194
Returns the path to the user's home directory.
244
196
Chowns the user's directory within the jail to the given UID.
246
@param force: If False, raise an exception if the user already has a jail.
247
If True (default), rebuild the jail preserving /home.
198
Note: This takes separate username and uid arguments. The UID need not
199
*necessarily* correspond to a Unix username at all, if all you are
200
planning to do is setuid to it. This allows the caller the freedom of
201
deciding the binding between username and uid, if any.
203
force: If false, exception if jail already exists for this user.
204
If true (default), overwrites it, but preserves home directory.
206
svn_pass: If provided this will be a string, the randomly-generated
207
Subversion password for this user (if you happen to already have it).
208
If not provided, it will be read from the database.
249
210
# MUST run as root or some of this may fail
250
211
if os.getuid() != 0:
251
212
raise Exception("Must run make_jail as root")
253
214
# tempdir is for putting backup homes in
254
jail_src_base = config['paths']['jails']['src']
255
tempdir = os.path.join(jail_src_base, '__temp__')
215
tempdir = os.path.join(ivle.conf.jail_base, '__temp__')
256
216
if not os.path.exists(tempdir):
257
217
os.makedirs(tempdir)
258
218
elif not os.path.isdir(tempdir):
259
219
os.unlink(tempdir)
260
220
os.mkdir(tempdir)
261
userdir = os.path.join(jail_src_base, user.login)
221
userdir = os.path.join(ivle.conf.jail_src_base, username)
262
222
homedir = os.path.join(userdir, 'home')
263
tmpdir = os.path.join(userdir, 'tmp')
264
userhomedir = os.path.join(homedir, user.login) # Return value
223
userhomedir = os.path.join(homedir, username) # Return value
266
225
if os.path.exists(userdir):
269
228
# User jail already exists. Blow it away but preserve their home
270
229
# directory. It should be all that is there anyway, but you never
272
# Ignore warnings about the use of tempnam
231
# Ignore warnings about the use of tmpnam
273
232
warnings.simplefilter('ignore')
274
233
homebackup = os.tempnam(tempdir)
275
234
warnings.resetwarnings()
276
# Back up the /home directory, delete the entire jail, recreate the
277
# jail directory tree, then copy the /home back
278
# NOTE that shutil.move changed in Python 2.6, it now moves a
279
# directory INTO the target (like `mv`), which it didn't use to do.
280
# This code works regardless.
281
shutil.move(userhomedir, homebackup)
235
# Note: shutil.move does not behave like "mv" - it does not put a file
236
# into a directory if it already exists, just fails. Therefore it is
237
# not susceptible to tmpnam symlink attack.
238
shutil.move(homedir, homebackup)
282
239
shutil.rmtree(userdir)
283
240
os.makedirs(homedir)
284
shutil.move(homebackup, userhomedir)
241
shutil.move(homebackup, homedir)
285
242
# Change the ownership of all the files to the right unixid
286
243
logging.debug("chown %s's home directory files to uid %d"
287
%(user.login, user.unixid))
288
os.spawnvp(os.P_WAIT, 'chown', ['chown', '-R', '%d:%d' % (user.unixid,
289
user.unixid), userhomedir])
245
os.chown(userhomedir, uid, uid)
246
for root, dirs, files in os.walk(userhomedir):
247
for fsobj in dirs + files:
248
os.chown(os.path.join(root, fsobj), uid, uid)
291
250
# No user jail exists
292
251
# Set up the user's home directory
293
252
os.makedirs(userhomedir)
294
253
# Chown (and set the GID to the same as the UID).
295
os.chown(userhomedir, user.unixid, user.unixid)
254
os.chown(userhomedir, uid, uid)
296
255
# Chmod to rwxr-xr-x (755)
297
256
os.chmod(userhomedir, 0755)
299
make_ivle_conf(user.login, userdir, user.svn_pass, config)
300
make_etc_passwd(user.login, userdir, config['paths']['jails']['template'],
303
os.chmod(tmpdir, 01777)
258
# There are 2 special files which need to be generated specific to this
259
# user: ${python_site_packages}/lib/conf/conf.py and /etc/passwd.
260
# "__" username "__" users are exempt (special)
261
if not (username.startswith("__") and username.endswith("__")):
262
make_conf_py(username, userdir, ivle.conf.jail_system, svn_pass)
263
make_etc_passwd(username, userdir, ivle.conf.jail_system, uid)
305
265
return userhomedir
307
def make_ivle_conf(username, user_jail_dir, svn_pass, sys_config):
308
"""Generate an ivle.conf for a user's jail.
267
def make_conf_py(username, user_jail_dir, staging_dir, svn_pass=None):
310
269
Creates (overwriting any existing file, and creating directories) a
311
file /etc/ivle/ivle.conf in a given user's jail.
313
@param username: Username.
314
@param user_jail_dir: User's jail dir, ie. ['jails']['src'] + username
315
@param svn_pass: User's SVN password.
316
@param sys_config: An ivle.config.Config object (the system-wide config).
270
file ${python_site_packages}/ivle/conf/conf.py in a given user's jail.
272
user_jail_dir: User's jail dir, ie. ivle.conf.jail_base + username
273
staging_dir: The dir with the staging copy of the jail. (With the
274
template conf.py file).
275
svn_pass: As with make_jail. User's SVN password, but if not supplied,
276
will look up in the DB.
318
conf_path = os.path.join(user_jail_dir, "home/.ivle.conf")
319
if not os.path.exists(os.path.dirname(conf_path)):
320
os.makedirs(os.path.dirname(conf_path))
322
# In the "in-jail" version of conf, we don't need MOST of the details
323
# (it would be a security risk to have them here).
324
# So we just write root_dir.
325
conf_obj = ivle.config.Config(blank=True)
326
conf_obj.filename = conf_path
327
conf_obj['urls']['root'] = sys_config['urls']['root']
328
conf_obj['urls']['public_host'] = sys_config['urls']['public_host']
329
conf_obj['urls']['svn_addr'] = sys_config['urls']['svn_addr']
330
conf_obj['user_info']['login'] = username
331
conf_obj['user_info']['svn_pass'] = svn_pass
278
template_conf_path = os.path.join(staging_dir,
279
ivle.conf.python_site_packages[1:], "ivle/conf/conf.py")
280
conf_path = os.path.join(user_jail_dir,
281
ivle.conf.python_site_packages[1:], "ivle/conf/conf.py")
282
os.makedirs(os.path.dirname(conf_path))
284
# If svn_pass isn't supplied, grab it from the DB
286
dbconn = ivle.db.DB()
287
svn_pass = dbconn.get_user(username).svn_pass
290
# Read the contents of the template conf file
292
template_conf_file = open(template_conf_path, "r")
293
template_conf_data = template_conf_file.read()
294
template_conf_file.close()
296
# Couldn't open template conf.py for some reason
297
# Just treat it as empty file
298
template_conf_data = ("# Warning: Problem building config script.\n"
299
"# Could not find template conf.py file.\n")
301
conf_file = open(conf_path, "w")
302
conf_file.write(template_conf_data)
303
conf_file.write("\n# The login name for the owner of the jail\n")
304
conf_file.write("login = %s\n" % repr(username))
305
conf_file.write("\n")
306
conf_file.write("# The subversion-only password for the owner of "
308
conf_file.write("svn_pass = %s\n" % repr(svn_pass))
334
311
# Make this file world-readable
335
312
# (chmod 644 conf_path)