#Прототип механизма подключения к удаленной машине

dev-linux
Ivan Maslov 6 years ago
parent 3b5dfcc405
commit 39402cb150

@ -0,0 +1,37 @@
import datetime
import http.client
import json
#{
# actionList:
# [
# {
# type: <RemoteMachineProcessingRun>,
# host: <localhost>,
# port: <port>,
# bodyObject: <object dict, int, str, list>
# }
# ]
#
#}
def ProcessingRun(inConfigurationDict):
lDateTimeString=datetime.datetime.strftime(datetime.datetime.now(),"%Y.%m.%d %H:%M:%S::%f")
lResult={"dateTime":lDateTimeString, "state":"connected", "actionListResult":[]}
for lItem in inConfigurationDict["actionList"]:
#Добавить входные значения
lResult["actionListResult"].append({"inArgs":lItem})
#Обработка запроса на отправку команды на удаленную машину
if lItem["type"]=="RemoteMachineProcessingRun":
lHTTPConnection = http.client.HTTPConnection(lItem["host"], lItem["port"], timeout=5)
try:
lHTTPConnection.request("POST","/ProcessingRun",json.dumps(lItem["bodyObject"]))
except Exception as e:
#Объединение словарей
lResult["actionListResult"][-1] = {**lResult["actionListResult"][-1], **{"state":"disconnected","errorMessage":str(e)}}
#lResult["actionListResult"][-1].join({"state":"disconnected","errorMessage":str(e)})
else:
lHTTPResponse=lHTTPConnection.getresponse()
lHTTPResponseByteArray=lHTTPResponse.read()
lResult["actionListResult"][-1] = {**lResult["actionListResult"][-1], **json.loads(lHTTPResponseByteArray.decode('utf8'))}
#Вернуть результат
return lResult

@ -9,6 +9,7 @@ import os
import PIL import PIL
from PIL import ImageGrab from PIL import ImageGrab
from threading import Thread from threading import Thread
import robotDaemonProcessor
def SaveScreenshot(inFilePath): def SaveScreenshot(inFilePath):
# grab fullscreen # grab fullscreen
lScreenshot = ImageGrab.grab() lScreenshot = ImageGrab.grab()
@ -75,7 +76,6 @@ class testHTTPServer_RequestHandler(BaseHTTPRequestHandler):
if self.path == '/3rdParty/Handlebars/handlebars-v4.1.2.js': if self.path == '/3rdParty/Handlebars/handlebars-v4.1.2.js':
self.SendResponseContentTypeFile('application/javascript',"..\\..\\3rdParty\\Handlebars\\handlebars-v4.1.2.js") self.SendResponseContentTypeFile('application/javascript',"..\\..\\3rdParty\\Handlebars\\handlebars-v4.1.2.js")
#Получить скриншот #Получить скриншот
if self.path.split("?")[0] == '/GetScreenshot': if self.path.split("?")[0] == '/GetScreenshot':
#Сохранить файл на диск #Сохранить файл на диск
SaveScreenshot("Screenshot.png") SaveScreenshot("Screenshot.png")
@ -91,88 +91,24 @@ class testHTTPServer_RequestHandler(BaseHTTPRequestHandler):
message = json.dumps(mJSONConfigurationDict) message = json.dumps(mJSONConfigurationDict)
# Write content as utf-8 data # Write content as utf-8 data
self.wfile.write(bytes(message, "utf8")) self.wfile.write(bytes(message, "utf8"))
# POST # POST
def do_POST(self): def do_POST(self):
#Action ObjectInspector GetObjectList #Централизованная функция получения запросов/отправки
if self.path == '/ObjectDetector/JSONGetWindowListArgs': if self.path == '/ProcessingRun':
#ReadRequest
lInputByteArrayLength = int(self.headers.get('Content-Length'))
lInputByteArray=self.rfile.read(lInputByteArrayLength)
#Превращение массива байт в объект
print(lInputByteArray.decode('utf8'))
lInputObject=json.loads(lInputByteArray.decode('utf8'))
# Send response status code
self.send_response(200)
# Send headers
self.send_header('Content-type','application/json')
self.end_headers()
# Send message back to client
#{'functionName':'', 'argsArray':[]}
lRequestObject={'functionName':'ElementGetChildElementList','argsArray':lInputObject}
#Отправить запрос в дочерний процесс, который отвечает за работу с Windows окнами
#ProcessChildSendObject(p,lRequestObject)
#Получить ответ от дочернего процесса
#lResponseObject=ProcessChildReadWaitObject(p)
print(str(lResponseObject))
message = json.dumps(lResponseObject)
# Write content as utf-8 data
self.wfile.write(bytes(message, "utf8"))
if self.path == '/GUIAction':
#ReadRequest
lInputByteArrayLength = int(self.headers.get('Content-Length'))
lInputByteArray=self.rfile.read(lInputByteArrayLength)
#Превращение массива байт в объект
lInputObject=json.loads(lInputByteArray.decode('utf8'))
# Send response status code
self.send_response(200)
# Send headers
self.send_header('Content-type','application/json')
self.end_headers()
# Send message back to client
#{'functionName':'', 'argsArray':[]}
#pdb.set_trace()
lRequestObject=lInputObject
#Отправить запрос в дочерний процесс, который отвечает за работу с Windows окнами
#ProcessChildSendObject(p,lRequestObject)
#Получить ответ от дочернего процесса
#lResponseObject=ProcessChildReadWaitObject(p)
message = json.dumps(lResponseObject)
# Write content as utf-8 data
self.wfile.write(bytes(message, "utf8"))
if self.path == '/GUIActionList':
#ReadRequest #ReadRequest
lInputByteArrayLength = int(self.headers.get('Content-Length')) lInputObject={}
lInputByteArray=self.rfile.read(lInputByteArrayLength) if self.headers.get('Content-Length') is not None:
#Превращение массива байт в объект lInputByteArrayLength = int(self.headers.get('Content-Length'))
lInputObject=json.loads(lInputByteArray.decode('utf8')) lInputByteArray=self.rfile.read(lInputByteArrayLength)
#Превращение массива байт в объект
lInputObject=json.loads(lInputByteArray.decode('utf8'))
# Send response status code # Send response status code
self.send_response(200) self.send_response(200)
# Send headers # Send headers
self.send_header('Content-type','application/json') self.send_header('Content-type','application/json')
self.end_headers() self.end_headers()
# Send message back to client # Send message back to client
#{'functionName':'', 'argsArray':[]} message = json.dumps(robotDaemonProcessor.ProcessingRun(lInputObject))
lRequestObject=lInputObject
lOutputObject=[]
#pdb.set_trace()
#Циклическая отправка запросов в дочерний объект
for lItem in lRequestObject:
#Отправить запрос в дочерний процесс, который отвечает за работу с Windows окнами
#ProcessChildSendObject(p,lItem)
#Получить ответ от дочернего процесса
#lResponseObject=ProcessChildReadWaitObject(p)
#Добавить в выходной массив
lOutputObject.append(lResponseObject)
#Сформировать текстовый ответ
message = json.dumps(lOutputObject)
# Write content as utf-8 data # Write content as utf-8 data
self.wfile.write(bytes(message, "utf8")) self.wfile.write(bytes(message, "utf8"))
return return

Loading…
Cancel
Save