feat: update middleware [OpsPortal]

Signed-off-by: Damian Skrzyński <polprog.tech@gmail.com>

Author: polprog-dev

.github/workflows/ci.yml

@@ -25,10 +25,12 @@ jobs:
           python-version: ${{ matrix.python-version }}
 
       - name: Install dependencies
-        run: pip install -e ".[dev]" httpx
+        run: pip install -e ".[dev]"
 
       - name: Lint with ruff
-        run: ruff check src/ tests/
+        run: |
+          ruff check src/ tests/
+          ruff format --check src/ tests/
 
       - name: Run tests
         run: pytest --cov=flowboard --cov-report=xml -v --junitxml=test-results.xml

.gitignore

@@ -27,3 +27,7 @@ venv/
 *.swo
 *~
 .DS_Store
+
+# OpsPortal runtime
+opsportal.yaml
+work/

README.md

@@ -1,5 +1,5 @@
 <p align="center">
-  <img src="docs/assets/logo-full.svg" alt="FlowBoard" width="420">
+  <img src="docs/assets/logo-full.svg" alt="FlowBoard" width="370">
 </p>
 
 <p align="center">

docs/assets/logo-full.svg

@@ -39,6 +39,7 @@ dev = [
     "pytest>=7.4,<9",
     "pytest-cov>=4.1,<6",
     "responses>=0.24,<1",
+    "httpx>=0.27,<1",
     "ruff>=0.4,<1",
     "mypy>=1.8,<2",
 ]

pyproject.toml

@@ -26,17 +26,21 @@
 
 def _timed(stage: str):
     """Log pipeline stage timing at INFO level."""
+
     class _Timer:
         def __enter__(self):
             self.start = time.monotonic()
             logger.info("Pipeline stage '%s' started.", stage)
             return self
+
         def __exit__(self, *exc):
             elapsed = time.monotonic() - self.start
             logger.info(
                 "Pipeline stage '%s' completed in %.2fs.",
-                stage, elapsed,
+                stage,
+                elapsed,
             )
+
     return _Timer()
 
 
@@ -70,7 +74,9 @@ def run(self) -> Path:
         total = time.monotonic() - pipeline_start
         logger.info(
             "Dashboard generated: %s (total pipeline: %.2fs, issues: %d)",
-            output_path, total, len(snapshot.issues),
+            output_path,
+            total,
+            len(snapshot.issues),
         )
         return output_path
 
@@ -93,9 +99,7 @@ def _render(self, snapshot: BoardSnapshot) -> Path:
         # Blocker #16: pre-check output directory writability
         output_path.parent.mkdir(parents=True, exist_ok=True)
         if not os.access(output_path.parent, os.W_OK):
-            raise PermissionError(
-                f"Output directory is not writable: {output_path.parent}"
-            )
+            raise PermissionError(f"Output directory is not writable: {output_path.parent}")
         output_path.write_text(html, encoding="utf-8")
         return output_path
 
@@ -117,6 +121,7 @@ def snapshot_from_payload(self, raw: dict[str, Any]) -> BoardSnapshot:
 # Standalone analysis helper (no orchestrator instance needed)
 # ------------------------------------------------------------------
 
