remove executor pool

Signed-off-by: nikpivkin <nikita.pivkin@smartforce.io>

pkg/iac/scanners/terraform/executor/executor.go

@@ -1,8 +1,8 @@
 package executor
 
 import (
+	"context"
 	"fmt"
-	"runtime"
 	"sort"
 
 	"github.com/zclconf/go-cty/cty"
@@ -35,22 +35,16 @@ func New(options ...Option) *Executor {
 	return s
 }
 
-func (e *Executor) Execute(modules terraform.Modules) (scan.Results, error) {
+func (e *Executor) Execute(ctx context.Context, modules terraform.Modules, basePath string) (scan.Results, error) {
 
 	e.logger.Debug("Adapting modules...")
 	infra := adapter.Adapt(modules)
 	e.logger.Debug("Adapted module(s) into state data.", log.Int("count", len(modules)))
 
-	threads := runtime.NumCPU()
-	if threads > 1 {
-		threads--
-	}
-
-	e.logger.Debug("Using max routines", log.Int("count", threads))
-
-	pool := NewPool(threads, modules, infra, e.regoScanner)
-
-	results, err := pool.Run()
+	results, err := e.regoScanner.ScanInput(ctx, rego.Input{
+		Contents: infra.ToRego(),
+		Path:     basePath,
+	})
 	if err != nil {
 		return nil, err
 	}

pkg/iac/scanners/terraform/performance_test.go

@@ -29,7 +29,7 @@ func BenchmarkCalculate(b *testing.B) {
 		if err != nil {
 			b.Fatal(err)
 		}
-		executor.New().Execute(modules)
+		executor.New().Execute(context.TODO(), modules, "project")
 	}
 }
 

pkg/iac/scanners/terraform/scanner.go

@@ -150,7 +150,7 @@ func (s *Scanner) ScanFS(ctx context.Context, target fs.FS, dir string) (scan.Re
 		s.execLock.RLock()
 		e := executor.New(s.executorOpt...)
 		s.execLock.RUnlock()
-		results, err := e.Execute(module.childs)
+		results, err := e.Execute(ctx, module.childs, module.rootPath)
 		if err != nil {
 			return nil, err
 		}