32
32
import ivle.console
35
34
from ivle.webapp.base.rest import JSONRESTView, named_operation
36
35
from ivle.webapp.errors import BadRequest
38
37
# XXX: Should be RPC view, with actions in URL?
39
38
class ConsoleServiceRESTView(JSONRESTView):
40
39
'''An RPC interface to a Python console.'''
41
def get_permissions(self, user):
40
def get_permissions(self, user, config):
42
41
if user is not None:
43
42
return set(['use'])
51
50
uid = req.user.unixid
54
jail_path = os.path.join(ivle.conf.jail_base, req.user.login)
55
cons = ivle.console.Console(uid, jail_path, working_dir)
53
jail_path = os.path.join(req.config['paths']['jails']['mounts'],
55
cons = ivle.console.Console(req.config, uid, jail_path, working_dir)
57
57
# Assemble the key and return it. Yes, it is double-encoded.
58
58
return {'key': cjson.encode({"host": cons.host,
60
60
"magic": cons.magic}).encode('hex')}
62
62
@named_operation('use')
63
def chat(self, req, key, text='', kind="chat"):
63
def chat(self, req, key, text='', cwd='', kind="chat"):
64
64
# The request *should* have the following four fields:
65
65
# key: Hex JSON dict of host and port where the console server lives,
66
66
# and the secret to use to digitally sign the communication with the
77
77
raise BadRequest("Invalid console key.")
79
jail_path = os.path.join(ivle.conf.jail_base, req.user.login)
80
working_dir = os.path.join("/home", req.user.login) # Within jail
79
jail_path = os.path.join(req.config['paths']['jails']['mounts'],
82
working_dir = os.path.join("/home", req.user.login, cwd)
81
83
uid = req.user.unixid
85
# XXX: JSONRESTView should do this for us.
86
text = text.decode('utf-8')
83
88
msg = {'cmd':kind, 'text':text}
85
json_response = ivle.chat.chat(host, port, msg, magic,decode=False)
87
# Snoop the response from python-console to check that it's valid
91
json_response = ivle.chat.chat(host, port, msg, magic,decode=False)
92
# Snoop the response from python-console to check that it's valid
89
93
response = cjson.decode(json_response)
90
except cjson.DecodeError:
94
except (cjson.DecodeError, ivle.chat.ProtocolError):
91
95
# Could not decode the reply from the python-console server
92
96
response = {"terminate":
93
97
"Communication to console process lost"}
94
98
if "terminate" in response:
95
response = restart_console(uid, jail_path, working_dir,
96
response["terminate"])
99
response = restart_console(req.config, uid, jail_path,
100
working_dir, response["terminate"])
97
101
except socket.error, (enumber, estring):
98
102
if enumber == errno.ECONNREFUSED:
99
103
# Timeout: Restart the session
100
response = restart_console(uid, jail_path, working_dir,
104
response = restart_console(req.config, uid, jail_path,
101
106
"The IVLE console has timed out due to inactivity")
102
107
elif enumber == errno.ECONNRESET:
103
108
# Communication issue: Restart the session
104
response = restart_console(uid, jail_path, working_dir,
109
response = restart_console(req.config, uid, jail_path,
105
111
"Connection with the console has been reset")
107
113
# Some other error - probably serious
112
def restart_console(uid, jail_path, working_dir, reason):
118
def restart_console(config, uid, jail_path, working_dir, reason):
113
119
"""Tells the client that it must be issued a new console since the old
114
120
console is no longer availible. The client must accept the new key.
115
121
Returns the JSON response to be given to the client.
117
123
# Start a new console server console
118
cons = ivle.console.Console(uid, jail_path, working_dir)
124
cons = ivle.console.Console(config, uid, jail_path, working_dir)
120
126
# Make a JSON object to tell the browser to restart its console client
121
127
new_key = cjson.encode(