Method uaaAuth.VerifySession has a Cognitive Complexity of 10 (exceeds 8 allowed). Consider refactoring.

Open

func (a *uaaAuth) VerifySession(c echo.Context, sessionUser string, sessionExpireTime int64) error {

    tr, err := a.p.GetUAATokenRecord(sessionUser)

    if err != nil {

• Read up
  Read up

Method portalProxy.RefreshOidcToken has 5 return statements (exceeds 4 allowed).

Open

func (p *portalProxy) RefreshOidcToken(skipSSLValidation bool, cnsiGUID, userGUID, client, clientSecret, tokenEndpoint string) (t interfaces.TokenRecord, err error) {
    log.Debug("RefreshOidcToken")
    userToken, ok := p.GetCNSITokenRecordWithDisconnected(cnsiGUID, userGUID)
    if !ok {
        return t, fmt.Errorf("Info could not be found for user with GUID %s", userGUID)

Function UnMarshalHelper has a Cognitive Complexity of 10 (exceeds 8 allowed). Consider refactoring.

Open

func UnMarshalHelper(values map[string]interface{}, intf interface{}) error {

    value := reflect.ValueOf(intf)

    if value.Kind() != reflect.Ptr {

• Read up
  Read up

Method CloudFoundrySpecification.Info has 5 return statements (exceeds 4 allowed).

Open

func (c *CloudFoundrySpecification) Info(apiEndpoint string, skipSSLValidation bool) (interfaces.CNSIRecord, interface{}, error) {
    log.Debug("Info")
    var v2InfoResponse interfaces.V2Info
    var newCNSI interfaces.CNSIRecord

Method ConsoleConfig.IsSetupComplete has 5 return statements (exceeds 4 allowed).

Open

func (consoleConfig *ConsoleConfig) IsSetupComplete() bool {

    // No auth, then setup is complete
    if AuthEndpointTypes[consoleConfig.AuthEndpointType] == AuthNone {
        return true

Function MakePluginsFromConfig has a Cognitive Complexity of 10 (exceeds 8 allowed). Consider refactoring.

Open

func MakePluginsFromConfig() {
    log.Debug("MakePluginsFromConfig")

    var config []pluginConfig

• Read up
  Read up

Function readCFFile has 5 return statements (exceeds 4 allowed).

Open

func readCFFile() (*CFConfigFile, *url.URL, error) {

    var url *url.URL
    usr, err := user.Current()
    if err != nil {

Method portalProxy.login has 5 return statements (exceeds 4 allowed).

Open

func (p *portalProxy) login(c echo.Context, skipSSLValidation bool, client string, clientSecret string, endpoint string) (uaaRes *interfaces.UAAResponse, u *interfaces.JWTUserTokenInfo, err error) {
    log.Debug("login")
    if c.Request().Method == http.MethodGet {
        code := c.QueryParam("code")
        state := c.QueryParam("state")

Function parseConsoleConfigFromForm has 5 return statements (exceeds 4 allowed).

Open

func parseConsoleConfigFromForm(c echo.Context) (*interfaces.ConsoleConfig, error) {
    consoleConfig := new(interfaces.ConsoleConfig)

    // Local admin user configuration?
    password := c.FormValue("local_admin_password")

Method PostgresCNSIRepository.ListByUser has 5 return statements (exceeds 4 allowed).

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)

Function getRecentLogs has a Cognitive Complexity of 10 (exceeds 8 allowed). Consider refactoring.

Open

func getRecentLogs(ac *AuthorizedConsumer, cnsiGUID, appGUID string) ([]*events.LogMessage, error) {
    log.Debug("getRecentLogs")
    messages, err := ac.consumer.RecentLogs(appGUID, ac.authToken)
    if err != nil {
        errorPattern := "Failed to get recent messages for App %s on CNSI %s [%v]"

• Read up
  Read up

Function init has 5 return statements (exceeds 4 allowed).

Open

func init() {
    RegisterMigration(20190522121200, "LocalUsers", func(txn *sql.Tx, conf *goose.DBConf) error {
        binaryDataType := "BYTEA"
        if strings.Contains(conf.Driver.Name, "mysql") {
            binaryDataType = "BLOB"

Method portalProxy.writeSessionHook has a Cognitive Complexity of 10 (exceeds 8 allowed). Consider refactoring.

Open

func (p *portalProxy) writeSessionHook(c echo.Context) func() {
    return func() {
        // Has the session been modified and need saving?
        sessionModifed := c.Get(jetStreamSessionContextUpdatedKey)
        sessionIntf := c.Get(jetStreamSessionContextKey)

• Read up
  Read up

Function getKubeDashboardServiceAccount has 5 return statements (exceeds 4 allowed).

Open

func getKubeDashboardServiceAccount(p interfaces.PortalProxy, cnsiGUID, userGUID string, labelSelector string) (*v1.ServiceAccount, error) {
    log.Debug("getKubeDashboardService request")

    response, err := p.DoProxySingleRequest(cnsiGUID, userGUID, "GET", "/api/v1/serviceaccounts?labelSelector="+labelSelector, nil, nil)
    if err != nil || response.StatusCode != 200 {

Method KubeConfigFile.GetUserForCluster has 5 return statements (exceeds 4 allowed).

Open

func (k *KubeConfigFile) GetUserForCluster(clusterEndpoint string) (*KubeConfigUser, error) {

    var cluster *KubeConfigCluster
    var err error

Method CustomBinder.Bind has 5 return statements (exceeds 4 allowed).

Open

func (b *CustomBinder) Bind(i interface{}, c echo.Context) error {
    db := new(echo.DefaultBinder)
    err := db.Bind(i, c)

    if err != nil {

Function init has 5 return statements (exceeds 4 allowed).

Open

func init() {
    RegisterMigration(20180824092600, "LinkedTokens", func(txn *sql.Tx, conf *goose.DBConf) error {

        addTokenID := "ALTER TABLE tokens ADD token_guid VARCHAR(36) DEFAULT 'default-token'"
        _, err := txn.Exec(addTokenID)

Method FavoritesDBStore.List has 5 return statements (exceeds 4 allowed).

Open

func (p *FavoritesDBStore) List(userGUID string) ([]*UserFavoriteRecord, error) {
    log.Debug("List")
    rows, err := p.db.Query(getFavorites, userGUID)
    if err != nil {
        return nil, fmt.Errorf("Unable to retrieve User Favorite records: %v", err)

Function readKubeConfigFile has 5 return statements (exceeds 4 allowed).

Open

func readKubeConfigFile() (*clientcmdapi.Config, error) {

    // Use the KUBECONFIG env var if set, otherwise use default
    kcFile := os.Getenv("KUBECONFIG")
    if len(kcFile) == 0 {

Method portalProxy.RefreshOAuthToken has 5 return statements (exceeds 4 allowed).

Open

func (p *portalProxy) RefreshOAuthToken(skipSSLValidation bool, cnsiGUID, userGUID, client, clientSecret, tokenEndpoint string) (t interfaces.TokenRecord, err error) {
    log.Debug("refreshToken")
    userToken, ok := p.GetCNSITokenRecordWithDisconnected(cnsiGUID, userGUID)
    if !ok {
        return t, fmt.Errorf("Info could not be found for user with GUID %s", userGUID)