aggregation: refactor, define roles used in the aggregation flow