adding mcap to mat script for temp usage

.gitignore

@@ -5,3 +5,4 @@ result
 result/
 .env
 .idea/
+*.mat

default.nix

@@ -15,6 +15,7 @@ python311Packages.buildPythonApplication {
   propagatedBuildInputs = [
     python311Packages.cantools
     python311Packages.systemd
+
     python311Packages.websockets
     python311Packages.pprintpp
     python311Packages.can

flake.nix

@@ -93,6 +93,7 @@
           ht_can_pkg
           cmake
           can-utils
+          python311Packages.scipy
         ];
         # Setting up the environment variables you need during
         # development.

mcap_to_mat.py

@@ -0,0 +1,37 @@
+import sys
+from pathlib import Path
+from mcap.reader import make_reader
+from mcap_protobuf.reader import read_protobuf_messages
+from mcap_protobuf.decoder import DecoderFactory
+from scipy.io import savemat
+
+def main():
+    with open(sys.argv[1], "rb") as f:
+        reader = make_reader(f, decoder_factories=[DecoderFactory()])
+        topics = []
+        for channel in reader.get_summary().channels:
+            topics.append(reader.get_summary().channels[channel].topic)
+
+        msgs_lists = []
+        for topic in topics:
+            msgs = []
+            for schema, channel, message, proto_msg in reader.iter_decoded_messages(topics=[topic]):
+
+
+                res = [f.name for f in proto_msg.DESCRIPTOR.fields]
+                msg = {}
+                msg["recvd_time"] = message.log_time
+                for name in res:    
+                    msg[name] = getattr(proto_msg, name)
+                msgs.append(msg)
+            msgs_lists.append(msgs)
+        mdict= {}
+        for index, topic in enumerate(topics):
+            mdict[topic] = msgs_lists[index]
+        out_name = Path(sys.argv[1]).stem
+        savemat(out_name+".mat", mdict, long_field_names=True)
+
+
+
+if __name__ == "__main__":
+    main()

py_data_acq/py_data_acq/mcap_writer/writer.py

@@ -36,9 +36,7 @@ def __aenter__(self):
     async def __aexit__(self, exc_type: Any, exc_val: Any, traceback: Any):
         super().finish()
         self.writing_file.close()
-
     async def write_msg(self, msg):
-
         super().write_message(topic=msg.DESCRIPTOR.name+"_data", message=msg, log_time=int(time.time_ns()), publish_time=int(time.time_ns()))
         self.writing_file.flush()
         return True

test_mcap.py

@@ -3,7 +3,7 @@
 from mcap_protobuf.reader import read_protobuf_messages
 
 def main():
-    for msg in read_protobuf_messages("/home/ben/hytech_mcaps/recordings/03_17_2024_01_34_00_fixed.mcap", log_time_order=False):
+    for msg in read_protobuf_messages(sys.argv[1], log_time_order=False):
         print(f"{msg.topic}: {msg.proto_msg}")
 
 if __name__ == "__main__":