Method parseDispatchRepositoryConfig

pkg/workflow/dispatch_repository.go:30–124

parseDispatchRepositoryConfig parses dispatch-repository configuration from the safe-outputs map.

(outputMap map[string]any)

// parseDispatchRepositoryConfig parses dispatch-repository configuration from the safe-outputs map.
func (c *Compiler) parseDispatchRepositoryConfig(outputMap map[string]any) *DispatchRepositoryConfig {
	dispatchRepositoryLog.Print("Parsing dispatch-repository configuration")

	var configData any
	var exists bool

	// dispatch-repository is canonical; keep underscore form as a backward-compatible alias.
	if configData, exists = outputMap["dispatch-repository"]; !exists {
		if configData, exists = outputMap["dispatch_repository"]; !exists {
			return nil
		}
		dispatchRepositoryLog.Print("WARNING: safe-outputs.dispatch_repository is deprecated; rename to dispatch-repository or run `gh aw fix`")
	}

	configMap, ok := configData.(map[string]any)
	if !ok {
		dispatchRepositoryLog.Print("dispatch-repository value is not a map, skipping")
		return nil
	}

	dispatchRepositoryLog.Printf("Parsing dispatch-repository tools map with %d entries", len(configMap))

	dispatchRepoConfig := &DispatchRepositoryConfig{
		Tools: make(map[string]*DispatchRepositoryToolConfig),
	}

	for toolKey, toolValue := range configMap {
		toolMap, ok := toolValue.(map[string]any)
		if !ok {
			dispatchRepositoryLog.Printf("Skipping tool %q: value is not a map", toolKey)
			continue
		}

		tool := &DispatchRepositoryToolConfig{}

		if desc, ok := toolMap["description"].(string); ok {
			tool.Description = desc
		}

		if workflow, ok := toolMap["workflow"].(string); ok {
			tool.Workflow = workflow
		}

		if eventType, ok := toolMap["event_type"].(string); ok {
			tool.EventType = eventType
		}

		if repo, ok := toolMap["repository"].(string); ok {
			tool.Repository = repo
		}

		// Parse allowed_repositories (list of repos)
		if allowedReposRaw, exists := toolMap["allowed_repositories"]; exists {
			if allowedReposList, ok := allowedReposRaw.([]any); ok {
				for _, r := range allowedReposList {
					if rStr, ok := r.(string); ok {
						tool.AllowedRepositories = append(tool.AllowedRepositories, rStr)
					}