]> git.ipfire.org Git - thirdparty/pdns.git/commitdiff
Use assertIn
authorJosh Soref <2119212+jsoref@users.noreply.github.com>
Wed, 12 Nov 2025 19:17:36 +0000 (14:17 -0500)
committerJosh Soref <2119212+jsoref@users.noreply.github.com>
Wed, 12 Nov 2025 21:45:26 +0000 (16:45 -0500)
https://docs.python.org/3/library/unittest.html#unittest.TestCase.assertIn
Signed-off-by: Josh Soref <2119212+jsoref@users.noreply.github.com>
regression-tests.auth-py/authtests.py
regression-tests.dnsdist/test_API.py
regression-tests.dnsdist/test_DOH.py
regression-tests.dnsdist/test_OpenTelemetryTracing.py
regression-tests.dnsdist/test_SNMP.py
regression-tests.recursor-dnssec/recursortests.py
regression-tests.recursor-dnssec/test_Protobuf.py
regression-tests.recursor-dnssec/test_SNMP.py

index 1ad1abb2b999a2393d1483d76f7357a6fb5eef5e..5ffe878f0170722dc8774e9fd368a98d7744788d 100644 (file)
@@ -492,7 +492,7 @@ options {
             raise TypeError("msg is not a dns.message.Message")
 
         msgFlags = dns.flags.to_text(msg.flags)
-        self.assertTrue('AD' in msgFlags, "No AD flag found in the message for %s" % msg.question[0].name)
+        self.assertIn('AD', msgFlags, "No AD flag found in the message for %s" % msg.question[0].name)
 
     def assertRRsetInAnswer(self, msg, rrset):
         """Asserts the rrset (without comparing TTL) exists in the
index 72529696bb8a59d55c27f6aa164334681cbaaabc..3da966fd14da3d9784e1308f7f72646bf87e3fed 100644 (file)
@@ -154,7 +154,7 @@ class TestAPIBasics(APITestsBase):
                         'qps', 'queries', 'order', 'tcpLatency', 'responses', 'nonCompliantResponses']:
                 self.assertGreaterEqual(server[key], 0)
 
-            self.assertTrue(server['state'] in ['up', 'down', 'UP', 'DOWN'])
+            self.assertIn(server['state'], ['up', 'down', 'UP', 'DOWN'])
 
         for frontend in content['frontends']:
             for key in ['id', 'address', 'udp', 'tcp', 'type', 'queries', 'nonCompliantQueries']:
@@ -211,7 +211,7 @@ class TestAPIBasics(APITestsBase):
                         'qps', 'queries', 'order', 'tcpLatency', 'responses', 'nonCompliantResponses']:
                 self.assertGreaterEqual(server[key], 0)
 
-            self.assertTrue(server['state'] in ['up', 'down', 'UP', 'DOWN'])
+            self.assertIn(server['state'], ['up', 'down', 'UP', 'DOWN'])
 
     def testServersIDontExist(self):
         """
@@ -542,7 +542,7 @@ class TestAPICustomHeaders(APITestsBase):
         self.assertTrue(r)
         self.assertEqual(r.status_code, 200)
         self.assertEqual(r.headers.get('x-powered-by'), "dnsdist")
-        self.assertTrue("x-frame-options" in r.headers)
+        self.assertIn("x-frame-options", r.headers)
 
 class TestStatsWithoutAuthentication(APITestsBase):
     __test__ = True
index 7df517e7e7d5b1874b5a818bfefa29831f9f3bce..87275902490d5babc8fadb04d020257254121ff8 100644 (file)
@@ -89,11 +89,11 @@ class DOHTests(object):
         self.assertTrue(receivedResponse)
         receivedQuery.id = expectedQuery.id
         self.assertEqual(expectedQuery, receivedQuery)
-        self.assertTrue((self._customResponseHeader1) in self._response_headers.decode())
-        self.assertTrue((self._customResponseHeader2) in self._response_headers.decode())
+        self.assertIn(self._customResponseHeader1, self._response_headers.decode())
+        self.assertIn(self._customResponseHeader2, self._response_headers.decode())
         self.assertFalse(('UPPERCASE: VaLuE' in self._response_headers.decode()))
-        self.assertTrue(('uppercase: VaLuE' in self._response_headers.decode()))
-        self.assertTrue(('cache-control: max-age=3600' in self._response_headers.decode()))
+        self.assertIn('uppercase: VaLuE', self._response_headers.decode())
+        self.assertIn('cache-control: max-age=3600', self._response_headers.decode())
         self.checkQueryEDNSWithoutECS(expectedQuery, receivedQuery)
         self.assertEqual(response, receivedResponse)
         self.checkHasHeader('cache-control', 'max-age=3600')
@@ -694,7 +694,7 @@ class DOHTests(object):
         self.assertTrue(receivedResponse)
         self.assertEqual(receivedResponse, b'Plaintext answer')
         self.assertEqual(self._rcode, 200)
-        self.assertTrue('content-type: text/plain' in self._response_headers.decode())
+        self.assertIn('content-type: text/plain', self._response_headers.decode())
 
     def testHTTPStatusAction307(self):
         """
@@ -707,7 +707,7 @@ class DOHTests(object):
         (_, receivedResponse) = self.sendDOHQuery(self._dohServerPort, self._serverName, self._dohBaseURL, query, caFile=self._caCert, useQueue=False, rawResponse=True)
         self.assertTrue(receivedResponse)
         self.assertEqual(self._rcode, 307)
-        self.assertTrue('location: https://doh.powerdns.org' in self._response_headers.decode())
+        self.assertIn('location: https://doh.powerdns.org', self._response_headers.decode())
 
     def testHTTPLuaResponse(self):
         """
@@ -721,7 +721,7 @@ class DOHTests(object):
         self.assertTrue(receivedResponse)
         self.assertEqual(receivedResponse, b'It works!')
         self.assertEqual(self._rcode, 200)
-        self.assertTrue('content-type: text/plain' in self._response_headers.decode())
+        self.assertIn('content-type: text/plain', self._response_headers.decode())
 
     def testHTTPEarlyResponse(self):
         """
@@ -1495,7 +1495,7 @@ class DOHFFI(object):
         self.assertTrue(receivedResponse)
         self.assertEqual(receivedResponse, b'It works!')
         self.assertEqual(self._rcode, 200)
-        self.assertTrue('content-type: text/plain' in self._response_headers.decode())
+        self.assertIn('content-type: text/plain', self._response_headers.decode())
 
 class TestDOHFFINGHTTP2(DOHFFI, DNSDistDOHTest):
     _dohLibrary = 'nghttp2'
index 49d991f6a07c5e574430cee8d31169681c312f85..a7fe3d489c9bec7a99b2f85f9a8f17c5901bd7cd 100644 (file)
@@ -90,7 +90,7 @@ class DNSDistOpenTelemetryProtobufBaseTest(DNSDistOpenTelemetryProtobufTest):
 
         # Ensure all attributes exist
         for field in ot_data["resource_spans"][0]["resource"]["attributes"]:
-            self.assertTrue(field["key"] in ["service.name"])
+            self.assertIn(field["key"], ["service.name"])
 
         # Ensure the values are correct
         # TODO: query.remote with port
index 34552a03e2b81ba3a6f97d3978ab5cf24275db86..c7859ac0908eb3b1be04c55dfe7c0778b042f2a4 100644 (file)
@@ -27,7 +27,7 @@ class TestSNMP(DNSDistTest):
     def _checkStatsValues(self, results, queriesCountersValue):
         for i in list(range(1, 5)) + list(range(6, 20)) + list(range(24, 35)) + [ 35 ] :
             oid = self._snmpOID + '.1.' + str(i) + '.0'
-            self.assertTrue(oid in results)
+            self.assertIn(oid, results)
             self.assertTrue(isinstance(results[oid], Counter64))
 
         for i in range(20, 23):
index 249dd66d4d6fc541532724928aaa0e862826e4c1..689be837398facbc8b65e04f9024a70f2894402c 100644 (file)
@@ -969,7 +969,7 @@ distributor-threads={threads}
             raise TypeError("msg is not a dns.message.Message")
 
         msgFlags = dns.flags.to_text(msg.flags)
-        self.assertTrue('AD' in msgFlags, "No AD flag found in the message for %s" % msg.question[0].name)
+        self.assertIn('AD', msgFlags, "No AD flag found in the message for %s" % msg.question[0].name)
 
     def assertRRsetInAnswer(self, msg, rrset):
         """Asserts the rrset (without comparing TTL) exists in the
index 894c81ff0bfe5add736a014684f2b13671e4db82..f673db10519c812c2f47ab866a97a216a72cadfc 100644 (file)
@@ -244,7 +244,7 @@ class TestRecursorProtobuf(RecursorTest):
         #print(msg.response.tags)
         self.assertEqual(len(msg.response.tags), len(tags))
         for tag in msg.response.tags:
-            self.assertTrue(tag in tags)
+            self.assertIn(tag, tags)
 
     def checkProtobufMetas(self, msg, metas):
         #print(metas)
@@ -254,11 +254,11 @@ class TestRecursorProtobuf(RecursorTest):
         for m in msg.meta:
             self.assertTrue(m.HasField('key'))
             self.assertTrue(m.HasField('value'))
-            self.assertTrue(m.key in metas)
+            self.assertIn(m.key, metas)
             for i in m.value.intVal :
-              self.assertTrue(i in metas[m.key]['intVal'])
+              self.assertIn(i, metas[m.key]['intVal'])
             for s in m.value.stringVal :
-              self.assertTrue(s in metas[m.key]['stringVal'])
+              self.assertIn(s, metas[m.key]['stringVal'])
 
     def checkProtobufOutgoingQuery(self, msg, protocol, query, qclass, qtype, qname, initiator='127.0.0.1', length=None, expectedECS=None):
         self.assertEqual(msg.type, dnsmessage_pb2.PBDNSMessage.DNSOutgoingQueryType)
@@ -1526,7 +1526,7 @@ auth-zones=example=configs/%s/example.zone""" % _confdir
         self.checkProtobufResponse(msg, dnsmessage_pb2.PBDNSMessage.UDP, res, '127.0.0.1', receivedSize=len(raw))
         self.assertEqual(len(msg.response.rrs), 5)
         for rr in msg.response.rrs:
-            self.assertTrue(rr.type in [dns.rdatatype.AAAA, dns.rdatatype.TXT, dns.rdatatype.MX, dns.rdatatype.SPF, dns.rdatatype.SRV])
+            self.assertIn(rr.type, [dns.rdatatype.AAAA, dns.rdatatype.TXT, dns.rdatatype.MX, dns.rdatatype.SPF, dns.rdatatype.SRV])
 
             if rr.type == dns.rdatatype.AAAA:
                 self.checkProtobufResponseRecord(rr, dns.rdataclass.IN, dns.rdatatype.AAAA, name, 15)
index 34088ba8d3718737add87680f2170b91efa058e9..c25ecb73014989a5243218f3ff0ea8b0f14b158f 100644 (file)
@@ -24,7 +24,7 @@ class SNMPTest(RecursorTest):
         count = 161
         for i in list(range(1, count)):
             oid = self._snmpOID + '.1.' + str(i) + '.0'
-            self.assertTrue(oid in results)
+            self.assertIn(oid, results)
             self.assertTrue(isinstance(results[oid], Counter64))
 
         oid = self._snmpOID + '.1.' + str(count + 1) + '.0'