Merge pull request #7 from fangdingjun/dependabot/go_modules/github.com/pires/go-proxyproto-0.6.1

Bump github.com/pires/go-proxyproto from 0.6.0 to 0.6.1

common.go

@@ -69,9 +69,11 @@ const (
 )
 
 // TLS compression types.
+/*
 const (
 	compressionNone uint8 = 0
 )
+*/
 
 // TLS extension numbers
 const (
@@ -107,9 +109,11 @@ const (
 
 // TLS Elliptic Curve Point Formats
 // http://www.iana.org/assignments/tls-parameters/tls-parameters.xml#tls-parameters-9
+/*
 const (
 	pointFormatUncompressed uint8 = 0
 )
+*/
 
 // TLS CertificateStatusType (RFC 3546)
 const (
@@ -117,6 +121,7 @@ const (
 )
 
 // Certificate types (for certificateRequestMsg)
+/*
 const (
 	certTypeRSASign    = 1 // A certificate containing an RSA key
 	certTypeDSSSign    = 2 // A certificate containing a DSA key
@@ -130,19 +135,24 @@ const (
 
 	// Rest of these are reserved by the TLS spec
 )
+*/
 
 // Hash functions for TLS 1.2 (See RFC 5246, section A.4.1)
+/*
 const (
 	hashSHA1   uint8 = 2
 	hashSHA256 uint8 = 4
 	hashSHA384 uint8 = 5
 )
+*/
 
 // Signature algorithms for TLS 1.2 (See RFC 5246, section A.4.1)
+/*
 const (
 	signatureRSA   uint8 = 1
 	signatureECDSA uint8 = 3
 )
+*/
 
 // signatureAndHash mirrors the TLS 1.2, SignatureAndHashAlgorithm struct. See
 // RFC 5246, section A.4.1.
@@ -153,6 +163,7 @@ type signatureAndHash struct {
 // supportedSignatureAlgorithms contains the signature and hash algorithms that
 // the code advertises as supported in a TLS 1.2 ClientHello and in a TLS 1.2
 // CertificateRequest.
+/*
 var supportedSignatureAlgorithms = []signatureAndHash{
 	{hashSHA256, signatureRSA},
 	{hashSHA256, signatureECDSA},
@@ -161,6 +172,7 @@ var supportedSignatureAlgorithms = []signatureAndHash{
 	{hashSHA1, signatureRSA},
 	{hashSHA1, signatureECDSA},
 }
+*/
 
 // ConnectionState records basic TLS details about the connection.
 type ConnectionState struct {
@@ -201,6 +213,7 @@ const (
 
 // ClientSessionState contains the state needed by clients to resume TLS
 // sessions.
+/*
 type ClientSessionState struct {
 	sessionTicket      []uint8               // Encrypted ticket used for session resumption with server
 	vers               uint16                // SSL/TLS version negotiated for the session
@@ -209,12 +222,14 @@ type ClientSessionState struct {
 	serverCertificates []*x509.Certificate   // Certificate chain presented by the server
 	verifiedChains     [][]*x509.Certificate // Certificate chains we built for verification
 }
+*/
 
 // ClientSessionCache is a cache of ClientSessionState objects that can be used
 // by a client to resume a TLS session with a given server. ClientSessionCache
 // implementations should expect to be called concurrently from different
 // goroutines. Only ticket-based resumption is supported, not SessionID-based
 // resumption.
+/*
 type ClientSessionCache interface {
 	// Get searches for a ClientSessionState associated with the given key.
 	// On return, ok is true if one was found.
@@ -223,6 +238,7 @@ type ClientSessionCache interface {
 	// Put adds the ClientSessionState to the cache with the given key.
 	Put(sessionKey string, cs *ClientSessionState)
 }
+*/
 
 /*
 // SignatureScheme identifies a signature algorithm supported by TLS. See

conf_test.go

@@ -1,14 +1,14 @@
 package main
 
 import (
-	"io/ioutil"
+	"os"
 	"testing"
 
 	yaml "gopkg.in/yaml.v2"
 )
 
 func TestConf(t *testing.T) {
-	data, err := ioutil.ReadFile("config.sample.yaml")
+	data, err := os.ReadFile("config.sample.yaml")
 	if err != nil {
 		t.Fatal(err)
 	}

go.mod

@@ -5,7 +5,7 @@ go 1.17
 require (
 	github.com/fangdingjun/go-log/v5 v5.0.0
 	github.com/fangdingjun/protolistener v0.0.0-20210804081554-626e6590d6e7
-	github.com/pires/go-proxyproto v0.6.0
+	github.com/pires/go-proxyproto v0.6.1
 	gopkg.in/yaml.v2 v2.4.0
 )
 

go.sum

@@ -2,8 +2,9 @@ github.com/fangdingjun/go-log/v5 v5.0.0 h1:vdh9Bk9C4ZFL6KoO6rII73zQIyaLf7hFdBvuc
 github.com/fangdingjun/go-log/v5 v5.0.0/go.mod h1:V012Oxo0/pSbccX4OFSp9MJglXwNsZo2ByBBorr7zzM=
 github.com/fangdingjun/protolistener v0.0.0-20210804081554-626e6590d6e7 h1:z5NlLvUNbGZxQhtUZELvIorAqpDmcIhGQXE5GdO7+5I=
 github.com/fangdingjun/protolistener v0.0.0-20210804081554-626e6590d6e7/go.mod h1:ljbjhI4fVrT5GwMu1iBhWTZwLJSqsXKwKlGKas5GudM=
-github.com/pires/go-proxyproto v0.6.0 h1:cLJUPnuQdiNf7P/wbeOKmM1khVdaMgTFDLj8h9ZrVYk=
 github.com/pires/go-proxyproto v0.6.0/go.mod h1:Odh9VFOZJCf9G8cLW5o435Xf1J95Jw9Gw5rnCjcwzAY=
+github.com/pires/go-proxyproto v0.6.1 h1:EBupykFmo22SDjv4fQVQd2J9NOoLPmyZA/15ldOGkPw=
+github.com/pires/go-proxyproto v0.6.1/go.mod h1:Odh9VFOZJCf9G8cLW5o435Xf1J95Jw9Gw5rnCjcwzAY=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 golang.org/x/crypto v0.0.0-20210711020723-a769d52b0f97 h1:/UOmuWzQfxxo9UtlXMwuQU8CMgg1eZXqTRwkSQJWKOI=
 golang.org/x/crypto v0.0.0-20210711020723-a769d52b0f97/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=

handshake_messages.go

@@ -33,7 +33,7 @@ type clientHelloMsg struct {
 }
 
 /*
-func (m *clientHelloMsg) equal(i interface{}) bool {
+	func (m *clientHelloMsg) equal(i interface{}) bool {
 		m1, ok := i.(*clientHelloMsg)
 		if !ok {
 			return false
@@ -57,9 +57,9 @@ func (m *clientHelloMsg) equal(i interface{}) bool {
 			m.secureRenegotiationSupported == m1.secureRenegotiationSupported &&
 			bytes.Equal(m.secureRenegotiation, m1.secureRenegotiation) &&
 			eqStrings(m.alpnProtocols, m1.alpnProtocols)
-}
+	}
 
-func (m *clientHelloMsg) marshal() []byte {
+	func (m *clientHelloMsg) marshal() []byte {
 		if m.raw != nil {
 			return m.raw
 		}
@@ -298,7 +298,7 @@ func (m *clientHelloMsg) marshal() []byte {
 		m.raw = x
 
 		return x
-}
+	}
 */
 func (m *clientHelloMsg) unmarshal(data []byte) bool {
 	if len(data) < 42 {

main.go

@@ -5,7 +5,6 @@ import (
 	"flag"
 	"fmt"
 	"io"
-	"io/ioutil"
 	"net"
 	"os"
 	"os/signal"
@@ -78,7 +77,11 @@ func forward(ctx context.Context, c net.Conn, data []byte, dst string) {
 			Command:           proxyproto.PROXY,
 			TransportProtocol: proxyproto.TCPv4,
 			SourceAddr:        raddr,
-			DestinationAddr:   &net.TCPAddr{},
+			DestinationAddr: &net.TCPAddr{
+				IP:   []byte{0, 0, 0, 0},
+				Port: 0,
+				Zone: "",
+			},
 		}
 
 		switch strings.ToLower(ss[1]) {
@@ -186,7 +189,7 @@ func main() {
 	flag.StringVar(&loglevel, "log_level", "INFO", "log level")
 	flag.Parse()
 
-	data, err := ioutil.ReadFile(cfgfile)
+	data, err := os.ReadFile(cfgfile)
 	if err != nil {
 		glog.Fatal(err)
 	}
@@ -231,9 +234,7 @@ func main() {
 
 	ch := make(chan os.Signal, 2)
 	signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM)
-	select {
+	s := <-ch
-	case s := <-ch:
 	cancel()
 	glog.Printf("received signal %s, exit.", s)
-	}
 }

proto_test.go

@@ -3,8 +3,8 @@ package main
 import (
 	"context"
 	"crypto/tls"
-	"io/ioutil"
 	"net"
+	"os"
 	"testing"
 
 	"github.com/fangdingjun/go-log/v5"
@@ -15,7 +15,7 @@ import (
 func TestProxyProto(t *testing.T) {
 	log.Default.Level = log.DEBUG
 
-	data, err := ioutil.ReadFile("config.sample.yaml")
+	data, err := os.ReadFile("config.sample.yaml")
 	if err != nil {
 		log.Fatal(err)
 	}