kubenetworks/kubevpn

Method Server.Connect has 93 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (svr *Server) Connect(req *rpc.ConnectRequest, resp rpc.Daemon_ConnectServer) (e error) {
    defer func() {
        util.InitLoggerForServer(true)
        log.SetOutput(svr.LogFile)
        config.Debug = false

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

Open

    go func() {
        var listDone bool
        for ctx.Err() == nil {
            err := func() error {
                if !listDone {

• Read up
  Read up

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

Open

    go func() {
        var listDone bool
        for ctx.Err() == nil {
            err := func() error {
                if !listDone {

• Read up
  Read up

CloneRequest has 24 methods (exceeds 20 allowed). Consider refactoring.

Open

type CloneRequest struct {
    state         protoimpl.MessageState
    sizeCache     protoimpl.SizeCache
    unknownFields protoimpl.UnknownFields

Function StartClient has 91 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func StartClient(ctx context.Context, localDir string, localAddr, remoteAddr string) error {
    if err := MakeSureGui(); err != nil {
        return err
    }
    err := cmdutil.SetConfigDataLocationsFromFlags(pkgconfig.GetSyncthingPath(), "", "")

Function handle has 90 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func handle(ctx context.Context, tcpConn net.Conn, udpConn *net.UDPConn) {
    defer udpConn.Close()
    log.Debugf("[TUN-UDP] %s <-> %s", tcpConn.RemoteAddr(), udpConn.LocalAddr())
    errChan := make(chan error, 2)
    go func() {

Function serve has 89 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func serve(w http.ResponseWriter, r *http.Request, admit admitHandler) {
    var body []byte
    if r.Body != nil {
        if data, err := io.ReadAll(r.Body); err == nil {
            body = data

Method Config.watchServiceToAddHosts has 89 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (c *Config) watchServiceToAddHosts(ctx context.Context, serviceInterface v13.ServiceInterface, hosts []Entry) {
    ticker := time.NewTicker(time.Second * 15)
    defer ticker.Stop()
    immediate := make(chan struct{}, 1)
    immediate <- struct{}{}

Method wsHandler.handle has 88 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

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

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

Open

func _Daemon_Identify_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(IdentifyRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

func _Daemon_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(ListRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

func _Daemon_Version_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(VersionRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

func _Daemon_SshStart_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(SshStartRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

func _DHCP_RentIP_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(RentIPRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

func _Daemon_SshStop_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(SshStopRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

func _Daemon_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(GetRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

func _DHCP_ReleaseIP_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(ReleaseIPRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

func _Daemon_ConfigRemove_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(ConfigRemoveRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

func _Daemon_Upgrade_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(UpgradeRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

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

Open

func _Daemon_ConfigAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(ConfigAddRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up