Method MetricsSpecification.Connect has 9 return statements (exceeds 4 allowed).

Open

func (m *MetricsSpecification) Connect(ec echo.Context, cnsiRecord interfaces.CNSIRecord, userId string) (*interfaces.TokenRecord, bool, error) {
    log.Debug("Metrics Connect...")

    params := new(interfaces.LoginToCNSIParams)
    err := interfaces.BindOnce(params, ec)

Method KubernetesSpecification.InstallRelease has 9 return statements (exceeds 4 allowed).

Open

func (c *KubernetesSpecification) InstallRelease(ec echo.Context) error {
    bodyReader := ec.Request().Body
    buf := new(bytes.Buffer)
    buf.ReadFrom(bodyReader)

Method portalProxy.endpointUpdateDeleteMiddleware has a Cognitive Complexity of 12 (exceeds 8 allowed). Consider refactoring.

Open

func (p *portalProxy) endpointUpdateDeleteMiddleware(h echo.HandlerFunc) echo.HandlerFunc {
    return func(c echo.Context) error {
        log.Debug("endpointUpdateDeleteMiddleware")
        userID, err := p.GetSessionValue(c, "user_id")
        if err != nil {

• Read up
  Read up

Method PgsqlTokenRepository.SaveAuthToken has a Cognitive Complexity of 12 (exceeds 8 allowed). Consider refactoring.

Open

func (p *PgsqlTokenRepository) SaveAuthToken(userGUID string, tr interfaces.TokenRecord, encryptionKey []byte) error {
    log.Debug("SaveAuthToken")
    if userGUID == "" {
        msg := "Unable to save Auth Token without a valid User GUID."
        log.Debug(msg)

• Read up
  Read up

Method portalProxy.updateEndpoint has 9 return statements (exceeds 4 allowed).

Open

func (p *portalProxy) updateEndpoint(ec echo.Context) error {
    log.Debug("updateEndpoint")

    params := new(interfaces.UpdateEndpointParams)
    if err := ec.Bind(params); err != nil {

Function makeSpan has a Cognitive Complexity of 12 (exceeds 8 allowed). Consider refactoring.

Open

  makeSpan() {
    let span = '';
    if (this.boldOn || this.currentFg || this.currentBg) {
      span += '<span class="';
      if (this.boldOn) {

• Read up
  Read up

Function sortEndpointTiles has a Cognitive Complexity of 12 (exceeds 8 allowed). Consider refactoring.

Open

  protected sortEndpointTiles(
    { label: aLabel, renderPriority: aRenderPriority }: IStratosEndpointDefinition,
    { label: bLabel, renderPriority: bRenderPriority }: IStratosEndpointDefinition
  ) {
    // We're going to do a little more work than just to compare the render priority to ensure

• Read up
  Read up

Method CFAppPush.getConfigData has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (cfAppPush *CFAppPush) getConfigData(echoContext echo.Context, cnsiGUID string, orgGUID string, spaceGUID string, spaceName string, orgName string, clientWebSocket *websocket.Conn) (*CFPushAppConfig, error) {

Function setUpTestOrgSpaceUserRoles has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

  cfGuid: string,
  defaultCf: E2EConfigCloudFoundry,
  orgName: string,
  spaceName: string,
  userName: string,

Function handleOrgRoleChange has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

  state: IAllCfRolesState,
  endpointGuid: string,
  cf: ICfRolesState,
  orgGuid: string,
  orgState: IOrgRoleState,

Function buildMetricsChartConfig has 7 arguments (exceeds 4 allowed). Consider refactoring.

Open

  metricsAction: MetricsAction,
  yAxisLabel: string,
  getSeriesName: (result) => string,
  dataType: ChartDataTypes = null,
  filterSeries?: MetricsFilterSeries,

Function KubeDashboardProxy has 8 return statements (exceeds 4 allowed).

Open

func KubeDashboardProxy(c echo.Context, p interfaces.PortalProxy, config *rest.Config) error {
    log.Debugf("KubeDashboardProxy request for: %s", c.Request().RequestURI)

    cnsiGUID := c.Param("guid")
    prefix := "/pp/v1/apps/kubedash/ui/" + cnsiGUID + "/"

Function InstallDashboard has 8 return statements (exceeds 4 allowed).

Open

func InstallDashboard(p interfaces.PortalProxy, endpointGUID, userGUID string) error {
    // Download the Yaml for the dashboard
    kubeDashboardImage := p.Env().String("STRATOS_KUBERNETES_DASHBOARD_IMAGE", "")
    if len(kubeDashboardImage) == 0 {
        kubeDashboardImage = dashboardInstallYAMLDownloadURL

Method MetricsSpecification.createMetadata has 8 return statements (exceeds 4 allowed).

Open

func (m *MetricsSpecification) createMetadata(metricEndpoint *url.URL, httpClient http.Client, auth *MetricsAuth) (string, error) {
    basicMetricRequest := fmt.Sprintf("%s/api/v1/query?query=firehose_total_metrics_received", metricEndpoint)
    req, err := http.NewRequest("GET", basicMetricRequest, nil)
    if err != nil {
        msg := "Failed to create request for the Metrics Endpoint: %v"

Method KubernetesSpecification.Info has 8 return statements (exceeds 4 allowed).

Open

func (c *KubernetesSpecification) Info(apiEndpoint string, skipSSLValidation bool) (interfaces.CNSIRecord, interface{}, error) {

    log.Debug("Kubernetes Info")
    var v2InfoResponse interfaces.V2Info
    var newCNSI interfaces.CNSIRecord

Function getSSHCode has 8 return statements (exceeds 4 allowed).

Open

func getSSHCode(authorizeEndpoint, clientID, token string, skipSSLValidation bool) (string, error) {
    authorizeURL, err := url.Parse(authorizeEndpoint)
    if err != nil {
        return "", err
    }

Method Monocular.artifactHubGetIcon has 8 return statements (exceeds 4 allowed).

Open

func (m *Monocular) artifactHubGetIcon(c echo.Context) error {
    endpoint := c.Param("guid")
    repo := c.Param("repo")
    chartName := c.Param("name")
    version := c.Param("version")

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

Open

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

Function saveUAAConsoleConfig has 8 return statements (exceeds 4 allowed).

Open

func saveUAAConsoleConfig(consoleRepo console_config.Repository, consoleConfig *interfaces.ConsoleConfig) error {
    log.Debugf("Saving ConsoleConfig: %+v", consoleConfig)

    if err := consoleRepo.SetValue(systemGroupName, "UAA_ENDPOINT", consoleConfig.UAAEndpoint.String()); err != nil {
        return err

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()