+
 def analyse_raw_payload(
     raw: dict[str, Any],
     config: FlowBoardConfig,

src/flowboard/application/orchestrator.py

@@ -33,7 +33,9 @@ def describe_config(config: FlowBoardConfig, t: Translator | None = None) -> dic
     return {
         "jira_url": config.jira.base_url or t("config.not_set"),
         "auth_email": config.jira.auth_email or t("config.not_set"),
-        "auth_token": mask_secret(config.jira.auth_token) if config.jira.auth_token else t("config.not_set"),
+        "auth_token": mask_secret(config.jira.auth_token)
+        if config.jira.auth_token
+        else t("config.not_set"),
         "projects": ", ".join(config.jira.projects) or t("config.all"),
         "boards": ", ".join(str(b) for b in config.jira.boards) or t("config.auto_detect"),
         "teams": str(len(config.teams)),

src/flowboard/application/services.py

@@ -221,7 +221,11 @@ def compute_flow_metrics(
 
     avg_ct = statistics.mean(ct_values) if ct_values else 0.0
     median_ct = statistics.median(ct_values) if ct_values else 0.0
-    p85_ct = sorted(ct_values)[min(int(len(ct_values) * 0.85), len(ct_values) - 1)] if len(ct_values) > 1 else avg_ct
+    p85_ct = (
+        sorted(ct_values)[min(int(len(ct_values) * 0.85), len(ct_values) - 1)]
+        if len(ct_values) > 1
+        else avg_ct
+    )
     avg_lt = statistics.mean(lt_values) if lt_values else 0.0
 
     # Throughput per week (average of non-zero weeks)

src/flowboard/domain/kanban_compute.py

@@ -18,9 +18,11 @@
 # Data structures
 # ---------------------------------------------------------------------------
 
+
 @dataclass(frozen=True, slots=True)
 class PISprintSlot:
     """One sprint slot inside a PI."""
+
     index: int  # 1-based (1 … sprints_per_pi)
     name: str
     start_date: date
@@ -34,6 +36,7 @@ class PISprintSlot:
 @dataclass(slots=True)
 class PISnapshot:
     """Complete PI-level snapshot for the presentation layer."""
+
     name: str
     start_date: date
     end_date: date
@@ -50,6 +53,7 @@ class PISnapshot:
 # Business-day helpers
 # ---------------------------------------------------------------------------
 
+
 def _to_wd_set(working_days: list[int] | frozenset[int] | None) -> frozenset[int]:
     if working_days is None:
         return DEFAULT_WORKING_DAYS
@@ -104,6 +108,7 @@ def count_working_days(start: date, end: date, working_days: list[int] | None =
 # Sprint boundary computation
 # ---------------------------------------------------------------------------
 
+
 def compute_sprint_boundaries(
     pi_start: date,
     sprint_length: int = 10,
@@ -139,6 +144,7 @@ def compute_sprint_boundaries(
 # PI snapshot computation
 # ---------------------------------------------------------------------------
 
+
 def compute_pi_snapshot(
     name: str,
     pi_start_iso: str,
@@ -192,19 +198,23 @@ def compute_pi_snapshot(
             elapsed = total_wd if today > s_end else 0
             remaining = 0 if today > s_end else total_wd
 
-        slots.append(PISprintSlot(
-            index=i,
-            name=f"{sprint_name_prefix} {i}",
-            start_date=s_start,
-            end_date=s_end,
-            is_current=is_current,
-            working_days_total=total_wd,
-            working_days_elapsed=elapsed,
-            working_days_remaining=remaining,
-        ))
+        slots.append(
+            PISprintSlot(
+                index=i,
+                name=f"{sprint_name_prefix} {i}",
+                start_date=s_start,
+                end_date=s_end,
+                is_current=is_current,
+                working_days_total=total_wd,
+                working_days_elapsed=elapsed,
+                working_days_remaining=remaining,
+            )
+        )
 
     total_wd = count_working_days(pi_start, pi_end, wd_list)
-    elapsed_wd = count_working_days(pi_start, min(today, pi_end), wd_list) if today >= pi_start else 0
+    elapsed_wd = (
+        count_working_days(pi_start, min(today, pi_end), wd_list) if today >= pi_start else 0
+    )
     remaining_wd = max(0, total_wd - elapsed_wd)
     progress = (elapsed_wd / total_wd * 100) if total_wd > 0 else 0.0
 

src/flowboard/domain/pi.py

@@ -43,6 +43,7 @@ def detect_all_risks(
     today = today or date.today()
     if t is None:
         from flowboard.i18n.translator import get_translator
+
         t = get_translator()
     signals: list[RiskSignal] = []
     signals.extend(_detect_overload_risks(workload_records, thresholds, t=t))
@@ -67,6 +68,7 @@ def detect_all_risks(
 # Individual detectors
 # ------------------------------------------------------------------
 
+
 def _detect_overload_risks(
     records: list[WorkloadRecord],
     thresholds: Thresholds,
@@ -121,7 +123,9 @@ def _detect_aging_risks(
             continue
         if issue.created:
             # Compare at date level to avoid timezone mismatch issues
-            created_date = issue.created.date() if isinstance(issue.created, datetime) else issue.created
+            created_date = (
+                issue.created.date() if isinstance(issue.created, datetime) else issue.created
+            )
             age = (today - created_date).days
             if age < 0:
                 continue  # future-dated issue, skip
@@ -162,7 +166,8 @@ def _detect_blocked_risks(issues: list[Issue], *, t: Translator | None = None) -
         )
     for issue in blocked:
         blockers = [
-            lnk.target_key for lnk in issue.links
+            lnk.target_key
+            for lnk in issue.links
             if lnk.link_type in (LinkType.IS_BLOCKED_BY, LinkType.DEPENDS_ON)
             and not lnk.is_resolved
         ]