Function parse

pkg/messageprocessors/normalizedpayload/uplink.go:548–588

(dst *ParsedMeasurement, src *structpb.Struct, prefix string)

}

func parse(dst *ParsedMeasurement, src *structpb.Struct, prefix string) error {
	for k, v := range src.GetFields() {
		path := fmt.Sprintf("%s%s", prefix, k)
		parser, ok := fieldParsers[path]
		if !ok {
			return errUnknownField.WithAttributes("path", path)
		}
		if errs := parser(&dst.Measurement, v, path); errs != nil {
			for _, err := range errs {
				if !errors.IsDataLoss(err) {
					return err
				}
				dst.ValidationErrors = append(dst.ValidationErrors, err)
			}
			continue
		}
		if s, ok := v.Kind.(*structpb.Value_StructValue); ok {
			nested := &ParsedMeasurement{
				Measurement: dst.Measurement,
				Valid: &structpb.Struct{
					Fields: make(map[string]*structpb.Value),
				},
			}
			if err := parse(nested, s.StructValue, path+"."); err != nil {
				return err
			}
			dst.Measurement = nested.Measurement
			dst.ValidationErrors = append(dst.ValidationErrors, nested.ValidationErrors...)
			if len(nested.Valid.Fields) > 0 {
				dst.Valid.Fields[k] = &structpb.Value{
					Kind: &structpb.Value_StructValue{
						StructValue: nested.Valid,
					},
				}
			}
		} else {
			dst.Valid.Fields[k] = v
		}
	}
	return nil
}