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