hickory-proto 0.26.0

// Copyright 2015-2019 Benjamin Fry <benjaminfry@me.com>
//
// Licensed under the Apache License, Version 2.0, <LICENSE-APACHE or
// https://apache.org/licenses/LICENSE-2.0> or the MIT license <LICENSE-MIT or
// https://opensource.org/licenses/MIT>, at your option. This file may not be
// copied, modified, or distributed except according to those terms.

//! Hickory-DNS implementation of Secret Key Transaction Authentication for DNS (TSIG)
//! [RFC 8945](https://www.rfc-editor.org/rfc/rfc8945) November 2020
//!
//! Current deviations from RFC in implementation as of 2022-10-28
//!
//! - Truncated MACs are not supported.
//! - Time checking is not performed in the TSIG implementation but by the caller.

#[cfg(feature = "__dnssec")]
use alloc::boxed::Box;
#[cfg(feature = "__dnssec")]
use alloc::string::ToString;
use alloc::sync::Arc;
use alloc::vec::Vec;
#[cfg(feature = "__dnssec")]
use core::ops::Range;

#[cfg(feature = "__dnssec")]
use tracing::debug;

#[cfg(feature = "__dnssec")]
use crate::dnssec::DnsSecError;

use super::rdata::tsig::TsigAlgorithm;
#[cfg(feature = "__dnssec")]
use super::rdata::tsig::{
    TSIG, TsigError, make_tsig_record, message_tbs, signed_bitmessage_to_buf,
};
#[cfg(feature = "__dnssec")]
use crate::error::{ProtoError, ProtoResult};
#[cfg(feature = "__dnssec")]
use crate::op::DnsResponse;
use crate::op::{Message, OpCode};
#[cfg(feature = "__dnssec")]
use crate::rr::Record;
use crate::rr::{Name, RecordType};
#[cfg(feature = "__dnssec")]
use crate::serialize::binary::BinEncoder;

/// Context for a TSIG response, used to construct a TSIG response signer
pub struct TSigResponseContext {
    #[cfg(feature = "__dnssec")]
    request_id: u16,
    #[cfg(feature = "__dnssec")]
    time: u64,
    #[cfg(feature = "__dnssec")]
    kind: TsigResponseKind,
}

#[cfg(feature = "__dnssec")]
impl TSigResponseContext {
    /// Create a new TSIG response context
    /// Create a new TSIG response context
    pub fn new(
        request_id: u16,
        time: u64,
        signer: TSigner,
        request_mac: Vec<u8>,
        error: Option<TsigError>,
    ) -> Self {
        Self {
            request_id,
            time,
            kind: TsigResponseKind::Signed {
                signer,
                request_mac,
                error,
            },
        }
    }

    /// Yield a response signer context for a bad request signature
    pub fn bad_signature(request_id: u16, time: u64, signer: TSigner) -> Self {
        Self {
            request_id,
            time,
            kind: TsigResponseKind::BadSignature { signer },
        }
    }

    /// Yield a response signer context for an unknown key
    pub fn unknown_key(request_id: u16, time: u64, key_name: Name) -> Self {
        Self {
            request_id,
            time,
            kind: TsigResponseKind::UnknownKey { key_name },
        }
    }

