Initial implementation of aggregation services, both blocking and non-blocking + working tests