import db

from .ensure_flow_blocks_schema import ensure_flow_blocks_schema


def create_flow_block(slug, screen_id, name, description=""):
    name = (name or "").strip()
    if not name:
        return None
    ensure_flow_blocks_schema(slug)
    conn = db.connect(slug)
    conn.execute(
        "INSERT INTO _flow_blocks (screen_id, name, description) VALUES (?, ?, ?)",
        (screen_id, name, (description or "").strip()),
    )
    new_id = conn.execute("SELECT last_insert_rowid() AS id").fetchone()["id"]
    conn.commit()
    conn.close()
    return new_id