.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:
@@ -47,4 +53,10 @@ steps:
 
 volumes:
   - name: cache
-    temp: {}
+    temp: { }
+
+---
+kind: signature
+hmac: 8c21312bcfbaa9b7d2d3c31b1a5c13b54b4ecd1da853aa66a8ed11d72154fcca
+
+...

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 != "" {

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)