Method mock_server has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

  def mock_server(server)
    server.mount_proc('/geo/proxy_git_ssh/info_refs_upload_pack') do |req, res|
      res.content_type = 'application/json'
      res.status = 200

• Read up
  Read up

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

Open

func pktLineSplitter(data []byte, atEOF bool) (advance int, token []byte, err error) {
    if len(data) < 4 {
        if atEOF && len(data) > 0 {
            return 0, nil, fmt.Errorf("pktLineSplitter: incomplete length prefix on %q", data)
        }

Avoid deeply nested control flow statements.

Open

                } else if r.URL.Query().Get("username") == "broken_json" {
                    w.Write([]byte("{ \"message\": \"broken json!\""))
                } else if r.URL.Query().Get("username") == "broken_empty" {
                    w.WriteHeader(http.StatusForbidden)
                } else {

Method mock_server has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

  def mock_server(server)
    server.mount_proc('/api/v4/internal/discover') do |req, res|
      identifier = req.query['key_id'] || req.query['username'] || req.query['user_id']
      known_identifiers = %w(10 someuser 100)
      if known_identifiers.include?(identifier)

• Read up
  Read up

Method Client.Batch has 6 return statements (exceeds 4 allowed).

Open

func (c *Client) Batch(operation string, reqObjects []*BatchObject, ref string, reqHashAlgo string) (*BatchResponse, error) {
    var bref *batchRef

    // FIXME: This causes tests to fail
    // if ref == "" {

Method Command.Execute has 6 return statements (exceeds 4 allowed).

Open

func (c *Command) Execute(ctx context.Context) (context.Context, error) {
    args := c.Args.SshArgs
    if len(args) != 2 {
        return ctx, disallowedcommand.Error
    }

Method Command.Execute has 6 return statements (exceeds 4 allowed).

Open

func (c *Command) Execute(ctx context.Context) (context.Context, error) {
    args := c.Args.SshArgs
    if len(args) != 2 {
        return ctx, disallowedcommand.Error
    }

Function writeCommandArgsAndTextData has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func writeCommandArgsAndTextData(t *testing.T, pl *pktline.Pktline, command string, args []string, data []string) {

Function Audit has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func Audit(ctx context.Context, commandType commandargs.CommandType, c *config.Config, response *accessverifier.Response, packfileStats *pb.PackfileNegotiationStatistics) {

Method Client.getRequestBody has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (c *Client) getRequestBody(ctx context.Context, args *commandargs.Shell, name string, scopes *[]string, expiresAt string) (*RequestBody, error) {

Function writeCommandArgsAndBinaryData has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func writeCommandArgsAndBinaryData(t *testing.T, pl *pktline.Pktline, command string, args []string, data [][]byte) {

Method Client.GetPersonalAccessToken has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (c *Client) GetPersonalAccessToken(ctx context.Context, args *commandargs.Shell, name string, scopes *[]string, expiresAt string) (*Response, error) {

Method Client.Audit has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (c *Client) Audit(ctx context.Context, username string, action commandargs.CommandType, repo string, packfileStats *pb.PackfileNegotiationStatistics) error {

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

Open

func newFromFile(path string) (*Config, error) {
    cfg := &Config{}
    *cfg = DefaultConfig
    cfg.RootDir = filepath.Dir(path)

Method Client.do has 5 return statements (exceeds 4 allowed).

Open

func (c *Client) do(request *http.Request) (*http.Response, error) {
    for k, v := range c.Headers {
        request.Header.Add(k, v)
    }

Method Command.processAPIEndpoints has 5 return statements (exceeds 4 allowed).

Open

func (c *Command) processAPIEndpoints(ctx context.Context, response *accessverifier.Response) error {
    client, err := gitlabnet.GetClient(c.Config)

    if err != nil {
        return err

Method Command.Execute has 5 return statements (exceeds 4 allowed).

Open

func (c *Command) Execute(ctx context.Context) (context.Context, error) {
    args := c.Args.SshArgs
    if len(args) < 3 {
        return ctx, disallowedcommand.Error
    }

Method Command.Execute has 5 return statements (exceeds 4 allowed).

Open

func (c *Command) Execute(ctx context.Context) (context.Context, error) {
    args := c.Args.SshArgs
    if len(args) != 3 {
        return ctx, disallowedcommand.Error
    }

Method serverConfig.get has 5 return statements (exceeds 4 allowed).

Open

func (s *serverConfig) get(ctx context.Context) *ssh.ServerConfig {
    var gssapiWithMICConfig *ssh.GSSAPIWithMICConfig
    if s.cfg.Server.GSSAPI.Enabled {
        gssApiServer, _ := NewGSSAPIServer(&s.cfg.Server.GSSAPI)

Method OSGSSAPIServer.AcceptSecContext has 5 return statements (exceeds 4 allowed).

Open

func (server *OSGSSAPIServer) AcceptSecContext(
    token []byte,
) (
    outputToken []byte,
    srcName string,