Revert "Capnp memoryview (#36163)"

This reverts commit 6ed8f07cb6.

bump

opendbc_repo

@@ -1 +1 @@
-Subproject commit 0c8676f74cf386ac914faa80a6b14303693ccde9
+Subproject commit c70bd060c6a410c1083186a1e4165e43a4eda0df

pyproject.toml

@@ -23,7 +23,7 @@ dependencies = [
   # core
   "cffi",
   "scons",
-  "pycapnp",
+  "pycapnp==2.1.0",
   "Cython",
   "setuptools",
   "numpy >=2.0",
@@ -119,7 +119,7 @@ dev = [
   "tabulate",
   "types-requests",
   "types-tabulate",
-  "raylib==5.5.0.2",  # 5.5.0.3 has regression with gui_set_style
+  "raylib",
 ]
 
 tools = [

system/loggerd/tests/test_loggerd.py

@@ -178,7 +178,7 @@ class TestLoggerd:
     assert logged_params['AccessToken'] == b'', f"DONT_LOG param value was logged: {repr(logged_params['AccessToken'])}"
     for param_key, initData_key, v in fake_params:
       assert getattr(initData, initData_key) == v
-      assert logged_params[param_key].tobytes().decode() == v
+      assert logged_params[param_key].decode() == v
 
   @pytest.mark.xdist_group("camera_encoder_tests")  # setting xdist group ensures tests are run in same worker, prevents encoderd from crashing
   def test_rotation(self):

system/webrtc/device/video.py

@@ -30,7 +30,7 @@ class LiveStreamVideoStreamTrack(TiciVideoStreamTrack):
 
     evta = getattr(msg, msg.which())
 
-    packet = av.Packet(evta.header.tobytes() + evta.data.tobytes())
+    packet = av.Packet(evta.header + evta.data)
     packet.time_base = self._time_base
     packet.pts = self._pts
 

system/webrtc/webrtcd.py

@@ -22,13 +22,6 @@ from openpilot.system.webrtc.schema import generate_field
 from cereal import messaging, log
 
 
-# pycapnp 2.2.0+ is using memoryview instead of bytes for data fields
-def memoryview_fallback(obj):
-  if isinstance(obj, memoryview):
-    return obj.tobytes().decode()
-  return obj
-
-
 class CerealOutgoingMessageProxy:
   def __init__(self, sm: messaging.SubMaster):
     self.sm = sm
@@ -44,8 +37,6 @@ class CerealOutgoingMessageProxy:
       msg_dict = [self.to_json(msg) for msg in msg_content]
     elif isinstance(msg_content, bytes):
       msg_dict = msg_content.decode()
-    elif isinstance(msg_content, memoryview):
-      msg_dict = msg_content.tobytes().decode()
     else:
       msg_dict = msg_content
 
@@ -60,7 +51,7 @@ class CerealOutgoingMessageProxy:
       msg_dict = self.to_json(self.sm[service])
       mono_time, valid = self.sm.logMonoTime[service], self.sm.valid[service]
       outgoing_msg = {"type": service, "logMonoTime": mono_time, "valid": valid, "data": msg_dict}
-      encoded_msg = json.dumps(outgoing_msg, default=memoryview_fallback).encode()
+      encoded_msg = json.dumps(outgoing_msg).encode()
       for channel in self.channels:
         channel.send(encoded_msg)