kubenetworks/kubevpn

Method Manager.updateDHCPConfigMap has 56 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (m *Manager) updateDHCPConfigMap(ctx context.Context, f func(ipv4 *ipallocator.Range, ipv6 *ipallocator.Range) error) error {
    cm, err := m.client.Get(ctx, config.ConfigMapPodTrafficManager, metav1.GetOptions{})
    if err != nil {
        return fmt.Errorf("failed to get configmap DHCP server, err: %v", err)
    }

Function Complete has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func Complete(ctx context.Context, route *core.Route) error {
    if v, ok := os.LookupEnv(config.EnvInboundPodTunIPv4); !ok || v != "" {
        return nil
    }

Function TCPForwarder has 55 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func TCPForwarder(s *stack.Stack) func(stack.TransportEndpointID, *stack.PacketBuffer) bool {
    GvisorTCPForwardAddr := GvisorTCPForwardAddr
    return tcp.NewForwarder(s, 0, 100000, func(request *tcp.ForwarderRequest) {
        defer request.Complete(false)
        id := request.ID()

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func printDisconnectResp(disconnect rpc.Daemon_DisconnectClient) error {
    for {
        recv, err := disconnect.Recv()
        if err == io.EOF {
            return nil

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func printResetResp(resp rpc.Daemon_ResetClient) error {
    for {
        recv, err := resp.Recv()
        if err == io.EOF {
            return nil

• Read up
  Read up

Method ConnectOptions.addExtraRoute has 12 return statements (exceeds 4 allowed).

Open

func (c *ConnectOptions) addExtraRoute(ctx context.Context, nameserver string) error {
    if len(c.ExtraRouteInfo.ExtraDomain) == 0 {
        return nil
    }

Method Options.Connect has 12 return statements (exceeds 4 allowed).

Open

func (option *Options) Connect(ctx context.Context, sshConfig *pkgssh.SshConfig, transferImage bool, portBindings nat.PortMap) error {
    switch option.ConnectMode {
    case ConnectModeHost:
        daemonCli := daemon.GetClient(false)
        if daemonCli == nil {

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    for _, address := range cred.Addresses {
        // Type
        err = binary.Write(b, *endian, uint16(address.AddrType))
        if err != nil {
            return []byte{}, err

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    for _, authData := range cred.AuthData {
        // Type
        err = binary.Write(b, *endian, uint16(authData.ADType))
        if err != nil {
            return []byte{}, err

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    go func() {
        buf := config.LPool.Get().([]byte)[:]
        defer config.LPool.Put(buf[:])
        _, err := io.CopyBuffer(local, remote, buf)
        if err != nil && !errors.Is(err, net.ErrClosed) && !errors.Is(err, io.EOF) {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    go func() {
        buf := config.LPool.Get().([]byte)[:]
        defer config.LPool.Put(buf[:])
        _, err := io.CopyBuffer(remote, local, buf)
        if err != nil && !errors.Is(err, net.ErrClosed) && !errors.Is(err, io.EOF) {

• Read up
  Read up

Method ConnectOptions.PreCheckResource has 54 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *ConnectOptions) PreCheckResource() error {
    if len(c.Workloads) == 0 {
        return nil
    }

Method SvrOption.detectUnixSocksFile has 53 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (o *SvrOption) detectUnixSocksFile(ctx context.Context) {
    var f = func() {
        _, err := os.Stat(config.GetSockPath(o.IsSudo))
        if errors.Is(err, os.ErrNotExist) {
            o.Stop()

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    configFlags.WrapConfigFn = func(c *rest.Config) *rest.Config {
        if path, ok := os.LookupEnv(config.EnvSSHJump); ok {
            kubeconfigBytes, err := os.ReadFile(path)
            cmdutil.CheckErr(err)
            var conf *restclient.Config

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    configFlags.WrapConfigFn = func(c *rest.Config) *rest.Config {
        if path, ok := os.LookupEnv(config.EnvSSHJump); ok {
            bytes, err := os.ReadFile(path)
            cmdutil.CheckErr(err)
            var conf *rest.Config

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

type UploaderEntity struct {
    Login             string `json:"login"`
    Id                int64  `json:"id"`
    NodeId            string `json:"node_id"`
    AvatarUrl         string `json:"avatar_url"`

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

type AuthorEntity struct {
    Login             string `json:"login"`
    Id                int64  `json:"id"`
    NodeId            string `json:"node_id"`
    AvatarUrl         string `json:"avatar_url"`

• Read up
  Read up

Function CmdGet has 11 return statements (exceeds 4 allowed).

Open

func CmdGet(f cmdutil.Factory) *cobra.Command {
    var printFlags = cmdget.NewGetPrintFlags()
    cmd := &cobra.Command{
        Use:    "get",
        Hidden: true,

Function createTun has 11 return statements (exceeds 4 allowed).

Open

func createTun(cfg Config) (conn net.Conn, itf *net.Interface, err error) {
    if cfg.Addr == "" && cfg.Addr6 == "" {
        err = fmt.Errorf("IPv4 address and IPv6 address can not be empty at same time")
        return
    }

Method wsHandler.handle has 11 return statements (exceeds 4 allowed).

Open

func (w *wsHandler) handle(c context.Context) {
    ctx, f := context.WithCancel(c)
    defer f()

    cli, err := pkgssh.DialSshRemote(ctx, w.sshConfig, ctx.Done())