from datetime import datetime
from typing import List

from mev_inspect.db import write_as_csv
from mev_inspect.schemas.blocks import Block


def delete_blocks(
    db_session,
    after_block_number: int,
    before_block_number: int,
) -> None:
    db_session.execute(
        """
        DELETE FROM blocks
        WHERE
            block_number >= :after_block_number AND
            block_number < :before_block_number
        """,
        params={
            "after_block_number": after_block_number,
            "before_block_number": before_block_number,
        },
    )
    db_session.commit()


def write_blocks(
    db_session,
    blocks: List[Block],
) -> None:
    items_generator = (
        (
            block.block_number,
            datetime.fromtimestamp(block.block_timestamp),
        )
        for block in blocks
    )
    write_as_csv(db_session, "blocks", items_generator)