def on_message_received()

in tools/can-to-someip/can-to-someip.py [0:0]

• 12 lines of code
• 1 McCabe index (conditional complexity)

    def on_message_received(self, message: can.Message):
        timestamp_us = int(message.timestamp * 1e6)
        payload = b"".join(
            [
                message.arbitration_id.to_bytes(4, "big"),
                timestamp_us.to_bytes(8, "big"),
                bytes(message.data),
            ]
        )
        asyncio.run_coroutine_threadsafe(
            self._can_service.event_group.add_message(payload), self._event_loop
        )