2 # -*- coding: utf-8 -*-
4 # ------------------------------------------------------------
7 # executes a cygwin command inside the opensecurity project
9 # Autor: Mihai Bartha, <mihai.bartha@ait.ac.at>
10 # Oliver Maurhart, <oliver.maurhart@ait.ac.at>
12 # Copyright (C) 2013 AIT Austrian Institute of Technology
13 # AIT Austrian Institute of Technology GmbH
14 # Donau-City-Strasse 1 | 1220 Vienna | Austria
15 # http://www.ait.ac.at
17 # This program is free software; you can redistribute it and/or
18 # modify it under the terms of the GNU General Public License
19 # as published by the Free Software Foundation version 2.
21 # This program is distributed in the hope that it will be useful,
22 # but WITHOUT ANY WARRANTY; without even the implied warranty of
23 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
24 # GNU General Public License for more details.
26 # You should have received a copy of the GNU General Public License
27 # along with this program; if not, write to the Free Software
28 # Foundation, Inc., 51 Franklin Street, Fifth Floor,
29 # Boston, MA 02110-1301, USA.
30 # ------------------------------------------------------------
33 # ------------------------------------------------------------
40 from subprocess import Popen, PIPE, call, STARTUPINFO, _subprocess
43 from environment import Environment
44 from opensecurity_util import logger, setupLogger, OpenSecurityException
46 # ------------------------------------------------------------
50 """get the path to our local cygwin installment"""
51 home_drive = os.path.expandvars("%HOMEDRIVE%") + os.sep
53 os.path.abspath(os.path.join(Environment('OpenSecurity').prefix_path, 'cygwin')),
54 os.path.abspath(os.path.join(Environment('OpenSecurity').prefix_path, 'cygwin64')),
55 os.path.abspath(os.path.join(home_drive, 'cygwin')),
56 os.path.abspath(os.path.join(home_drive, 'cygwin64'))
58 path_valid = [ p for p in path_hint if os.path.exists(p) ]
60 theClass.cygwin_root = path_valid[0]
61 theClass.cygwin_bin = os.path.join(theClass.cygwin_root, 'bin') + os.path.sep
62 theClass.cygwin_bash = os.path.join(theClass.cygwin_bin, 'bash.exe')
63 theClass.cygwin_ssh = os.path.join(theClass.cygwin_bin, 'ssh.exe')
64 theClass.cygwin_scp = os.path.join(theClass.cygwin_bin, 'scp.exe')
65 theClass.cygwin_x11 = os.path.join(theClass.cygwin_bin, 'XWin.exe')
66 theClass.win_cmd = os.environ.get("COMSPEC", "cmd.exe")
67 """get the path to the VirtualBox installation on this system"""
68 theClass.vbox_root = theClass.getRegEntry('SOFTWARE\Oracle\VirtualBox', 'InstallDir')[0]
69 theClass.vbox_man = os.path.join(theClass.vbox_root, 'VBoxManage.exe')
70 #theClass.user_home = os.path.expanduser("~")
71 theClass.user_home = os.environ['APPDATA']#os.path.expandvars("%APPDATA%")
74 class XRunner(threading.Thread):
77 threading.Thread.__init__(self)
84 logger.info('X starting')
85 if not Cygwin.is_X11_running():
86 #os.system('"'+Cygwin.cygwin_x11+'" :0 -multiwindow -resize')
87 sts = call('"'+Cygwin.cygwin_x11+'" :0 -multiwindow -resize', shell=True)
89 logger.info('X already started')
105 """Some nifty methods working with Cygwin"""
107 def __call__(self, command, arguments, wait_return=True, window = False):
108 """make an instance of this object act as a function"""
109 return self.execute(command, arguments, wait_return, window)
112 def getRegEntry(key, value):
114 k = _winreg.OpenKey(_winreg.HKEY_LOCAL_MACHINE, key)
115 value = _winreg.QueryValueEx(k, value)
124 return Cygwin.cygwin_root
128 return Cygwin.cygwin_bin
132 return Cygwin.cygwin_bash
136 return Cygwin.cygwin_ssh
140 return Cygwin.cygwin_scp
144 return Cygwin.cygwin_x11
148 return Cygwin.vbox_man
152 return Cygwin.win_cmd
156 return Cygwin.user_home
158 executeLock = threading.Lock()
159 #executes command on host system
161 def execute(program, arguments, wait_return=True, window = False, stdin = PIPE, stdout = PIPE, stderr = PIPE):
162 _startupinfo = STARTUPINFO()
164 _startupinfo.dwFlags |= _subprocess.STARTF_USESHOWWINDOW
165 _startupinfo.wShowWindow = _subprocess.SW_HIDE
167 #logger.debug('trying to launch: ' + program + ' ' + ''.join(arguments))
170 # quote the executable otherwise we run into troubles
171 # when the path contains spaces and additonal arguments
172 # are presented as well.
173 # special: invoking bash as login shell here with
174 # an unquoted command does not execute /etc/profile
175 args = '"' + program + '" ' + arguments
176 process = Popen(args, startupinfo = _startupinfo, stdin = stdin, stdout = stdout, stderr = stderr, shell = False)
177 logger.debug('Launched: ' + program + ' ' + ''.join(arguments))
179 return [0, 'working in background', '']
180 result = process.wait()
181 res_stdout = process.stdout.read();
182 res_stderr = process.stderr.read();
184 except Exception as ex:
185 res_stderr = ''.join(str(ex.args))
188 return result, res_stdout, res_stderr
191 def vboxExecute(command, wait_return=True, window = False, bash_opts=''):
195 if Cygwin.executeLock.acquire(True):
196 result = Cygwin.execute(Cygwin.vbox_man, command, wait_return, window)
197 Cygwin.executeLock.release()
205 def bashExecute(command, wait_return=True, window = False, bash_opts='', stdin = PIPE, stdout = PIPE, stderr = PIPE):
206 # for some reason, the '-l' is ignored when started via python
207 # so the same behavior is triggered by calling /etc/profile
209 command = bash_opts + ' -l -c "' + command + '"'
210 return Cygwin.execute(Cygwin.cygwin_bash, command, wait_return, window, stdin = stdin, stdout = stdout, stderr = stderr)
213 def cmdExecute(command, wait_return=True, window = False):
214 command = ' /c ' + command
215 return Cygwin.execute(Cygwin.win_cmd, command, wait_return, window)
217 # executes command over ssh on guest vm
219 def sshExecute(command, address, user_name, certificate, wait_return=True, window = False):
220 command = ' -v -o StrictHostKeyChecking=no -i "' + certificate + '" ' + user_name + '@' + address + ' ' + command
221 return Cygwin.execute(Cygwin.cygwin_ssh, command, wait_return, window)
223 #machineFolder + '/' + vm_name + '/dvm_key
224 #address = self.getHostOnlyIP(vm_name)
225 #machineFolder = self.getDefaultMachineFolder()
226 #machineFolder = Cygwin.cygwinPath(machineFolder)
228 # executes command over ssh on guest vm with X forwarding
230 def sshExecuteX11(command, address, user_name, certificate, wait_return=True):
231 #return call('"'+ Cygwin.cygwin_bash +'" -l -c "' + 'DISPLAY=:0.0 ssh -Y -i \\\"' + certificate +'\\\" ' + user_name + '@' + address + ' ' + command + '"', shell=True)
232 return Cygwin.bashExecute('DISPLAY=:0.0 ssh -Y -o StrictHostKeyChecking=no -i \\\"' + certificate +'\\\" ' + user_name + '@' + address + ' ' + command + '')
235 def is_X11_running():
236 """check if we can connect to a X11 running instance"""
237 p = Cygwin.bashExecute('xset -display :0.0 q', wait_return = True, window = False)
242 """start X11 in the background (if not already running) on DISPLAY=:0"""
245 return (0, None, None)
248 #return Cygwin.execute(Cygwin.cygwin_x11, ':0 -multiwindow', wait_return = True, window = False)
249 #return Cygwin.bashExecute('XWin :0 -multiwindow', wait_return = True, window = False)
250 #return Cygwin.bashExecute('DISPLAY=:0.0 xhost +', wait_return = True, window = False)
251 #return os.system('"'+Cygwin.cygwin_x11+'" :0 -multiwindow -resize')
255 cmd = 'cygpath -u \'' + path + '\''
256 return Cygwin.bashExecute(cmd)[1].rstrip('\n')
264 if __name__ == "__main__":
265 logger = setupLogger('Cygwin')
267 #logger.info(c.root())
268 #logger.info(c.bin())
269 #logger.info(c.bash())
270 #logger.info(c.ssh())
271 #logger.info(c.x11())
272 #logger.info(c.home())
275 #tasklist /v /fo list /fi "IMAGENAME eq explorer.exe"
287 #print (Cygwin.is_X11_running())
288 #print (Cygwin.is_X11_running())
289 #new_sdvm = 'SecurityDVM0'
290 #new_ip = Cygwin.vboxExecute('guestproperty get ' + new_sdvm + ' /VirtualBox/GuestInfo/Net/0/V4/IP')[1]
291 #new_ip = new_ip[new_ip.index(':')+1:].strip()
293 #result = Cygwin.bashExecute('DISPLAY=:0.0 xhost '+new_ip)
294 #browser = '/usr/bin/midori '
295 #print(Cygwin.sshExecuteX11(browser, new_ip, 'osecuser', '/cygdrive/c/Users/BarthaM/VirtualBox VMs' + '/' + new_sdvm + '/dvm_key'))
297 #print(Cygwin.bashExecute('echo $PATH')[1])
298 #print(Cygwin.cygPath('C:'))
299 #print('C:\\Program Files\\OpenSecurity: ' + c.cygPath('C:\\Program Files\\OpenSecurity'))