From 6ef0571e4ec1127f2d50c4cc0000c81e69337fbe Mon Sep 17 00:00:00 2001
From: Erick Ahmed <engineering@erickahmed.com>
Date: Thu, 9 Jul 2026 23:57:37 +0200
Subject: [PATCH] Add J1939 decoder

---
 src/j1939_decoder.py | 14 ++++++++++++++
 1 file changed, 14 insertions(+)
 create mode 100644 src/j1939_decoder.py

diff --git a/src/j1939_decoder.py b/src/j1939_decoder.py
new file mode 100644
index 0000000..e49788c
--- /dev/null
+++ b/src/j1939_decoder.py
@@ -0,0 +1,14 @@
+import argparse
+import polars as pl
+
+def get_j1939_mask() -> pl.Expr:
+    id_int = pl.col("ID").str.to_integer(base=16).cast(pl.UInt32)
+    return (
+        (id_int > 0x7FF) &
+        ((id_int & 0x02000000) == 0) &
+        (pl.col("DLC") <= 8)
+    )
+
+
+
+if __name__ == "__main__":