func updatePolicyTemplate()

in dev/import-beats/policy_templates.go [81:108]


func updatePolicyTemplate(dsc policyTemplateContent, params updatePolicyTemplateParameters) (policyTemplateContent, error) {
	dsc.moduleName = params.moduleName
	dsc.moduleTitle = params.moduleTitle

	if dsc.inputs == nil {
		dsc.inputs = map[string]policyTemplateInput{}
	}

	for _, dataStream := range params.dataStreams {
		for _, stream := range dataStream.manifest.Streams {
			inputType := stream.Input

			v, ok := dsc.inputs[inputType]
			if !ok {
				v = policyTemplateInput{
					packageType: params.packageType,
					inputType:   inputType,
					vars:        params.inputVars[inputType],
				}
			}

			v.dataStreamNames = append(v.dataStreamNames, dataStream.name)
			dsc.inputs[inputType] = v
		}
	}

	return dsc, nil
}