seems I need something like a merged RETE/ECA engine (e.g. as described http://ceur-ws.org/Vol-412/paper3.pdf) as I first need to distill events into state

Thanks for the link, now I’m curious and will have to read that paper 🙂