From 2de1fa6b6d08647a7e6cd17f68069797038bedc1 Mon Sep 17 00:00:00 2001 From: Justin Myers Date: Thu, 29 Feb 2024 21:16:55 -0800 Subject: [PATCH] Update legacy set_socket examples --- examples/aws_iot_shadows.py | 13 +++++++++---- examples/aws_iot_simpletest.py | 13 +++++++++---- 2 files changed, 18 insertions(+), 8 deletions(-) diff --git a/examples/aws_iot_shadows.py b/examples/aws_iot_shadows.py index a3c39bd..0836904 100644 --- a/examples/aws_iot_shadows.py +++ b/examples/aws_iot_shadows.py @@ -7,9 +7,10 @@ import busio from digitalio import DigitalInOut import neopixel +import adafruit_connection_manager from adafruit_esp32spi import adafruit_esp32spi from adafruit_esp32spi import adafruit_esp32spi_wifimanager -import adafruit_esp32spi.adafruit_esp32spi_socket as socket +import adafruit_esp32spi.adafruit_esp32spi_socket as pool import adafruit_minimqtt.adafruit_minimqtt as MQTT from adafruit_aws_iot import MQTT_CLIENT @@ -134,11 +135,15 @@ def message(client, topic, msg): wifi.connect() print("Connected!") -# Initialize MQTT interface with the esp interface -MQTT.set_socket(socket, esp) +ssl_context = adafruit_connection_manager.create_fake_ssl_context(pool, esp) # Set up a new MiniMQTT Client -client = MQTT.MQTT(broker=secrets["broker"], client_id=secrets["client_id"]) +client = MQTT.MQTT( + broker=secrets["broker"], + client_id=secrets["client_id"], + socket_pool=pool, + ssl_context=ssl_context, +) # Initialize AWS IoT MQTT API Client aws_iot = MQTT_CLIENT(client) diff --git a/examples/aws_iot_simpletest.py b/examples/aws_iot_simpletest.py index ce8ee26..e79a56f 100644 --- a/examples/aws_iot_simpletest.py +++ b/examples/aws_iot_simpletest.py @@ -7,9 +7,10 @@ import busio from digitalio import DigitalInOut import neopixel +import adafruit_connection_manager from adafruit_esp32spi import adafruit_esp32spi from adafruit_esp32spi import adafruit_esp32spi_wifimanager -import adafruit_esp32spi.adafruit_esp32spi_socket as socket +import adafruit_esp32spi.adafruit_esp32spi_socket as pool import adafruit_minimqtt.adafruit_minimqtt as MQTT from adafruit_aws_iot import MQTT_CLIENT @@ -131,11 +132,15 @@ def message(client, topic, msg): wifi.connect() print("Connected!") -# Initialize MQTT interface with the esp interface -MQTT.set_socket(socket, esp) +ssl_context = adafruit_connection_manager.create_fake_ssl_context(pool, esp) # Set up a new MiniMQTT Client -client = MQTT.MQTT(broker=secrets["broker"], client_id=secrets["client_id"]) +client = MQTT.MQTT( + broker=secrets["broker"], + client_id=secrets["client_id"], + socket_pool=pool, + ssl_context=ssl_context, +) # Initialize AWS IoT MQTT API Client aws_iot = MQTT_CLIENT(client)