processing: extract progress reporting from business logic

While trying to update pyright, it started complaining about
potentially unbound variables[^1]. These are not actual correctness
issues, but signals some code smell due to conditionally configured
variables.

The progress bar handling got extracted from `_process_task`, and got
converted to a context manager, so its lifetime management became
simpler. To eliminate if conditions sprinkled everywhere, a
`NullProgressDisplay` is also added for the case where we want to do
nothing.

[^1]:

    ```
    /home/vlaci/devel/git/github.com/onekey-sec/unblob/unblob/processing.py
      /home/vlaci/devel/git/github.com/onekey-sec/unblob/unblob/processing.py:163:36 - error: "progress_display" is possibly unbound (reportUnboundVariable)
      /home/vlaci/devel/git/github.com/onekey-sec/unblob/unblob/processing.py:164:13 - error: "progress_display" is possibly unbound (reportUnboundVariable)
      /home/vlaci/devel/git/github.com/onekey-sec/unblob/unblob/processing.py:165:17 - error: "overall_progress_task" is possibly unbound (reportUnboundVariable)
      /home/vlaci/devel/git/github.com/onekey-sec/unblob/unblob/processing.py:167:23 - error: "progress_display" is possibly unbound (reportUnboundVariable)
      /home/vlaci/devel/git/github.com/onekey-sec/unblob/unblob/processing.py:184:9 - error: "progress_display" is possibly unbound (reportUnboundVariable)
      /home/vlaci/devel/git/github.com/onekey-sec/unblob/unblob/processing.py:184:38 - error: "overall_progress_task" is possibly unbound (reportUnboundVariable)
      /home/vlaci/devel/git/github.com/onekey-sec/unblob/unblob/processing.py:185:9 - error: "progress_display" is possibly unbound (reportUnboundVariable)
    7 errors, 0 warnings, 0 informations
    ```

Author: vlaci

tests/test_cli.py

@@ -1,5 +1,5 @@
 from pathlib import Path
-from typing import List, Optional
+from typing import List, Optional, Type
 from unittest import mock
 
 import pytest
@@ -11,6 +11,11 @@
 from unblob.handlers import BUILTIN_HANDLERS
 from unblob.models import DirectoryHandler, Glob, Handler, HexString, MultiFile
 from unblob.processing import DEFAULT_DEPTH, DEFAULT_PROCESS_NUM, ExtractionConfig
+from unblob.ui import (
+    NullProgressReporter,
+    ProgressReporter,
+    RichConsoleProgressReporter,
+)
 
 
 class TestHandler(Handler):
@@ -174,18 +179,50 @@ def test_dir_for_file(tmp_path: Path):
 
 
 @pytest.mark.parametrize(
-    "params, expected_depth, expected_entropy_depth, expected_process_num, expected_verbosity",
+    "params, expected_depth, expected_entropy_depth, expected_process_num, expected_verbosity, expected_progress_reporter",
     [
-        pytest.param([], DEFAULT_DEPTH, 1, DEFAULT_PROCESS_NUM, 0, id="empty"),
         pytest.param(
-            ["--verbose"], DEFAULT_DEPTH, 1, DEFAULT_PROCESS_NUM, 1, id="verbose-1"
+            [],
+            DEFAULT_DEPTH,
+            1,
+            DEFAULT_PROCESS_NUM,
+            0,
+            RichConsoleProgressReporter,
+            id="empty",
+        ),
+        pytest.param(
+            ["--verbose"],
+            DEFAULT_DEPTH,
+            1,
+            DEFAULT_PROCESS_NUM,
+            1,
+            NullProgressReporter,
+            id="verbose-1",
+        ),
+        pytest.param(
+            ["-vv"],
+            DEFAULT_DEPTH,
+            1,
+            DEFAULT_PROCESS_NUM,
+            2,
+            NullProgressReporter,
+            id="verbose-2",
+        ),
+        pytest.param(
+            ["-vvv"],
+            DEFAULT_DEPTH,
+            1,
+            DEFAULT_PROCESS_NUM,
+            3,
+            NullProgressReporter,
+            id="verbose-3",
+        ),
+        pytest.param(
+            ["--depth", "2"], 2, 1, DEFAULT_PROCESS_NUM, 0, mock.ANY, id="depth"
         ),
-        pytest.param(["-vv"], DEFAULT_DEPTH, 1, DEFAULT_PROCESS_NUM, 2, id="verbose-2"),
         pytest.param(
-            ["-vvv"], DEFAULT_DEPTH, 1, DEFAULT_PROCESS_NUM, 3, id="verbose-3"
+            ["--process-num", "2"], DEFAULT_DEPTH, 1, 2, 0, mock.ANY, id="process-num"
         ),
-        pytest.param(["--depth", "2"], 2, 1, DEFAULT_PROCESS_NUM, 0, id="depth"),
-        pytest.param(["--process-num", "2"], DEFAULT_DEPTH, 1, 2, 0, id="process-num"),
     ],
 )
 def test_archive_success(
@@ -194,6 +231,7 @@ def test_archive_success(
     expected_entropy_depth: int,
     expected_process_num: int,
     expected_verbosity: int,
+    expected_progress_reporter: Type[ProgressReporter],
     tmp_path: Path,
 ):
     runner = CliRunner()
@@ -225,6 +263,7 @@ def test_archive_success(
         process_num=expected_process_num,
         handlers=BUILTIN_HANDLERS,
         verbose=expected_verbosity,
+        progress_reporter=expected_progress_reporter,
     )
     process_file_mock.assert_called_once_with(config, in_path, None)
     logger_config_mock.assert_called_once_with(expected_verbosity, tmp_path, log_path)

unblob/cli.py

@@ -26,6 +26,7 @@
     ExtractionConfig,
     process_file,
 )
