diff --git a/src/gateware/cxp.py b/src/gateware/cxp.py
index cd23c54..fa324e5 100644
--- a/src/gateware/cxp.py
+++ b/src/gateware/cxp.py
@@ -23,6 +23,17 @@ class DownConn_Interface(Module, AutoCSR):
         self.submodules.phy = phy = CXP_DownConn_PHY(refclk, downconn_pads, sys_clk_freq, debug_sma, pmod_pads)
         self.gtxs = phy.gtxs
 
+        # TODO add mux here and fifos
+        # decoder -> priorities mux(normal packet vs trigger ack) -> data packet mux (control ack, data stream, heartbeat, testmode, (optional Genlcam event))
+
+        self.submodules.debug_src = debug_src = TX_Command_Packet()
+        self.submodules.conv = conv = stream.StrideConverter(upconn_layout, downconn_layout, reverse=True)
+        self.submodules.debug_out = debug_out = RX_Debug_Buffer()
+
+        rx_pipeline = [debug_src, conv, debug_out]
+
+        for s, d in zip(rx_pipeline, rx_pipeline[1:]):
+            self.comb += s.source.connect(d.sink)
 
         
 class UpConn_Interface(Module, AutoCSR):