(
target: str,
timeout: int,
is_parallel: bool = False,
json_output: bool = False,
)
| 419 | |
| 420 | |
| 421 | async def _handle_email( |
| 422 | target: str, |
| 423 | timeout: int, |
| 424 | is_parallel: bool = False, |
| 425 | json_output: bool = False, |
| 426 | ) -> None: |
| 427 | if is_parallel: |
| 428 | print(f"[*] Email scan (parallel): {target}", file=sys.stderr) |
| 429 | email_result, breach_result = await asyncio.gather( |
| 430 | run_email_osint(email=target, timeout_seconds=timeout), |
| 431 | run_breach_osint(email=target), |
| 432 | ) |
| 433 | if json_output: |
| 434 | _emit_json( |
| 435 | [ |
| 436 | format_tool_result("search_email", target, email_result), |
| 437 | format_tool_result("search_breach", target, breach_result), |
| 438 | ] |
| 439 | ) |
| 440 | else: |
| 441 | _print_result_labeled("search_email", email_result) |
| 442 | _print_result_labeled("search_breach", breach_result) |
| 443 | else: |
| 444 | print(f"[*] Email scan: {target}", file=sys.stderr) |
| 445 | print(f"[*] Timeout: {timeout}s\n", file=sys.stderr) |
| 446 | result = await run_email_osint(email=target, timeout_seconds=timeout) |
| 447 | if json_output: |
| 448 | _emit_json(format_tool_result("search_email", target, result)) |
| 449 | else: |
| 450 | _print_result(result) |
| 451 | |
| 452 | |
| 453 | async def _handle_username( |
no test coverage detected