from typing import Any

import db

from .ensure_flow_blocks_schema import ensure_flow_blocks_schema


def get_flow_block(slug: str, block_id: int | None) -> dict[str, Any] | None:
    if not block_id:
        return None
    ensure_flow_blocks_schema(slug)
    conn = db.connect(slug)
    row = conn.execute("SELECT * FROM _flow_blocks WHERE id = ?", (block_id,)).fetchone()
    conn.close()
    return dict(row) if row else None