Trying out asyncio

Not shure if this is the right derection or not thoughts?

Author: odwdinc

SimConnect/RequestList.py

@@ -1,28 +1,27 @@
 from SimConnect import *
 from .Enum import *
 from .Constants import *
+import asyncio
 
 
 class Request(object):
 
-	def get(self):
+	async def get(self):
 		return self.value
 
 	def set(self, _value):
 		self.value = _value
 
 	@property
-	def value(self):
+	async def value(self):
 		if self._deff_test():
 			# self.sm.run()
 			if (self.LastData + self.time) < millis():
-				if self.sm.get_data(self):
-					self.LastData = millis()
-				else:
-					return None
+				await self.sm.get_data(self)
+				self.LastData = millis()
 			return self.outData
 		else:
-			return None
+			raise Exception(self.definitions[0][0])
 
 	@value.setter
 	def value(self, val):
@@ -69,9 +68,9 @@ def redefine(self):
 			)
 			self.defined = False
 			# self.sm.run()
-		if self._deff_test():
-			# self.sm.run()
-			self.sm.get_data(self)
+		# if self._deff_test():
+		# 	# self.sm.run()
+		# 	self.sm.get_data(self)
 
 	def _deff_test(self):
 		if ':index' in str(self.definitions[0][0]):
@@ -132,10 +131,10 @@ def __getattr__(self, _name):
 			return ne
 		return None
 
-	def get(self, _name):
+	async def get(self, _name):
 		if getattr(self, _name) is None:
 			return None
-		return getattr(self, _name).value
+		return await getattr(self, _name).value
 
 	def set(self, _name, _value=0):
 		temp = getattr(self, _name)
@@ -170,6 +169,8 @@ def find(self, key):
 			if key in clas.list:
 				rqest = getattr(clas, key)
 				if index is not None:
+					if 'index' in index:
+						index = 0
 					rqest.setIndex(index)
 				return rqest
 		return None

SimConnect/SimConnect.py

@@ -7,6 +7,7 @@
 from .Attributes import *
 import os
 import threading
+import asyncio
 
 _library_path = os.path.abspath(__file__).replace(".py", ".dll")
 
@@ -239,18 +240,13 @@ def set_data(self, _Request):
 		else:
 			return False
 
-	def get_data(self, _Request):
-		self.request_data(_Request)
-		# self.run()
-		attemps = 0
-		while _Request.outData is None and attemps < _Request.attemps:
-			# self.run()
-			time.sleep(.01)
-			attemps += 1
-		if _Request.outData is None:
-			return False
+	async def get_return_data(self, _Request):
+		while _Request.outData is None:
+			await asyncio.sleep(0.01)
 
-		return True
+	async def get_data(self, _Request):
+		self.request_data(_Request)
+		await self.get_return_data(_Request)
 
 	def send_event(self, evnt, data=DWORD(0)):
 		err = self.dll.TransmitClientEvent(

local_example.py

@@ -1,94 +1,34 @@
 from SimConnect import *
 import logging
-from SimConnect.Enum import *
 from time import sleep
-
-
+import asyncio
 logging.basicConfig(level=logging.DEBUG)
 LOGGER = logging.getLogger(__name__)
 LOGGER.info("START")
-# time holder for inline commands
-ct_g = millis()
-
-# creat simconnection and pass used user classes
 sm = SimConnect()
 aq = AircraftRequests(sm)
-ae = AircraftEvents(sm)
-
-
-mc = aq.find("MAGNETIC_COMPASS")
-mv = aq.find("MAGVAR")
-print(mc.get() + mv.get())
-
-sm.exit()
-quit()
-
-# Set pos arund space nedle in WA.
-sm.set_pos(
-	_Altitude=1000.0,
-	_Latitude=47.614699,
-	_Longitude=-122.358473,
-	_Airspeed=130,
-	_Heading=70.0,
-	# _Pitch=0.0,
-	# _Bank=0.0,
-	# _OnGround=0
-)
-
-# PARKING_BRAKES = Event(b'PARKING_BRAKES', sm)
-# long path
-PARKING_BRAKES = ae.Miscellaneous_Systems.PARKING_BRAKES
-# using get
-GEAR_TOGGLE = ae.Miscellaneous_Systems.get("GEAR_TOGGLE")
-# Using find to lookup Event
-AP_MASTER = ae.find("AP_MASTER")
-
-# THROTTLE1 Event
-THROTTLE1 = ae.Engine.THROTTLE1_SET
-
-
-# THROTTLE1 Request
-Throttle = aq.find('GENERAL_ENG_THROTTLE_LEVER_POSITION:1')
-
-# If useing
-# Throttle = aq.find('GENERAL_ENG_THROTTLE_LEVER_POSITION:index')
-# Need to set index befor read/write
-# Note to set index 2 vs 1 just re-run
-# Throttle.setIndex(1)
 
+Data = {}
 
-# print the built in description
-# AP_MASTER Toggles AP on/off
-print("AP_MASTER", AP_MASTER.description) 
-# Throttle Percent of max throttle position
-print("Throttle", Throttle.description)
-# THROTTLE1 Set throttle 1 exactly (0 to 16383)
-print("THROTTLE1", THROTTLE1.description)
 
+async def pintVal(name):
+	global Data
+	Data[name] = await aq.get(name)
 
-while not sm.quit:
-	print("Throttle:", Throttle.value)
-	print("Alt=%f Lat=%f Lon=%f Kohlsman=%.2f" % (
-		aq.PositionandSpeedData.get('PLANE_ALTITUDE'),
-		aq.PositionandSpeedData.get('PLANE_LATITUDE'),
-		aq.PositionandSpeedData.get('PLANE_LONGITUDE'),
-		aq.FlightInstrumentationData.get('KOHLSMAN_SETTING_HG')
-	))
-	sleep(2)
 
-	# Send Event with value
-	# THROTTLE1(1500)
+async def main():
+	while not sm.quit:
+		temp = {}
+		for ed in aq.PositionandSpeedData.list:
+			temp[ed] = asyncio.create_task(pintVal(ed))
 
-	# Send Event toggle AP_MASTER
-	# AP_MASTER()
+		for ed in aq.PositionandSpeedData.list:
+			await temp[ed]
 
-	# PARKING_BRAKES()
+		print(Data)
+		sleep(2)
+	sm.exit()
+	quit()
 
-	# send new data inine @ 5s
-	if ct_g + 5000 < millis():
-		if Throttle.value < 100:
-			Throttle.value += 5
-			print("THROTTLE SET")
-		ct_g = millis()
 
-sm.exit()
+asyncio.run(main())