Commit 6cb0fe65 authored by Alex's avatar Alex
Browse files

refactor: move validk8sfiles to validatiomManager

parent 6a321201
No related merge requests found
Showing with 37 additions and 31 deletions
+37 -31
......@@ -247,9 +247,9 @@ func test(ctx *TestCommandContext, paths []string, flags TestCommandFlags) error
}
}
validK8sFilesConfigurations := aggregateValidK8sFiles(validK8sFilesConfigurationsChan)
validationManager.AggregateValidK8sFiles(validK8sFilesConfigurationsChan)
results, err := ctx.Evaluator.Evaluate(validK8sFilesConfigurations, createEvaluationResponse.EvaluationId)
results, err := ctx.Evaluator.Evaluate(validationManager.ValidK8sFilesConfigurations(), createEvaluationResponse.EvaluationId)
if _spinner != nil {
_spinner.Stop()
......@@ -261,16 +261,14 @@ func test(ctx *TestCommandContext, paths []string, flags TestCommandFlags) error
}
passedYamlValidationCount := filesPathsLen - validationManager.InvalidYamlFilesCount()
passedK8sValidationCount := len(validK8sFilesConfigurations)
configsCount := countConfigurations(validK8sFilesConfigurations)
evaluationSummary := printer.EvaluationSummary{
FilesCount: filesPathsLen,
RulesCount: createEvaluationResponse.RulesCount,
PassedYamlValidationCount: passedYamlValidationCount,
PassedK8sValidationCount: passedK8sValidationCount,
ConfigsCount: configsCount,
PassedK8sValidationCount: validationManager.ValidK8sFilesConfigurationsCount(),
ConfigsCount: validationManager.ValidK8sConfigurationsCount(),
PassedPolicyCheckCount: passedPolicyCheckCount,
}
......@@ -303,34 +301,59 @@ func test(ctx *TestCommandContext, paths []string, flags TestCommandFlags) error
}
type ValidationManager struct {
invalidYamlFiles []*validation.InvalidYamlFile
invalidK8sFiles []*validation.InvalidK8sFile
invalidYamlFiles []*validation.InvalidYamlFile
invalidK8sFiles []*validation.InvalidK8sFile
validK8sFilesConfigurations []*extractor.FileConfigurations
}
func (v ValidationManager) AggregateInvalidYamlFiles(invalidFilesChan chan *validation.InvalidYamlFile) {
func (v *ValidationManager) AggregateInvalidYamlFiles(invalidFilesChan chan *validation.InvalidYamlFile) {
for invalidFile := range invalidFilesChan {
v.invalidYamlFiles = append(v.invalidYamlFiles, invalidFile)
}
}
func (v ValidationManager) InvalidYamlFiles() []*validation.InvalidYamlFile {
func (v *ValidationManager) InvalidYamlFiles() []*validation.InvalidYamlFile {
return v.invalidYamlFiles
}
func (v ValidationManager) InvalidYamlFilesCount() int {
func (v *ValidationManager) InvalidYamlFilesCount() int {
return len(v.invalidYamlFiles)
}
func (v ValidationManager) AggregateInvalidK8sFiles(invalidFilesChan chan *validation.InvalidK8sFile) {
func (v *ValidationManager) AggregateInvalidK8sFiles(invalidFilesChan chan *validation.InvalidK8sFile) {
for invalidFile := range invalidFilesChan {
v.invalidK8sFiles = append(v.invalidK8sFiles, invalidFile)
}
}
func (v ValidationManager) InvalidK8sFiles() []*validation.InvalidK8sFile {
func (v *ValidationManager) InvalidK8sFiles() []*validation.InvalidK8sFile {
return v.invalidK8sFiles
}
func (v ValidationManager) InvalidK8sFilesCount() int {
func (v *ValidationManager) InvalidK8sFilesCount() int {
return len(v.invalidK8sFiles)
}
func (v *ValidationManager) AggregateValidK8sFiles(validK8sFilesConfigurationsChan chan *extractor.FileConfigurations){
for fileConfigurations := range validK8sFilesConfigurationsChan {
v.validK8sFilesConfigurations = append(v.validK8sFilesConfigurations, fileConfigurations)
}
}
func (v *ValidationManager) ValidK8sFilesConfigurations() []*extractor.FileConfigurations {
return v.validK8sFilesConfigurations
}
func (v *ValidationManager) ValidK8sFilesConfigurationsCount() int {
return len(v.validK8sFilesConfigurations)
}
func (v *ValidationManager) ValidK8sConfigurationsCount() int {
totalConfigs := 0
for _, fileConfiguration := range v.validK8sFilesConfigurations {
totalConfigs += len(fileConfiguration.Configurations)
}
return totalConfigs
}
......@@ -16,13 +16,6 @@ func createSpinner(text string, color string) *spinner.Spinner {
return s
}
func aggregateValidK8sFiles (validK8sFilesConfigurationsChan chan *extractor.FileConfigurations) (validK8sFilesConfigurations []*extractor.FileConfigurations){
for fileConfigurations := range validK8sFilesConfigurationsChan {
validK8sFilesConfigurations = append(validK8sFilesConfigurations, fileConfigurations)
}
return
}
func aggregateIgnoredYamlFiles(ignoredFilesChan chan *extractor.FileConfigurations) []extractor.FileConfigurations {
var ignoredFiles []extractor.FileConfigurations
......@@ -32,16 +25,6 @@ func aggregateIgnoredYamlFiles(ignoredFilesChan chan *extractor.FileConfiguratio
return ignoredFiles
}
func countConfigurations(filesConfigurations []*extractor.FileConfigurations) int {
totalConfigs := 0
for _, fileConfiguration := range filesConfigurations {
totalConfigs += len(fileConfiguration.Configurations)
}
return totalConfigs
}
func openBrowser(url string) {
fmt.Printf("Opening %s in your browser.\n", url)
browser.OpenURL(url)
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment