Method LocalUserInfo.UpdatePassword has 7 return statements (exceeds 4 allowed).

Open

func (userInfo *LocalUserInfo) UpdatePassword(id string, passwordInfo *passwordChangeInfo) (int, error) {

    // Fetch the user, make updates and save
    localUsersRepo, err := localusers.NewPgsqlLocalUsersRepository(userInfo.portalProxy.GetDatabaseConnection())
    if err != nil {

Function echoV2DefaultHTTPErrorHandler has a Cognitive Complexity of 11 (exceeds 8 allowed). Consider refactoring.

Open

func echoV2DefaultHTTPErrorHandler(err error, c echo.Context) {

    code := http.StatusInternalServerError
    msg := http.StatusText(code)
    if he, ok := err.(*echo.HTTPError); ok {

• Read up
  Read up

Function makePrometheusRequestInfos has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func makePrometheusRequestInfos(c echo.Context, userGUID string, metrics map[string]EndpointMetricsRelation, prometheusOp string, queries string, addJob bool) []interfaces.ProxyRequestInfo {

Avoid deeply nested control flow statements.

Open

                        if err == nil {
                            isValid, err := k.PortalProxy.GetSessionDataStore().IsValidSession(i)
                            if err == nil && !isValid {
                                log.Debugf("Deleting secret %s", secret.Name)
                                secretClient.Delete(secret.Name, nil)

Method HelmRelease.UpdatePods has a Cognitive Complexity of 11 (exceeds 8 allowed). Consider refactoring.

Open

func (r *HelmRelease) UpdatePods(jetstream interfaces.PortalProxy) {
    var jobs []KubeResourceJob
    for _, job := range r.PodJobs {
        jobs = append(jobs, job)
    }

• Read up
  Read up

Method CFAppPush.getGitSCMSource has 7 return statements (exceeds 4 allowed).

Open

func (cfAppPush *CFAppPush) getGitSCMSource(clientWebSocket *websocket.Conn, tempDir string, msg SocketMessage, userGUID string) (StratosProject, string, error) {
    var (
        err error
    )

Avoid deeply nested control flow statements.

Open

                        if err == nil {
                            isValid, err := k.PortalProxy.GetSessionDataStore().IsValidSession(i)
                            if err == nil && !isValid {
                                log.Debugf("Deleting pod %s", pod.Name)
                                podClient.Delete(pod.Name, nil)

Method CFPushApp.Run has 7 return statements (exceeds 4 allowed).

Open

func (c *CFPushApp) Run(msgSender DeployAppMessageSender, clientWebsocket *websocket.Conn) error {

    // Get a CF Config
    config, err := configv3.LoadConfig()
    if err != nil {

Method KubernetesSpecification.UpgradeRelease has 7 return statements (exceeds 4 allowed).

Open

func (c *KubernetesSpecification) UpgradeRelease(ec echo.Context) error {
    endpointGUID := ec.Param("endpoint")
    releaseName := ec.Param("name")
    namespace := ec.Param("namespace")

Method GKEKubeAuth.FetchToken has 7 return statements (exceeds 4 allowed).

Open

func (c *GKEKubeAuth) FetchToken(cnsiRecord interfaces.CNSIRecord, ec echo.Context) (*interfaces.TokenRecord, *interfaces.CNSIRecord, error) {
    log.Debug("FetchToken (GKE)")

    // We should already have the refresh token in the body sent to us
    req := ec.Request()

Method portalProxy.setupGetAvailableScopes has 7 return statements (exceeds 4 allowed).

Open

func (p *portalProxy) setupGetAvailableScopes(c echo.Context) error {

    // Check if already set up
    if p.GetConfig().ConsoleConfig.IsSetupComplete() {
        return c.NoContent(http.StatusServiceUnavailable)

Method PostgresCNSIRepository.ListByUser has a Cognitive Complexity of 11 (exceeds 8 allowed). Consider refactoring.

Open

func (p *PostgresCNSIRepository) ListByUser(userGUID string) ([]*interfaces.ConnectedEndpoint, error) {
    log.Debug("ListByUser")
    rows, err := p.db.Query(listCNSIsByUser, "cnsi", userGUID)
    if err != nil {
        return nil, fmt.Errorf("Unable to retrieve CNSI records: %v", err)

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                    if err != nil {
                        return fmt.Errorf("Can not get endpoint type for %s: '%v'", endpoint.CNSIType, err)
                    }

Method portalProxy.ProxyRequest has 7 return statements (exceeds 4 allowed).

Open

func (p *portalProxy) ProxyRequest(c echo.Context, uri *url.URL) (map[string]*interfaces.CNSIRequest, error) {
    log.Debug("ProxyRequest")
    cnsiList := strings.Split(c.Request().Header.Get("x-cap-cnsi-list"), ",")
    shouldPassthrough := "true" == c.Request().Header.Get("x-cap-passthrough")
    longRunning := "true" == c.Request().Header.Get(longRunningTimeoutHeader)

Avoid deeply nested control flow statements.

Open

            if consoleConfig.AuthorizationEndpoint == nil {
                // No Authorization endpoint
                consoleConfig.AuthorizationEndpoint = consoleConfig.UAAEndpoint
                log.Debugf("Using UAA Endpoint for Auth Endpoint: %s", consoleConfig.AuthorizationEndpoint)
            }

Function KubeDashboardLogin has a Cognitive Complexity of 11 (exceeds 8 allowed). Consider refactoring.

Open

func KubeDashboardLogin(c echo.Context, p interfaces.PortalProxy) error {
    log.Debug("kubeDashboardLogin request")

    endpointGUID := c.Param("guid")
    userGUID := c.Get("user_id").(string)

• Read up
  Read up

Function updateCFFIle has 7 return statements (exceeds 4 allowed).

Open

func updateCFFIle(updates map[string]string) error {
    usr, err := user.Current()
    if err != nil {
        return err
    }

Function NewDatabaseConnectionParametersFromConfig has 7 return statements (exceeds 4 allowed).

Open

func NewDatabaseConnectionParametersFromConfig(dc DatabaseConfig) (DatabaseConfig, error) {

    if len(dc.DatabaseProvider) == 0 {
        dc.DatabaseProvider = DefaultDatabaseProvider
    }

Function SetStructFieldValue has a Cognitive Complexity of 11 (exceeds 8 allowed). Consider refactoring.

Open

func SetStructFieldValue(value reflect.Value, field reflect.Value, val string) error {

    var newVal interface{}
    var err error
    typ := field.Type()

• Read up
  Read up

Function updateCFFIle has 7 return statements (exceeds 4 allowed).

Open

func updateCFFIle(updates map[string]string) error {
    usr, err := user.Current()
    if err != nil {
        return err
    }