nps/server/socks5/socks5_handshake_handle.go

package socks5

import (
	"context"
	"ehang.io/nps/core"
	"errors"
	"fmt"
	"io"
)

type Handshake struct {
	core.NpsPlugin
}

func (handshake *Handshake) Run(ctx context.Context) (context.Context, error) {
	clientConn := handshake.GetClientConn(ctx)
	buf := make([]byte, 2)
	if _, err := io.ReadFull(clientConn, buf); err != nil {
		return ctx, errors.New("negotiation err while read 2 bytes from client connection: " + err.Error())
	}

	if version := buf[0]; version != 5 {
		return ctx, errors.New("only support socks5")
	}
	nMethods := buf[1]

	methods := make([]byte, nMethods)

	if n, err := clientConn.Read(methods); n != int(nMethods) || err != nil {
		return ctx, errors.New(fmt.Sprintf("read methods error, need %d , read  %d, error %s", nMethods, n, err.Error()))
	} else {
		ctx = context.WithValue(ctx, "methods", methods[:n])
	}

	return ctx, nil
}