Function TestUnpackHandshakeV10 has 88 lines of code (exceeds 70 allowed). Consider refactoring.

Open

func TestUnpackHandshakeV10(t *testing.T) {

    type UnpackHandshakeV10Assert struct {
        Packet   []byte
        HasError bool

Method AuthenticationHandshake.handleBackendAuthResponse has 87 lines of code (exceeds 70 allowed). Consider refactoring.

Open

func (h *AuthenticationHandshake) handleBackendAuthResponse() {
    if h.err != nil {
        return
    }

Function UnpackHandshakeV10 has 87 lines of code (exceeds 70 allowed). Consider refactoring.

Open

func UnpackHandshakeV10(packet []byte) (*HandshakeV10, error) {
    r := bytes.NewReader(packet)

    // Header
    header, err := GetPacketHeader(r)

Method LogTest.RunAllTests has 86 lines of code (exceeds 70 allowed). Consider refactoring.

Open

func (lt *LogTest) RunAllTests(t *testing.T) {

    // Format strings and sample arguments used in the test cases
    const testCaseFormatStr = "aaa %s bbb %d ccc %2.1f ddd \t eee"
    testCaseArgs := []interface{}{"stringval", 123, 1.234}

Method AuthenticationHandshake.handleBackendAuthResponse has 17 return statements (exceeds 7 allowed).

Open

func (h *AuthenticationHandshake) handleBackendAuthResponse() {
    if h.err != nil {
        return
    }

Method proxyService.Start has a Cognitive Complexity of 26 (exceeds 20 allowed). Consider refactoring.

Open

func (proxy *proxyService) Start() error {
    logger := proxy.logger

    logger.Infof("Starting service")

• Read up
  Read up

Function extractShellCommand has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

function extractShellCommand(shellBlock) {
  var blockLines = shellBlock.innerText.split("\n");
  var command = "";

  var includeNextLine = true;

• Read up
  Read up

Function main has 74 lines of code (exceeds 70 allowed). Consider refactoring.

Open

func main() {
    log.Println("Secretless CRD watcher starting up...")

    var kubeConfig *string
    if home := getHomeDir(); home != "" {

Function handleAuthSCRAM has 14 return statements (exceeds 7 allowed).

Open

func handleAuthSCRAM(username string, password string, connection net.Conn) error {
    sc := scram.NewClient(sha256.New, username, password)
    sc.Step(nil)
    if sc.Err() != nil {
        return fmt.Errorf("SCRAM-SHA-256 error: %s", sc.Err().Error())

Function UnpackHandshakeV10 has 14 return statements (exceeds 7 allowed).

Open

func UnpackHandshakeV10(packet []byte) (*HandshakeV10, error) {
    r := bytes.NewReader(packet)

    // Header
    header, err := GetPacketHeader(r)

Function UnpackHandshakeResponse41 has 72 lines of code (exceeds 70 allowed). Consider refactoring.

Open

func UnpackHandshakeResponse41(packet []byte) (*HandshakeResponse41, error) {
    r := bytes.NewReader(packet)

    // Skip packet header (but save in struct)
    header, err := GetPacketHeader(r)

Function TestV1HttpHandlerConversion has 72 lines of code (exceeds 70 allowed). Consider refactoring.

Open

func TestV1HttpHandlerConversion(t *testing.T) {
    t.Run("connectorConfig field maps correctly", func(t *testing.T) {
        v1Cfg := v1HttpExample()
        v2Cfg, err := NewV2Config(v1Cfg)
        assert.NoError(t, err)

Function UnpackHandshakeV10 has a Cognitive Complexity of 24 (exceeds 20 allowed). Consider refactoring.

Open

func UnpackHandshakeV10(packet []byte) (*HandshakeV10, error) {
    r := bytes.NewReader(packet)

    // Header
    header, err := GetPacketHeader(r)

• Read up
  Read up

Function UnpackHandshakeResponse41 has 11 return statements (exceeds 7 allowed).

Open

func UnpackHandshakeResponse41(packet []byte) (*HandshakeResponse41, error) {
    r := bytes.NewReader(packet)

    // Skip packet header (but save in struct)
    header, err := GetPacketHeader(r)

Function UnpackOkResponse has 9 return statements (exceeds 7 allowed).

Open

func UnpackOkResponse(packet []byte) (*OkResponse, error) {

    // Min packet length = header(4 bytes) + PacketType(1 byte)
    if err := CheckPacketLength(5, packet); err != nil {
        return nil, err

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

Open

func runTest(backendName string, threadIndex int, aggregateTimings *timing.AggregateTimings,
    testManager *TestManager, round int) time.Duration {

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

Open

    pluginDir string,
    checksumsFile string,
    internalLookupFunc InternalPluginLookupFunc,
    externalLookupfunc ExternalPluginLookupFunc,
    logger log.Logger,

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

Open

func InjectCredentials(authPlugin string, clientHandshake *HandshakeResponse41, salt []byte, username string, password string) (err error) {

Function TestConfigEnv has 8 return statements (exceeds 7 allowed).

Open

func TestConfigEnv(t *testing.T) {

    // Shared mocks and doubles

    logger := loggermock.NewLogger()

Function RegisterCRDListener has 8 return statements (exceeds 7 allowed).

Open

func RegisterCRDListener(namespace string, configSpec string, resourceEventHandler ResourceEventHandler) error {
    log.Printf("%s: Registering CRD watcher...", PluginName)

    clientConfig, err := NewKubernetesConfig()
    if err != nil {