websocket management
Finish rotating queue of writers, hook up to API
Add async, code cleanup