🪄 all: go fmt ./... && go fix ./...

Author: database64128

cache/cache.go

@@ -158,7 +158,8 @@ func (c *BoundedCache[K, V]) insert(key K, value V) {
 
 	node := &boundedNode[K, V]{
 		prev:  c.tail,
-		Entry: Entry[K, V]{Key: key, Value: value},
+		Key:   key,
+		Value: value,
 	}
 
 	c.nodeByKey[key] = node

dns/dns.go

@@ -250,10 +250,8 @@ func (r *Resolver) sendQueries(ctx context.Context, nameString string, result *r
 	qBuf := make([]byte, 2+512+2+512)
 
 	q4 := dnsmessage.Message{
-		Header: dnsmessage.Header{
-			ID:               4,
-			RecursionDesired: true,
-		},
+		ID:               4,
+		RecursionDesired: true,
 		Questions: []dnsmessage.Question{
 			{
 				Name:  name,
@@ -275,10 +273,8 @@ func (r *Resolver) sendQueries(ctx context.Context, nameString string, result *r
 	q4PktEnd := 2 + len(q4Pkt)
 
 	q6 := dnsmessage.Message{
-		Header: dnsmessage.Header{
-			ID:               6,
-			RecursionDesired: true,
-		},
+		ID:               6,
+		RecursionDesired: true,
 		Questions: []dnsmessage.Question{
 			{
 				Name:  name,

netio/pipe.go

@@ -149,24 +149,24 @@ func NewPipe() (pl, pr *PipeConn) {
 	oe2 := newOnceError()
 
 	return &PipeConn{
-			rdRx: cb1, rdTx: cn1,
-			wrTx: cb2, wrRx: cn2,
-			localDone: done1, remoteDone: done2,
-			closeLocalDone: closeDone1, closeRemoteDone: closeDone2,
-			readError:     oe1,
-			writeError:    oe2,
-			readDeadline:  makePipeDeadline(),
-			writeDeadline: makePipeDeadline(),
-		}, &PipeConn{
-			rdRx: cb2, rdTx: cn2,
-			wrTx: cb1, wrRx: cn1,
-			localDone: done2, remoteDone: done1,
-			closeLocalDone: closeDone2, closeRemoteDone: closeDone1,
-			readError:     oe2,
-			writeError:    oe1,
-			readDeadline:  makePipeDeadline(),
-			writeDeadline: makePipeDeadline(),
-		}
+		rdRx: cb1, rdTx: cn1,
+		wrTx: cb2, wrRx: cn2,
+		localDone: done1, remoteDone: done2,
+		closeLocalDone: closeDone1, closeRemoteDone: closeDone2,
+		readError:     oe1,
+		writeError:    oe2,
+		readDeadline:  makePipeDeadline(),
+		writeDeadline: makePipeDeadline(),
+	}, &PipeConn{
+		rdRx: cb2, rdTx: cn2,
+		wrTx: cb1, wrRx: cn1,
+		localDone: done2, remoteDone: done1,
+		closeLocalDone: closeDone2, closeRemoteDone: closeDone1,
+		readError:     oe2,
+		writeError:    oe1,
+		readDeadline:  makePipeDeadline(),
+		writeDeadline: makePipeDeadline(),
+	}
 }
 
 // LocalAddr implements [Conn.LocalAddr].

probe/udp.go

@@ -75,10 +75,8 @@ func (p UDPProbe) Probe(ctx context.Context, client zerocopy.UDPClient) error {
 
 	const rrTypeHTTPS = 65
 	msg := dnsmessage.Message{
-		Header: dnsmessage.Header{
-			ID:               uint16(rand.Uint64()),
-			RecursionDesired: true,
-		},
+		ID:               uint16(rand.Uint64()),
+		RecursionDesired: true,
 		Questions: []dnsmessage.Question{
 			{
 				Name:  name,

ss2022/crypto.go

@@ -153,9 +153,7 @@ func clientPSKHashes(iPSKs [][]byte, psk []byte) [][IdentityHeaderLength]byte {
 // NewClientCipherConfig returns a new ClientCipherConfig.
 func NewClientCipherConfig(psk []byte, iPSKs [][]byte, enableUDP bool) (c *ClientCipherConfig, err error) {
 	c = &ClientCipherConfig{
-		UserCipherConfig: UserCipherConfig{
-			PSK: psk,
-		},
+		PSK:          psk,
 		iPSKs:        iPSKs,
 		eihPSKHashes: clientPSKHashes(iPSKs, psk),
 	}

ss2022/tcp.go

@@ -176,11 +176,9 @@ func (c *StreamClient) DialStream(ctx context.Context, targetAddr conn.Addr, pay
 	}
 
 	clientConn = &ShadowStreamClientConn{
-		ShadowStreamConn: ShadowStreamConn{
-			Conn:        innerConn,
-			writeBuf:    writeBuf,
-			writeCipher: shadowStreamCipher,
-		},
+		Conn:                       innerConn,
+		writeBuf:                   writeBuf,
+		writeCipher:                shadowStreamCipher,
 		readOnceOrFull:             c.readOnceOrFull,
 		unsafeResponseStreamPrefix: c.unsafeResponseStreamPrefix,
 		cipherConfig:               c.cipherConfig,
@@ -413,11 +411,9 @@ func (s *StreamServer) HandleStream(rawRW netio.Conn, logger *zap.Logger) (req n
 	}
 
 	req.PendingConn = netio.NopPendingConn(&ShadowStreamServerConn{
-		ShadowStreamConn: ShadowStreamConn{
-			Conn:       rawRW,
-			readCipher: shadowStreamCipher,
-			writeBuf:   writeBuf,
-		},
+		Conn:                       rawRW,
+		readCipher:                 shadowStreamCipher,
+		writeBuf:                   writeBuf,
 		unsafeResponseStreamPrefix: s.unsafeResponseStreamPrefix,
 		cipherConfig:               userCipherConfig,
 		requestSalt:                extendedSalt,