func()

in controllers/gerritreplicationconfig/gerritreplicationconfig_controller.go [251:287]

• 29 lines of code
• 7 McCabe index (conditional complexity)

func (r *ReconcileGerritReplicationConfig) getConfigurationArgs(gerritObj *gerritApi.Gerrit,
) (*configurationArguments, error) {
	podList, err := r.platform.GetPods(gerritObj.Namespace, &metaV1.ListOptions{LabelSelector: fmt.Sprintf("deploymentconfig=%s", gerritObj.Name)})
	if err != nil {
		return nil, fmt.Errorf("failed to get Gerrit pods: %w", err)
	}

	if len(podList.Items) != 1 {
		return nil, errors.New("found multiple pods of Gerrit instance. It seems that some of old pods did not shutdown yet")
	}

	var args configurationArguments

	args.gerritPodName = podList.Items[0].Name

	args.gerritUrl, err = r.componentService.GetGerritSSHUrl(gerritObj)
	if err != nil {
		return nil, fmt.Errorf("failed to Get ssh url for gerrit instance: %w", err)
	}

	args.sshPortService, err = r.componentService.GetServicePort(gerritObj)
	if err != nil {
		return nil, fmt.Errorf("failed to Get ssh port for gerrit: %w", err)
	}

	args.gerritAdminSshKeys, err = r.platform.GetSecret(gerritObj.Namespace, gerritObj.Name+"-admin")
	if err != nil {
		return nil, fmt.Errorf("failed to Get a ssh key for admin user : %w", err)
	}

	args.gerritVCSSshKey, err = r.platform.GetSecret(gerritObj.Namespace, spec.GerritDefaultVCSKeyName)
	if err != nil {
		return nil, fmt.Errorf("failed to Get a ssh key for autouser: %w", err)
	}

	return &args, nil
}