Function SplitYAMLDocuments

app/cli/pkg/action/apply.go:165–211

SplitYAMLDocuments splits a potentially multi-document YAML file into individual documents, extracting kind and name from each.

(rawData []byte)

// SplitYAMLDocuments splits a potentially multi-document YAML file into individual documents,
// extracting kind and name from each.
func SplitYAMLDocuments(rawData []byte) ([]*YAMLDoc, error) {
	decoder := yaml.NewDecoder(bytes.NewReader(rawData))

	var docs []*YAMLDoc
	for {
		var node yaml.Node
		if err := decoder.Decode(&node); err != nil {
			if errors.Is(err, io.EOF) {
				break
			}
			return nil, fmt.Errorf("decoding YAML document: %w", err)
		}

		// Marshal node back to bytes for the per-resource apply
		docBytes, err := yaml.Marshal(&node)
		if err != nil {
			return nil, fmt.Errorf("marshalling YAML node: %w", err)
		}

		// Extract kind and name via partial unmarshal
		var header struct {
			Kind     string `yaml:"kind"`
			Metadata struct {
				Name string `yaml:"name"`
			} `yaml:"metadata"`
		}
		if err := yaml.Unmarshal(docBytes, &header); err != nil {
			return nil, fmt.Errorf("extracting document kind: %w", err)
		}

		if header.Kind == "" {
			return nil, fmt.Errorf("missing 'kind' field in YAML document")
		}

		if header.Metadata.Name == "" {
			return nil, fmt.Errorf("missing 'metadata.name' field in YAML document of kind %q", header.Kind)
		}

		docs = append(docs, &YAMLDoc{
			Kind:    header.Kind,
			Name:    header.Metadata.Name,
			RawData: docBytes,
		})
	}

	return docs, nil
}