Merge branch 'develop' into multiarch

.drone.yml

@@ -1,8 +1,14 @@
+---
 kind: pipeline
 type: docker
 name: default
 
 steps:
+  - name: format
+    image: golang:1.15
+    commands:
+      - bash -c "gofmt -l . | wc -l | cmp -s <(echo 0) || (gofmt -l . && exit 1)"
+
   - name: install
     image: golang:1.15
     environment:
@@ -49,4 +55,10 @@ steps:
 
 volumes:
   - name: cache
-    temp: {}
+    temp: { }
+
+---
+kind: signature
+hmac: 8c21312bcfbaa9b7d2d3c31b1a5c13b54b4ecd1da853aa66a8ed11d72154fcca
+
+...

LICENSE

@@ -0,0 +1,22 @@
+MIT License
+
+Copyright (c) 2020 Jake Hillion
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.
+

config/builder.go

@@ -88,11 +88,11 @@ func buildUdp(p *proxy.Proxy, peer Peer) error {
 	var c func() udp.Congestion
 	switch peer.Congestion {
 	case "None":
-		c = func() udp.Congestion {return congestion.NewNone()}
+		c = func() udp.Congestion { return congestion.NewNone() }
 	default:
 		fallthrough
 	case "NewReno":
-		c = func() udp.Congestion {return congestion.NewNewReno()}
+		c = func() udp.Congestion { return congestion.NewNewReno() }
 	}
 
 	if peer.RemoteHost != "" {

config/config.go

@@ -24,7 +24,7 @@ type Peer struct {
 	RemoteHost string `validate:"required_with=RemotePort,omitempty,fqdn|ip"`
 	RemotePort uint   `validate:"required_with=RemoteHost,omitempty,max=65535"`
 
-	Congestion string `validate:"oneof=NewReno None"`
+	Congestion string `validate:"required_unless=Method TCP,omitempty,oneof=NewReno None"`
 
 	KeepAlive uint
 	Timeout   uint

proxy/packet_test.go

@@ -30,7 +30,7 @@ func TestUnmarshalPacket(t *testing.T) {
 		require.Nil(t, err)
 		assert.Len(t, p.Contents(), len(testContent))
 	})
-	
+
 	t.Run("Contents", func(t *testing.T) {
 		p, err := UnmarshalSimplePacket(testMarshalled)
 

udp/congestion/newreno.go

@@ -17,8 +17,8 @@ type NewReno struct {
 	keepalive chan bool
 
 	outboundTimes, inboundTimes map[uint32]time.Time
-	outboundTimesLock sync.Mutex
+	outboundTimesLock           sync.Mutex
-	inboundTimesLock sync.RWMutex
+	inboundTimesLock            sync.RWMutex
 
 	ack, lastAck   uint32
 	nack, lastNack uint32
@@ -34,7 +34,7 @@ type NewReno struct {
 	lastSent time.Time
 	hasAcked bool
 
-	acksToSend utils.Uint32Heap
+	acksToSend     utils.Uint32Heap
 	acksToSendLock sync.Mutex
 }
 

udp/packet_test.go

@@ -33,7 +33,7 @@ func TestUnmarshalPacket(t *testing.T) {
 		data: proxy.NewSimplePacket(testContent),
 	}
 	testMarshalled := testPacket.Marshal()
-	
+
 	t.Run("Length", func(t *testing.T) {
 		p, err := UnmarshalPacket(testMarshalled)
 
@@ -47,7 +47,7 @@ func TestUnmarshalPacket(t *testing.T) {
 		require.Nil(t, err)
 		assert.Equal(t, p.Contents(), testContent)
 	})
-	
+
 	t.Run("Header", func(t *testing.T) {
 		p, err := UnmarshalPacket(testMarshalled)
 		require.Nil(t, err)