Method parseCloseEntityConfig

pkg/workflow/close_entity_helpers.go:104–142

parseCloseEntityConfig is a generic function to parse close entity configurations

(outputMap map[string]any, params CloseEntityJobParams, logger *logger.Logger)

// parseCloseEntityConfig is a generic function to parse close entity configurations
func (c *Compiler) parseCloseEntityConfig(outputMap map[string]any, params CloseEntityJobParams, logger *logger.Logger) *CloseEntityConfig {
	// Check if the key exists
	if _, exists := outputMap[params.ConfigKey]; !exists {
		return nil
	}

	// Get config data for pre-processing before YAML unmarshaling
	configData, _ := outputMap[params.ConfigKey].(map[string]any)

	// Pre-process templatable int fields
	if err := preprocessIntFieldAsString(configData, "max", logger); err != nil {
		logger.Printf("Invalid max value for %s: %v", params.ConfigKey, err)
		return nil
	}

	config := parseConfigScaffold(outputMap, params.ConfigKey, logger, func(err error) *CloseEntityConfig {
		logger.Printf("Failed to unmarshal config: %v", err)
		// For backward compatibility, handle nil/empty config
		return &CloseEntityConfig{}
	})
	if config == nil {
		return nil
	}

	// Set default max if not specified
	if config.Max == nil {
		config.Max = defaultIntStr(1)
		logger.Printf("Set default max to 1 for %s", params.ConfigKey)
	}

	// Backward compatibility: map deprecated title-prefix to required-title-prefix.
	if config.RequiredTitlePrefix == "" && config.TitlePrefix != "" {
		config.RequiredTitlePrefix = config.TitlePrefix
	}

	logger.Printf("Parsed %s configuration: max=%s, target=%s", params.ConfigKey, *config.Max, config.Target)

	return config
}

// closeEntityDefinition holds all parameters for a close entity type
type closeEntityDefinition struct {