f24a802de5
* feat: add new alembic migration Signed-off-by: Luca Georges Francois <luca@quartz.technology> * feat: add method to store total profits in bulk Signed-off-by: Luca Georges Francois <luca@quartz.technology> Signed-off-by: Luca Georges Francois <luca@quartz.technology>
23 lines
795 B
Python
23 lines
795 B
Python
from typing import List
|
|
|
|
from mev_inspect.db import write_as_csv
|
|
from mev_inspect.schemas.total_profits import TotalProfits
|
|
|
|
|
|
def write_total_profits_for_blocks(
|
|
inspect_db_session,
|
|
total_profits_for_blocks: List[TotalProfits],
|
|
) -> None:
|
|
items_generator = (
|
|
(
|
|
total_profits_for_unique_block.block_number,
|
|
total_profits_for_unique_block.transaction_hash,
|
|
total_profits_for_unique_block.token_debt,
|
|
total_profits_for_unique_block.amount_debt,
|
|
total_profits_for_unique_block.token_received,
|
|
total_profits_for_unique_block.amount_received,
|
|
)
|
|
for total_profits_for_unique_block in total_profits_for_blocks
|
|
)
|
|
write_as_csv(inspect_db_session, "total_profit_by_block", items_generator)
|