private Object webListenHandler(IEntity e, IFlowSignal s)
{
    debugMsg("web session received \""~s.type~"\"", 2);
    auto service = e.process.get((cast(WebSessionContext)e.context).service.id);
    auto c = cast(WebServiceContext)service.context;
    auto info = c.sessions.filter!(i => i.session.id == e.id).front;
    foreach(l; info.listenings)
    {
        if(l.signal == s.type)
            foreach(src; l.sources)
                if(src == UUID.init || src == s.source.id)
                    return new PushWebSignal;
    }

    // TODO WTF
    /*if(info.listenings.any!(l => l.signal == s.type))
    {
        auto listening = info.listenings.filter!(l => l.signal == s.type).front;

        if(listening.sources.any!(src => src == UUID.init || src == s.source.id))
            return new PushWebSignal;
    }*/

    return null;
}