1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
#!/usr/bin/python
# -*- coding: utf-8 -*-
# Copyright (C) 2010-2023 by Mike Gabriel <mike.gabriel@das-netzwerkteam.de>
#
# Python X2Go is free software; you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation; either version 3 of the License, or
# (at your option) any later version.
#
# Python X2Go is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU Affero General Public License for more details.
#
# You should have received a copy of the GNU Affero General Public License
# along with this program; if not, write to the
# Free Software Foundation, Inc.,
# 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA.
###
### short example for python-phoca usage
###
# import x2go before you import other thread based modules (e.g. paramiko)
import x2go
import gevent
import getpass
import threading
# modify to your needs...
server = "server.mydomain.tld"
port = 22
username = "foo"
command = "XFCE"
def my_progress_bar(ps):
for status in ps:
print('---------------')
print('SESSION STATUS: ' + '#' * status + "(" + str(status) + "%%)")
print('---------------')
password = getpass.getpass()
cli = x2go.X2GoClient(use_cache=False, loglevel=x2go.log.loglevel_DEBUG)
s_uuid = cli.register_session(server, port=port,
username=username,
cmd=command,
add_to_known_hosts=True,
)
cli.connect_session(s_uuid, password=password)
# clean sessions and check the result
cli.clean_sessions(s_uuid)
# initialize a ProgressStatus event and iterator
progress_event = threading.Event()
progress_status = x2go.utils.ProgressStatus(progress_event, cli.get_session(s_uuid).get_progress_status)
# start the status bar
gevent.spawn(my_progress_bar, progress_status)
# start the session
gevent.spawn(cli.start_session, s_uuid, progress_event=progress_event)
# wait long enough for session to come up completely
while (cli.get_session(s_uuid).get_progress_status() < 100) and (cli.get_session(s_uuid).get_progress_status() != -1):
gevent.sleep(1)
try:
while cli.session_ok(s_uuid):
gevent.sleep(2)
except KeyboardInterrupt:
pass
# suspend the session
cli.suspend_session(s_uuid)
|
