WIP: tailable cursors and major cleanup
Major refactor with streaming sockets