    /// Sign an encoded DNS response message according to the context
    #[cfg(feature = "__dnssec")]
    pub fn sign(self, response: &[u8]) -> Result<Box<Record<TSIG>>, ProtoError> {
        match self.kind {
            TsigResponseKind::Signed {
                signer,
                request_mac,
                error,
            } => {
                // BadSig and BadKey are both spec'd to return **unsigned** TSIG RRs.
                debug_assert!(!matches!(
                    error,
                    Some(TsigError::BadSig | TsigError::BadKey)
                ));

                let mut stub_tsig = TSIG::stub(self.request_id, self.time, &signer);
                if let Some(err) = error {
                    stub_tsig.error = Some(err);
                }

                let tbs_tsig_encoded =
                    signer.encode_response_tbs(&request_mac, response, &stub_tsig)?;
                let resp_tsig = stub_tsig.set_mac(
                    signer
                        .sign(&tbs_tsig_encoded)
                        .map_err(|e| ProtoError::from(e.to_string()))?,
                );

                Ok(Box::new(make_tsig_record(
                    signer.signer_name().clone(),
                    resp_tsig,
                )))
            }
            TsigResponseKind::BadSignature { signer } => {
                let mut stub_tsig = TSIG::stub(self.request_id, self.time, &signer);
                stub_tsig.error = Some(TsigError::BadSig);
                Ok(Box::new(make_tsig_record(
                    signer.signer_name().clone(),
                    stub_tsig,
                )))
            }
            TsigResponseKind::UnknownKey { key_name } => {
                // "If a non-forwarding server does not recognize the key or algorithm used by the
                // client (or recognizes the algorithm but does not implement it), the server MUST
                // generate an error response with RCODE 9 (NOTAUTH) and TSIG ERROR 17 (BADKEY).
                // This response MUST be unsigned"
                //
                // Note that this doesn't specify what TSIG algorithm, fudge, or key name we
                // should use in the response since we didn't recognize the key name as one
                // of our configured signers. We choose a stand-in algorithm and reflect the
                // unknown key name in absence of further direction.
                Ok(Box::new(make_tsig_record(
                    key_name.clone(),
                    TSIG::new(
                        TsigAlgorithm::HmacSha256,
                        self.time,
                        300,
                        Vec::new(),
                        self.request_id,
                        Some(TsigError::BadKey),
                        Vec::new(),
                    ),
                )))
            }
        }
    }
}

/// An enum describing the kind of response we may generate a response TSIG record for.
#[cfg(feature = "__dnssec")]
enum TsigResponseKind {
    /// A TSIG response that has a populated MAC produced by the `signer`.
    Signed {
        signer: TSigner,
        request_mac: Vec<u8>,
        error: Option<TsigError>,
    },
    /// An unsigned TSIG response that populates a stub TSIG based on `signer`.
    BadSignature { signer: TSigner },
    /// An unsigned TSIG response where we were unable to find a `TSigner` with `key_name`.
    UnknownKey { key_name: Name },
}

/// Struct to pass to a client for it to authenticate requests using TSIG.
#[derive(Clone)]
pub struct TSigner(Arc<TSignerInner>);

struct TSignerInner {
    key: Vec<u8>, // TODO this might want to be some sort of auto-zeroing on drop buffer, as it's cryptographic material
    algorithm: TsigAlgorithm,
    signer_name: Name,
    fudge: u16,
}

impl TSigner {
    /// Create a new TSigner from its parts
    ///
    /// # Arguments
    ///
    /// * `key` - cryptographic key used to authenticate exchanges
    /// * `algorithm` - algorithm used to authenticate exchanges
    /// * `signer_name` - name of the key. Must match the name known to the server
    /// * `fudge` - maximum difference between client and server time, in seconds, see [fudge](TSigner::fudge) for details
    #[cfg(feature = "__dnssec")]
    pub fn new(
        key: Vec<u8>,
        algorithm: TsigAlgorithm,
        mut signer_name: Name,
        fudge: u16,
    ) -> Result<Self, DnsSecError> {
        if !algorithm.supported() {
            return Err(DnsSecError::TsigUnsupportedMacAlgorithm(algorithm));
        }

        signer_name.set_fqdn(true);
        Ok(Self(Arc::new(TSignerInner {
            key,
            algorithm,
            signer_name,
            fudge,
        })))
    }

    /// Return the key used for message authentication
    pub fn key(&self) -> &[u8] {
        &self.0.key
    }

    /// Return the algorithm used for message authentication
    pub fn algorithm(&self) -> &TsigAlgorithm {
        &self.0.algorithm
    }

    /// Name of the key used by this signer
    pub fn signer_name(&self) -> &Name {
        &self.0.signer_name
    }

