Function NewApp

internal/bootstrap/bootstrap.go:108–168

NewApp constructs a new bootstrap application with the specified configuration and a list of options. The configuration is passed from individual command work functions.

(cfg *config.Config, options ...Option)

// and a list of options. The configuration is passed from individual command work
// functions.
func NewApp(cfg *config.Config, options ...Option) (*App, error) {
	if err := InitConfigAndLogger(cfg); err != nil {
		return nil, err
	}
	var opts opts
	var sigs chan struct{}
	for _, opt := range options {
		opt(&opts)
	}
	if cfg.DebugPrivilege && opts.setDebugPrivilege {
		sys.SetDebugPrivilege()
	}
	if opts.installSignals {
		sigs = signals.Install()
	}
	if opts.isCaptureReplay {
		reader, err := cap.NewReader(cfg.CapFile, cfg)
		if err != nil {
			return nil, err
		}
		app := &App{
			config:  cfg,
			reader:  reader,
			signals: sigs,
		}
		return app, nil
	}

	hsnap := handle.NewSnapshotter(cfg, opts.handleSnapshotFn)
	psnap := ps.NewSnapshotter(hsnap, cfg)

	var engine *rules.Engine
	var rs *config.RulesCompileResult

	if cfg.Filters.Rules.Enabled && !cfg.ForwardMode && !cfg.IsCaptureSet() && !cfg.IsFilamentSet() {
		engine = rules.NewEngine(psnap, cfg)
		var err error
		rs, err = engine.Compile()
		if err != nil {
			return nil, err
		}
		if rs != nil {
			log.Infof("rules compile summary: %s", rs)
		}
	} else {
		log.Info("rule engine is disabled")
	}

	evs := NewEventSourceControl(psnap, hsnap, cfg, rs)

	app := &App{
		config:  cfg,
		evs:     evs,
		engine:  engine,
		hsnap:   hsnap,
		psnap:   psnap,
		signals: sigs,
	}