Merge pull request #84 from blinklabs-io/fix/query-root-domain

fix: store on-chain domain using canonical name

Author: agaffney

internal/dns/dns.go

@@ -292,6 +292,8 @@ func findNameserversForDomain(
 	// Check on-chain domains first
 	for startLabelIdx := 0; startLabelIdx < len(queryLabels); startLabelIdx++ {
 		lookupDomainName := strings.Join(queryLabels[startLabelIdx:], ".")
+		// Convert to canonical form for consistency
+		lookupDomainName = dns.CanonicalName(lookupDomainName)
 		nameservers, err := state.GetState().LookupDomain(lookupDomainName)
 		if err != nil {
 			return "", nil, err

internal/indexer/indexer.go

@@ -23,6 +23,7 @@ import (
 	input_chainsync "github.com/blinklabs-io/snek/input/chainsync"
 	output_embedded "github.com/blinklabs-io/snek/output/embedded"
 	"github.com/blinklabs-io/snek/pipeline"
+	"github.com/miekg/dns"
 )
 
 type Domain struct {
@@ -169,6 +170,8 @@ func (i *Indexer) handleEvent(evt event.Event) error {
 				continue
 			}
 			domainName := string(dnsDomain.Origin)
+			// Convert to canonical form for consistency
+			domainName = dns.CanonicalName(domainName)
 			nameServers := map[string]string{}
 			for _, record := range dnsDomain.Records {
 				// NOTE: we're losing information here, but we need to revamp the storage