47
import ivle.pulldown_subj
49
from ivle.database import ProjectGroup
30
from storm.expr import Select, Max
33
from ivle.database import (User, ProjectGroup, Assessed, ProjectSubmission,
34
Project, ProjectSet, Offering, Enrolment, Subject, Semester)
51
36
def chown_to_webserver(filename):
53
Chowns a file so the web server user owns it.
54
(This is useful in setting up Subversion conf files).
37
"""chown a directory and its contents to the web server.
39
Recursively chowns a file or directory so the web server user owns it.
58
os.system("chown -R www-data:www-data %s" % filename)
42
subprocess.call(['chown', '-R', 'www-data:www-data', filename])
62
44
def make_svn_repo(path, throw_on_error=True):
63
"""Create a Subversion repository at the given path.
45
"""Create a Subversion repository at the given path."""
66
res = os.system("svnadmin create '%s'" % path)
47
res = subprocess.call(['svnadmin', 'create', path])
67
48
if res != 0 and throw_on_error:
68
49
raise Exception("Cannot create repository: %s" % path)
69
50
except Exception, exc:
76
57
def rebuild_svn_config(store, config):
77
58
"""Build the complete SVN configuration file.
78
60
@param config: An ivle.config.Config object.
80
users = store.find(ivle.database.User)
82
# TODO: Populate groups with per-offering tutors/lecturers/etc.
62
users = store.find(User)
83
63
conf_name = config['paths']['svn']['conf']
84
64
temp_name = conf_name + ".new"
85
65
f = open(temp_name, "w")
86
f.write("# IVLE SVN Repositories Configuration\n")
87
f.write("# Auto-generated on %s\n" % time.asctime())
90
for (g,ls) in groups.iteritems():
91
f.write("%s = %s\n" % (g, ",".join(ls)))
67
# IVLE SVN repository authorisation configuration
69
""" % {'time': time.asctime()})
94
f.write("[%s:/]\n" % u.login)
95
f.write("%s = rw\n" % u.login)
96
#f.write("@tutor = r\n")
97
#f.write("@lecturer = rw\n")
98
#f.write("@admin = rw\n")
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)
101
121
os.rename(temp_name, conf_name)
102
122
chown_to_webserver(conf_name)
104
124
def rebuild_svn_group_config(store, config):
105
125
"""Build the complete SVN configuration file for groups
106
127
@param config: An ivle.config.Config object.
108
129
conf_name = config['paths']['svn']['group_conf']
109
130
temp_name = conf_name + ".new"
110
131
f = open(temp_name, "w")
111
f.write("# IVLE SVN Group Repositories Configuration\n")
112
f.write("# Auto-generated on %s\n" % time.asctime())
134
# IVLE SVN group repository authorisation configuration
135
# Generated: %(time)s
137
""" % {'time': time.asctime()})
139
group_members_cache = {}
114
140
for group in store.find(ProjectGroup):
115
141
offering = group.project_set.offering
116
142
reponame = "_".join([offering.subject.short_name,
117
143
offering.semester.year,
118
144
offering.semester.semester,
120
f.write("[%s:/]\n"%reponame)
147
f.write("[%s:/]\n" % reponame)
148
if group.id not in group_members_cache:
149
group_members_cache[group.id] = set()
121
150
for user in group.members:
151
group_members_cache[group.id].add(user.login)
122
152
f.write("%s = rw\n" % user.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)
125
203
os.rename(temp_name, conf_name)
126
204
chown_to_webserver(conf_name)
128
206
def make_svn_auth(store, login, config, throw_on_error=True):
129
"""Setup svn authentication for the given user.
130
Uses the given DB store object. Does not commit to the db.
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.
132
212
# filename is, eg, /var/lib/ivle/svn/ivle.auth
133
213
filename = config['paths']['svn']['auth_ivle']
154
def generate_manifest(basedir, targetdir, parent=''):
155
""" From a basedir and a targetdir work out which files are missing or out
156
of date and need to be added/updated and which files are redundant and need
159
parent: This is used for the recursive call to track the relative paths
160
that we have decended.
163
cmp = filecmp.dircmp(basedir, targetdir)
165
# Add all new files and files that have changed
166
to_add = [os.path.join(parent,x) for x in (cmp.left_only + cmp.diff_files)]
168
# Remove files that are redundant
169
to_remove = [os.path.join(parent,x) for x in cmp.right_only]
172
for d in cmp.common_dirs:
173
newbasedir = os.path.join(basedir, d)
174
newtargetdir = os.path.join(targetdir, d)
175
newparent = os.path.join(parent, d)
176
(sadd,sremove) = generate_manifest(newbasedir, newtargetdir, newparent)
180
return (to_add, to_remove)
183
234
def make_jail(user, config, force=True):
184
"""Creates a new user's jail space, in the jail directory as configured in
235
"""Create or update a user's jail.
187
This only creates things within /home - everything else is expected to be
188
part of another UnionFS branch.
237
Only the user-specific parts of the jail are created here - everything
238
else is expected to be part of another aufs branch.
190
240
Returns the path to the user's home directory.
192
242
Chowns the user's directory within the jail to the given UID.
194
force: If false, exception if jail already exists for this user.
195
If true (default), overwrites it, but preserves home directory.
244
@param force: If False, raise an exception if the user already has a jail.
245
If True (default), rebuild the jail preserving /home.
197
247
# MUST run as root or some of this may fail
198
248
if os.getuid() != 0:
added
removed
ivle/makeuser.py
