database

var New = func(cfg config.Database, log *logger.Logger) (DatabaseInterface, error) {
	dsn := fmt.Sprintf(
		"host=%s port=%d user=%s password=%s dbname=%s sslmode=disable",
		cfg.Host,
		cfg.Port,
		cfg.User,
		cfg.Password,
		cfg.DBName,
	)

	db, err := sql.Open("postgres", dsn)

	if err != nil {
		return nil, fmt.Errorf("failed to open database connection: %w", err)
	}

	db.SetMaxOpenConns(25)
	db.SetMaxIdleConns(25)
	db.SetConnMaxIdleTime(5 * time.Minute)
	db.SetConnMaxLifetime(2 * time.Hour)

	dbInstance := &Database{
		db:     db,
		logger: log,
	}

	if err = dbInstance.Ping(); err != nil {
		_ = dbInstance.Close()
		return nil, err
	}

	if log != nil {
		log.Info("Database connection established", nil)
	}

	return dbInstance, nil
}