func New()

in plugins/vpc-eni/config/netconfig.go [51:115]
46 lines of code
14 McCabe index (conditional complexity)

func New(args *cniSkel.CmdArgs) (*NetConfig, error) {
	// Parse network configuration.
	var config netConfigJSON
	err := json.Unmarshal(args.StdinData, &config)
	if err != nil {
		return nil, fmt.Errorf("failed to parse network config: %v", err)
	}

	// Validate if all the required fields are present.

	// If we are supposed to use an existing network then network name is required.
	// This check is for backward compatibility in case older cni release versions are being used
	// which did not validate network name before addNetwork call.
	if config.UseExistingNetwork && config.Name == "" {
		return nil, fmt.Errorf("missing required parameter network name")
	}

	// If new network creation is required, then ENI Name or MAC and ENI IP addresses are required.
	if !config.UseExistingNetwork {
		if config.ENIName == "" && config.ENIMACAddress == "" {
			return nil, fmt.Errorf("missing required parameter ENIName or ENIMACAddress")
		}
		if len(config.ENIIPAddresses) == 0 {
			return nil, fmt.Errorf("missing required parameter ENIIPAddresses")
		}
	}

	// Parse the received config into NetConfig.
	netConfig := NetConfig{
		NetConf:            config.NetConf,
		ENIName:            config.ENIName,
		UseExistingNetwork: config.UseExistingNetwork,
		BlockIMDS:          config.BlockIMDS,
	}

	// Parse the ENI MAC address.
	if config.ENIMACAddress != "" {
		netConfig.ENIMACAddress, err = net.ParseMAC(config.ENIMACAddress)
		if err != nil {
			return nil, fmt.Errorf("invalid ENIMACAddress %s", config.ENIMACAddress)
		}
	}

	// Parse the ENI IP addresses.
	for _, ipAddr := range config.ENIIPAddresses {
		parsedIPAddr, err := vpc.GetIPAddressFromString(ipAddr)
		if err != nil {
			return nil, fmt.Errorf("invalid ENIIPAddress %s", ipAddr)
		}
		netConfig.ENIIPAddresses = append(netConfig.ENIIPAddresses, *parsedIPAddr)
	}

	// Parse the optional gateway IP addresses.
	for _, gatewayIPAddr := range config.GatewayIPAddresses {
		parsedGatewayIPAddr := net.ParseIP(gatewayIPAddr)
		if parsedGatewayIPAddr == nil {
			return nil, fmt.Errorf("invalid GatewayIPAddress %s", gatewayIPAddr)
		}
		netConfig.GatewayIPAddresses = append(netConfig.GatewayIPAddresses, parsedGatewayIPAddr)
	}

	// Validation complete. Return the parsed NetConfig object.
	log.Debugf("Created NetConfig: %+v.", netConfig)
	return &netConfig, nil
}