client_log.go 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. package dns
  2. import (
  3. "context"
  4. "strings"
  5. "github.com/sagernet/sing/common/logger"
  6. "github.com/miekg/dns"
  7. )
  8. func logCachedResponse(logger logger.ContextLogger, ctx context.Context, response *dns.Msg, ttl int) {
  9. if logger == nil || len(response.Question) == 0 {
  10. return
  11. }
  12. domain := FqdnToDomain(response.Question[0].Name)
  13. logger.DebugContext(ctx, "cached ", domain, " ", dns.RcodeToString[response.Rcode], " ", ttl)
  14. for _, recordList := range [][]dns.RR{response.Answer, response.Ns, response.Extra} {
  15. for _, record := range recordList {
  16. logger.InfoContext(ctx, "cached ", dns.Type(record.Header().Rrtype).String(), " ", FormatQuestion(record.String()))
  17. }
  18. }
  19. }
  20. func logExchangedResponse(logger logger.ContextLogger, ctx context.Context, response *dns.Msg, ttl uint32) {
  21. if logger == nil || len(response.Question) == 0 {
  22. return
  23. }
  24. domain := FqdnToDomain(response.Question[0].Name)
  25. logger.DebugContext(ctx, "exchanged ", domain, " ", dns.RcodeToString[response.Rcode], " ", ttl)
  26. for _, recordList := range [][]dns.RR{response.Answer, response.Ns, response.Extra} {
  27. for _, record := range recordList {
  28. logger.InfoContext(ctx, "exchanged ", dns.Type(record.Header().Rrtype).String(), " ", FormatQuestion(record.String()))
  29. }
  30. }
  31. }
  32. func logRejectedResponse(logger logger.ContextLogger, ctx context.Context, response *dns.Msg) {
  33. if logger == nil || len(response.Question) == 0 {
  34. return
  35. }
  36. for _, recordList := range [][]dns.RR{response.Answer, response.Ns, response.Extra} {
  37. for _, record := range recordList {
  38. logger.InfoContext(ctx, "rejected ", dns.Type(record.Header().Rrtype).String(), " ", FormatQuestion(record.String()))
  39. }
  40. }
  41. }
  42. func FqdnToDomain(fqdn string) string {
  43. if dns.IsFqdn(fqdn) {
  44. return fqdn[:len(fqdn)-1]
  45. }
  46. return fqdn
  47. }
  48. func FormatQuestion(string string) string {
  49. for strings.HasPrefix(string, ";") {
  50. string = string[1:]
  51. }
  52. string = strings.ReplaceAll(string, "\t", " ")
  53. string = strings.ReplaceAll(string, "\n", " ")
  54. string = strings.ReplaceAll(string, ";; ", " ")
  55. string = strings.ReplaceAll(string, "; ", " ")
  56. for strings.Contains(string, " ") {
  57. string = strings.ReplaceAll(string, " ", " ")
  58. }
  59. return strings.TrimSpace(string)
  60. }