fix(dns,auth): handle TypeANY DNS queries and support dynamic peer IPv6 updates

- Return both A and AAAA records for TypeANY DNS queries in awldns
- Allow updating peer.IPAddrV6 when a peer announces a changed IPv6 address in auth_status
- Trigger ensureIPv6AddressLocked in SetIdentity to prevent unassigned IPv6 prefix on fresh node configs
- Revert unintended comment formatting in test_suite_test.go

Author: NNdroid

awldns/awldns.go

@@ -222,7 +222,7 @@ func (r *Resolver) dnsLocalDomainHandler(resp dns.ResponseWriter, req *dns.Msg)
 		mappedIPv6, foundV6 := cfg.directMappingV6[hostnameLower]
 
 		switch qtype {
-		case dns.TypeA, dns.TypeANY:
+		case dns.TypeA:
 			if !found {
 				if foundV6 {
 					continue // domain exists but no A record, return NOERROR with 0 answers (NODATA)
@@ -261,6 +261,37 @@ func (r *Resolver) dnsLocalDomainHandler(resp dns.ResponseWriter, req *dns.Msg)
 					AAAA: ip,
 				})
 			}
+		case dns.TypeANY:
+			if !found && !foundV6 {
+				m.SetRcode(req, dns.RcodeNameError)
+				continue
+			}
+			if found {
+				if ip := net.ParseIP(mappedIP).To4(); ip != nil {
+					m.Answer = append(m.Answer, &dns.A{
+						Hdr: dns.RR_Header{
+							Name:   hostname,
+							Rrtype: dns.TypeA,
+							Class:  dns.ClassINET,
+							Ttl:    defaultTTLSeconds,
+						},
+						A: ip,
+					})
+				}
+			}
+			if foundV6 {
+				if ip := net.ParseIP(mappedIPv6).To16(); ip != nil {
+					m.Answer = append(m.Answer, &dns.AAAA{
+						Hdr: dns.RR_Header{
+							Name:   hostname,
+							Rrtype: dns.TypeAAAA,
+							Class:  dns.ClassINET,
+							Ttl:    defaultTTLSeconds,
+						},
+						AAAA: ip,
+					})
+				}
+			}
 		}
 	}
 

test_suite_test.go

@@ -53,8 +53,8 @@ type TestSuite struct {
 
 func NewTestSuite(t testing.TB) *TestSuite {
 	// Snapshot goroutine state before anything starts. Because t.Cleanup is LIFO,
-	// registering here means this check runs last   ?after all peers and bootstrap
-	// nodes have been closed   ?so it reliably detects goroutine leaks.
+	// registering here means this check runs last — after all peers and bootstrap
+	// nodes have been closed — so it reliably detects goroutine leaks.
 	//
 	// libp2p.NATPortMap() spawns a short-lived UPnP SSDP discovery goroutine
 	// (koron/go-ssdp.Search) with a 5-second timeout. It exits on its own and
@@ -312,7 +312,7 @@ func (ts *TestSuite) makeFriends(peer1, peer2 TestPeer) {
 
 // makeFriendsWithAliases is the same as makeFriends but lets the caller pick
 // the per-side aliases. Tests that wire up more than two peers per Application
-// need distinct aliases   ?awl rejects duplicate names.
+// need distinct aliases — awl rejects duplicate names.
 func (ts *TestSuite) makeFriendsWithAliases(peer1, peer2 TestPeer, alias1, alias2 string) {
 	ts.ensurePeersAvailableInDHT(peer1, peer2)
 	ts.sendAndAcceptFriendRequest(peer1, peer2, alias1, alias2)

vpn/vpn.go

@@ -79,31 +79,6 @@ func (d *Device) PutTempPacket(data *Packet) {
 	d.packetsPool.Put(data)
 }
 
-func (d *Device) WritePacket(data *Packet, senderIP net.IP) error {
-	if data.IsIPv6 {
-		if d.localIP6 == nil {
-			// IPv6 not configured on this device — drop silently.
-			return nil
-		}
-		copy(data.Src, senderIP)
-		copy(data.Dst, d.localIP6)
-	} else {
-		copy(data.Src, senderIP)
-		copy(data.Dst, d.localIP)
-	}
-	data.RecalculateChecksum()
-
-	bufs := [][]byte{data.Buf()}
-	packetsCount, err := d.tun.Write(bufs, tunPacketOffset)
-	if err != nil {
-		return fmt.Errorf("write packet to tun: %v", err)
-	} else if packetsCount < len(bufs) {
-		d.logger.Warnf("wrote %d packets, len(bufs): %d", packetsCount, len(bufs))
-	}
-
-	return nil
-}
-
 // LocalIP returns the awl IPv4 address assigned to this device. Set once in NewDevice.
 func (d *Device) LocalIP() net.IP {
 	return d.localIP