← Back to branch summary

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

« back to all changes in this revision

Viewing changes to services/usrmgt-server

  • Committer: matt.giuca
  • Date: 2009-01-12 00:34:59 UTC
  • Revision ID: svn-v3-trunk0:2b9c9e99-6f39-0410-b283-7f802c844ae2:trunk:1073
usrmgt-server: When creating svn repo, now explicitly asks for the exception
    to be thrown up, rather than ignored.

Show diffs side-by-side

added added

removed removed

Lines of Context:
services/usrmgt-server
4
4
import sys
5
5
import logging
6
6
 
7
 
import ivle.config
8
 
import ivle.database
9
 
import ivle.chat
10
 
import ivle.makeuser
11
 
 
12
 
config = ivle.config.Config()
 
7
import conf
 
8
import common.db
 
9
import common.chat
 
10
import common.makeuser
 
11
import common.studpath
13
12
 
14
13
# usage:
15
14
#   usrmgt-server <port> <magic>
29
28
#   - Rebuild svn auth file
30
29
#   - Rebuild passwd + push to nodes.
31
30
 
32
 
def activate_user(store, props, config):
 
31
def activate_user(props):
33
32
    """Create the on-disk stuff for the given user.
34
33
       Sets the state of the user in the db from pending to enabled.
35
 
    @param config: An ivle.config.Config object.
36
34
       Expected properties:
37
35
        login       - the user name for the jail
38
36
                      STRING REQUIRED
39
 
    @return: None
 
37
       Return Value: None
40
38
    """
41
39
 
42
40
    os.umask(0022) # Bad, but start_server sets it worse.
43
41
 
44
42
    login = props['login']
45
43
 
46
 
    # FIXME: check we're pending
47
 
 
48
 
    # Get the full User object from the db associated with this
49
 
    user = ivle.database.User.get_by_login(store, login)
50
 
 
51
 
    # make svn config/auth
52
 
    repopath = os.path.join(config['paths']['svn']['repo_path'],
53
 
                            'users', login)
54
 
    logging.debug("Creating user's Subversion repository")
55
 
    ivle.makeuser.make_svn_repo(repopath, throw_on_error=True)
56
 
 
57
 
    rebuild_svn_config(store, props, config)
58
 
 
59
 
    logging.debug("Adding Subversion authentication")
60
 
    passwd = ivle.makeuser.make_svn_auth(store, login, config,
61
 
                                         throw_on_error=True)
62
 
 
63
 
    logging.debug("Creating jail")
64
 
    ivle.makeuser.make_jail(user, config)
65
 
 
66
 
    logging.info("Enabling user")
67
 
    user.state = u'enabled'
68
 
 
69
 
    return {"response": "okay"}
70
 
 
71
 
def rebuild_svn_config(store, props, config):
 
44
    db = common.db.DB()
 
45
 
 
46
    try:
 
47
 
 
48
        # FIXME: check we're pending
 
49
 
 
50
        details = db.get_user(login)
 
51
 
 
52
        # make svn config/auth
 
53
 
 
54
        repopath = os.path.join(conf.svn_repo_path, 'users', login)
 
55
        logging.debug("Creating user's Subversion repository")
 
56
        common.makeuser.make_svn_repo(repopath, throw_on_error=True)
 
57
 
 
58
        rebuild_svn_config(props)
 
59
 
 
60
        logging.debug("Adding Subversion authentication")
 
61
        passwd = common.makeuser.make_svn_auth(login, throw_on_error=True)
 
62
        logging.debug("passwd: %s" % passwd)
 
63
 
 
64
        logging.debug("Creating jail")
 
65
        common.makeuser.make_jail(login, details.unixid, svn_pass=passwd)
 
66
 
 
67
        logging.info("Enabling user")
 
68
        db.update_user(login, state='enabled')
 
69
 
 
70
        return {"response": "okay"}
 
71
 
 
72
    finally:
 
73
        db.close()
 
