db

var (
	// ErrEmptyUsername indicates database username is not configured.
	ErrEmptyUsername = errors.New("database username cannot be empty")
	// ErrEmptyPassword indicates database password is not configured.
	ErrEmptyPassword = errors.New("database password cannot be empty")
	// ErrEmptyDatabase indicates database name is not configured.
	ErrEmptyDatabase = errors.New("database name cannot be empty")
	// ErrInvalidPort indicates database port is out of valid range.
	ErrInvalidPort = errors.New("database port must be between 1 and 65535")
)

var Module = fx.Module("db",
	fx.Provide(func(lc fx.Lifecycle) (*pgxpool.Pool, error) {
		var pool *pgxpool.Pool
		var err error

		lc.Append(fx.Hook{
			OnStart: func(ctx context.Context) error {
				pool, err = NewDBPool(ctx)
				if err != nil {
					return err
				}
				return pool.Ping(ctx)
			},
			OnStop: func(ctx context.Context) error {
				if pool != nil {
					pool.Close()
				}
				return nil
			},
		})

		return pool, err
	}),
)