This commit is contained in:
Ice3man 2025-07-15 16:47:18 +05:30
parent 7f0026b090
commit 49974403f7

View File

@ -82,6 +82,7 @@ func (e *Engine) executeTemplateWithTargets(ctx context.Context, template *templ
fmt.Printf("[iter] iterating target: %s %s\n", template.ID, scannedValue.Input) fmt.Printf("[iter] iterating target: %s %s\n", template.ID, scannedValue.Input)
select { select {
case <-ctx.Done(): case <-ctx.Done():
fmt.Printf("[iter] ctx done: %s %s\n", template.ID, scannedValue.Input)
return false // exit return false // exit
default: default:
} }
@ -110,6 +111,7 @@ func (e *Engine) executeTemplateWithTargets(ctx context.Context, template *templ
// Skip if the host has had errors // Skip if the host has had errors
if e.executerOpts.HostErrorsCache != nil && e.executerOpts.HostErrorsCache.Check(e.executerOpts.ProtocolType.String(), contextargs.NewWithMetaInput(ctx, scannedValue)) { if e.executerOpts.HostErrorsCache != nil && e.executerOpts.HostErrorsCache.Check(e.executerOpts.ProtocolType.String(), contextargs.NewWithMetaInput(ctx, scannedValue)) {
fmt.Printf("[iter] host error: %s %s\n", template.ID, scannedValue.Input)
return true return true
} }
@ -118,6 +120,7 @@ func (e *Engine) executeTemplateWithTargets(ctx context.Context, template *templ
defer wg.Done() defer wg.Done()
defer cleanupInFlight(index) defer cleanupInFlight(index)
if skip { if skip {
fmt.Printf("[iter] skip: %s %s\n", template.ID, value.Input)
return return
} }
@ -130,6 +133,7 @@ func (e *Engine) executeTemplateWithTargets(ctx context.Context, template *templ
case types.WorkflowProtocol: case types.WorkflowProtocol:
match = e.executeWorkflow(ctx, template.CompiledWorkflow) match = e.executeWorkflow(ctx, template.CompiledWorkflow)
default: default:
fmt.Printf("[iter] executing template: %s %s\n", template.ID, value.Input)
if e.Callback != nil { if e.Callback != nil {
if results, err := template.Executer.ExecuteWithResults(ctx); err == nil { if results, err := template.Executer.ExecuteWithResults(ctx); err == nil {
for _, result := range results { for _, result := range results {
@ -141,7 +145,9 @@ func (e *Engine) executeTemplateWithTargets(ctx context.Context, template *templ
match, err = template.Executer.Execute(ctx) match, err = template.Executer.Execute(ctx)
} }
} }
fmt.Printf("[iter] match: %s %s %v\n", template.ID, value.Input, match)
if err != nil { if err != nil {
fmt.Printf("[iter] error: %s %s\n", template.ID, value.Input)
gologger.Warning().Msgf("[%s] Could not execute step on %s: %s\n", e.executerOpts.Colorizer.BrightBlue(template.ID), value.Input, err) gologger.Warning().Msgf("[%s] Could not execute step on %s: %s\n", e.executerOpts.Colorizer.BrightBlue(template.ID), value.Input, err)
} }
results.CompareAndSwap(false, match) results.CompareAndSwap(false, match)