Implement better pubsub for SSE

[Fak3]

Currently SSE uses database polling, which might overload database when multiple users have the stream opened simultaneously.

More scalable solutions are postgres or redis pubsub