message.go 49 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993
  1. // Copyright 2009 The Go Authors. All rights reserved.
  2. // Use of this source code is governed by a BSD-style
  3. // license that can be found in the LICENSE file.
  4. // Package dnsmessage provides a mostly RFC 1035 compliant implementation of
  5. // DNS message packing and unpacking.
  6. //
  7. // This implementation is designed to minimize heap allocations and avoid
  8. // unnecessary packing and unpacking as much as possible.
  9. package dnsmessage
  10. import (
  11. "errors"
  12. )
  13. // Packet formats
  14. // A Type is a type of DNS request and response.
  15. type Type uint16
  16. // A Class is a type of network.
  17. type Class uint16
  18. // An OpCode is a DNS operation code.
  19. type OpCode uint16
  20. // An RCode is a DNS response status code.
  21. type RCode uint16
  22. // Wire constants.
  23. const (
  24. // ResourceHeader.Type and Question.Type
  25. TypeA Type = 1
  26. TypeNS Type = 2
  27. TypeCNAME Type = 5
  28. TypeSOA Type = 6
  29. TypePTR Type = 12
  30. TypeMX Type = 15
  31. TypeTXT Type = 16
  32. TypeAAAA Type = 28
  33. TypeSRV Type = 33
  34. // Question.Type
  35. TypeWKS Type = 11
  36. TypeHINFO Type = 13
  37. TypeMINFO Type = 14
  38. TypeAXFR Type = 252
  39. TypeALL Type = 255
  40. // ResourceHeader.Class and Question.Class
  41. ClassINET Class = 1
  42. ClassCSNET Class = 2
  43. ClassCHAOS Class = 3
  44. ClassHESIOD Class = 4
  45. // Question.Class
  46. ClassANY Class = 255
  47. // Message.Rcode
  48. RCodeSuccess RCode = 0
  49. RCodeFormatError RCode = 1
  50. RCodeServerFailure RCode = 2
  51. RCodeNameError RCode = 3
  52. RCodeNotImplemented RCode = 4
  53. RCodeRefused RCode = 5
  54. )
  55. var (
  56. // ErrNotStarted indicates that the prerequisite information isn't
  57. // available yet because the previous records haven't been appropriately
  58. // parsed, skipped or finished.
  59. ErrNotStarted = errors.New("parsing/packing of this type isn't available yet")
  60. // ErrSectionDone indicated that all records in the section have been
  61. // parsed or finished.
  62. ErrSectionDone = errors.New("parsing/packing of this section has completed")
  63. errBaseLen = errors.New("insufficient data for base length type")
  64. errCalcLen = errors.New("insufficient data for calculated length type")
  65. errReserved = errors.New("segment prefix is reserved")
  66. errTooManyPtr = errors.New("too many pointers (>10)")
  67. errInvalidPtr = errors.New("invalid pointer")
  68. errResourceLen = errors.New("insufficient data for resource body length")
  69. errSegTooLong = errors.New("segment length too long")
  70. errZeroSegLen = errors.New("zero length segment")
  71. errResTooLong = errors.New("resource length too long")
  72. errTooManyQuestions = errors.New("too many Questions to pack (>65535)")
  73. errTooManyAnswers = errors.New("too many Answers to pack (>65535)")
  74. errTooManyAuthorities = errors.New("too many Authorities to pack (>65535)")
  75. errTooManyAdditionals = errors.New("too many Additionals to pack (>65535)")
  76. errNonCanonicalName = errors.New("name is not in canonical format (it must end with a .)")
  77. )
  78. // Internal constants.
  79. const (
  80. // packStartingCap is the default initial buffer size allocated during
  81. // packing.
  82. //
  83. // The starting capacity doesn't matter too much, but most DNS responses
  84. // Will be <= 512 bytes as it is the limit for DNS over UDP.
  85. packStartingCap = 512
  86. // uint16Len is the length (in bytes) of a uint16.
  87. uint16Len = 2
  88. // uint32Len is the length (in bytes) of a uint32.
  89. uint32Len = 4
  90. // headerLen is the length (in bytes) of a DNS header.
  91. //
  92. // A header is comprised of 6 uint16s and no padding.
  93. headerLen = 6 * uint16Len
  94. )
  95. type nestedError struct {
  96. // s is the current level's error message.
  97. s string
  98. // err is the nested error.
  99. err error
  100. }
  101. // nestedError implements error.Error.
  102. func (e *nestedError) Error() string {
  103. return e.s + ": " + e.err.Error()
  104. }
  105. // Header is a representation of a DNS message header.
  106. type Header struct {
  107. ID uint16
  108. Response bool
  109. OpCode OpCode
  110. Authoritative bool
  111. Truncated bool
  112. RecursionDesired bool
  113. RecursionAvailable bool
  114. RCode RCode
  115. }
  116. func (m *Header) pack() (id uint16, bits uint16) {
  117. id = m.ID
  118. bits = uint16(m.OpCode)<<11 | uint16(m.RCode)
  119. if m.RecursionAvailable {
  120. bits |= headerBitRA
  121. }
  122. if m.RecursionDesired {
  123. bits |= headerBitRD
  124. }
  125. if m.Truncated {
  126. bits |= headerBitTC
  127. }
  128. if m.Authoritative {
  129. bits |= headerBitAA
  130. }
  131. if m.Response {
  132. bits |= headerBitQR
  133. }
  134. return
  135. }
  136. // Message is a representation of a DNS message.
  137. type Message struct {
  138. Header
  139. Questions []Question
  140. Answers []Resource
  141. Authorities []Resource
  142. Additionals []Resource
  143. }
  144. type section uint8
  145. const (
  146. sectionNotStarted section = iota
  147. sectionHeader
  148. sectionQuestions
  149. sectionAnswers
  150. sectionAuthorities
  151. sectionAdditionals
  152. sectionDone
  153. headerBitQR = 1 << 15 // query/response (response=1)
  154. headerBitAA = 1 << 10 // authoritative
  155. headerBitTC = 1 << 9 // truncated
  156. headerBitRD = 1 << 8 // recursion desired
  157. headerBitRA = 1 << 7 // recursion available
  158. )
  159. var sectionNames = map[section]string{
  160. sectionHeader: "header",
  161. sectionQuestions: "Question",
  162. sectionAnswers: "Answer",
  163. sectionAuthorities: "Authority",
  164. sectionAdditionals: "Additional",
  165. }
  166. // header is the wire format for a DNS message header.
  167. type header struct {
  168. id uint16
  169. bits uint16
  170. questions uint16
  171. answers uint16
  172. authorities uint16
  173. additionals uint16
  174. }
  175. func (h *header) count(sec section) uint16 {
  176. switch sec {
  177. case sectionQuestions:
  178. return h.questions
  179. case sectionAnswers:
  180. return h.answers
  181. case sectionAuthorities:
  182. return h.authorities
  183. case sectionAdditionals:
  184. return h.additionals
  185. }
  186. return 0
  187. }
  188. func (h *header) pack(msg []byte) []byte {
  189. msg = packUint16(msg, h.id)
  190. msg = packUint16(msg, h.bits)
  191. msg = packUint16(msg, h.questions)
  192. msg = packUint16(msg, h.answers)
  193. msg = packUint16(msg, h.authorities)
  194. return packUint16(msg, h.additionals)
  195. }
  196. func (h *header) unpack(msg []byte, off int) (int, error) {
  197. newOff := off
  198. var err error
  199. if h.id, newOff, err = unpackUint16(msg, newOff); err != nil {
  200. return off, &nestedError{"id", err}
  201. }
  202. if h.bits, newOff, err = unpackUint16(msg, newOff); err != nil {
  203. return off, &nestedError{"bits", err}
  204. }
  205. if h.questions, newOff, err = unpackUint16(msg, newOff); err != nil {
  206. return off, &nestedError{"questions", err}
  207. }
  208. if h.answers, newOff, err = unpackUint16(msg, newOff); err != nil {
  209. return off, &nestedError{"answers", err}
  210. }
  211. if h.authorities, newOff, err = unpackUint16(msg, newOff); err != nil {
  212. return off, &nestedError{"authorities", err}
  213. }
  214. if h.additionals, newOff, err = unpackUint16(msg, newOff); err != nil {
  215. return off, &nestedError{"additionals", err}
  216. }
  217. return newOff, nil
  218. }
  219. func (h *header) header() Header {
  220. return Header{
  221. ID: h.id,
  222. Response: (h.bits & headerBitQR) != 0,
  223. OpCode: OpCode(h.bits>>11) & 0xF,
  224. Authoritative: (h.bits & headerBitAA) != 0,
  225. Truncated: (h.bits & headerBitTC) != 0,
  226. RecursionDesired: (h.bits & headerBitRD) != 0,
  227. RecursionAvailable: (h.bits & headerBitRA) != 0,
  228. RCode: RCode(h.bits & 0xF),
  229. }
  230. }
  231. // A Resource is a DNS resource record.
  232. type Resource struct {
  233. Header ResourceHeader
  234. Body ResourceBody
  235. }
  236. // A ResourceBody is a DNS resource record minus the header.
  237. type ResourceBody interface {
  238. // pack packs a Resource except for its header.
  239. pack(msg []byte, compression map[string]int) ([]byte, error)
  240. // realType returns the actual type of the Resource. This is used to
  241. // fill in the header Type field.
  242. realType() Type
  243. }
  244. func (r *Resource) pack(msg []byte, compression map[string]int) ([]byte, error) {
  245. oldMsg := msg
  246. r.Header.Type = r.Body.realType()
  247. msg, length, err := r.Header.pack(msg, compression)
  248. if err != nil {
  249. return msg, &nestedError{"ResourceHeader", err}
  250. }
  251. preLen := len(msg)
  252. msg, err = r.Body.pack(msg, compression)
  253. if err != nil {
  254. return msg, &nestedError{"content", err}
  255. }
  256. if err := r.Header.fixLen(msg, length, preLen); err != nil {
  257. return oldMsg, err
  258. }
  259. return msg, nil
  260. }
  261. // A Parser allows incrementally parsing a DNS message.
  262. //
  263. // When parsing is started, the Header is parsed. Next, each Question can be
  264. // either parsed or skipped. Alternatively, all Questions can be skipped at
  265. // once. When all Questions have been parsed, attempting to parse Questions
  266. // will return (nil, nil) and attempting to skip Questions will return
  267. // (true, nil). After all Questions have been either parsed or skipped, all
  268. // Answers, Authorities and Additionals can be either parsed or skipped in the
  269. // same way, and each type of Resource must be fully parsed or skipped before
  270. // proceeding to the next type of Resource.
  271. //
  272. // Note that there is no requirement to fully skip or parse the message.
  273. type Parser struct {
  274. msg []byte
  275. header header
  276. section section
  277. off int
  278. index int
  279. resHeaderValid bool
  280. resHeader ResourceHeader
  281. }
  282. // Start parses the header and enables the parsing of Questions.
  283. func (p *Parser) Start(msg []byte) (Header, error) {
  284. if p.msg != nil {
  285. *p = Parser{}
  286. }
  287. p.msg = msg
  288. var err error
  289. if p.off, err = p.header.unpack(msg, 0); err != nil {
  290. return Header{}, &nestedError{"unpacking header", err}
  291. }
  292. p.section = sectionQuestions
  293. return p.header.header(), nil
  294. }
  295. func (p *Parser) checkAdvance(sec section) error {
  296. if p.section < sec {
  297. return ErrNotStarted
  298. }
  299. if p.section > sec {
  300. return ErrSectionDone
  301. }
  302. p.resHeaderValid = false
  303. if p.index == int(p.header.count(sec)) {
  304. p.index = 0
  305. p.section++
  306. return ErrSectionDone
  307. }
  308. return nil
  309. }
  310. func (p *Parser) resource(sec section) (Resource, error) {
  311. var r Resource
  312. var err error
  313. r.Header, err = p.resourceHeader(sec)
  314. if err != nil {
  315. return r, err
  316. }
  317. p.resHeaderValid = false
  318. r.Body, p.off, err = unpackResourceBody(p.msg, p.off, r.Header)
  319. if err != nil {
  320. return Resource{}, &nestedError{"unpacking " + sectionNames[sec], err}
  321. }
  322. p.index++
  323. return r, nil
  324. }
  325. func (p *Parser) resourceHeader(sec section) (ResourceHeader, error) {
  326. if p.resHeaderValid {
  327. return p.resHeader, nil
  328. }
  329. if err := p.checkAdvance(sec); err != nil {
  330. return ResourceHeader{}, err
  331. }
  332. var hdr ResourceHeader
  333. off, err := hdr.unpack(p.msg, p.off)
  334. if err != nil {
  335. return ResourceHeader{}, err
  336. }
  337. p.resHeaderValid = true
  338. p.resHeader = hdr
  339. p.off = off
  340. return hdr, nil
  341. }
  342. func (p *Parser) skipResource(sec section) error {
  343. if p.resHeaderValid {
  344. newOff := p.off + int(p.resHeader.Length)
  345. if newOff > len(p.msg) {
  346. return errResourceLen
  347. }
  348. p.off = newOff
  349. p.resHeaderValid = false
  350. p.index++
  351. return nil
  352. }
  353. if err := p.checkAdvance(sec); err != nil {
  354. return err
  355. }
  356. var err error
  357. p.off, err = skipResource(p.msg, p.off)
  358. if err != nil {
  359. return &nestedError{"skipping: " + sectionNames[sec], err}
  360. }
  361. p.index++
  362. return nil
  363. }
  364. // Question parses a single Question.
  365. func (p *Parser) Question() (Question, error) {
  366. if err := p.checkAdvance(sectionQuestions); err != nil {
  367. return Question{}, err
  368. }
  369. var name Name
  370. off, err := name.unpack(p.msg, p.off)
  371. if err != nil {
  372. return Question{}, &nestedError{"unpacking Question.Name", err}
  373. }
  374. typ, off, err := unpackType(p.msg, off)
  375. if err != nil {
  376. return Question{}, &nestedError{"unpacking Question.Type", err}
  377. }
  378. class, off, err := unpackClass(p.msg, off)
  379. if err != nil {
  380. return Question{}, &nestedError{"unpacking Question.Class", err}
  381. }
  382. p.off = off
  383. p.index++
  384. return Question{name, typ, class}, nil
  385. }
  386. // AllQuestions parses all Questions.
  387. func (p *Parser) AllQuestions() ([]Question, error) {
  388. qs := make([]Question, 0, p.header.questions)
  389. for {
  390. q, err := p.Question()
  391. if err == ErrSectionDone {
  392. return qs, nil
  393. }
  394. if err != nil {
  395. return nil, err
  396. }
  397. qs = append(qs, q)
  398. }
  399. }
  400. // SkipQuestion skips a single Question.
  401. func (p *Parser) SkipQuestion() error {
  402. if err := p.checkAdvance(sectionQuestions); err != nil {
  403. return err
  404. }
  405. off, err := skipName(p.msg, p.off)
  406. if err != nil {
  407. return &nestedError{"skipping Question Name", err}
  408. }
  409. if off, err = skipType(p.msg, off); err != nil {
  410. return &nestedError{"skipping Question Type", err}
  411. }
  412. if off, err = skipClass(p.msg, off); err != nil {
  413. return &nestedError{"skipping Question Class", err}
  414. }
  415. p.off = off
  416. p.index++
  417. return nil
  418. }
  419. // SkipAllQuestions skips all Questions.
  420. func (p *Parser) SkipAllQuestions() error {
  421. for {
  422. if err := p.SkipQuestion(); err == ErrSectionDone {
  423. return nil
  424. } else if err != nil {
  425. return err
  426. }
  427. }
  428. }
  429. // AnswerHeader parses a single Answer ResourceHeader.
  430. func (p *Parser) AnswerHeader() (ResourceHeader, error) {
  431. return p.resourceHeader(sectionAnswers)
  432. }
  433. // Answer parses a single Answer Resource.
  434. func (p *Parser) Answer() (Resource, error) {
  435. return p.resource(sectionAnswers)
  436. }
  437. // AllAnswers parses all Answer Resources.
  438. func (p *Parser) AllAnswers() ([]Resource, error) {
  439. as := make([]Resource, 0, p.header.answers)
  440. for {
  441. a, err := p.Answer()
  442. if err == ErrSectionDone {
  443. return as, nil
  444. }
  445. if err != nil {
  446. return nil, err
  447. }
  448. as = append(as, a)
  449. }
  450. }
  451. // SkipAnswer skips a single Answer Resource.
  452. func (p *Parser) SkipAnswer() error {
  453. return p.skipResource(sectionAnswers)
  454. }
  455. // SkipAllAnswers skips all Answer Resources.
  456. func (p *Parser) SkipAllAnswers() error {
  457. for {
  458. if err := p.SkipAnswer(); err == ErrSectionDone {
  459. return nil
  460. } else if err != nil {
  461. return err
  462. }
  463. }
  464. }
  465. // AuthorityHeader parses a single Authority ResourceHeader.
  466. func (p *Parser) AuthorityHeader() (ResourceHeader, error) {
  467. return p.resourceHeader(sectionAuthorities)
  468. }
  469. // Authority parses a single Authority Resource.
  470. func (p *Parser) Authority() (Resource, error) {
  471. return p.resource(sectionAuthorities)
  472. }
  473. // AllAuthorities parses all Authority Resources.
  474. func (p *Parser) AllAuthorities() ([]Resource, error) {
  475. as := make([]Resource, 0, p.header.authorities)
  476. for {
  477. a, err := p.Authority()
  478. if err == ErrSectionDone {
  479. return as, nil
  480. }
  481. if err != nil {
  482. return nil, err
  483. }
  484. as = append(as, a)
  485. }
  486. }
  487. // SkipAuthority skips a single Authority Resource.
  488. func (p *Parser) SkipAuthority() error {
  489. return p.skipResource(sectionAuthorities)
  490. }
  491. // SkipAllAuthorities skips all Authority Resources.
  492. func (p *Parser) SkipAllAuthorities() error {
  493. for {
  494. if err := p.SkipAuthority(); err == ErrSectionDone {
  495. return nil
  496. } else if err != nil {
  497. return err
  498. }
  499. }
  500. }
  501. // AdditionalHeader parses a single Additional ResourceHeader.
  502. func (p *Parser) AdditionalHeader() (ResourceHeader, error) {
  503. return p.resourceHeader(sectionAdditionals)
  504. }
  505. // Additional parses a single Additional Resource.
  506. func (p *Parser) Additional() (Resource, error) {
  507. return p.resource(sectionAdditionals)
  508. }
  509. // AllAdditionals parses all Additional Resources.
  510. func (p *Parser) AllAdditionals() ([]Resource, error) {
  511. as := make([]Resource, 0, p.header.additionals)
  512. for {
  513. a, err := p.Additional()
  514. if err == ErrSectionDone {
  515. return as, nil
  516. }
  517. if err != nil {
  518. return nil, err
  519. }
  520. as = append(as, a)
  521. }
  522. }
  523. // SkipAdditional skips a single Additional Resource.
  524. func (p *Parser) SkipAdditional() error {
  525. return p.skipResource(sectionAdditionals)
  526. }
  527. // SkipAllAdditionals skips all Additional Resources.
  528. func (p *Parser) SkipAllAdditionals() error {
  529. for {
  530. if err := p.SkipAdditional(); err == ErrSectionDone {
  531. return nil
  532. } else if err != nil {
  533. return err
  534. }
  535. }
  536. }
  537. // CNAMEResource parses a single CNAMEResource.
  538. //
  539. // One of the XXXHeader methods must have been called before calling this
  540. // method.
  541. func (p *Parser) CNAMEResource() (CNAMEResource, error) {
  542. if !p.resHeaderValid || p.resHeader.Type != TypeCNAME {
  543. return CNAMEResource{}, ErrNotStarted
  544. }
  545. r, err := unpackCNAMEResource(p.msg, p.off)
  546. if err != nil {
  547. return CNAMEResource{}, err
  548. }
  549. p.off += int(p.resHeader.Length)
  550. p.resHeaderValid = false
  551. p.index++
  552. return r, nil
  553. }
  554. // MXResource parses a single MXResource.
  555. //
  556. // One of the XXXHeader methods must have been called before calling this
  557. // method.
  558. func (p *Parser) MXResource() (MXResource, error) {
  559. if !p.resHeaderValid || p.resHeader.Type != TypeMX {
  560. return MXResource{}, ErrNotStarted
  561. }
  562. r, err := unpackMXResource(p.msg, p.off)
  563. if err != nil {
  564. return MXResource{}, err
  565. }
  566. p.off += int(p.resHeader.Length)
  567. p.resHeaderValid = false
  568. p.index++
  569. return r, nil
  570. }
  571. // NSResource parses a single NSResource.
  572. //
  573. // One of the XXXHeader methods must have been called before calling this
  574. // method.
  575. func (p *Parser) NSResource() (NSResource, error) {
  576. if !p.resHeaderValid || p.resHeader.Type != TypeNS {
  577. return NSResource{}, ErrNotStarted
  578. }
  579. r, err := unpackNSResource(p.msg, p.off)
  580. if err != nil {
  581. return NSResource{}, err
  582. }
  583. p.off += int(p.resHeader.Length)
  584. p.resHeaderValid = false
  585. p.index++
  586. return r, nil
  587. }
  588. // PTRResource parses a single PTRResource.
  589. //
  590. // One of the XXXHeader methods must have been called before calling this
  591. // method.
  592. func (p *Parser) PTRResource() (PTRResource, error) {
  593. if !p.resHeaderValid || p.resHeader.Type != TypePTR {
  594. return PTRResource{}, ErrNotStarted
  595. }
  596. r, err := unpackPTRResource(p.msg, p.off)
  597. if err != nil {
  598. return PTRResource{}, err
  599. }
  600. p.off += int(p.resHeader.Length)
  601. p.resHeaderValid = false
  602. p.index++
  603. return r, nil
  604. }
  605. // SOAResource parses a single SOAResource.
  606. //
  607. // One of the XXXHeader methods must have been called before calling this
  608. // method.
  609. func (p *Parser) SOAResource() (SOAResource, error) {
  610. if !p.resHeaderValid || p.resHeader.Type != TypeSOA {
  611. return SOAResource{}, ErrNotStarted
  612. }
  613. r, err := unpackSOAResource(p.msg, p.off)
  614. if err != nil {
  615. return SOAResource{}, err
  616. }
  617. p.off += int(p.resHeader.Length)
  618. p.resHeaderValid = false
  619. p.index++
  620. return r, nil
  621. }
  622. // TXTResource parses a single TXTResource.
  623. //
  624. // One of the XXXHeader methods must have been called before calling this
  625. // method.
  626. func (p *Parser) TXTResource() (TXTResource, error) {
  627. if !p.resHeaderValid || p.resHeader.Type != TypeTXT {
  628. return TXTResource{}, ErrNotStarted
  629. }
  630. r, err := unpackTXTResource(p.msg, p.off, p.resHeader.Length)
  631. if err != nil {
  632. return TXTResource{}, err
  633. }
  634. p.off += int(p.resHeader.Length)
  635. p.resHeaderValid = false
  636. p.index++
  637. return r, nil
  638. }
  639. // SRVResource parses a single SRVResource.
  640. //
  641. // One of the XXXHeader methods must have been called before calling this
  642. // method.
  643. func (p *Parser) SRVResource() (SRVResource, error) {
  644. if !p.resHeaderValid || p.resHeader.Type != TypeSRV {
  645. return SRVResource{}, ErrNotStarted
  646. }
  647. r, err := unpackSRVResource(p.msg, p.off)
  648. if err != nil {
  649. return SRVResource{}, err
  650. }
  651. p.off += int(p.resHeader.Length)
  652. p.resHeaderValid = false
  653. p.index++
  654. return r, nil
  655. }
  656. // AResource parses a single AResource.
  657. //
  658. // One of the XXXHeader methods must have been called before calling this
  659. // method.
  660. func (p *Parser) AResource() (AResource, error) {
  661. if !p.resHeaderValid || p.resHeader.Type != TypeA {
  662. return AResource{}, ErrNotStarted
  663. }
  664. r, err := unpackAResource(p.msg, p.off)
  665. if err != nil {
  666. return AResource{}, err
  667. }
  668. p.off += int(p.resHeader.Length)
  669. p.resHeaderValid = false
  670. p.index++
  671. return r, nil
  672. }
  673. // AAAAResource parses a single AAAAResource.
  674. //
  675. // One of the XXXHeader methods must have been called before calling this
  676. // method.
  677. func (p *Parser) AAAAResource() (AAAAResource, error) {
  678. if !p.resHeaderValid || p.resHeader.Type != TypeAAAA {
  679. return AAAAResource{}, ErrNotStarted
  680. }
  681. r, err := unpackAAAAResource(p.msg, p.off)
  682. if err != nil {
  683. return AAAAResource{}, err
  684. }
  685. p.off += int(p.resHeader.Length)
  686. p.resHeaderValid = false
  687. p.index++
  688. return r, nil
  689. }
  690. // Unpack parses a full Message.
  691. func (m *Message) Unpack(msg []byte) error {
  692. var p Parser
  693. var err error
  694. if m.Header, err = p.Start(msg); err != nil {
  695. return err
  696. }
  697. if m.Questions, err = p.AllQuestions(); err != nil {
  698. return err
  699. }
  700. if m.Answers, err = p.AllAnswers(); err != nil {
  701. return err
  702. }
  703. if m.Authorities, err = p.AllAuthorities(); err != nil {
  704. return err
  705. }
  706. if m.Additionals, err = p.AllAdditionals(); err != nil {
  707. return err
  708. }
  709. return nil
  710. }
  711. // Pack packs a full Message.
  712. func (m *Message) Pack() ([]byte, error) {
  713. // Validate the lengths. It is very unlikely that anyone will try to
  714. // pack more than 65535 of any particular type, but it is possible and
  715. // we should fail gracefully.
  716. if len(m.Questions) > int(^uint16(0)) {
  717. return nil, errTooManyQuestions
  718. }
  719. if len(m.Answers) > int(^uint16(0)) {
  720. return nil, errTooManyAnswers
  721. }
  722. if len(m.Authorities) > int(^uint16(0)) {
  723. return nil, errTooManyAuthorities
  724. }
  725. if len(m.Additionals) > int(^uint16(0)) {
  726. return nil, errTooManyAdditionals
  727. }
  728. var h header
  729. h.id, h.bits = m.Header.pack()
  730. h.questions = uint16(len(m.Questions))
  731. h.answers = uint16(len(m.Answers))
  732. h.authorities = uint16(len(m.Authorities))
  733. h.additionals = uint16(len(m.Additionals))
  734. msg := make([]byte, 0, packStartingCap)
  735. msg = h.pack(msg)
  736. // RFC 1035 allows (but does not require) compression for packing. RFC
  737. // 1035 requires unpacking implementations to support compression, so
  738. // unconditionally enabling it is fine.
  739. //
  740. // DNS lookups are typically done over UDP, and RFC 1035 states that UDP
  741. // DNS packets can be a maximum of 512 bytes long. Without compression,
  742. // many DNS response packets are over this limit, so enabling
  743. // compression will help ensure compliance.
  744. compression := map[string]int{}
  745. for i := range m.Questions {
  746. var err error
  747. if msg, err = m.Questions[i].pack(msg, compression); err != nil {
  748. return nil, &nestedError{"packing Question", err}
  749. }
  750. }
  751. for i := range m.Answers {
  752. var err error
  753. if msg, err = m.Answers[i].pack(msg, compression); err != nil {
  754. return nil, &nestedError{"packing Answer", err}
  755. }
  756. }
  757. for i := range m.Authorities {
  758. var err error
  759. if msg, err = m.Authorities[i].pack(msg, compression); err != nil {
  760. return nil, &nestedError{"packing Authority", err}
  761. }
  762. }
  763. for i := range m.Additionals {
  764. var err error
  765. if msg, err = m.Additionals[i].pack(msg, compression); err != nil {
  766. return nil, &nestedError{"packing Additional", err}
  767. }
  768. }
  769. return msg, nil
  770. }
  771. // A Builder allows incrementally packing a DNS message.
  772. type Builder struct {
  773. msg []byte
  774. header header
  775. section section
  776. compression map[string]int
  777. }
  778. // Start initializes the builder.
  779. //
  780. // buf is optional (nil is fine), but if provided, Start takes ownership of buf.
  781. func (b *Builder) Start(buf []byte, h Header) {
  782. b.StartWithoutCompression(buf, h)
  783. b.compression = map[string]int{}
  784. }
  785. // StartWithoutCompression initializes the builder with compression disabled.
  786. //
  787. // This avoids compression related allocations, but can result in larger message
  788. // sizes. Be careful with this mode as it can cause messages to exceed the UDP
  789. // size limit.
  790. //
  791. // buf is optional (nil is fine), but if provided, Start takes ownership of buf.
  792. func (b *Builder) StartWithoutCompression(buf []byte, h Header) {
  793. *b = Builder{msg: buf}
  794. b.header.id, b.header.bits = h.pack()
  795. if cap(b.msg) < headerLen {
  796. b.msg = make([]byte, 0, packStartingCap)
  797. }
  798. b.msg = b.msg[:headerLen]
  799. b.section = sectionHeader
  800. }
  801. func (b *Builder) startCheck(s section) error {
  802. if b.section <= sectionNotStarted {
  803. return ErrNotStarted
  804. }
  805. if b.section > s {
  806. return ErrSectionDone
  807. }
  808. return nil
  809. }
  810. // StartQuestions prepares the builder for packing Questions.
  811. func (b *Builder) StartQuestions() error {
  812. if err := b.startCheck(sectionQuestions); err != nil {
  813. return err
  814. }
  815. b.section = sectionQuestions
  816. return nil
  817. }
  818. // StartAnswers prepares the builder for packing Answers.
  819. func (b *Builder) StartAnswers() error {
  820. if err := b.startCheck(sectionAnswers); err != nil {
  821. return err
  822. }
  823. b.section = sectionAnswers
  824. return nil
  825. }
  826. // StartAuthorities prepares the builder for packing Authorities.
  827. func (b *Builder) StartAuthorities() error {
  828. if err := b.startCheck(sectionAuthorities); err != nil {
  829. return err
  830. }
  831. b.section = sectionAuthorities
  832. return nil
  833. }
  834. // StartAdditionals prepares the builder for packing Additionals.
  835. func (b *Builder) StartAdditionals() error {
  836. if err := b.startCheck(sectionAdditionals); err != nil {
  837. return err
  838. }
  839. b.section = sectionAdditionals
  840. return nil
  841. }
  842. func (b *Builder) incrementSectionCount() error {
  843. var count *uint16
  844. var err error
  845. switch b.section {
  846. case sectionQuestions:
  847. count = &b.header.questions
  848. err = errTooManyQuestions
  849. case sectionAnswers:
  850. count = &b.header.answers
  851. err = errTooManyAnswers
  852. case sectionAuthorities:
  853. count = &b.header.authorities
  854. err = errTooManyAuthorities
  855. case sectionAdditionals:
  856. count = &b.header.additionals
  857. err = errTooManyAdditionals
  858. }
  859. if *count == ^uint16(0) {
  860. return err
  861. }
  862. *count++
  863. return nil
  864. }
  865. // Question adds a single Question.
  866. func (b *Builder) Question(q Question) error {
  867. if b.section < sectionQuestions {
  868. return ErrNotStarted
  869. }
  870. if b.section > sectionQuestions {
  871. return ErrSectionDone
  872. }
  873. msg, err := q.pack(b.msg, b.compression)
  874. if err != nil {
  875. return err
  876. }
  877. if err := b.incrementSectionCount(); err != nil {
  878. return err
  879. }
  880. b.msg = msg
  881. return nil
  882. }
  883. func (b *Builder) checkResourceSection() error {
  884. if b.section < sectionAnswers {
  885. return ErrNotStarted
  886. }
  887. if b.section > sectionAdditionals {
  888. return ErrSectionDone
  889. }
  890. return nil
  891. }
  892. // CNAMEResource adds a single CNAMEResource.
  893. func (b *Builder) CNAMEResource(h ResourceHeader, r CNAMEResource) error {
  894. if err := b.checkResourceSection(); err != nil {
  895. return err
  896. }
  897. h.Type = r.realType()
  898. msg, length, err := h.pack(b.msg, b.compression)
  899. if err != nil {
  900. return &nestedError{"ResourceHeader", err}
  901. }
  902. preLen := len(msg)
  903. if msg, err = r.pack(msg, b.compression); err != nil {
  904. return &nestedError{"CNAMEResource body", err}
  905. }
  906. if err := h.fixLen(msg, length, preLen); err != nil {
  907. return err
  908. }
  909. if err := b.incrementSectionCount(); err != nil {
  910. return err
  911. }
  912. b.msg = msg
  913. return nil
  914. }
  915. // MXResource adds a single MXResource.
  916. func (b *Builder) MXResource(h ResourceHeader, r MXResource) error {
  917. if err := b.checkResourceSection(); err != nil {
  918. return err
  919. }
  920. h.Type = r.realType()
  921. msg, length, err := h.pack(b.msg, b.compression)
  922. if err != nil {
  923. return &nestedError{"ResourceHeader", err}
  924. }
  925. preLen := len(msg)
  926. if msg, err = r.pack(msg, b.compression); err != nil {
  927. return &nestedError{"MXResource body", err}
  928. }
  929. if err := h.fixLen(msg, length, preLen); err != nil {
  930. return err
  931. }
  932. if err := b.incrementSectionCount(); err != nil {
  933. return err
  934. }
  935. b.msg = msg
  936. return nil
  937. }
  938. // NSResource adds a single NSResource.
  939. func (b *Builder) NSResource(h ResourceHeader, r NSResource) error {
  940. if err := b.checkResourceSection(); err != nil {
  941. return err
  942. }
  943. h.Type = r.realType()
  944. msg, length, err := h.pack(b.msg, b.compression)
  945. if err != nil {
  946. return &nestedError{"ResourceHeader", err}
  947. }
  948. preLen := len(msg)
  949. if msg, err = r.pack(msg, b.compression); err != nil {
  950. return &nestedError{"NSResource body", err}
  951. }
  952. if err := h.fixLen(msg, length, preLen); err != nil {
  953. return err
  954. }
  955. if err := b.incrementSectionCount(); err != nil {
  956. return err
  957. }
  958. b.msg = msg
  959. return nil
  960. }
  961. // PTRResource adds a single PTRResource.
  962. func (b *Builder) PTRResource(h ResourceHeader, r PTRResource) error {
  963. if err := b.checkResourceSection(); err != nil {
  964. return err
  965. }
  966. h.Type = r.realType()
  967. msg, length, err := h.pack(b.msg, b.compression)
  968. if err != nil {
  969. return &nestedError{"ResourceHeader", err}
  970. }
  971. preLen := len(msg)
  972. if msg, err = r.pack(msg, b.compression); err != nil {
  973. return &nestedError{"PTRResource body", err}
  974. }
  975. if err := h.fixLen(msg, length, preLen); err != nil {
  976. return err
  977. }
  978. if err := b.incrementSectionCount(); err != nil {
  979. return err
  980. }
  981. b.msg = msg
  982. return nil
  983. }
  984. // SOAResource adds a single SOAResource.
  985. func (b *Builder) SOAResource(h ResourceHeader, r SOAResource) error {
  986. if err := b.checkResourceSection(); err != nil {
  987. return err
  988. }
  989. h.Type = r.realType()
  990. msg, length, err := h.pack(b.msg, b.compression)
  991. if err != nil {
  992. return &nestedError{"ResourceHeader", err}
  993. }
  994. preLen := len(msg)
  995. if msg, err = r.pack(msg, b.compression); err != nil {
  996. return &nestedError{"SOAResource body", err}
  997. }
  998. if err := h.fixLen(msg, length, preLen); err != nil {
  999. return err
  1000. }
  1001. if err := b.incrementSectionCount(); err != nil {
  1002. return err
  1003. }
  1004. b.msg = msg
  1005. return nil
  1006. }
  1007. // TXTResource adds a single TXTResource.
  1008. func (b *Builder) TXTResource(h ResourceHeader, r TXTResource) error {
  1009. if err := b.checkResourceSection(); err != nil {
  1010. return err
  1011. }
  1012. h.Type = r.realType()
  1013. msg, length, err := h.pack(b.msg, b.compression)
  1014. if err != nil {
  1015. return &nestedError{"ResourceHeader", err}
  1016. }
  1017. preLen := len(msg)
  1018. if msg, err = r.pack(msg, b.compression); err != nil {
  1019. return &nestedError{"TXTResource body", err}
  1020. }
  1021. if err := h.fixLen(msg, length, preLen); err != nil {
  1022. return err
  1023. }
  1024. if err := b.incrementSectionCount(); err != nil {
  1025. return err
  1026. }
  1027. b.msg = msg
  1028. return nil
  1029. }
  1030. // SRVResource adds a single SRVResource.
  1031. func (b *Builder) SRVResource(h ResourceHeader, r SRVResource) error {
  1032. if err := b.checkResourceSection(); err != nil {
  1033. return err
  1034. }
  1035. h.Type = r.realType()
  1036. msg, length, err := h.pack(b.msg, b.compression)
  1037. if err != nil {
  1038. return &nestedError{"ResourceHeader", err}
  1039. }
  1040. preLen := len(msg)
  1041. if msg, err = r.pack(msg, b.compression); err != nil {
  1042. return &nestedError{"SRVResource body", err}
  1043. }
  1044. if err := h.fixLen(msg, length, preLen); err != nil {
  1045. return err
  1046. }
  1047. if err := b.incrementSectionCount(); err != nil {
  1048. return err
  1049. }
  1050. b.msg = msg
  1051. return nil
  1052. }
  1053. // AResource adds a single AResource.
  1054. func (b *Builder) AResource(h ResourceHeader, r AResource) error {
  1055. if err := b.checkResourceSection(); err != nil {
  1056. return err
  1057. }
  1058. h.Type = r.realType()
  1059. msg, length, err := h.pack(b.msg, b.compression)
  1060. if err != nil {
  1061. return &nestedError{"ResourceHeader", err}
  1062. }
  1063. preLen := len(msg)
  1064. if msg, err = r.pack(msg, b.compression); err != nil {
  1065. return &nestedError{"AResource body", err}
  1066. }
  1067. if err := h.fixLen(msg, length, preLen); err != nil {
  1068. return err
  1069. }
  1070. if err := b.incrementSectionCount(); err != nil {
  1071. return err
  1072. }
  1073. b.msg = msg
  1074. return nil
  1075. }
  1076. // AAAAResource adds a single AAAAResource.
  1077. func (b *Builder) AAAAResource(h ResourceHeader, r AAAAResource) error {
  1078. if err := b.checkResourceSection(); err != nil {
  1079. return err
  1080. }
  1081. h.Type = r.realType()
  1082. msg, length, err := h.pack(b.msg, b.compression)
  1083. if err != nil {
  1084. return &nestedError{"ResourceHeader", err}
  1085. }
  1086. preLen := len(msg)
  1087. if msg, err = r.pack(msg, b.compression); err != nil {
  1088. return &nestedError{"AAAAResource body", err}
  1089. }
  1090. if err := h.fixLen(msg, length, preLen); err != nil {
  1091. return err
  1092. }
  1093. if err := b.incrementSectionCount(); err != nil {
  1094. return err
  1095. }
  1096. b.msg = msg
  1097. return nil
  1098. }
  1099. // Finish ends message building and generates a binary packet.
  1100. func (b *Builder) Finish() ([]byte, error) {
  1101. if b.section < sectionHeader {
  1102. return nil, ErrNotStarted
  1103. }
  1104. b.section = sectionDone
  1105. b.header.pack(b.msg[:0])
  1106. return b.msg, nil
  1107. }
  1108. // A ResourceHeader is the header of a DNS resource record. There are
  1109. // many types of DNS resource records, but they all share the same header.
  1110. type ResourceHeader struct {
  1111. // Name is the domain name for which this resource record pertains.
  1112. Name Name
  1113. // Type is the type of DNS resource record.
  1114. //
  1115. // This field will be set automatically during packing.
  1116. Type Type
  1117. // Class is the class of network to which this DNS resource record
  1118. // pertains.
  1119. Class Class
  1120. // TTL is the length of time (measured in seconds) which this resource
  1121. // record is valid for (time to live). All Resources in a set should
  1122. // have the same TTL (RFC 2181 Section 5.2).
  1123. TTL uint32
  1124. // Length is the length of data in the resource record after the header.
  1125. //
  1126. // This field will be set automatically during packing.
  1127. Length uint16
  1128. }
  1129. // pack packs all of the fields in a ResourceHeader except for the length. The
  1130. // length bytes are returned as a slice so they can be filled in after the rest
  1131. // of the Resource has been packed.
  1132. func (h *ResourceHeader) pack(oldMsg []byte, compression map[string]int) (msg []byte, length []byte, err error) {
  1133. msg = oldMsg
  1134. if msg, err = h.Name.pack(msg, compression); err != nil {
  1135. return oldMsg, nil, &nestedError{"Name", err}
  1136. }
  1137. msg = packType(msg, h.Type)
  1138. msg = packClass(msg, h.Class)
  1139. msg = packUint32(msg, h.TTL)
  1140. lenBegin := len(msg)
  1141. msg = packUint16(msg, h.Length)
  1142. return msg, msg[lenBegin : lenBegin+uint16Len], nil
  1143. }
  1144. func (h *ResourceHeader) unpack(msg []byte, off int) (int, error) {
  1145. newOff := off
  1146. var err error
  1147. if newOff, err = h.Name.unpack(msg, newOff); err != nil {
  1148. return off, &nestedError{"Name", err}
  1149. }
  1150. if h.Type, newOff, err = unpackType(msg, newOff); err != nil {
  1151. return off, &nestedError{"Type", err}
  1152. }
  1153. if h.Class, newOff, err = unpackClass(msg, newOff); err != nil {
  1154. return off, &nestedError{"Class", err}
  1155. }
  1156. if h.TTL, newOff, err = unpackUint32(msg, newOff); err != nil {
  1157. return off, &nestedError{"TTL", err}
  1158. }
  1159. if h.Length, newOff, err = unpackUint16(msg, newOff); err != nil {
  1160. return off, &nestedError{"Length", err}
  1161. }
  1162. return newOff, nil
  1163. }
  1164. func (h *ResourceHeader) fixLen(msg []byte, length []byte, preLen int) error {
  1165. conLen := len(msg) - preLen
  1166. if conLen > int(^uint16(0)) {
  1167. return errResTooLong
  1168. }
  1169. // Fill in the length now that we know how long the content is.
  1170. packUint16(length[:0], uint16(conLen))
  1171. h.Length = uint16(conLen)
  1172. return nil
  1173. }
  1174. func skipResource(msg []byte, off int) (int, error) {
  1175. newOff, err := skipName(msg, off)
  1176. if err != nil {
  1177. return off, &nestedError{"Name", err}
  1178. }
  1179. if newOff, err = skipType(msg, newOff); err != nil {
  1180. return off, &nestedError{"Type", err}
  1181. }
  1182. if newOff, err = skipClass(msg, newOff); err != nil {
  1183. return off, &nestedError{"Class", err}
  1184. }
  1185. if newOff, err = skipUint32(msg, newOff); err != nil {
  1186. return off, &nestedError{"TTL", err}
  1187. }
  1188. length, newOff, err := unpackUint16(msg, newOff)
  1189. if err != nil {
  1190. return off, &nestedError{"Length", err}
  1191. }
  1192. if newOff += int(length); newOff > len(msg) {
  1193. return off, errResourceLen
  1194. }
  1195. return newOff, nil
  1196. }
  1197. func packUint16(msg []byte, field uint16) []byte {
  1198. return append(msg, byte(field>>8), byte(field))
  1199. }
  1200. func unpackUint16(msg []byte, off int) (uint16, int, error) {
  1201. if off+uint16Len > len(msg) {
  1202. return 0, off, errBaseLen
  1203. }
  1204. return uint16(msg[off])<<8 | uint16(msg[off+1]), off + uint16Len, nil
  1205. }
  1206. func skipUint16(msg []byte, off int) (int, error) {
  1207. if off+uint16Len > len(msg) {
  1208. return off, errBaseLen
  1209. }
  1210. return off + uint16Len, nil
  1211. }
  1212. func packType(msg []byte, field Type) []byte {
  1213. return packUint16(msg, uint16(field))
  1214. }
  1215. func unpackType(msg []byte, off int) (Type, int, error) {
  1216. t, o, err := unpackUint16(msg, off)
  1217. return Type(t), o, err
  1218. }
  1219. func skipType(msg []byte, off int) (int, error) {
  1220. return skipUint16(msg, off)
  1221. }
  1222. func packClass(msg []byte, field Class) []byte {
  1223. return packUint16(msg, uint16(field))
  1224. }
  1225. func unpackClass(msg []byte, off int) (Class, int, error) {
  1226. c, o, err := unpackUint16(msg, off)
  1227. return Class(c), o, err
  1228. }
  1229. func skipClass(msg []byte, off int) (int, error) {
  1230. return skipUint16(msg, off)
  1231. }
  1232. func packUint32(msg []byte, field uint32) []byte {
  1233. return append(
  1234. msg,
  1235. byte(field>>24),
  1236. byte(field>>16),
  1237. byte(field>>8),
  1238. byte(field),
  1239. )
  1240. }
  1241. func unpackUint32(msg []byte, off int) (uint32, int, error) {
  1242. if off+uint32Len > len(msg) {
  1243. return 0, off, errBaseLen
  1244. }
  1245. v := uint32(msg[off])<<24 | uint32(msg[off+1])<<16 | uint32(msg[off+2])<<8 | uint32(msg[off+3])
  1246. return v, off + uint32Len, nil
  1247. }
  1248. func skipUint32(msg []byte, off int) (int, error) {
  1249. if off+uint32Len > len(msg) {
  1250. return off, errBaseLen
  1251. }
  1252. return off + uint32Len, nil
  1253. }
  1254. func packText(msg []byte, field string) []byte {
  1255. for len(field) > 0 {
  1256. l := len(field)
  1257. if l > 255 {
  1258. l = 255
  1259. }
  1260. msg = append(msg, byte(l))
  1261. msg = append(msg, field[:l]...)
  1262. field = field[l:]
  1263. }
  1264. return msg
  1265. }
  1266. func unpackText(msg []byte, off int) (string, int, error) {
  1267. if off >= len(msg) {
  1268. return "", off, errBaseLen
  1269. }
  1270. beginOff := off + 1
  1271. endOff := beginOff + int(msg[off])
  1272. if endOff > len(msg) {
  1273. return "", off, errCalcLen
  1274. }
  1275. return string(msg[beginOff:endOff]), endOff, nil
  1276. }
  1277. func skipText(msg []byte, off int) (int, error) {
  1278. if off >= len(msg) {
  1279. return off, errBaseLen
  1280. }
  1281. endOff := off + 1 + int(msg[off])
  1282. if endOff > len(msg) {
  1283. return off, errCalcLen
  1284. }
  1285. return endOff, nil
  1286. }
  1287. func packBytes(msg []byte, field []byte) []byte {
  1288. return append(msg, field...)
  1289. }
  1290. func unpackBytes(msg []byte, off int, field []byte) (int, error) {
  1291. newOff := off + len(field)
  1292. if newOff > len(msg) {
  1293. return off, errBaseLen
  1294. }
  1295. copy(field, msg[off:newOff])
  1296. return newOff, nil
  1297. }
  1298. func skipBytes(msg []byte, off int, field []byte) (int, error) {
  1299. newOff := off + len(field)
  1300. if newOff > len(msg) {
  1301. return off, errBaseLen
  1302. }
  1303. return newOff, nil
  1304. }
  1305. const nameLen = 255
  1306. // A Name is a non-encoded domain name. It is used instead of strings to avoid
  1307. // allocations.
  1308. type Name struct {
  1309. Data [nameLen]byte
  1310. Length uint8
  1311. }
  1312. // NewName creates a new Name from a string.
  1313. func NewName(name string) (Name, error) {
  1314. if len([]byte(name)) > nameLen {
  1315. return Name{}, errCalcLen
  1316. }
  1317. n := Name{Length: uint8(len(name))}
  1318. copy(n.Data[:], []byte(name))
  1319. return n, nil
  1320. }
  1321. func (n Name) String() string {
  1322. return string(n.Data[:n.Length])
  1323. }
  1324. // pack packs a domain name.
  1325. //
  1326. // Domain names are a sequence of counted strings split at the dots. They end
  1327. // with a zero-length string. Compression can be used to reuse domain suffixes.
  1328. //
  1329. // The compression map will be updated with new domain suffixes. If compression
  1330. // is nil, compression will not be used.
  1331. func (n *Name) pack(msg []byte, compression map[string]int) ([]byte, error) {
  1332. oldMsg := msg
  1333. // Add a trailing dot to canonicalize name.
  1334. if n.Length == 0 || n.Data[n.Length-1] != '.' {
  1335. return oldMsg, errNonCanonicalName
  1336. }
  1337. // Allow root domain.
  1338. if n.Data[0] == '.' && n.Length == 1 {
  1339. return append(msg, 0), nil
  1340. }
  1341. // Emit sequence of counted strings, chopping at dots.
  1342. for i, begin := 0, 0; i < int(n.Length); i++ {
  1343. // Check for the end of the segment.
  1344. if n.Data[i] == '.' {
  1345. // The two most significant bits have special meaning.
  1346. // It isn't allowed for segments to be long enough to
  1347. // need them.
  1348. if i-begin >= 1<<6 {
  1349. return oldMsg, errSegTooLong
  1350. }
  1351. // Segments must have a non-zero length.
  1352. if i-begin == 0 {
  1353. return oldMsg, errZeroSegLen
  1354. }
  1355. msg = append(msg, byte(i-begin))
  1356. for j := begin; j < i; j++ {
  1357. msg = append(msg, n.Data[j])
  1358. }
  1359. begin = i + 1
  1360. continue
  1361. }
  1362. // We can only compress domain suffixes starting with a new
  1363. // segment. A pointer is two bytes with the two most significant
  1364. // bits set to 1 to indicate that it is a pointer.
  1365. if (i == 0 || n.Data[i-1] == '.') && compression != nil {
  1366. if ptr, ok := compression[string(n.Data[i:])]; ok {
  1367. // Hit. Emit a pointer instead of the rest of
  1368. // the domain.
  1369. return append(msg, byte(ptr>>8|0xC0), byte(ptr)), nil
  1370. }
  1371. // Miss. Add the suffix to the compression table if the
  1372. // offset can be stored in the available 14 bytes.
  1373. if len(msg) <= int(^uint16(0)>>2) {
  1374. compression[string(n.Data[i:])] = len(msg)
  1375. }
  1376. }
  1377. }
  1378. return append(msg, 0), nil
  1379. }
  1380. // unpack unpacks a domain name.
  1381. func (n *Name) unpack(msg []byte, off int) (int, error) {
  1382. // currOff is the current working offset.
  1383. currOff := off
  1384. // newOff is the offset where the next record will start. Pointers lead
  1385. // to data that belongs to other names and thus doesn't count towards to
  1386. // the usage of this name.
  1387. newOff := off
  1388. // ptr is the number of pointers followed.
  1389. var ptr int
  1390. // Name is a slice representation of the name data.
  1391. name := n.Data[:0]
  1392. Loop:
  1393. for {
  1394. if currOff >= len(msg) {
  1395. return off, errBaseLen
  1396. }
  1397. c := int(msg[currOff])
  1398. currOff++
  1399. switch c & 0xC0 {
  1400. case 0x00: // String segment
  1401. if c == 0x00 {
  1402. // A zero length signals the end of the name.
  1403. break Loop
  1404. }
  1405. endOff := currOff + c
  1406. if endOff > len(msg) {
  1407. return off, errCalcLen
  1408. }
  1409. name = append(name, msg[currOff:endOff]...)
  1410. name = append(name, '.')
  1411. currOff = endOff
  1412. case 0xC0: // Pointer
  1413. if currOff >= len(msg) {
  1414. return off, errInvalidPtr
  1415. }
  1416. c1 := msg[currOff]
  1417. currOff++
  1418. if ptr == 0 {
  1419. newOff = currOff
  1420. }
  1421. // Don't follow too many pointers, maybe there's a loop.
  1422. if ptr++; ptr > 10 {
  1423. return off, errTooManyPtr
  1424. }
  1425. currOff = (c^0xC0)<<8 | int(c1)
  1426. default:
  1427. // Prefixes 0x80 and 0x40 are reserved.
  1428. return off, errReserved
  1429. }
  1430. }
  1431. if len(name) == 0 {
  1432. name = append(name, '.')
  1433. }
  1434. if len(name) > len(n.Data) {
  1435. return off, errCalcLen
  1436. }
  1437. n.Length = uint8(len(name))
  1438. if ptr == 0 {
  1439. newOff = currOff
  1440. }
  1441. return newOff, nil
  1442. }
  1443. func skipName(msg []byte, off int) (int, error) {
  1444. // newOff is the offset where the next record will start. Pointers lead
  1445. // to data that belongs to other names and thus doesn't count towards to
  1446. // the usage of this name.
  1447. newOff := off
  1448. Loop:
  1449. for {
  1450. if newOff >= len(msg) {
  1451. return off, errBaseLen
  1452. }
  1453. c := int(msg[newOff])
  1454. newOff++
  1455. switch c & 0xC0 {
  1456. case 0x00:
  1457. if c == 0x00 {
  1458. // A zero length signals the end of the name.
  1459. break Loop
  1460. }
  1461. // literal string
  1462. newOff += c
  1463. if newOff > len(msg) {
  1464. return off, errCalcLen
  1465. }
  1466. case 0xC0:
  1467. // Pointer to somewhere else in msg.
  1468. // Pointers are two bytes.
  1469. newOff++
  1470. // Don't follow the pointer as the data here has ended.
  1471. break Loop
  1472. default:
  1473. // Prefixes 0x80 and 0x40 are reserved.
  1474. return off, errReserved
  1475. }
  1476. }
  1477. return newOff, nil
  1478. }
  1479. // A Question is a DNS query.
  1480. type Question struct {
  1481. Name Name
  1482. Type Type
  1483. Class Class
  1484. }
  1485. func (q *Question) pack(msg []byte, compression map[string]int) ([]byte, error) {
  1486. msg, err := q.Name.pack(msg, compression)
  1487. if err != nil {
  1488. return msg, &nestedError{"Name", err}
  1489. }
  1490. msg = packType(msg, q.Type)
  1491. return packClass(msg, q.Class), nil
  1492. }
  1493. func unpackResourceBody(msg []byte, off int, hdr ResourceHeader) (ResourceBody, int, error) {
  1494. var (
  1495. r ResourceBody
  1496. err error
  1497. name string
  1498. )
  1499. switch hdr.Type {
  1500. case TypeA:
  1501. var rb AResource
  1502. rb, err = unpackAResource(msg, off)
  1503. r = &rb
  1504. name = "A"
  1505. case TypeNS:
  1506. var rb NSResource
  1507. rb, err = unpackNSResource(msg, off)
  1508. r = &rb
  1509. name = "NS"
  1510. case TypeCNAME:
  1511. var rb CNAMEResource
  1512. rb, err = unpackCNAMEResource(msg, off)
  1513. r = &rb
  1514. name = "CNAME"
  1515. case TypeSOA:
  1516. var rb SOAResource
  1517. rb, err = unpackSOAResource(msg, off)
  1518. r = &rb
  1519. name = "SOA"
  1520. case TypePTR:
  1521. var rb PTRResource
  1522. rb, err = unpackPTRResource(msg, off)
  1523. r = &rb
  1524. name = "PTR"
  1525. case TypeMX:
  1526. var rb MXResource
  1527. rb, err = unpackMXResource(msg, off)
  1528. r = &rb
  1529. name = "MX"
  1530. case TypeTXT:
  1531. var rb TXTResource
  1532. rb, err = unpackTXTResource(msg, off, hdr.Length)
  1533. r = &rb
  1534. name = "TXT"
  1535. case TypeAAAA:
  1536. var rb AAAAResource
  1537. rb, err = unpackAAAAResource(msg, off)
  1538. r = &rb
  1539. name = "AAAA"
  1540. case TypeSRV:
  1541. var rb SRVResource
  1542. rb, err = unpackSRVResource(msg, off)
  1543. r = &rb
  1544. name = "SRV"
  1545. }
  1546. if err != nil {
  1547. return nil, off, &nestedError{name + " record", err}
  1548. }
  1549. if r == nil {
  1550. return nil, off, errors.New("invalid resource type: " + string(hdr.Type+'0'))
  1551. }
  1552. return r, off + int(hdr.Length), nil
  1553. }
  1554. // A CNAMEResource is a CNAME Resource record.
  1555. type CNAMEResource struct {
  1556. CNAME Name
  1557. }
  1558. func (r *CNAMEResource) realType() Type {
  1559. return TypeCNAME
  1560. }
  1561. func (r *CNAMEResource) pack(msg []byte, compression map[string]int) ([]byte, error) {
  1562. return r.CNAME.pack(msg, compression)
  1563. }
  1564. func unpackCNAMEResource(msg []byte, off int) (CNAMEResource, error) {
  1565. var cname Name
  1566. if _, err := cname.unpack(msg, off); err != nil {
  1567. return CNAMEResource{}, err
  1568. }
  1569. return CNAMEResource{cname}, nil
  1570. }
  1571. // An MXResource is an MX Resource record.
  1572. type MXResource struct {
  1573. Pref uint16
  1574. MX Name
  1575. }
  1576. func (r *MXResource) realType() Type {
  1577. return TypeMX
  1578. }
  1579. func (r *MXResource) pack(msg []byte, compression map[string]int) ([]byte, error) {
  1580. oldMsg := msg
  1581. msg = packUint16(msg, r.Pref)
  1582. msg, err := r.MX.pack(msg, compression)
  1583. if err != nil {
  1584. return oldMsg, &nestedError{"MXResource.MX", err}
  1585. }
  1586. return msg, nil
  1587. }
  1588. func unpackMXResource(msg []byte, off int) (MXResource, error) {
  1589. pref, off, err := unpackUint16(msg, off)
  1590. if err != nil {
  1591. return MXResource{}, &nestedError{"Pref", err}
  1592. }
  1593. var mx Name
  1594. if _, err := mx.unpack(msg, off); err != nil {
  1595. return MXResource{}, &nestedError{"MX", err}
  1596. }
  1597. return MXResource{pref, mx}, nil
  1598. }
  1599. // An NSResource is an NS Resource record.
  1600. type NSResource struct {
  1601. NS Name
  1602. }
  1603. func (r *NSResource) realType() Type {
  1604. return TypeNS
  1605. }
  1606. func (r *NSResource) pack(msg []byte, compression map[string]int) ([]byte, error) {
  1607. return r.NS.pack(msg, compression)
  1608. }
  1609. func unpackNSResource(msg []byte, off int) (NSResource, error) {
  1610. var ns Name
  1611. if _, err := ns.unpack(msg, off); err != nil {
  1612. return NSResource{}, err
  1613. }
  1614. return NSResource{ns}, nil
  1615. }
  1616. // A PTRResource is a PTR Resource record.
  1617. type PTRResource struct {
  1618. PTR Name
  1619. }
  1620. func (r *PTRResource) realType() Type {
  1621. return TypePTR
  1622. }
  1623. func (r *PTRResource) pack(msg []byte, compression map[string]int) ([]byte, error) {
  1624. return r.PTR.pack(msg, compression)
  1625. }
  1626. func unpackPTRResource(msg []byte, off int) (PTRResource, error) {
  1627. var ptr Name
  1628. if _, err := ptr.unpack(msg, off); err != nil {
  1629. return PTRResource{}, err
  1630. }
  1631. return PTRResource{ptr}, nil
  1632. }
  1633. // An SOAResource is an SOA Resource record.
  1634. type SOAResource struct {
  1635. NS Name
  1636. MBox Name
  1637. Serial uint32
  1638. Refresh uint32
  1639. Retry uint32
  1640. Expire uint32
  1641. // MinTTL the is the default TTL of Resources records which did not
  1642. // contain a TTL value and the TTL of negative responses. (RFC 2308
  1643. // Section 4)
  1644. MinTTL uint32
  1645. }
  1646. func (r *SOAResource) realType() Type {
  1647. return TypeSOA
  1648. }
  1649. func (r *SOAResource) pack(msg []byte, compression map[string]int) ([]byte, error) {
  1650. oldMsg := msg
  1651. msg, err := r.NS.pack(msg, compression)
  1652. if err != nil {
  1653. return oldMsg, &nestedError{"SOAResource.NS", err}
  1654. }
  1655. msg, err = r.MBox.pack(msg, compression)
  1656. if err != nil {
  1657. return oldMsg, &nestedError{"SOAResource.MBox", err}
  1658. }
  1659. msg = packUint32(msg, r.Serial)
  1660. msg = packUint32(msg, r.Refresh)
  1661. msg = packUint32(msg, r.Retry)
  1662. msg = packUint32(msg, r.Expire)
  1663. return packUint32(msg, r.MinTTL), nil
  1664. }
  1665. func unpackSOAResource(msg []byte, off int) (SOAResource, error) {
  1666. var ns Name
  1667. off, err := ns.unpack(msg, off)
  1668. if err != nil {
  1669. return SOAResource{}, &nestedError{"NS", err}
  1670. }
  1671. var mbox Name
  1672. if off, err = mbox.unpack(msg, off); err != nil {
  1673. return SOAResource{}, &nestedError{"MBox", err}
  1674. }
  1675. serial, off, err := unpackUint32(msg, off)
  1676. if err != nil {
  1677. return SOAResource{}, &nestedError{"Serial", err}
  1678. }
  1679. refresh, off, err := unpackUint32(msg, off)
  1680. if err != nil {
  1681. return SOAResource{}, &nestedError{"Refresh", err}
  1682. }
  1683. retry, off, err := unpackUint32(msg, off)
  1684. if err != nil {
  1685. return SOAResource{}, &nestedError{"Retry", err}
  1686. }
  1687. expire, off, err := unpackUint32(msg, off)
  1688. if err != nil {
  1689. return SOAResource{}, &nestedError{"Expire", err}
  1690. }
  1691. minTTL, _, err := unpackUint32(msg, off)
  1692. if err != nil {
  1693. return SOAResource{}, &nestedError{"MinTTL", err}
  1694. }
  1695. return SOAResource{ns, mbox, serial, refresh, retry, expire, minTTL}, nil
  1696. }
  1697. // A TXTResource is a TXT Resource record.
  1698. type TXTResource struct {
  1699. Txt string // Not a domain name.
  1700. }
  1701. func (r *TXTResource) realType() Type {
  1702. return TypeTXT
  1703. }
  1704. func (r *TXTResource) pack(msg []byte, compression map[string]int) ([]byte, error) {
  1705. return packText(msg, r.Txt), nil
  1706. }
  1707. func unpackTXTResource(msg []byte, off int, length uint16) (TXTResource, error) {
  1708. var txt string
  1709. for n := uint16(0); n < length; {
  1710. var t string
  1711. var err error
  1712. if t, off, err = unpackText(msg, off); err != nil {
  1713. return TXTResource{}, &nestedError{"text", err}
  1714. }
  1715. // Check if we got too many bytes.
  1716. if length-n < uint16(len(t))+1 {
  1717. return TXTResource{}, errCalcLen
  1718. }
  1719. n += uint16(len(t)) + 1
  1720. txt += t
  1721. }
  1722. return TXTResource{txt}, nil
  1723. }
  1724. // An SRVResource is an SRV Resource record.
  1725. type SRVResource struct {
  1726. Priority uint16
  1727. Weight uint16
  1728. Port uint16
  1729. Target Name // Not compressed as per RFC 2782.
  1730. }
  1731. func (r *SRVResource) realType() Type {
  1732. return TypeSRV
  1733. }
  1734. func (r *SRVResource) pack(msg []byte, compression map[string]int) ([]byte, error) {
  1735. oldMsg := msg
  1736. msg = packUint16(msg, r.Priority)
  1737. msg = packUint16(msg, r.Weight)
  1738. msg = packUint16(msg, r.Port)
  1739. msg, err := r.Target.pack(msg, nil)
  1740. if err != nil {
  1741. return oldMsg, &nestedError{"SRVResource.Target", err}
  1742. }
  1743. return msg, nil
  1744. }
  1745. func unpackSRVResource(msg []byte, off int) (SRVResource, error) {
  1746. priority, off, err := unpackUint16(msg, off)
  1747. if err != nil {
  1748. return SRVResource{}, &nestedError{"Priority", err}
  1749. }
  1750. weight, off, err := unpackUint16(msg, off)
  1751. if err != nil {
  1752. return SRVResource{}, &nestedError{"Weight", err}
  1753. }
  1754. port, off, err := unpackUint16(msg, off)
  1755. if err != nil {
  1756. return SRVResource{}, &nestedError{"Port", err}
  1757. }
  1758. var target Name
  1759. if _, err := target.unpack(msg, off); err != nil {
  1760. return SRVResource{}, &nestedError{"Target", err}
  1761. }
  1762. return SRVResource{priority, weight, port, target}, nil
  1763. }
  1764. // An AResource is an A Resource record.
  1765. type AResource struct {
  1766. A [4]byte
  1767. }
  1768. func (r *AResource) realType() Type {
  1769. return TypeA
  1770. }
  1771. func (r *AResource) pack(msg []byte, compression map[string]int) ([]byte, error) {
  1772. return packBytes(msg, r.A[:]), nil
  1773. }
  1774. func unpackAResource(msg []byte, off int) (AResource, error) {
  1775. var a [4]byte
  1776. if _, err := unpackBytes(msg, off, a[:]); err != nil {
  1777. return AResource{}, err
  1778. }
  1779. return AResource{a}, nil
  1780. }
  1781. // An AAAAResource is an AAAA Resource record.
  1782. type AAAAResource struct {
  1783. AAAA [16]byte
  1784. }
  1785. func (r *AAAAResource) realType() Type {
  1786. return TypeAAAA
  1787. }
  1788. func (r *AAAAResource) pack(msg []byte, compression map[string]int) ([]byte, error) {
  1789. return packBytes(msg, r.AAAA[:]), nil
  1790. }
  1791. func unpackAAAAResource(msg []byte, off int) (AAAAResource, error) {
  1792. var aaaa [16]byte
  1793. if _, err := unpackBytes(msg, off, aaaa[:]); err != nil {
  1794. return AAAAResource{}, err
  1795. }
  1796. return AAAAResource{aaaa}, nil
  1797. }