+from .ui import NullProgressReporter, RichConsoleProgressReporter
 
 logger = get_logger()
 
@@ -258,6 +259,9 @@ def cli(
         dir_handlers=dir_handlers,
         keep_extracted_chunks=keep_extracted_chunks,
         verbose=verbose,
+        progress_reporter=NullProgressReporter
+        if verbose
+        else RichConsoleProgressReporter,
     )
 
     logger.info("Start processing file", file=file)

unblob/processing.py

@@ -2,13 +2,11 @@
 import shutil
 from operator import attrgetter
 from pathlib import Path
-from typing import Iterable, List, Optional, Sequence, Set, Tuple
+from typing import Iterable, List, Optional, Sequence, Set, Tuple, Type
 
 import attr
 import magic
 import plotext as plt
-from rich import progress
-from rich.style import Style
 from structlog import get_logger
 from unblob_native import math_tools as mt
 
@@ -45,6 +43,7 @@
     UnknownError,
 )
 from .signals import terminate_gracefully
+from .ui import NullProgressReporter, ProgressReporter
 
 logger = get_logger()
 
@@ -94,6 +93,7 @@ class ExtractionConfig:
     handlers: Handlers = BUILTIN_HANDLERS
     dir_handlers: DirectoryHandlers = BUILTIN_DIR_HANDLERS
     verbose: int = 1
+    progress_reporter: Type[ProgressReporter] = NullProgressReporter
 
     def get_extract_dir_for(self, path: Path) -> Path:
         """Return extraction dir under root with the name of path."""
@@ -146,26 +146,11 @@ def _process_task(config: ExtractionConfig, task: Task) -> ProcessResult:
     processor = Processor(config)
     aggregated_result = ProcessResult()
 
-    if not config.verbose:
-        progress_display = progress.Progress(
-            progress.TextColumn(
-                "Extraction progress: {task.percentage:>3.0f}%",
-                style=Style(color="#00FFC8"),
-            ),
-            progress.BarColumn(
-                complete_style=Style(color="#00FFC8"), style=Style(color="#002060")
-            ),
-        )
-        progress_display.start()
-        overall_progress_task = progress_display.add_task("Extraction progress:")
+    progress_reporter = config.progress_reporter()
 
     def process_result(pool, result):
-        if config.verbose == 0 and progress_display.tasks[0].total is not None:
-            progress_display.update(
-                overall_progress_task,
-                advance=1,
-                total=progress_display.tasks[0].total + len(result.subtasks),
-            )
+        progress_reporter.update(result)
+
         for new_task in result.subtasks:
             pool.submit(new_task)
         aggregated_result.register(result)
@@ -176,14 +161,10 @@ def process_result(pool, result):
         result_callback=process_result,
     )
 
-    with pool:
+    with pool, progress_reporter:
         pool.submit(task)
         pool.process_until_done()
 
-    if not config.verbose:
-        progress_display.remove_task(overall_progress_task)
-        progress_display.stop()
-
     return aggregated_result
 
 

unblob/ui.py

@@ -0,0 +1,57 @@
+from typing import Protocol
+
+from rich import progress
+from rich.style import Style
+
+from .models import TaskResult
+
+
+class ProgressReporter(Protocol):
+    def __enter__(self):
+        ...
+
+    def __exit__(self, _exc_type, _exc_value, _tb):
+        ...
+
+    def update(self, result: TaskResult):
+        ...
+
+
+class NullProgressReporter:
+    def __enter__(self):
+        pass
+
+    def __exit__(self, _exc_type, _exc_value, _tb):
+        pass
+
+    def update(self, result: TaskResult):
+        pass
+
+
+class RichConsoleProgressReporter:
+    def __init__(self):
+        self._progress = progress.Progress(
+            progress.TextColumn(
+                "Extraction progress: {task.percentage:>3.0f}%",
+                style=Style(color="#00FFC8"),
+            ),
+            progress.BarColumn(
+                complete_style=Style(color="#00FFC8"), style=Style(color="#002060")
+            ),
+        )
+        self._overall_progress_task = self._progress.add_task("Extraction progress:")
+
+    def __enter__(self):
+        self._progress.start()
+
+    def __exit__(self, _exc_type, _exc_value, _tb):
+        self._progress.remove_task(self._overall_progress_task)
+        self._progress.stop()
+
+    def update(self, result: TaskResult):
+        if (total := self._progress.tasks[0].total) is not None:
+            self._progress.update(
+                self._overall_progress_task,
+                advance=1,
+                total=total + len(result.subtasks),
+            )