examples: use new connection syntax

Author: julianoes

examples/all_params.py

@@ -7,7 +7,7 @@
 async def run():
     # Connect to the drone
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     # Get the list of parameters
     all_params = await drone.param.get_all_params()

examples/calibration.py

@@ -7,7 +7,7 @@
 async def run():
 
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("-- Starting gyroscope calibration")
     async for progress_data in drone.calibration.calibrate_gyro():

examples/camera.py

@@ -8,7 +8,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/camera_params.py

@@ -22,7 +22,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     asyncio.ensure_future(observe_current_settings(drone))
     asyncio.ensure_future(observe_camera_mode(drone))

examples/do_orbit.py

@@ -5,7 +5,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/failure_injection.py

@@ -8,7 +8,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/firmware_version.py

@@ -6,7 +6,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/follow_me_example.py

@@ -25,7 +25,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/geofence.py

@@ -21,7 +21,7 @@ async def run():
 
     # Connect to the Simulation
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     # Wait for the drone to connect
     print("Waiting for drone to connect...")

examples/gimbal.py

@@ -33,7 +33,7 @@ async def fetch_gimbals():
 async def run():
     # Init the drone
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     gimbals = await get_gimbals(drone)
 

examples/goto.py

@@ -6,7 +6,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/gripper.py

@@ -6,7 +6,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/highres_imu.py

@@ -5,7 +5,7 @@
 async def get_imu_data():
     # Connect to the drone
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     # Wait for the drone to connect
     print("Waiting for drone to connect...")

examples/logfile_download.py

@@ -7,7 +7,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/manual_control.py

@@ -34,7 +34,7 @@ async def manual_controls():
     """Main function to connect to the drone and input manual controls"""
     # Connect to the Simulation
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     # This waits till a mavlink based drone is connected
     print("Waiting for drone to connect...")

examples/mission.py

@@ -8,7 +8,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/mission_import.py

@@ -8,7 +8,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/mission_raw.py

@@ -7,7 +7,7 @@
 
 async def px4_connect_drone():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/offboard_attitude.py

@@ -15,7 +15,7 @@ async def run():
     """ Does Offboard control using attitude commands. """
 
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/offboard_from_csv/offboard_from_csv.py

@@ -108,7 +108,7 @@ async def run():
 
     # Connect to the drone
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     # Wait for the drone to connect
     print("Waiting for drone to connect...")

examples/offboard_position_ned.py

@@ -18,7 +18,7 @@ async def run():
     """ Does Offboard control using position NED coordinates. """
 
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/offboard_position_velocity_ned.py

@@ -8,7 +8,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/offboard_velocity_body.py

@@ -11,7 +11,7 @@ async def run():
     """ Does Offboard control using velocity body coordinates. """
 
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/offboard_velocity_ned.py

@@ -11,7 +11,7 @@ async def run():
     """ Does Offboard control using velocity NED coordinates. """
 
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/px4_ev_automation.py

@@ -52,7 +52,7 @@ async def print_mode(drone):
 
 async def main():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/px4_ev_automation_keyboard.py

@@ -32,7 +32,7 @@ async def set_params(system, params, announcement):
 
 async def main():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/send_status_message.py

@@ -19,7 +19,7 @@
 async def run():
 
     drone = System(sysid=1)
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/shell.py

@@ -8,7 +8,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     asyncio.ensure_future(observe_shell(drone))
 

examples/takeoff_and_land.py

@@ -7,7 +7,7 @@
 async def run():
 
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     status_text_task = asyncio.ensure_future(print_status_text(drone))
 

examples/telemetry.py

@@ -7,7 +7,7 @@
 async def run():
     # Init the drone
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     # Start the tasks
     asyncio.ensure_future(print_battery(drone))

examples/telemetry_flight_mode.py

@@ -6,7 +6,7 @@
 
 async def print_flight_mode():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/telemetry_is_armed_is_in_air.py

@@ -6,7 +6,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     asyncio.ensure_future(print_is_armed(drone))
     asyncio.ensure_future(print_is_in_air(drone))

examples/telemetry_status_text.py

@@ -6,7 +6,7 @@
 
 async def print_status_text():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/telemetry_takeoff_and_land.py

@@ -26,7 +26,7 @@ async def run():
 
     # Init the drone
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/tune.py

@@ -8,7 +8,7 @@
 async def run():
 
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():

examples/upload_params.py

@@ -10,7 +10,7 @@ def main():
     parser = argparse.ArgumentParser()
     parser.add_argument(
         "connection",
-        help="Connection string (e.g. udp://:14540)")
+        help="Connection string (e.g. udpin://0.0.0.0:14540)")
     parser.add_argument(
         "param_file", help="Param file to be uploaded with .params format")
 

examples/winch.py

@@ -6,7 +6,7 @@
 
 async def run():
     drone = System()
-    await drone.connect(system_address="udp://:14540")
+    await drone.connect(system_address="udpin://0.0.0.0:14540")
 
     print("Waiting for drone to connect...")
     async for state in drone.core.connection_state():