content-find-agent-new/content_agent/business_modules/content_discovery/source_evidence.py

from __future__ import annotations

import copy
from typing import Any


def build_source_evidence(
    run_id: str,
    policy_run_id: str,
    discovered_content_item: dict[str, Any],
    result: dict[str, Any],
    source_context: dict[str, Any],
) -> dict[str, Any]:
    evidence_pack = copy.deepcopy(source_context["ext_data"]["evidence_pack"])
    source_evidence = {
        **evidence_pack,
        "run_id": run_id,
        "policy_run_id": policy_run_id,
        "search_query_id": discovered_content_item["search_query_id"],
        "search_query": result.get("search_query"),
        "search_query_generation_method": result.get("search_query_generation_method"),
        "query_sources": copy.deepcopy(result.get("query_sources", [])),
        "matched_search_query_ids": list(result.get("matched_search_query_ids", [])),
        "matched_search_queries": list(result.get("matched_search_queries", [])),
        "matched_search_query_generation_methods": list(
            result.get("matched_search_query_generation_methods", [])
        ),
        "discovery_start_source": discovered_content_item["discovery_start_source"],
        "previous_discovery_step": discovered_content_item["previous_discovery_step"],
        "origin_path_id": (
            "search_query_to_content:"
            f"{discovered_content_item['search_query_id']}:"
            f"{discovered_content_item['platform_content_id']}"
        ),
        "source_path_record_ids": [],
        "discovered_platform_content_id": discovered_content_item["platform_content_id"],
        "discovery_relation": result.get(
            "discovery_relation", "derived_from_pattern_demand"
        ),
    }
    return source_evidence