[FEATURE] ... Add execution method for targets, templates, and callback in the SDK module

[tongchengbin]

Describe your feature request

We would like to request a new method in the Nuclei SDK module that allows users to specify targets, templates, and a callback method for execution.

This method should:

Targets: Accept one or multiple targets as input for scanning. Templates: Specify a set of templates to use, allowing users to choose from predefined templates or define their own template files. Callback Method: Allow users to provide a callback method that processes scan results after execution (e.g., for logging or report generation).

Describe the use case of the feature

This is a version I implemented, but I am unable to control using a separate callback for each execution, as I need to carry task-specific information for different tasks. Therefore, I cannot use the same result_callback.

func (e *NucleiEngine) ExecuteWithProvider(ctx context.Context, target provider.InputProvider, templateIds []string, callback func(event *output.ResultEvent)) error {
	if target.Count() == 0 {
		return ErrNoTargetsAvailable
	}
	var filtered []func(event *output.ResultEvent)
	if callback != nil {
		filtered = append(filtered, callback)
	}
	templatesAndWorkflows := append(e.store.Templates(), e.store.Workflows()...)
	if len(templatesAndWorkflows) == 0 {
		return ErrNoTemplatesAvailable
	}
	// load templates
	var finalTemplates []*templates.Template
	for _, id := range templateIds {
		tmpl := e.templateMaps[FormatName(id)]
		if tmpl != nil {
			finalTemplates = append(finalTemplates, tmpl)
		}
	}
	_ = e.engine.ExecuteScanWithOpts(ctx, finalTemplates, target, false)
	defer e.engine.WorkPool().Wait()
	return nil
}

func TestMultipleTarget(t *testing.T) {
	ne, err := NewNucleiEngineCtx(
		context.Background(),
		WithVerbosity(VerbosityOptions{
			Debug: false,
		}),
		WithProxy([]string{"http://127.0.0.1:9000"}, true),
		WithTemplatesOrWorkflows(TemplateSources{
			Templates: []string{
				"http/cves/2024/CVE-2024-4040.yaml"},
		}),
		WithTemplateFilters(TemplateFilters{
			ExcludeTags:   []string{"code"},
			ProtocolTypes: "http,tcp",
		}),
	)
	assert.Nil(t, err)
	assert.Equal(t, 1, len(ne.GetTemplates()))
	err = ne.LoadAllTemplates()
	ne.resultCallbacks = append(ne.resultCallbacks, func(event *output.ResultEvent) {
		if event.TemplateID != "" {
			b := FormatEvent(event)
			_, _ = os.Stdout.Write(b)
			_, _ = os.Stdout.Write([]byte("\n"))
		}
	})
	templateIds := []string{
		"CVE-2024-4040",
	}
	wg := sync.WaitGroup{}
	for i := 0; i < 32; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			err = ne.ExecuteWithProvider(context.Background(), provider.NewSimpleInputProviderWithUrls("http://ctf.lostpeach.cn:49264"), templateIds, nil)
			assert.Nil(t, err)

		}()
	}
	wg.Wait()
}

Describe alternatives you've considered

No response

Additional context

No response