Purify

"""
Purify: Pipeline Null Handler & Type Coalescer
Recursively sweeps sparse dictionaries, substituting type-safe domain fallbacks.
"""
from typing import Dict, Any, List
from pydantic import BaseModel

class CleanedRecord(BaseModel):
    null_keys_repaired: int
    payload: Dict[str, Any]

class PurifyNullHandler:
    def __init__(self, type_defaults: Dict[str, Any] = None):
        self.defaults = type_defaults or {
            "str": "",
            "int": 0,
            "float": 0.0,
            "list": [],
            "dict": {}
        }

    def sanitize(self, raw_data: Dict[str, Any]) -> CleanedRecord:
        repaired_count = 0

        def _clean_node(node: Any) -> Any:
            nonlocal repaired_count
            if isinstance(node, dict):
                cleaned = {}
                for k, v in node.items():
                    if v is None:
                        repaired_count += 1
                        cleaned[k] = ""
                    else:
                        cleaned[k] = _clean_node(v)
                return cleaned
            elif isinstance(node, list):
                return [_clean_node(item) for item in node if item is not None]
            return node

        sanitized_data = _clean_node(raw_data)
        return CleanedRecord(null_keys_repaired=repaired_count, payload=sanitized_data)