monitor

var (
	// ErrCpuInfoNotReady indicates CPU information is not yet available from background sampling.
	ErrCpuInfoNotReady = errors.New("cpu info not ready")
	// ErrProcessInfoNotReady indicates process information is not yet available from background sampling.
	ErrProcessInfoNotReady = errors.New("process info not ready")
)

var Module = fx.Module(
	"vef:monitor",
	fx.Decorate(func(cfg *config.MonitorConfig) *config.MonitorConfig {
		cfgToUse := DefaultConfig()
		if cfg != nil {
			if cfg.SampleInterval > 0 {
				cfgToUse.SampleInterval = cfg.SampleInterval
			}

			if cfg.SampleDuration > 0 {
				cfgToUse.SampleDuration = cfg.SampleDuration
			}
		}

		return &cfgToUse
	}),
	fx.Decorate(
		fx.Annotate(
			func(buildInfo *monitor.BuildInfo) *monitor.BuildInfo {

				if buildInfo != nil {
					buildInfo.VEFVersion = constants.VEFVersion
				} else {
					buildInfo = &monitor.BuildInfo{
						VEFVersion: constants.VEFVersion,
						AppVersion: "v0.0.0",
						BuildTime:  "2022-08-08 01:00:00",
						GitCommit:  "-",
					}
				}

				return buildInfo
			},
			fx.ParamTags(`optional:"true"`),
		),
	),
	fx.Provide(

		fx.Annotate(
			NewService,
			fx.ParamTags(``, `optional:"true"`),
			fx.OnStart(func(ctx context.Context, svc monitor.Service) error {
				if initializer, ok := svc.(contract.Initializer); ok {
					if err := initializer.Init(ctx); err != nil {
						return fmt.Errorf("failed to initialize monitor service: %w", err)
					}
				}

				return nil
			}),
			fx.OnStop(func(svc monitor.Service) error {
				if closer, ok := svc.(io.Closer); ok {
					if err := closer.Close(); err != nil {
						return fmt.Errorf("failed to close monitor service: %w", err)
					}
				}

				return nil
			}),
		),

		fx.Annotate(
			NewResource,
			fx.ResultTags(`group:"vef:api:resources"`),
		),
	),
)