refactor(server): Create streams for each calculation done by mapReduce.

* Drastically decreases complexity and makes each calculation much more contained.