74
 
 
75
def rebuild_svn_config(props):
72
76
    """Rebuilds the svn config file
73
 
    @param config: An ivle.config.Config object.
74
 
    @return: response (okay, failure)
 
77
    Return value:
 
78
        response (okay, failure)
75
79
    """
76
80
    try:
77
 
        ivle.makeuser.rebuild_svn_config(store, config)
 
81
        common.makeuser.rebuild_svn_config()
78
82
    except Exception, e:
79
83
        logging.warning('Rebuild of Subversion authorization config failed!')
80
84
        return{'response': 'failure', 'msg': repr(e)}
81
85
 
82
86
    return {'response': 'okay'}
83
87
 
84
 
def rebuild_svn_group_config(store, props, config):
 
88
def rebuild_svn_group_config(props):
85
89
    """Rebuilds the svn group config file
86
 
    @param config: An ivle.config.Config object.
87
 
    @return: response (okay, failure)
 
90
    Return value:
 
91
        response (okay, failure)
88
92
    """
89
93
    try:
90
 
        ivle.makeuser.rebuild_svn_group_config(store, config)
 
94
        common.makeuser.rebuild_svn_group_config()
91
95
    except Exception, e:
92
96
        logging.warning(
93
97
            'Rebuild of Subversion group authorization config failed!')
95
99
 
96
100
    return {'response': 'okay'}
97
101
 
98
 
def create_group_repository(store, props, config):
 
102
def create_group_repository(props):
99
103
    """Creates on disk repository for the given group
100
 
    @param config: An ivle.config.Config object.
101
104
    Expected properties:
102
105
        subj_short_name, year, semester, groupnm
103
 
    @return: response (okay, failure)
 
106
    Return value:
 
107
        response (okay, failure)
104
108
    """
105
109
 
106
110
    subj_short_name = props['subj_short_name']
109
113
    groupnm = props['groupnm']
110
114
 
111
115
    namespace = "_".join([subj_short_name, year, semester, groupnm])
112
 
    repopath = os.path.join(config['paths']['svn']['repo_path'],
113
 
                            'groups', namespace)
 
116
    repopath = os.path.join(conf.svn_repo_path, 'groups', namespace)
114
117
    logging.debug("Creating Subversion repository %s"%repopath)
115
118
    try:
116
 
        ivle.makeuser.make_svn_repo(repopath)
 
119
        common.makeuser.make_svn_repo(repopath)
117
120
    except Exception, e:
118
121
        logging.error("Failed to create Subversion repository %s: %s"%
119
122
            (repopath,repr(e)))
129
132
    }
130
133
 
131
134
def initializer():
132
 
    logging.basicConfig(filename="/var/log/usrmgt.log", level=logging.INFO)
133
 
    logging.info("Starting usrmgt server on port %d (pid = %d)" %
134
 
                 (config['usrmgt']['port'], pid))
135
 
 
136
135
    try:
137
136
        pidfile = open('/var/run/usrmgt-server.pid', 'w')
138
137
        pidfile.write('%d\n' % os.getpid())
143
142
 
144
143
def dispatch(props):
145
144
    logging.debug(repr(props))
146
 
 
147
 
    store = ivle.database.get_store(config)
148
145
    action = props.keys()[0]
149
 
    res = actions[action](store, props[action], config)
150
 
 
151
 
    if res['response'] == 'okay':
152
 
        store.commit()
153
 
    else:
154
 
        store.rollback()
155
 
    store.close()
156
 
    return res
 
146
    return actions[action](props[action])
157
147
 
158
148
if __name__ == "__main__":
159
149
    pid = os.getpid()
160
150
 
161
 
    ivle.chat.start_server(config['usrmgt']['port'],config['usrmgt']['magic'],
162
 
                           True, dispatch, initializer)
 
151
    logging.basicConfig(filename="/var/log/usrmgt.log", level=logging.INFO)
 
152
    logging.info("Starting usrmgt server on port %d (pid = %d)" %
 
153
                 (conf.usrmgt_port, pid))
 
154
 
 
155
    common.chat.start_server(conf.usrmgt_port, conf.usrmgt_magic, True, dispatch, initializer)