    /// Maximum time difference between client time when issuing a message, and server time when
    /// receiving it, in second. If time is out, the server will consider the request invalid.
    /// Longer values means more room for replay by an attacker. A few minutes are usually a good
    /// value.
    pub fn fudge(&self) -> u16 {
        self.0.fudge
    }

    /// Compute authentication tag for a buffer
    #[cfg(feature = "__dnssec")]
    pub fn sign(&self, tbs: &[u8]) -> Result<Vec<u8>, DnsSecError> {
        self.0.algorithm.mac_data(&self.0.key, tbs)
    }

    /// Verify hmac in constant time to prevent timing attacks
    #[cfg(feature = "__dnssec")]
    pub fn verify(&self, tbv: &[u8], tag: &[u8]) -> Result<(), DnsSecError> {
        self.0.algorithm.verify_mac(&self.0.key, tbv, tag)
    }

    /// Returns true if the `TSigner` should sign the given `Message`
    pub fn should_sign_message(&self, message: &Message) -> bool {
        [OpCode::Update, OpCode::Notify].contains(&message.op_code)
            || message
                .queries
                .iter()
                .any(|q| [RecordType::AXFR, RecordType::IXFR].contains(&q.query_type()))
    }

    /// Verify the message is correctly signed
    ///
    /// This does not perform signature time verification. The caller should verify the
    /// current time lies in the returned `Range`. See [RFC 8945 Section 5.2.3] for more information.
    ///
    /// # Arguments
    /// * `message` - byte buffer containing the to-be-verified `Message`
    /// * `previous_hash` - Hash of the last message received before this one when processing chained
    ///   messages, or of a query for a first response message.
    /// * `first_message` - whether `message` is the first response message
    ///
    /// # Returns
    ///
    /// Return `Ok(_)` for valid signatures. Inner tuple contain the following values, in order:
    /// * a byte buffer containing the hash of `message`. This can be passed back when
    ///   authenticating a later chained message.
    /// * the time the signature was emitted. It must be greater or equal to the time of previous
    ///   messages, if any.
    /// * a `Range` of time that the signature is considered acceptable within based on the signer
    ///   fudge value.
    ///
    /// [RFC 8945 Section 5.2.3]: https://www.rfc-editor.org/rfc/rfc8945.html#section-5.2.3
    #[cfg(feature = "__dnssec")]
    pub fn verify_message_byte(
        &self,
        message: &[u8],
        previous_hash: Option<&[u8]>,
        first_message: bool,
    ) -> Result<(Vec<u8>, u64, Range<u64>), DnsSecError> {
        let (tbv, record) = signed_bitmessage_to_buf(message, previous_hash, first_message)?;
        let tsig = record.data;

        // https://tools.ietf.org/html/rfc8945#section-5.2
        // 1.  Check key
        if record.name != self.0.signer_name || tsig.algorithm != self.0.algorithm {
            return Err(DnsSecError::TsigWrongKey);
        }

        // 2.  Check MAC

        // If the MAC length doesn't match the algorithm output length, then it was truncated.
        // While the RFC supports this, we take a conservative approach and do not. Truncated
        // MAC tags offer less security than their full-width counterparts, and the spec includes
        // them only for backwards compatibility.
        if tsig.mac.len() < tsig.algorithm.output_len()? {
            return Err(DnsSecError::from(
                "Please file an issue with https://github.com/hickory-dns/hickory-dns to support truncated HMACs with TSIG",
            ));
        }
        self.verify(&tbv, &tsig.mac)?;

        // 3.  Check time values
        // Since we don't have a time source to use here we instead defer this to the caller.

        // 4.  Check truncation policy
        // We have already rejected truncated MACs so this step is not applicable.

        Ok((
            tsig.mac.to_vec(),
            tsig.time,
            Range {
                start: tsig.time - tsig.fudge as u64,
                end: tsig.time + tsig.fudge as u64,
            },
        ))
    }

