85fa8b69e7
Test: Unit tests in place, visualization is already updated with tech area Change-Id: Ib9114f93c2fbed42565f5672048f331722ee5b47
130 lines
3.1 KiB
Go
130 lines
3.1 KiB
Go
package controllers
|
|
|
|
import (
|
|
e "repodiff/entities"
|
|
"repodiff/interactors"
|
|
"repodiff/repositories"
|
|
)
|
|
|
|
func DenormalizeData(config e.ApplicationConfig) error {
|
|
return interactors.NewTaskRunner().ExecuteFunctionsAsync(
|
|
[]func() error{
|
|
func() error { return denormalizeViewRecentProject(config) },
|
|
func() error { return denormalizeDiffRows(config) },
|
|
func() error { return denormalizeViewRecentCommit(config) },
|
|
},
|
|
)
|
|
}
|
|
|
|
func denormalizeViewRecentProject(config e.ApplicationConfig) error {
|
|
for _, target := range config.DiffTargets {
|
|
err := denormalizeViewRecentProjectForTarget(target)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func denormalizeViewRecentProjectForTarget(target e.DiffTarget) error {
|
|
mappedTarget, err := getMappedTarget(target)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
denormalizeRepo, err := repositories.NewScopedDenormalizerRepository(target, mappedTarget)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
projectRepo, err := repositories.NewProjectRepository(mappedTarget)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
diffRows, err := projectRepo.GetMostRecentDifferentials()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return denormalizeRepo.DenormalizeToRecentView(diffRows)
|
|
}
|
|
|
|
func denormalizeDiffRows(config e.ApplicationConfig) error {
|
|
for _, target := range config.DiffTargets {
|
|
if err := denormalizeDiffRowsForTarget(target); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func denormalizeDiffRowsForTarget(target e.DiffTarget) error {
|
|
mappedTarget, err := getMappedTarget(target)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
denormalizeRepo, err := repositories.NewScopedDenormalizerRepository(target, mappedTarget)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
projectRepo, err := repositories.NewProjectRepository(mappedTarget)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
diffRows, err := projectRepo.GetMostRecentDifferentials()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return denormalizeRepo.DenormalizeToChangesOverTime(diffRows)
|
|
}
|
|
|
|
func getMappedTarget(target e.DiffTarget) (e.MappedDiffTarget, error) {
|
|
sourceRepo, err := repositories.NewSourceRepository()
|
|
if err != nil {
|
|
return e.MappedDiffTarget{}, err
|
|
}
|
|
return sourceRepo.DiffTargetToMapped(target)
|
|
}
|
|
|
|
func denormalizeViewRecentCommit(config e.ApplicationConfig) error {
|
|
for _, target := range config.DiffTargets {
|
|
if err := denormalizeCommitRows(target); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
return denormalizeViewRecentCommitGlobal()
|
|
}
|
|
|
|
func denormalizeViewRecentCommitGlobal() error {
|
|
denormalizeRepo, err := repositories.NewGlobalDenormalizerRepository()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if err := denormalizeRepo.DenormalizeToTopCommitter(); err != nil {
|
|
return err
|
|
}
|
|
return denormalizeRepo.DenormalizeToTopTechArea()
|
|
}
|
|
|
|
func denormalizeCommitRows(target e.DiffTarget) error {
|
|
mappedTarget, err := getMappedTarget(target)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
denormalizeRepo, err := repositories.NewScopedDenormalizerRepository(target, mappedTarget)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
commitRepo, err := repositories.NewCommitRepository(mappedTarget)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
commitRows, err := commitRepo.GetMostRecentCommits()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return denormalizeRepo.DenormalizeToRecentCommits(commitRows)
|
|
}
|