espressif/openthread
1
0
Fork 0
mirror of https://github.com/espressif/openthread.git synced 2026-06-06 05:24:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

[nexus] add SRP-TC-8 for removing some published services (#12771)

Browse Source 
This commit adds the Nexus test case 1_3_SRP_TC_8 which verifies that
the SRP server correctly removes only selected service instances while
keeping others registered, as per the Thread 1.3 test specification.

The implementation includes:
- tests/nexus/test_1_3_SRP_TC_8.cpp: Executes the test sequence by
  configuring a Thread Border Router (DUT), an End Device (ED), and
  an Infrastructure node (Eth). It registers multiple services and
  then removes one while verifying the remaining service.
- tests/nexus/verify_1_3_SRP_TC_8.py: Performs automated verification
  of the captured traffic (PCAP), ensuring that SRP Updates, DNS
  queries, and mDNS responses correctly reflect the removal of the
  selected service and the persistence of the other.
- Integrated the new test into tests/nexus/CMakeLists.txt and
  tests/nexus/run_nexus_tests.sh.

The test ensures that the SRP server properly handles service
deregistration according to the SRP draft and that DNS/mDNS discovery
responses are updated correctly.
This commit is contained in:
Jonathan Hui
2026-03-26 19:27:39 -05:00
committed by GitHub
parent 6dee5af2ae
commit 35512636b8
5 changed files with 957 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/nexus/CMakeLists.txt
+1
View File
@@ -270,6 +270,7 @@ ot_nexus_test(1_3_SRP_TC_3 "cert;nexus")
ot_nexus_test(1_3_SRP_TC_4 "cert;nexus")
ot_nexus_test(1_3_SRP_TC_5 "cert;nexus")
ot_nexus_test(1_3_SRP_TC_6 "cert;nexus")
ot_nexus_test(1_3_SRP_TC_8 "cert;nexus")
# Misc tests
ot_nexus_test(border_admitter "core;nexus")
tests/nexus/run_nexus_tests.sh
+1
View File
@@ -205,6 +205,7 @@ DEFAULT_TESTS=(
"1_3_SRP_TC_4"
"1_3_SRP_TC_5"
"1_3_SRP_TC_6"
"1_3_SRP_TC_8"
)
# Use provided arguments or the default test list
tests/nexus/test_1_3_SRP_TC_8.cpp
+490
View File
@@ -0,0 +1,490 @@
/*
* Copyright (c) 2026, The OpenThread Authors.
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* 3. Neither the name of the copyright holder nor the
* names of its contributors may be used to endorse or promote products
* derived from this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGE.
*/
#include <stdio.h>
#include <string.h>
#include "platform/nexus_core.hpp"
#include "platform/nexus_node.hpp"
#include "common/clearable.hpp"
namespace ot {
namespace Nexus {
/**
* Time to advance for a node to form a network and become leader, in milliseconds.
*/
static constexpr uint32_t kFormNetworkTime = 13 * 1000;
/**
* Time to advance for a node to join a network, in milliseconds.
*/
static constexpr uint32_t kJoinNetworkTime = 10 * 1000;
/**
* Time to advance for SRP server information to be updated in Network Data.
*/
static constexpr uint32_t kSrpServerInfoUpdateTime = 20 * 1000;
/**
* Time to advance for SRP registration, in milliseconds.
*/
static constexpr uint32_t kSrpRegistrationTime = 10 * 1000;
/**
* Time to advance for DNS query processing, in milliseconds.
*/
static constexpr uint32_t kDnsQueryTime = 5 * 1000;
/**
* Infrastructure interface index.
*/
static constexpr uint32_t kInfraIfIndex = 1;
/**
* SRP service registration parameters.
*/
static const char kSrpServiceType[] = "_thread-test._udp";
static const char kSrpInstanceName1[] = "service-test-1";
static const char kSrpInstanceName2[] = "service-test-2";
static const char kSrpHostName[] = "host-test-1";
static const char kSrpFullServiceType[] = "_thread-test._udp.default.service.arpa.";
static constexpr uint16_t kSrpServicePort1 = 55555;
static constexpr uint16_t kSrpServicePort2 = 55556;
static constexpr uint16_t kSrpServicePriority2 = 8;
static constexpr uint32_t kSrpLease = 10 * 60; // 10 minutes
static constexpr uint32_t kSrpKeyLease = 20 * 60; // 20 minutes
static constexpr uint32_t kSrpKeyLeaseShorter = 10 * 60; // 10 minutes
void Test_1_3_SRP_TC_8(const char *aJsonFileName)
{
Srp::Client::Service service1;
Srp::Client::Service service2;
/**
* 2.8. [1.3] [CERT] Removing Some Published Services
*
* 2.8.1. Purpose
* To test the following:
* - 1. Remove only selected service instances, not all.
*
* 2.8.2. Topology
* - BR 1 (DUT) - Thread Border Router and the Leader
* - ED 1-Test Bed device operating as a Thread End Device, attached to BR_1
* - Eth 1-Test Bed border router device on an Adjacent Infrastructure Link
*
* Spec Reference | V1.1 Section | V1.3.0 Section
* -----------------|--------------|---------------
* SRP Server | N/A | 1.3
*/
Core nexus;
Node &br1 = nexus.CreateNode();
Node &ed1 = nexus.CreateNode();
Node &eth1 = nexus.CreateNode();
br1.SetName("BR_1");
ed1.SetName("ED_1");
eth1.SetName("Eth_1");
br1.Form();
nexus.AdvanceTime(0);
Instance::SetLogLevel(kLogLevelNote);
Log("---------------------------------------------------------------------------------------");
/**
* Step 1
* Device: BR 1 (DUT)
* Description (SRP-2.8): Enable
* Pass Criteria:
* - N/A
*/
Log("Step 1: BR 1 (DUT) Enable");
SuccessOrQuit(br1.Get<Srp::Server>().SetAddressMode(Srp::Server::kAddressModeUnicast));
br1.Get<Srp::Server>().SetEnabled(true);
br1.Get<BorderRouter::InfraIf>().Init(kInfraIfIndex, true);
br1.Get<BorderRouter::RoutingManager>().Init();
SuccessOrQuit(br1.Get<BorderRouter::RoutingManager>().SetEnabled(true));
nexus.AdvanceTime(kFormNetworkTime);
/**
* Step 2
* Device: Eth 1, ED 1
* Description (SRP-2.8): Enable
* Pass Criteria:
* - N/A
*/
Log("Step 2: Eth 1, ED 1 Enable");
ed1.Join(br1, Node::kAsFed);
SuccessOrQuit(eth1.Get<Dns::Multicast::Core>().SetEnabled(true, kInfraIfIndex));
nexus.AdvanceTime(kJoinNetworkTime);
/**
* Step 3
* Device: BR_1 (DUT)
* Description (SRP-2.8): Automatically adds SRP Server information in the Thread Network Data. Automatically adds
* OMR prefix in Network Data.
* Pass Criteria:
* - [T1-T6] The DUT's SRP Server information MUST appear in the Thread Network Data.
*/
Log("Step 3: BR 1 (DUT) SRP Server info in Network Data");
nexus.AdvanceTime(kSrpServerInfoUpdateTime);
/**
* Step 4
* Device: ED 1
* Description (SRP-2.8): Harness instructs the device to send SRP Update: $ORIGIN default.service.arpa.
* service-test-1._thread-test._udp ( SRV 55555 host-test-1 ) host-test-1 AAAA <OMR address of ED_1> with the
* following options: Update Lease Option, Lease: 10 minutes, Key Lease: 20 minutes
* Pass Criteria:
* - N/A
*/
Log("Step 4: ED 1 sends SRP Update for service 1");
{
ed1.Get<Srp::Client>().EnableAutoStartMode(nullptr, nullptr);
SuccessOrQuit(ed1.Get<Srp::Client>().SetHostName(kSrpHostName));
SuccessOrQuit(ed1.Get<Srp::Client>().EnableAutoHostAddress());
ed1.Get<Srp::Client>().SetLeaseInterval(kSrpLease);
ed1.Get<Srp::Client>().SetKeyLeaseInterval(kSrpKeyLease);
ClearAllBytes(service1);
service1.mName = kSrpServiceType;
service1.mInstanceName = kSrpInstanceName1;
service1.mPort = kSrpServicePort1;
SuccessOrQuit(ed1.Get<Srp::Client>().AddService(service1));
}
nexus.AdvanceTime(kSrpRegistrationTime);
/**
* Step 5
* Device: BR 1 (DUT)
* Description (SRP-2.8): Automatically sends SRP Update Response.
* Pass Criteria:
* - [T7] The DUT MUST send a valid SRP Update Response, with RCODE=0 (NoError).
*/
Log("Step 5: BR 1 (DUT) sends SRP Update Response");
/**
* Step 6
* Device: ED 1
* Description (SRP-2.8): Harness instructs the device to unicast DNS query QType SRV for
* "service-test-1._thread-test. udp.default.service.arpa." to the DUT.
* Pass Criteria:
* - N/A
*/
Log("Step 6: ED 1 unicast DNS query SRV for service 1");
SuccessOrQuit(ed1.Get<Dns::Client>().ResolveService(kSrpInstanceName1, kSrpFullServiceType, nullptr, nullptr));
nexus.AdvanceTime(kDnsQueryTime);
/**
* Step 7
* Device: BR_1 (DUT)
* Description (SRP-2.8): Automatically sends DNS response.
* Pass Criteria:
* - [T8] The DUT MUST send a valid DNS Response, with RCODE=0 (NoError) and
* - [T9] contains answer record: $ORIGIN default.service.arpa. service-test-1. thread-test._udp ( SRV 55555
* host-test-1 )
* - [T10] The DNS Response MAY contain in Additional records section: SORIGIN default.service.arpa. host-test-1
* AAAA <OMR address of ED 1>
*/
Log("Step 7: BR 1 (DUT) sends DNS response");
/**
* Step 8
* Device: Eth_1
* Description (SRP-2.8): Harness instructs the device to send mDNS query QType SRV for "service-test-1.
* thread-test. udp.local.".
* Pass Criteria:
* - N/A
*/
Log("Step 8: Eth 1 sends mDNS query SRV for service 1");
{
Dns::Multicast::Core::SrvResolver resolver;
ClearAllBytes(resolver);
resolver.mCallback = [](otInstance *, const otPlatDnssdSrvResult *) {};
resolver.mServiceInstance = kSrpInstanceName1;
resolver.mServiceType = kSrpServiceType;
resolver.mInfraIfIndex = kInfraIfIndex;
SuccessOrQuit(eth1.Get<Dns::Multicast::Core>().StartSrvResolver(resolver));
nexus.AdvanceTime(kDnsQueryTime);
SuccessOrQuit(eth1.Get<Dns::Multicast::Core>().StopSrvResolver(resolver));
}
/**
* Step 9
* Device: BR_1 (DUT)
* Description (SRP-2.8): Automatically sends mDNS Response.
* Pass Criteria:
* - [T11] The DUT MUST send a valid mDNS Response, with RCODE=0 (NoError) and
* - [T12] contains answer record: SORIGIN local. service-test-1. thread-test._udp ( SRV 55555 host-test-1 )
* - [T13] DNS Response MAY contain in Additional records section: SORIGIN local. Host-test-1 AAAA <OMR address of
* ED 1>
*/
Log("Step 9: BR 1 (DUT) sends mDNS Response");
/**
* Step 10
* Device: ED_1
* Description (SRP-2.8): Harness instructs the device to send SRP Update, adding one more service: $ORIGIN
* default.service.arpa. service-test-2._thread-test._udp ( SRV 8 55556 host-test-1 ) host-test-1 AAAA <OMR
* address of ED_1> with the following options: Update Lease Option, Lease: 10 minutes, Key Lease: 20 minutes
* Pass Criteria:
* - N/A
*/
Log("Step 10: ED 1 sends SRP Update adding service 2");
{
ClearAllBytes(service2);
service2.mName = kSrpServiceType;
service2.mInstanceName = kSrpInstanceName2;
service2.mPort = kSrpServicePort2;
service2.mPriority = kSrpServicePriority2;
SuccessOrQuit(ed1.Get<Srp::Client>().AddService(service2));
}
nexus.AdvanceTime(kSrpRegistrationTime);
/**
* Step 11
* Device: BR 1 (DUT)
* Description (SRP-2.8): Automatically sends SRP Update Response.
* Pass Criteria:
* - [T14] The DUT MUST send a valid SRP Update Response, with RCODE=0 (NoError).
*/
Log("Step 11: BR 1 (DUT) sends SRP Update Response");
/**
* Step 12
* Device: ED_1
* Description (SRP-2.8): Harness instructs the device to unicast DNS query QType=SRV for service-test-2 to the
* DUT
* Pass Criteria:
* - N/A
*/
Log("Step 12: ED 1 unicast DNS query SRV for service 2");
SuccessOrQuit(ed1.Get<Dns::Client>().ResolveService(kSrpInstanceName2, kSrpFullServiceType, nullptr, nullptr));
nexus.AdvanceTime(kDnsQueryTime);
/**
* Step 13
* Device: BR 1 (DUT)
* Description (SRP-2.8): Automatically sends DNS response.
* Pass Criteria:
* - [T15] The DUT MUST send a valid DNS Response.
* - [T16] containing service-test-2 answer record: $ORIGIN default.service.arpa. service-test-2._thread-test._udp
* ( SRV 55556 host-test-1 )
* - [T17] DNS Response MAY contain in Additional records section: $ORIGIN default.service.arpa. host-test-1 AAAA
* <OMR address of ED_1>
*/
Log("Step 13: BR 1 (DUT) sends DNS response");
/**
* Step 14
* Device: Eth_1
* Description (SRP-2.8): Repeat Step 8. Note: this is repeated to verify that the first service is still there.
* Pass Criteria:
* - Repeat Step 8
*/
Log("Step 14: Eth 1 sends mDNS query SRV for service 1 (repeat)");
{
Dns::Multicast::Core::SrvResolver resolver;
ClearAllBytes(resolver);
resolver.mCallback = [](otInstance *, const otPlatDnssdSrvResult *) {};
resolver.mServiceInstance = kSrpInstanceName1;
resolver.mServiceType = kSrpServiceType;
resolver.mInfraIfIndex = kInfraIfIndex;
SuccessOrQuit(eth1.Get<Dns::Multicast::Core>().StartSrvResolver(resolver));
nexus.AdvanceTime(kDnsQueryTime);
SuccessOrQuit(eth1.Get<Dns::Multicast::Core>().StopSrvResolver(resolver));
}
/**
* Step 15
* Device: BR 1 (DUT)
* Description (SRP-2.8): Repeat Step 9
* Pass Criteria:
* - [T18-T20] Repeat Step 9
*/
Log("Step 15: BR 1 (DUT) sends mDNS Response (repeat)");
/**
* Step 16
* Device: ED 1
* Description (SRP-2.8): Harness instructs device to send SRP Update, removing the first service only: 1. Service
* Discovery Instruction Delete an RR from an RRset semantics using data: $ORIGIN default.service.arpa. PTR
* service-test-1. thread-test._udp 2. Service Description Instruction Delete All RRsets From a Name semantics:
* $ORIGIN default.service.arpa. service-test-1._thread-test._udp ANY <tt1=0> with the following options: Update
* Lease Option, Lease: 10 minutes (unchanged), Key Lease: 10 minutes (shorter). Note: this method to remove a
* service follows 3.2.5.5.2 of [draft-srp-23]. Note: for OT reference device, the command 'srp client
* keyleaseinterval 600' is used to shorten the key lease interval as indicated.
* Pass Criteria:
* - N/A
*/
Log("Step 16: ED 1 sends SRP Update removing service 1");
{
ed1.Get<Srp::Client>().SetKeyLeaseInterval(kSrpKeyLeaseShorter);
SuccessOrQuit(ed1.Get<Srp::Client>().RemoveService(service1));
}
nexus.AdvanceTime(kSrpRegistrationTime);
/**
* Step 17
* Device: BR 1 (DUT)
* Description (SRP-2.8): Automatically sends SRP Update Response.
* Pass Criteria:
* - [T21] The DUT MUST send a valid SRP Update Response, with RCODE=0 (NoError).
*/
Log("Step 17: BR 1 (DUT) sends SRP Update Response");
/**
* Step 18
* Device: ED 1
* Description (SRP-2.8): Harness instructs the device to unicast DNS query QType SRV for "service-test-1.
* thread-test. udp.default.service.arpa." to the DUT
* Pass Criteria:
* - N/A
*/
Log("Step 18: ED 1 unicast DNS query SRV for service 1");
SuccessOrQuit(ed1.Get<Dns::Client>().ResolveService(kSrpInstanceName1, kSrpFullServiceType, nullptr, nullptr));
nexus.AdvanceTime(kDnsQueryTime);
/**
* Step 19
* Device: BR 1 (DUT)
* Description (SRP-2.8): Automatically sends DNS response. Note: the service instance name with all associated
* records has been deleted in step 16.
* Pass Criteria:
* - [T22] The DUT MUST send a valid DNS Response, with RCODE=0 (NoError); and
* - [T23] MUST contain 0 answer records.
*/
Log("Step 19: BR 1 (DUT) sends DNS response (0 answers)");
/**
* Step 20
* Device: ED 1
* Description (SRP-2.8): Harness instructs the device to unicast DNS query QType SRV for "service-test-2.
* thread-test. udp.default.service.arpa." to the DUT.
* Pass Criteria:
* - N/A
*/
Log("Step 20: ED 1 unicast DNS query SRV for service 2");
SuccessOrQuit(ed1.Get<Dns::Client>().ResolveService(kSrpInstanceName2, kSrpFullServiceType, nullptr, nullptr));
nexus.AdvanceTime(kDnsQueryTime);
/**
* Step 21
* Device: BR_1 (DUT)
* Description (SRP-2.8): Automatically sends DNS response.
* Pass Criteria:
* - [T24] The DUT MUST send a valid DNS Response, with RCODE=0 (NoError) and
* - [T25] contains answer record: $ORIGIN default.service.arpa. service-test-2. thread-test._udp ( SRV 55556
* host-test-1 )
* - [T26] DNS Response MAY contain in Additional records section: $ORIGIN default.service.arpa. host-test-1 AAAA
* <OMR address of ED 1>
*/
Log("Step 21: BR 1 (DUT) sends DNS response (service 2)");
/**
* Step 22
* Device: Eth_1
* Description (SRP-2.8): Harness instructs the device to send mDNS query QType SRV for "service-test-1.
* thread-test. udp.local".
* Pass Criteria:
* - N/A
*/
Log("Step 22: Eth 1 sends mDNS query SRV for service 1");
{
Dns::Multicast::Core::SrvResolver resolver;
ClearAllBytes(resolver);
resolver.mCallback = [](otInstance *, const otPlatDnssdSrvResult *) {};
resolver.mServiceInstance = kSrpInstanceName1;
resolver.mServiceType = kSrpServiceType;
resolver.mInfraIfIndex = kInfraIfIndex;
SuccessOrQuit(eth1.Get<Dns::Multicast::Core>().StartSrvResolver(resolver));
nexus.AdvanceTime(kDnsQueryTime);
SuccessOrQuit(eth1.Get<Dns::Multicast::Core>().StopSrvResolver(resolver));
}
/**
* Step 23
* Device: BR_1 (DUT)
* Description (SRP-2.8): Does not send a mDNS response.
* Pass Criteria:
* - [T27] The DUT MUST NOT send an mDNS response.
*/
Log("Step 23: BR 1 (DUT) does NOT send mDNS response");
/**
* Step 24
* Device: Eth 1
* Description (SRP-2.8): Harness instructs the device to send mDNS query QType=PTR any services of type
* "_thread-test._udp.local".
* Pass Criteria:
* - N/A
*/
Log("Step 24: Eth 1 sends mDNS query PTR for services");
{
Dns::Multicast::Core::Browser browser;
ClearAllBytes(browser);
browser.mCallback = [](otInstance *, const otPlatDnssdBrowseResult *) {};
browser.mServiceType = kSrpServiceType;
browser.mInfraIfIndex = kInfraIfIndex;
SuccessOrQuit(eth1.Get<Dns::Multicast::Core>().StartBrowser(browser));
nexus.AdvanceTime(kDnsQueryTime);
SuccessOrQuit(eth1.Get<Dns::Multicast::Core>().StopBrowser(browser));
}
/**
* Step 25
* Device: BR_1 (DUT)
* Description (SRP-2.8): Automatically sends mDNS response with service-test-2.
* Pass Criteria:
* - [T28] The DUT MUST send a valid mDNS Response, with RCODE=0 (NoError) and
* - [T29] contains service-test-2 answer record: $ORIGIN local. _thread-test._udp ( PTR
* service-test-2._thread-test._udp )
* - [T30] Response MUST NOT contain any further records in the Answers section.
* - [T31-32] DNS Response MAY contain in Additional records section: SORIGIN local.
* Service-test-2._thread-test._udp ( SRV 8 0 55556 host-test-1 ) host-test-1 AAAA <OMR address of ED_1>
*/
Log("Step 25: BR 1 (DUT) sends mDNS response with service 2 only");
nexus.SaveTestInfo(aJsonFileName);
}
} // namespace Nexus
} // namespace ot
int main(int argc, char *argv[])
{
ot::Nexus::Test_1_3_SRP_TC_8((argc > 2) ? argv[2] : "test_1_3_SRP_TC_8.json");
printf("All tests passed\n");
return 0;
}
tests/nexus/verify_1_3_SRP_TC_8.py
+454
View File
@@ -0,0 +1,454 @@
#!/usr/bin/env python3
#
# Copyright (c) 2026, The OpenThread Authors.
# All rights reserved.
#
# Redistribution and use in source and binary forms, with or without
# modification, are permitted provided that the following conditions are met:
# 1. Redistributions of source code must retain the above copyright
# notice, this list of conditions and the following disclaimer.
# 2. Redistributions in binary form must reproduce the above copyright
# notice, this list of conditions and the following disclaimer in the
# documentation and/or other materials provided with the distribution.
# 3. Neither the name of the copyright holder nor the
# names of its contributors may be used to endorse or promote products
# derived from this software without specific prior written permission.
#
# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
# AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
# ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
# LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
# CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
# SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
# INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
# CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
# ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
# POSSIBILITY OF SUCH DAMAGE.
#
import sys
import os
import struct
# Add the current directory to sys.path to find verify_utils
CUR_DIR = os.path.dirname(os.path.abspath(__file__))
sys.path.append(CUR_DIR)
import verify_utils
from pktverify import consts
from pktverify.addrs import Ipv6Addr
from pktverify.bytes import Bytes
def verify(pv):
# 2.8. [1.3] [CERT] Removing Some Published Services
#
# 2.8.1. Purpose
# To test the following:
# - 1. Remove only selected service instances, not all.
#
# 2.8.2. Topology
# - BR 1 (DUT) - Thread Border Router and the Leader
# - ED 1-Test Bed device operating as a Thread End Device, attached to BR_1
# - Eth 1-Test Bed border router device on an Adjacent Infrastructure Link
#
# Spec Reference | V1.1 Section | V1.3.0 Section
# -----------------|--------------|---------------
# SRP Server | N/A | 1.3
pkts = pv.pkts
pv.summary.show()
ED_1_MLEID = Ipv6Addr(pv.vars['ED_1_MLEID_ADDR'])
BR_1_MLEID = Ipv6Addr(pv.vars['BR_1_MLEID_ADDR'])
br1_srp_port = int(pv.vars['BR_1_SRP_PORT'])
SRP_SERVICE_NAME = '_thread-test._udp.default.service.arpa'
SRP_INSTANCE_NAME_1 = 'service-test-1.' + SRP_SERVICE_NAME
SRP_INSTANCE_NAME_2 = 'service-test-2.' + SRP_SERVICE_NAME
SRP_HOST_NAME = 'host-test-1.default.service.arpa'
MDNS_SERVICE_NAME = '_thread-test._udp.local'
MDNS_INSTANCE_NAME_1 = 'service-test-1.' + MDNS_SERVICE_NAME
MDNS_INSTANCE_NAME_2 = 'service-test-2.' + MDNS_SERVICE_NAME
SRP_SERVICE_PORT_1 = 55555
SRP_SERVICE_PORT_2 = 55556
SRP_SERVICE_PRIORITY_2 = 8
SRP_LEASE_10M_20M = Bytes(struct.pack('>II', 600, 1200).hex())
SRP_LEASE_10M_10M = Bytes(struct.pack('>II', 600, 600).hex())
SERVICE_ID_SRP_UNICAST_DNS = 93
# Step 1
# Device: BR 1 (DUT)
# Description (SRP-2.8): Enable
# Pass Criteria:
# - N/A
print("Step 1: BR 1 (DUT) Enable")
# Step 2
# Device: Eth 1, ED 1
# Description (SRP-2.8): Enable
# Pass Criteria:
# - N/A
print("Step 2: Eth 1, ED 1 Enable")
# Step 3
# Device: BR_1 (DUT)
# Description (SRP-2.8): Automatically adds SRP Server information in the Thread Network Data. Automatically adds
# OMR prefix in Network Data.
# Pass Criteria:
# - [T1-T6] The DUT's SRP Server information MUST appear in the Thread Network Data.
print("Step 3: BR 1 (DUT) SRP Server info in Network Data")
pkts. \
filter_mle_cmd(consts.MLE_DATA_RESPONSE). \
filter(lambda p: SERVICE_ID_SRP_UNICAST_DNS in verify_utils.as_list(p.thread_nwd.tlv.service.srp_dataset_identifier)). \
must_next()
# Step 4
# Device: ED 1
# Description (SRP-2.8): Harness instructs the device to send SRP Update: $ORIGIN default.service.arpa.
# service-test-1._thread-test._udp ( SRV 55555 host-test-1 ) host-test-1 AAAA <OMR address of ED_1> with the
# following options: Update Lease Option, Lease: 10 minutes, Key Lease: 20 minutes
# Pass Criteria:
# - N/A
print("Step 4: ED 1 sends SRP Update for service 1")
pkts. \
filter_ipv6_dst(BR_1_MLEID). \
filter_ipv6_src(ED_1_MLEID). \
filter(lambda p: p.udp.dstport == br1_srp_port). \
filter(lambda p: p.dns.flags.opcode == consts.DNS_OPCODE_UPDATE). \
filter(lambda p: SRP_INSTANCE_NAME_1 in verify_utils.as_list(p.dns.resp.name)). \
filter(lambda p: SRP_SERVICE_PORT_1 in verify_utils.as_list(p.dns.srv.port)). \
filter(lambda p: SRP_HOST_NAME in verify_utils.as_list(p.dns.srv.target)). \
filter(lambda p: p.dns.opt.data is not None and
any(data.format_compact() == SRP_LEASE_10M_20M.format_compact() for data in p.dns.opt.data)). \
must_next()
# Step 5
# Device: BR 1 (DUT)
# Description (SRP-2.8): Automatically sends SRP Update Response.
# Pass Criteria:
# - [T7] The DUT MUST send a valid SRP Update Response, with RCODE=0 (NoError).
print("Step 5: BR 1 (DUT) sends SRP Update Response")
pkts. \
filter_ipv6_dst(ED_1_MLEID). \
filter_ipv6_src(BR_1_MLEID). \
filter(lambda p: p.udp.srcport == br1_srp_port). \
filter(lambda p: p.dns.flags.response == 1). \
filter(lambda p: p.dns.flags.rcode == consts.DNS_RCODE_NOERROR). \
must_next()
# Step 6
# Device: ED 1
# Description (SRP-2.8): Harness instructs the device to unicast DNS query QType SRV for
# "service-test-1._thread-test. udp.default.service.arpa." to the DUT.
# Pass Criteria:
# - N/A
print("Step 6: ED 1 unicast DNS query SRV for service 1")
pkts. \
filter_ipv6_dst(BR_1_MLEID). \
filter_ipv6_src(ED_1_MLEID). \
filter(lambda p: p.udp.dstport == 53). \
filter(lambda p: p.dns.flags.response == 0). \
filter(lambda p: SRP_INSTANCE_NAME_1 in verify_utils.as_list(p.dns.qry.name)). \
must_next()
# Step 7
# Device: BR_1 (DUT)
# Description (SRP-2.8): Automatically sends DNS response.
# Pass Criteria:
# - [T8] The DUT MUST send a valid DNS Response, with RCODE=0 (NoError) and
# - [T9] contains answer record: $ORIGIN default.service.arpa. service-test-1. thread-test._udp ( SRV 55555
# host-test-1 )
# - [T10] The DNS Response MAY contain in Additional records section: SORIGIN default.service.arpa. host-test-1
# AAAA <OMR address of ED 1>
print("Step 7: BR 1 (DUT) sends DNS response")
pkts. \
filter_ipv6_dst(ED_1_MLEID). \
filter_ipv6_src(BR_1_MLEID). \
filter(lambda p: p.udp.srcport == 53). \
filter(lambda p: p.dns.flags.response == 1). \
filter(lambda p: p.dns.flags.rcode == consts.DNS_RCODE_NOERROR). \
filter(lambda p: SRP_INSTANCE_NAME_1 in verify_utils.as_list(p.dns.resp.name)). \
filter(lambda p: SRP_SERVICE_PORT_1 in verify_utils.as_list(p.dns.srv.port)). \
must_next()
# Step 8
# Device: Eth_1
# Description (SRP-2.8): Harness instructs the device to send mDNS query QType SRV for "service-test-1.
# thread-test. udp.local.".
# Pass Criteria:
# - N/A
print("Step 8: Eth 1 sends mDNS query SRV for service 1")
pkts. \
filter_mDNS_query(MDNS_INSTANCE_NAME_1). \
filter(lambda p: p.dns.qry.type == consts.DNS_TYPE_SRV). \
must_next()
# Step 9
# Device: BR_1 (DUT)
# Description (SRP-2.8): Automatically sends mDNS Response.
# Pass Criteria:
# - [T11] The DUT MUST send a valid mDNS Response, with RCODE=0 (NoError) and
# - [T12] contains answer record: SORIGIN local. service-test-1. thread-test._udp ( SRV 55555 host-test-1 )
# - [T13] DNS Response MAY contain in Additional records section: SORIGIN local. Host-test-1 AAAA <OMR address of
# ED 1>
print("Step 9: BR 1 (DUT) sends mDNS Response")
pkts. \
filter_mDNS_response(). \
filter(lambda p: MDNS_INSTANCE_NAME_1 in verify_utils.as_list(p.dns.resp.name)). \
filter(lambda p: SRP_SERVICE_PORT_1 in verify_utils.as_list(p.dns.srv.port)). \
must_next()
# Step 10
# Device: ED_1
# Description (SRP-2.8): Harness instructs the device to send SRP Update, adding one more service: $ORIGIN
# default.service.arpa. service-test-2._thread-test._udp ( SRV 8 55556 host-test-1 ) host-test-1 AAAA <OMR address
# of ED_1> with the following options: Update Lease Option, Lease: 10 minutes, Key Lease: 20 minutes
# Pass Criteria:
# - N/A
print("Step 10: ED 1 sends SRP Update adding service 2")
pkts. \
filter_ipv6_dst(BR_1_MLEID). \
filter_ipv6_src(ED_1_MLEID). \
filter(lambda p: p.udp.dstport == br1_srp_port). \
filter(lambda p: p.dns.flags.opcode == consts.DNS_OPCODE_UPDATE). \
filter(lambda p: SRP_INSTANCE_NAME_2 in verify_utils.as_list(p.dns.resp.name)). \
filter(lambda p: SRP_SERVICE_PORT_2 in verify_utils.as_list(p.dns.srv.port)). \
filter(lambda p: SRP_SERVICE_PRIORITY_2 in verify_utils.as_list(p.dns.srv.priority)). \
filter(lambda p: p.dns.opt.data is not None and
any(data.format_compact() == SRP_LEASE_10M_20M.format_compact() for data in p.dns.opt.data)). \
must_next()
# Step 11
# Device: BR 1 (DUT)
# Description (SRP-2.8): Automatically sends SRP Update Response.
# Pass Criteria:
# - [T14] The DUT MUST send a valid SRP Update Response, with RCODE=0 (NoError).
print("Step 11: BR 1 (DUT) sends SRP Update Response")
pkts. \
filter_ipv6_dst(ED_1_MLEID). \
filter_ipv6_src(BR_1_MLEID). \
filter(lambda p: p.udp.srcport == br1_srp_port). \
filter(lambda p: p.dns.flags.response == 1). \
filter(lambda p: p.dns.flags.rcode == consts.DNS_RCODE_NOERROR). \
must_next()
# Step 12
# Device: ED_1
# Description (SRP-2.8): Harness instructs the device to unicast DNS query QType=SRV for service-test-2 to the DUT
# Pass Criteria:
# - N/A
print("Step 12: ED 1 unicast DNS query SRV for service 2")
pkts. \
filter_ipv6_dst(BR_1_MLEID). \
filter_ipv6_src(ED_1_MLEID). \
filter(lambda p: p.udp.dstport == 53). \
filter(lambda p: p.dns.flags.response == 0). \
filter(lambda p: SRP_INSTANCE_NAME_2 in verify_utils.as_list(p.dns.qry.name)). \
must_next()
# Step 13
# Device: BR 1 (DUT)
# Description (SRP-2.8): Automatically sends DNS response.
# Pass Criteria:
# - [T15] The DUT MUST send a valid DNS Response.
# - [T16] containing service-test-2 answer record: $ORIGIN default.service.arpa. service-test-2._thread-test._udp
# ( SRV 55556 host-test-1 )
# - [T17] DNS Response MAY contain in Additional records section: $ORIGIN default.service.arpa. host-test-1 AAAA
# <OMR address of ED_1>
print("Step 13: BR 1 (DUT) sends DNS response")
pkts. \
filter_ipv6_dst(ED_1_MLEID). \
filter_ipv6_src(BR_1_MLEID). \
filter(lambda p: p.udp.srcport == 53). \
filter(lambda p: p.dns.flags.response == 1). \
filter(lambda p: p.dns.flags.rcode == consts.DNS_RCODE_NOERROR). \
filter(lambda p: SRP_INSTANCE_NAME_2 in verify_utils.as_list(p.dns.resp.name)). \
filter(lambda p: SRP_SERVICE_PORT_2 in verify_utils.as_list(p.dns.srv.port)). \
must_next()
# Step 14
# Device: Eth_1
# Description (SRP-2.8): Repeat Step 8. Note: this is repeated to verify that the first service is still there.
# Pass Criteria:
# - Repeat Step 8
print("Step 14: Eth 1 sends mDNS query SRV for service 1 (repeat)")
pkts. \
filter_mDNS_query(MDNS_INSTANCE_NAME_1). \
filter(lambda p: p.dns.qry.type == consts.DNS_TYPE_SRV). \
must_next()
# Step 15
# Device: BR 1 (DUT)
# Description (SRP-2.8): Repeat Step 9
# Pass Criteria:
# - [T18-T20] Repeat Step 9
print("Step 15: BR 1 (DUT) sends mDNS Response (repeat)")
pkts. \
filter_mDNS_response(). \
filter(lambda p: MDNS_INSTANCE_NAME_1 in verify_utils.as_list(p.dns.resp.name)). \
filter(lambda p: SRP_SERVICE_PORT_1 in verify_utils.as_list(p.dns.srv.port)). \
must_next()
# Step 16
# Device: ED 1
# Description (SRP-2.8): Harness instructs device to send SRP Update, removing the first service only: 1. Service
# Discovery Instruction Delete an RR from an RRset semantics using data: $ORIGIN default.service.arpa. PTR
# service-test-1. thread-test._udp 2. Service Description Instruction Delete All RRsets From a Name semantics:
# $ORIGIN default.service.arpa. service-test-1._thread-test._udp ANY <tt1=0> with the following options: Update
# Lease Option, Lease: 10 minutes (unchanged), Key Lease: 10 minutes (shorter). Note: this method to remove a
# service follows 3.2.5.5.2 of [draft-srp-23]. Note: for OT reference device, the command 'srp client
# keyleaseinterval 600' is used to shorten the key lease interval as indicated.
# Pass Criteria:
# - N/A
print("Step 16: ED 1 sends SRP Update removing service 1")
pkts. \
filter_ipv6_dst(BR_1_MLEID). \
filter_ipv6_src(ED_1_MLEID). \
filter(lambda p: p.udp.dstport == br1_srp_port). \
filter(lambda p: p.dns.flags.opcode == consts.DNS_OPCODE_UPDATE). \
filter(lambda p: SRP_SERVICE_NAME in verify_utils.as_list(p.dns.resp.name)). \
filter(lambda p: SRP_INSTANCE_NAME_1 in verify_utils.as_list(p.dns.ptr.domain_name)). \
filter(lambda p: SRP_INSTANCE_NAME_1 in verify_utils.as_list(p.dns.resp.name)). \
filter(lambda p: any(ttl == 0 for ttl in verify_utils.as_list(p.dns.resp.ttl))). \
filter(lambda p: p.dns.opt.data is not None and
any(data.format_compact() == SRP_LEASE_10M_10M.format_compact() for data in p.dns.opt.data)). \
must_next()
# Step 17
# Device: BR 1 (DUT)
# Description (SRP-2.8): Automatically sends SRP Update Response.
# Pass Criteria:
# - [T21] The DUT MUST send a valid SRP Update Response, with RCODE=0 (NoError).
print("Step 17: BR 1 (DUT) sends SRP Update Response")
pkts. \
filter_ipv6_dst(ED_1_MLEID). \
filter_ipv6_src(BR_1_MLEID). \
filter(lambda p: p.udp.srcport == br1_srp_port). \
filter(lambda p: p.dns.flags.response == 1). \
filter(lambda p: p.dns.flags.rcode == consts.DNS_RCODE_NOERROR). \
must_next()
# Step 18
# Device: ED 1
# Description (SRP-2.8): Harness instructs the device to unicast DNS query QType SRV for "service-test-1.
# thread-test. udp.default.service.arpa." to the DUT
# Pass Criteria:
# - N/A
print("Step 18: ED 1 unicast DNS query SRV for service 1")
pkts. \
filter_ipv6_dst(BR_1_MLEID). \
filter_ipv6_src(ED_1_MLEID). \
filter(lambda p: p.udp.dstport == 53). \
filter(lambda p: p.dns.flags.response == 0). \
filter(lambda p: SRP_INSTANCE_NAME_1 in verify_utils.as_list(p.dns.qry.name)). \
must_next()
# Step 19
# Device: BR 1 (DUT)
# Description (SRP-2.8): Automatically sends DNS response. Note: the service instance name with all associated
# records has been deleted in step 16.
# Pass Criteria:
# - [T22] The DUT MUST send a valid DNS Response, with RCODE=0 (NoError); and
# - [T23] MUST contain 0 answer records.
print("Step 19: BR 1 (DUT) sends DNS response (0 answers)")
pkts. \
filter_ipv6_dst(ED_1_MLEID). \
filter_ipv6_src(BR_1_MLEID). \
filter(lambda p: p.udp.srcport == 53). \
filter(lambda p: p.dns.flags.response == 1). \
filter(lambda p: p.dns.flags.rcode in (consts.DNS_RCODE_NOERROR, consts.DNS_RCODE_NXDOMAIN)). \
filter(lambda p: p.dns.count.answers == 0). \
must_next()
# Step 20
# Device: ED 1
# Description (SRP-2.8): Harness instructs the device to unicast DNS query QType SRV for "service-test-2.
# thread-test. udp.default.service.arpa." to the DUT.
# Pass Criteria:
# - N/A
print("Step 20: ED 1 unicast DNS query SRV for service 2")
pkts. \
filter_ipv6_dst(BR_1_MLEID). \
filter_ipv6_src(ED_1_MLEID). \
filter(lambda p: p.udp.dstport == 53). \
filter(lambda p: p.dns.flags.response == 0). \
filter(lambda p: SRP_INSTANCE_NAME_2 in verify_utils.as_list(p.dns.qry.name)). \
must_next()
# Step 21
# Device: BR_1 (DUT)
# Description (SRP-2.8): Automatically sends DNS response.
# Pass Criteria:
# - [T24] The DUT MUST send a valid DNS Response, with RCODE=0 (NoError) and
# - [T25] contains answer record: $ORIGIN default.service.arpa. service-test-2. thread-test._udp ( SRV 55556
# host-test-1 )
# - [T26] DNS Response MAY contain in Additional records section: $ORIGIN default.service.arpa. host-test-1 AAAA
# <OMR address of ED 1>
print("Step 21: BR 1 (DUT) sends DNS response (service 2)")
pkts. \
filter_ipv6_dst(ED_1_MLEID). \
filter_ipv6_src(BR_1_MLEID). \
filter(lambda p: p.udp.srcport == 53). \
filter(lambda p: p.dns.flags.response == 1). \
filter(lambda p: p.dns.flags.rcode == consts.DNS_RCODE_NOERROR). \
filter(lambda p: SRP_INSTANCE_NAME_2 in verify_utils.as_list(p.dns.resp.name)). \
filter(lambda p: SRP_SERVICE_PORT_2 in verify_utils.as_list(p.dns.srv.port)). \
must_next()
# Step 22
# Device: Eth_1
# Description (SRP-2.8): Harness instructs the device to send mDNS query QType SRV for "service-test-1.
# thread-test. udp.local".
# Pass Criteria:
# - N/A
print("Step 22: Eth 1 sends mDNS query SRV for service 1")
pkts. \
filter_mDNS_query(MDNS_INSTANCE_NAME_1). \
filter(lambda p: p.dns.qry.type == consts.DNS_TYPE_SRV). \
must_next()
# Step 23
# Device: BR_1 (DUT)
# Description (SRP-2.8): Does not send a mDNS response.
# Pass Criteria:
# - [T27] The DUT MUST NOT send an mDNS response.
print("Step 23: BR 1 (DUT) does NOT send mDNS response")
pkts. \
filter_mDNS_response(). \
filter(lambda p: MDNS_INSTANCE_NAME_1 in verify_utils.as_list(p.dns.resp.name)). \
must_not_next()
# Step 24
# Device: Eth 1
# Description (SRP-2.8): Harness instructs the device to send mDNS query QType=PTR any services of type
# "_thread-test._udp.local".
# Pass Criteria:
# - N/A
print("Step 24: Eth 1 sends mDNS query PTR for services")
pkts. \
filter_mDNS_query(MDNS_SERVICE_NAME). \
filter(lambda p: p.dns.qry.type == consts.DNS_TYPE_PTR). \
must_next()
# Step 25
# Device: BR_1 (DUT)
# Description (SRP-2.8): Automatically sends mDNS response with service-test-2.
# Pass Criteria:
# - [T28] The DUT MUST send a valid mDNS Response, with RCODE=0 (NoError) and
# - [T29] contains service-test-2 answer record: $ORIGIN local. _thread-test._udp ( PTR
# service-test-2._thread-test._udp )
# - [T30] Response MUST NOT contain any further records in the Answers section.
# - [T31-32] DNS Response MAY contain in Additional records section: SORIGIN local.
# Service-test-2._thread-test._udp ( SRV 8 0 55556 host-test-1 ) host-test-1 AAAA <OMR address of ED_1>
print("Step 25: BR 1 (DUT) sends mDNS response with service 2 only")
pkts. \
filter_mDNS_response(). \
filter(lambda p: MDNS_SERVICE_NAME in verify_utils.as_list(p.dns.resp.name)). \
filter(lambda p: MDNS_INSTANCE_NAME_2 in verify_utils.as_list(p.dns.ptr.domain_name)). \
filter(lambda p: p.dns.count.answers == 1). \
must_next()
tests/scripts/thread-cert/pktverify/consts.py
+11 -1
View File
@@ -407,7 +407,7 @@ THREAD_VERSION_1_2 = 3
THREAD_VERSION_1_3 = 4
THREAD_VERSION_1_4 = 5
# ICMPv6 Types
# ICMPV6 Types
ICMPV6_TYPE_DESTINATION_UNREACHABLE = 1
ICMPV6_TYPE_PACKET_TO_BIG = 2
ICMPV6_TYPE_TIME_EXCEEDED = 3
@@ -415,6 +415,16 @@ ICMPV6_TYPE_PARAMETER_PROBLEM = 4
ICMPV6_TYPE_ECHO_REQUEST = 128
ICMPV6_TYPE_ECHO_REPLY = 129
# DNS constants
DNS_OPCODE_UPDATE = 5
DNS_TYPE_A = 1
DNS_TYPE_PTR = 12
DNS_TYPE_TXT = 16
DNS_TYPE_AAAA = 28
DNS_TYPE_SRV = 33
DNS_RCODE_NOERROR = 0
DNS_RCODE_NXDOMAIN = 3
ICMPV6_RA_OPT_TYPE_RIO = 24
THREAD_ALLOWED_ICMPV6_TYPES = [