    /// Encode the to-be-signed (TBS) bytes for an encoded response to a TSIG signed request
    ///
    /// The TSIG MAC of the query, the raw unsigned response bytes, and a stub TSIG
    /// record are combined to produce the overall to-be-signed response.
    ///
    /// `previous_mac` contains the TSIG MAC of the query the reply is in response to.
    /// `encoded_response` is the to-be-signed bytes of the constructed response.
    /// `resp_id` is the ID of the response to use for the TSIG RR stub.
    /// `now` is the timestamp to use for the TSIG RR stub.
    #[cfg(feature = "__dnssec")]
    pub fn encode_response_tbs(
        &self,
        previous_mac: &[u8],
        encoded_response: &[u8],
        stub_tsig: &TSIG,
    ) -> Result<Vec<u8>, ProtoError> {
        // the TBS buffer is sized based on the previous MAC, the overhead of its u16 len
        // prefix, the size of the encoded response, and a rough approximation of the
        // size of the stub TSIG RR.
        let mut tbs_buf = Vec::with_capacity(
            previous_mac.len() + size_of::<u16>() + encoded_response.len() + 128,
        );
        let mut encoder = BinEncoder::new(&mut tbs_buf);

        debug_assert!(previous_mac.len() <= u16::MAX as usize); // Shouldn't happen for supported algorithms.
        encoder.emit_u16(previous_mac.len() as u16)?;
        encoder.emit_vec(previous_mac)?;
        encoder.emit_vec(encoded_response)?;
        stub_tsig.emit_tsig_for_mac(&mut encoder, self.signer_name())?;

        Ok(tbs_buf)
    }

    /// Sign a `Message`
    #[cfg(feature = "__dnssec")]
    pub fn sign_message(
        &self,
        message: &Message,
        current_time: u64,
    ) -> ProtoResult<(Box<Record<TSIG>>, Option<TSigVerifier>)> {
        debug!("signing message: {:?}", message);

        let pre_tsig = TSIG::stub(message.id, current_time, self);
        let signature = self
            .sign(&message_tbs(message, &pre_tsig, &self.0.signer_name)?)
            .map_err(|err| ProtoError::from(err.to_string()))?;
        let tsig = make_tsig_record(
            self.0.signer_name.clone(),
            pre_tsig.set_mac(signature.clone()),
        );

        let verifier = TSigVerifier {
            signer: self.clone(),
            previous_signature: signature,
            remote_time: 0,
            request_time: current_time,
        };

        Ok((Box::new(tsig), Some(verifier)))
    }
}

/// A verifier for TSIG-signed DNS responses.
///
/// This struct maintains the state necessary to verify a chain of TSIG-signed
/// responses, tracking the previous MAC and response timestamps to ensure
/// proper ordering and validation.
#[cfg(feature = "__dnssec")]
pub struct TSigVerifier {
    signer: TSigner,
    previous_signature: Vec<u8>,
    remote_time: u64,
    request_time: u64,
}

#[cfg(feature = "__dnssec")]
impl TSigVerifier {
    /// Verify a TSIG-signed DNS response.
    ///
    /// This method validates the TSIG signature on the response, checks that
    /// the response timestamp is monotonically increasing (for chained responses),
    /// and validates that the response time falls within the acceptable fudge window.
    ///
    /// # Arguments
    ///
    /// * `response_bytes` - The raw bytes of the DNS response message
    ///
    /// # Returns
    ///
    /// Returns the verified `DnsResponse` on success, or a `ProtoError` if
    /// verification fails.
    pub fn verify(&mut self, response_bytes: &[u8]) -> ProtoResult<DnsResponse> {
        let (last_sig, rt, range) = self
            .signer
            .verify_message_byte(
                response_bytes,
                Some(&self.previous_signature),
                self.remote_time == 0,
            )
            .map_err(|err| ProtoError::from(err.to_string()))?;

        if rt >= self.remote_time && range.contains(&self.request_time) {
            self.previous_signature = last_sig;
            self.remote_time = rt;
            DnsResponse::from_buffer(response_bytes.to_vec())
        } else {
            Err(ProtoError::from("tsig validation error: outdated response"))
        }
    }
}

