docs(core): remove redundant inline notes

Author: frankovo

src/dns_benchmark/cli.py

@@ -161,7 +161,7 @@ def benchmark(
         progress_bar = None
         if not quiet:
             progress_bar = create_progress_bar(total_queries, "DNS Queries")
-            
+
             # New callback signature: (completed, total)
             def _progress_cb(completed: int, total: int) -> None:
                 """TQDM-friendly progress callback.

src/dns_benchmark/core.py

@@ -50,16 +50,10 @@ def __init__(
         self.timeout = timeout
         self.max_retries = max_retries
         self.semaphore = asyncio.Semaphore(max_concurrent_queries)
-        # self.progress_callback: Optional[Callable[[], None]] = None
         self.progress_callback: Optional[Callable[[int, int], None]] = None
         self.query_counter = 0  # New
         self.total_queries = 0  # New
 
-    # def set_progress_callback(self, callback: Callable[[], None]) -> None:
-    #     """Set callback for progress updates."""
-    #     self.progress_callback = callback
-    #     return None
-
     def set_progress_callback(self, callback: Callable[[int, int], None]) -> None:
         """Set callback for progress updates with completed/total counts."""
         self.progress_callback = callback
@@ -91,23 +85,6 @@ async def query_single(
                         else []
                     )
                     ttl = response.rrset.ttl if response.rrset else None
-
-                    # Update progress
-                    # if self.progress_callback:
-                    #     self.progress_callback()
-
-                    # return DNSQueryResult(
-                    #     resolver_ip=resolver_ip,
-                    #     resolver_name=resolver_name,
-                    #     domain=domain,
-                    #     record_type=record_type,
-                    #     start_time=start_time,
-                    #     end_time=end_time,
-                    #     latency_ms=latency_ms,
-                    #     status=QueryStatus.SUCCESS,
-                    #     answers=answers,
-                    #     ttl=ttl,
-                    # )
                     result = DNSQueryResult(
                         resolver_ip=resolver_ip,
                         resolver_name=resolver_name,
@@ -123,14 +100,10 @@ async def query_single(
                     if self.progress_callback:
                         self.query_counter += 1
                         self.progress_callback(self.query_counter, self.total_queries)
-
                     return result
-
             except dns.exception.Timeout:
                 if attempt == self.max_retries:
                     end_time = time.time()
-                    # if self.progress_callback:
-                    #     self.progress_callback()
                     if self.progress_callback:
                         self.query_counter += 1
                         self.progress_callback(self.query_counter, self.total_queries)
@@ -148,11 +121,8 @@ async def query_single(
                         error_message="Query timeout",
                     )
                 await asyncio.sleep(2**attempt)
-
             except dns.resolver.NXDOMAIN:
                 end_time = time.time()
-                # if self.progress_callback:
-                #     self.progress_callback()
                 if self.progress_callback:
                     self.query_counter += 1
                     self.progress_callback(self.query_counter, self.total_queries)
@@ -169,11 +139,8 @@ async def query_single(
                     ttl=None,
                     error_message="Non-existent domain",
                 )
-
             except dns.resolver.NoNameservers:
                 end_time = time.time()
-                # if self.progress_callback:
-                #     self.progress_callback()
                 if self.progress_callback:
                     self.query_counter += 1
                     self.progress_callback(self.query_counter, self.total_queries)
@@ -190,16 +157,12 @@ async def query_single(
                     ttl=None,
                     error_message="Server failure",
                 )
-
             except Exception as e:
                 if attempt == self.max_retries:
                     end_time = time.time()
                     error_status = QueryStatus.UNKNOWN_ERROR
                     if "refused" in str(e).lower():
                         error_status = QueryStatus.CONNECTION_REFUSED
-
-                    # if self.progress_callback:
-                    #     self.progress_callback()
                     if self.progress_callback:
                         self.query_counter += 1
                         self.progress_callback(self.query_counter, self.total_queries)
@@ -250,17 +213,6 @@ async def run_benchmark(
         )
 
         tasks = []
-        # for resolver in resolvers:
-        #     for domain in domains:
-        #         for record_type in record_types:
-        #             task = self.query_single(
-        #                 resolver_ip=resolver["ip"],
-        #                 resolver_name=resolver["name"],
-        #                 domain=domain,
-        #                 record_type=record_type,
-        #             )
-        #             tasks.append(task)
-
         for iteration in range(iterations):
             for resolver in resolvers:
                 for domain in domains: