Skip to content

Commit 993f8dd

Browse files
committed
updating to use adafruit_requests
1 parent b39acdb commit 993f8dd

File tree

4 files changed

+16
-195
lines changed

4 files changed

+16
-195
lines changed

adafruit_espatcontrol/adafruit_espatcontrol.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,8 +70,10 @@ class ESP_ATcontrol:
7070
MODE_SOFTAP = 2
7171
MODE_SOFTAPSTATION = 3
7272
TYPE_TCP = "TCP"
73+
TCP_MODE = "TCP"
7374
TYPE_UDP = "UDP"
7475
TYPE_SSL = "SSL"
76+
TLS_MODE = "SSL"
7577
STATUS_APCONNECTED = 2
7678
STATUS_SOCKETOPEN = 3
7779
STATUS_SOCKETCLOSED = 4

adafruit_espatcontrol/adafruit_espatcontrol_requests.py

Lines changed: 0 additions & 189 deletions
This file was deleted.

adafruit_espatcontrol/adafruit_espatcontrol_socket.py

Lines changed: 11 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -39,8 +39,10 @@ def connect(self, address, conntype=None):
3939
if not _the_interface.socket_connect(conntype, host, port, keepalive=10, retries=3):
4040
raise RuntimeError("Failed to connect to host", host)
4141
self._buffer = b''
42+
self.settimeout(0)
4243

43-
def write(self, data): # pylint: disable=no-self-use
44+
45+
def send(self, data): # pylint: disable=no-self-use
4446
"""Send some data to the socket"""
4547
_the_interface.socket_send(data)
4648

@@ -53,12 +55,12 @@ def readline(self):
5355
firstline, self._buffer = self._buffer.split(b'\r\n', 1)
5456
return firstline
5557

56-
def read(self, num=0):
58+
def recv(self, num=0):
5759
"""Read up to 'num' bytes from the socket, this may be buffered internally!
5860
If 'num' isnt specified, return everything in the buffer."""
5961
if num == 0:
6062
# read as much as we can
61-
ret = self._buffer + _the_interface.socket_receive(timeout=1)
63+
ret = self._buffer + _the_interface.socket_receive(timeout=self._timeout)
6264
self._buffer = b''
6365
else:
6466
ret = self._buffer[:num]
@@ -68,6 +70,11 @@ def read(self, num=0):
6870
def close(self):
6971
"""Close the socket, after reading whatever remains"""
7072
# read whatever's left
71-
self._buffer = self._buffer + _the_interface.socket_receive(timeout=1)
73+
self._buffer = self._buffer + _the_interface.socket_receive(timeout=self._timeout)
7274
_the_interface.socket_disconnect()
75+
76+
def settimeout(self, value):
77+
"""Set the read timeout for sockets, if value is 0 it will block"""
78+
self._timeout = value
79+
7380
# pylint: enable=unused-argument, redefined-builtin, invalid-name

adafruit_espatcontrol/adafruit_espatcontrol_wifimanager.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,8 @@
3131

3232
# pylint: disable=no-name-in-module
3333

34-
import adafruit_espatcontrol.adafruit_espatcontrol_requests as requests
34+
import adafruit_espatcontrol.adafruit_espatcontrol_socket as socket
35+
import adafruit_requests as requests
3536

3637
class ESPAT_WiFiManager:
3738
"""
@@ -50,7 +51,7 @@ def __init__(self, esp, secrets, status_pixel=None, attempts=2):
5051
self.debug = False
5152
self.secrets = secrets
5253
self.attempts = attempts
53-
requests.set_interface(self._esp)
54+
requests.set_socket(socket,esp)
5455
self.statuspix = status_pixel
5556
self.pixel_status(0)
5657

0 commit comments

Comments
 (0)