#[cfg(test)]
#[cfg(feature = "__dnssec")]
mod tests {
    #![allow(clippy::dbg_macro, clippy::print_stdout)]

    use crate::op::{Message, Query};
    use crate::rr::Name;
    use crate::serialize::binary::BinEncodable;

    use super::*;
    fn assert_send_and_sync<T: Send + Sync>() {}

    #[test]
    fn test_send_and_sync() {
        assert_send_and_sync::<TSigner>();
    }

    #[test]
    fn test_sign_and_verify_message_tsig() {
        let time_begin = 1609459200u64;
        let fudge = 300u64;
        let origin: Name = Name::parse("example.com.", None).unwrap();
        let key_name: Name = Name::from_ascii("key_name.").unwrap();
        let mut question = Message::query();
        let mut query: Query = Query::new();
        query.set_name(origin);
        question.add_query(query);

        let sig_key = b"some_key".to_vec();
        let signer =
            TSigner::new(sig_key, TsigAlgorithm::HmacSha512, key_name, fudge as u16).unwrap();

        assert!(question.signature().is_none());
        question
            .finalize(&signer, time_begin)
            .expect("should have signed");
        assert!(question.signature().is_some());

        let (_, _, validity_range) = signer
            .verify_message_byte(&question.to_bytes().unwrap(), None, true)
            .unwrap();
        assert!(validity_range.contains(&(time_begin + fudge / 2))); // slightly outdated, but still to be acceptable
        assert!(validity_range.contains(&(time_begin - fudge / 2))); // sooner than our time, but still acceptable
        assert!(!validity_range.contains(&(time_begin + fudge * 2))); // too late to be accepted
        assert!(!validity_range.contains(&(time_begin - fudge * 2))); // too soon to be accepted
    }

    // make rejection tests shorter by centralizing common setup code
    fn get_message_and_signer() -> (Message, TSigner) {
        let time_begin = 1609459200u64;
        let fudge = 300u64;
        let origin: Name = Name::parse("example.com.", None).unwrap();
        let key_name: Name = Name::from_ascii("key_name.").unwrap();
        let mut question = Message::query();
        let mut query: Query = Query::new();
        query.set_name(origin);
        question.add_query(query);

        let sig_key = b"some_key".to_vec();
        let signer =
            TSigner::new(sig_key, TsigAlgorithm::HmacSha512, key_name, fudge as u16).unwrap();

        assert!(question.signature().is_none());
        question
            .finalize(&signer, time_begin)
            .expect("should have signed");
        assert!(question.signature().is_some());

        // this should be ok, it has not been tampered with
        assert!(
            signer
                .verify_message_byte(&question.to_bytes().unwrap(), None, true)
                .is_ok()
        );

        (question, signer)
    }

    #[test]
    fn test_sign_and_verify_message_tsig_reject_keyname() {
        let (mut question, signer) = get_message_and_signer();

        let other_name = Name::from_ascii("other_name.").unwrap();
        let Some(mut signature) = question.take_signature() else {
            panic!("should have TSIG signed");
        };
        signature.name = other_name;
        question.set_signature(signature);

        assert!(
            signer
                .verify_message_byte(&question.to_bytes().unwrap(), None, true)
                .is_err()
        );
    }

    #[test]
    fn test_sign_and_verify_message_tsig_reject_invalid_mac() {
        let (mut question, signer) = get_message_and_signer();

        let mut query: Query = Query::new();
        let origin: Name = Name::parse("example.net.", None).unwrap();
        query.set_name(origin);
        question.add_query(query);

        assert!(
            signer
                .verify_message_byte(&question.to_bytes().unwrap(), None, true)
                .is_err()
        );
    }
}