Merge pull request #33 from ChrisTruncer/bin_
Small change to reference object attribute
This commit is contained in:
@@ -23,7 +23,9 @@ example of use rdpy
|
|||||||
take screenshot of login page
|
take screenshot of login page
|
||||||
"""
|
"""
|
||||||
|
|
||||||
import sys, os, getopt
|
import getopt
|
||||||
|
import os
|
||||||
|
import sys
|
||||||
|
|
||||||
from PyQt4 import QtCore, QtGui
|
from PyQt4 import QtCore, QtGui
|
||||||
from rdpy.protocol.rdp import rdp
|
from rdpy.protocol.rdp import rdp
|
||||||
@@ -32,15 +34,17 @@ import rdpy.core.log as log
|
|||||||
from rdpy.core.error import RDPSecurityNegoFail
|
from rdpy.core.error import RDPSecurityNegoFail
|
||||||
from twisted.internet import task
|
from twisted.internet import task
|
||||||
|
|
||||||
#set log level
|
# set log level
|
||||||
log._LOG_LEVEL = log.Level.INFO
|
log._LOG_LEVEL = log.Level.INFO
|
||||||
|
|
||||||
|
|
||||||
class RDPScreenShotFactory(rdp.ClientFactory):
|
class RDPScreenShotFactory(rdp.ClientFactory):
|
||||||
"""
|
"""
|
||||||
@summary: Factory for screenshot exemple
|
@summary: Factory for screenshot exemple
|
||||||
"""
|
"""
|
||||||
__INSTANCE__ = 0
|
__INSTANCE__ = 0
|
||||||
__STATE__ = []
|
__STATE__ = []
|
||||||
|
|
||||||
def __init__(self, reactor, app, width, height, path, timeout):
|
def __init__(self, reactor, app, width, height, path, timeout):
|
||||||
"""
|
"""
|
||||||
@param reactor: twisted reactor
|
@param reactor: twisted reactor
|
||||||
@@ -58,7 +62,7 @@ class RDPScreenShotFactory(rdp.ClientFactory):
|
|||||||
self._timeout = timeout
|
self._timeout = timeout
|
||||||
#NLA server can't be screenshooting
|
#NLA server can't be screenshooting
|
||||||
self._security = rdp.SecurityLevel.RDP_LEVEL_SSL
|
self._security = rdp.SecurityLevel.RDP_LEVEL_SSL
|
||||||
|
|
||||||
def clientConnectionLost(self, connector, reason):
|
def clientConnectionLost(self, connector, reason):
|
||||||
"""
|
"""
|
||||||
@summary: Connection lost event
|
@summary: Connection lost event
|
||||||
@@ -70,14 +74,14 @@ class RDPScreenShotFactory(rdp.ClientFactory):
|
|||||||
self._security = rdp.SecurityLevel.RDP_LEVEL_RDP
|
self._security = rdp.SecurityLevel.RDP_LEVEL_RDP
|
||||||
connector.connect()
|
connector.connect()
|
||||||
return
|
return
|
||||||
|
|
||||||
log.info("connection lost : %s"%reason)
|
log.info("connection lost : %s" % reason)
|
||||||
RDPScreenShotFactory.__STATE__.append((connector.host, connector.port, reason))
|
RDPScreenShotFactory.__STATE__.append((connector.host, connector.port, reason))
|
||||||
RDPScreenShotFactory.__INSTANCE__ -= 1
|
RDPScreenShotFactory.__INSTANCE__ -= 1
|
||||||
if(RDPScreenShotFactory.__INSTANCE__ == 0):
|
if(RDPScreenShotFactory.__INSTANCE__ == 0):
|
||||||
self._reactor.stop()
|
self._reactor.stop()
|
||||||
self._app.exit()
|
self._app.exit()
|
||||||
|
|
||||||
def clientConnectionFailed(self, connector, reason):
|
def clientConnectionFailed(self, connector, reason):
|
||||||
"""
|
"""
|
||||||
@summary: Connection failed event
|
@summary: Connection failed event
|
||||||
@@ -90,8 +94,7 @@ class RDPScreenShotFactory(rdp.ClientFactory):
|
|||||||
if(RDPScreenShotFactory.__INSTANCE__ == 0):
|
if(RDPScreenShotFactory.__INSTANCE__ == 0):
|
||||||
self._reactor.stop()
|
self._reactor.stop()
|
||||||
self._app.exit()
|
self._app.exit()
|
||||||
|
|
||||||
|
|
||||||
def buildObserver(self, controller, addr):
|
def buildObserver(self, controller, addr):
|
||||||
"""
|
"""
|
||||||
@summary: build ScreenShot observer
|
@summary: build ScreenShot observer
|
||||||
@@ -117,46 +120,46 @@ class RDPScreenShotFactory(rdp.ClientFactory):
|
|||||||
self._timeout = timeout
|
self._timeout = timeout
|
||||||
self._startTimeout = False
|
self._startTimeout = False
|
||||||
self._reactor = reactor
|
self._reactor = reactor
|
||||||
|
|
||||||
def onUpdate(self, destLeft, destTop, destRight, destBottom, width, height, bitsPerPixel, isCompress, data):
|
def onUpdate(self, destLeft, destTop, destRight, destBottom, width, height, bitsPerPixel, isCompress, data):
|
||||||
"""
|
"""
|
||||||
@summary: callback use when bitmap is received
|
@summary: callback use when bitmap is received
|
||||||
"""
|
"""
|
||||||
image = RDPBitmapToQtImage(width, height, bitsPerPixel, isCompress, data);
|
image = RDPBitmapToQtImage(width, height, bitsPerPixel, isCompress, data);
|
||||||
with QtGui.QPainter(self._buffer) as qp:
|
with QtGui.QPainter(self._buffer) as qp:
|
||||||
#draw image
|
# draw image
|
||||||
qp.drawImage(destLeft, destTop, image, 0, 0, destRight - destLeft + 1, destBottom - destTop + 1)
|
qp.drawImage(destLeft, destTop, image, 0, 0, destRight - destLeft + 1, destBottom - destTop + 1)
|
||||||
if not self._startTimeout:
|
if not self._startTimeout:
|
||||||
self._startTimeout = False
|
self._startTimeout = False
|
||||||
self._reactor.callLater(self._timeout, self.checkUpdate)
|
self._reactor.callLater(self._timeout, self.checkUpdate)
|
||||||
|
|
||||||
def onReady(self):
|
def onReady(self):
|
||||||
"""
|
"""
|
||||||
@summary: callback use when RDP stack is connected (just before received bitmap)
|
@summary: callback use when RDP stack is connected (just before received bitmap)
|
||||||
"""
|
"""
|
||||||
log.info("connected %s"%addr)
|
log.info("connected %s" % addr)
|
||||||
|
|
||||||
def onSessionReady(self):
|
def onSessionReady(self):
|
||||||
"""
|
"""
|
||||||
@summary: Windows session is ready
|
@summary: Windows session is ready
|
||||||
@see: rdp.RDPClientObserver.onSessionReady
|
@see: rdp.RDPClientObserver.onSessionReady
|
||||||
"""
|
"""
|
||||||
pass
|
pass
|
||||||
|
|
||||||
def onClose(self):
|
def onClose(self):
|
||||||
"""
|
"""
|
||||||
@summary: callback use when RDP stack is closed
|
@summary: callback use when RDP stack is closed
|
||||||
"""
|
"""
|
||||||
log.info("save screenshot into %s"%self._path)
|
log.info("save screenshot into %s" % self._path)
|
||||||
self._buffer.save(self._path)
|
self._buffer.save(self._path)
|
||||||
|
|
||||||
def checkUpdate(self):
|
def checkUpdate(self):
|
||||||
self._controller.close();
|
self._controller.close();
|
||||||
|
|
||||||
controller.setScreen(width, height);
|
controller.setScreen(self._width, self._height);
|
||||||
controller.setSecurityLevel(self._security)
|
controller.setSecurityLevel(self._security)
|
||||||
return ScreenShotObserver(controller, self._width, self._height, self._path, self._timeout, self._reactor)
|
return ScreenShotObserver(controller, self._width, self._height, self._path, self._timeout, self._reactor)
|
||||||
|
|
||||||
def main(width, height, path, timeout, hosts):
|
def main(width, height, path, timeout, hosts):
|
||||||
"""
|
"""
|
||||||
@summary: main algorithm
|
@summary: main algorithm
|
||||||
@@ -168,39 +171,40 @@ def main(width, height, path, timeout, hosts):
|
|||||||
"""
|
"""
|
||||||
#create application
|
#create application
|
||||||
app = QtGui.QApplication(sys.argv)
|
app = QtGui.QApplication(sys.argv)
|
||||||
|
|
||||||
#add qt4 reactor
|
#add qt4 reactor
|
||||||
import qt4reactor
|
import qt4reactor
|
||||||
qt4reactor.install()
|
qt4reactor.install()
|
||||||
|
|
||||||
from twisted.internet import reactor
|
from twisted.internet import reactor
|
||||||
|
|
||||||
for host in hosts:
|
for host in hosts:
|
||||||
if ':' in host:
|
if ':' in host:
|
||||||
ip, port = host.split(':')
|
ip, port = host.split(':')
|
||||||
else:
|
else:
|
||||||
ip, port = host, "3389"
|
ip, port = host, "3389"
|
||||||
|
|
||||||
reactor.connectTCP(ip, int(port), RDPScreenShotFactory(reactor, app, width, height, path + "%s.jpg"%ip, timeout))
|
reactor.connectTCP(ip, int(port), RDPScreenShotFactory(reactor, app, width, height, path + "%s.jpg" % ip, timeout))
|
||||||
|
|
||||||
reactor.runReturn()
|
reactor.runReturn()
|
||||||
app.exec_()
|
app.exec_()
|
||||||
return RDPScreenShotFactory.__STATE__
|
return RDPScreenShotFactory.__STATE__
|
||||||
|
|
||||||
|
|
||||||
def help():
|
def help():
|
||||||
print "Usage: rdpy-rdpscreenshot [options] ip[:port]"
|
print "Usage: rdpy-rdpscreenshot [options] ip[:port]"
|
||||||
print "\t-w: width of screen default value is 1024"
|
print "\t-w: width of screen default value is 1024"
|
||||||
print "\t-l: height of screen default value is 800"
|
print "\t-l: height of screen default value is 800"
|
||||||
print "\t-o: file path of screenshot default(/tmp/rdpy-rdpscreenshot.jpg)"
|
print "\t-o: file path of screenshot default(/tmp/rdpy-rdpscreenshot.jpg)"
|
||||||
print "\t-t: timeout of connection without any updating order (default is 2s)"
|
print "\t-t: timeout of connection without any updating order (default is 2s)"
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
#default script argument
|
# default script argument
|
||||||
width = 1024
|
width = 1024
|
||||||
height = 800
|
height = 800
|
||||||
path = "/tmp/"
|
path = "/tmp/"
|
||||||
timeout = 5.0
|
timeout = 5.0
|
||||||
|
|
||||||
try:
|
try:
|
||||||
opts, args = getopt.getopt(sys.argv[1:], "hw:l:o:t:")
|
opts, args = getopt.getopt(sys.argv[1:], "hw:l:o:t:")
|
||||||
except getopt.GetoptError:
|
except getopt.GetoptError:
|
||||||
@@ -217,5 +221,5 @@ if __name__ == '__main__':
|
|||||||
path = arg
|
path = arg
|
||||||
elif opt == "-t":
|
elif opt == "-t":
|
||||||
timeout = float(arg)
|
timeout = float(arg)
|
||||||
|
|
||||||
main(width, height, path, timeout, args)
|
main(width, height, path, timeout, args)
|
||||||
|
|||||||
Reference in New Issue
Block a user