Right now the aggregator will pull in all activities from connected Nodes indiscriminately. It should only pull in activities that have happened since the last aggregation for the given Node. This probably means adding a last_timeline_aggregation
timestamp to each Node.
activitystream:tv/4392
Code review + run tests.