blob: 5420a288a683978554deda8e18caad723697bebe [file] [log] [blame]
// Copyright (C) 2017 The Android Open Source Project
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package com.googlesource.gerrit.plugins.analytics.common
import java.util.Date
import com.googlesource.gerrit.plugins.analytics.common.AggregatedCommitHistogram.AggregationStrategyMapping
import org.eclipse.jgit.lib.PersonIdent
import org.eclipse.jgit.revwalk.RevCommit
import org.gitective.core.stat.{CommitHistogram, CommitHistogramFilter, UserCommitActivity}
class AggregatedUserCommitActivity(val key: String, val name: String, val email: String)
extends UserCommitActivity(name, email)
class AggregatedCommitHistogram(val aggregationStrategyForUser: AggregationStrategyMapping)
extends CommitHistogram {
override def include(commit: RevCommit, user: PersonIdent): AggregatedCommitHistogram = {
val key = aggregationStrategyForUser(user, commit.getAuthorIdent.getWhen)
val activity = Option(users.get(key)) match {
case None =>
val newActivity = new AggregatedUserCommitActivity(key,
user.getName, user.getEmailAddress)
users.put(key, newActivity)
newActivity
case Some(foundActivity) => foundActivity
}
activity.include(commit, user)
this
}
def getAggregatedUserActivity: Array[AggregatedUserCommitActivity] = {
users.values.toArray(new Array[AggregatedUserCommitActivity](users.size))
}
}
object AggregatedCommitHistogram {
type AggregationStrategyMapping = (PersonIdent, Date) => String
def apply(aggregationStrategy: AggregationStrategyMapping) =
new AggregatedCommitHistogram(aggregationStrategy)
}
abstract class AbstractCommitHistogramFilter(aggregationStrategyMapping: AggregationStrategyMapping)
extends CommitHistogramFilter {
val AbstractHistogram = new AggregatedCommitHistogram(aggregationStrategyMapping)
override def getHistogram = AbstractHistogram
}