@@ -187,10 +187,10 @@ async def check_domain(
187
187
Returns:
188
188
A dictionary containing the status of the domain configuration.
189
189
"""
190
- status = {"cname" : False , "owner_proof" : False }
190
+ status = {}
191
191
192
192
dns_rules = self .get_required_dns_rules (hostname , target , owner )
193
-
193
+ resolver = await self . get_resolver_for ( hostname )
194
194
for dns_rule in dns_rules :
195
195
status [dns_rule .name ] = False
196
196
@@ -199,26 +199,25 @@ async def check_domain(
199
199
record_value = dns_rule .dns ["value" ]
200
200
201
201
try :
202
- resolver = await self .get_resolver_for (hostname )
203
202
entries = await resolver .query (record_name , record_type .upper ())
204
203
except aiodns .error .DNSError :
205
204
# Continue checks
206
205
entries = None
207
206
208
- if entries and record_type == "txt" :
209
- for entry in entries :
210
- if hasattr ( entry , "text" ) and entry . text == record_value :
211
- break
212
- else :
213
- return dns_rule . raise_error ( status )
214
- elif (
215
- entries is None
216
- or not hasattr (entries , record_type )
217
- or getattr ( entries , record_type ) != record_value
218
- ):
219
- return dns_rule . raise_error ( status )
220
-
221
- status [ dns_rule .name ] = True
207
+ if entries :
208
+ if record_type == "txt" :
209
+ for entry in entries :
210
+ if hasattr ( entry , "text" ) and entry . text == record_value :
211
+ status [ dns_rule . name ] = True
212
+ break
213
+ elif (
214
+ hasattr ( entries , record_type )
215
+ and getattr (entries , record_type ) == record_value
216
+ ):
217
+ status [ dns_rule . name ] = True
218
+
219
+ if all ( status . values ()) is False :
220
+ dns_rule .raise_error ( status )
222
221
223
222
return status
224
223
0 commit comments