PYTHON-5544 Revert changes to base protocol layer

Author: blink1073

pymongo/asynchronous/encryption.py

@@ -202,6 +202,7 @@ async def kms_request(self, kms_context: MongoCryptKmsContext) -> None:
                 while kms_context.bytes_needed > 0:
                     # CSOT: update timeout.
                     conn.settimeout(max(_csot.clamp_remaining(_KMS_CONNECT_TIMEOUT), 0))
+                    data: memoryview | bytes
                     if _IS_SYNC:
                         data = conn.recv(kms_context.bytes_needed)
                     else:

pymongo/network_layer.py

@@ -103,7 +103,7 @@ def _is_ready(fut: Future[Any]) -> None:
 
         while sent < len(buf):
             try:
-                sent += sock.send(view[sent:])
+                sent += sock.send(view[sent:])  # type:ignore[arg-type]
             except BLOCKING_IO_ERRORS as exc:
                 fd = sock.fileno()
                 # Check for closed socket.
@@ -465,7 +465,7 @@ def sock(self) -> Union[socket.socket, _sslConn]:
     def fileno(self) -> int:
         return self.conn.fileno()
 
-    def recv_into(self, buffer: bytes) -> int:
+    def recv_into(self, buffer: bytes | memoryview) -> int:
         return self.conn.recv_into(buffer)
 
 
@@ -770,6 +770,7 @@ def receive_message(
             f"Message length ({length!r}) is larger than server max "
             f"message size ({max_message_size!r})"
         )
+    data: memoryview | bytes
     if op_code == 2012:
         op_code, _, compressor_id = _UNPACK_COMPRESSION_HEADER(receive_data(conn, 9, deadline))
         data = decompress(receive_data(conn, length - 25, deadline), compressor_id)

pymongo/synchronous/encryption.py

@@ -201,6 +201,7 @@ def kms_request(self, kms_context: MongoCryptKmsContext) -> None:
                 while kms_context.bytes_needed > 0:
                     # CSOT: update timeout.
                     conn.settimeout(max(_csot.clamp_remaining(_KMS_CONNECT_TIMEOUT), 0))
+                    data: memoryview | bytes
                     if _IS_SYNC:
                         data = conn.recv(kms_context.bytes_needed)
                     else: