Add crud for miner payments

This commit is contained in:
Luke Van Seters 2021-08-30 13:49:40 -04:00
parent f5222c1902
commit 9769498c9d

View File

@ -0,0 +1,31 @@
import json
from typing import List
from mev_inspect.models.miner_payments import MinerPaymentModel
from mev_inspect.schemas.miner_payments import MinerPayment
def delete_miner_payments_for_block(
db_session,
block_number: int,
) -> None:
(
db_session.query(MinerPaymentModel)
.filter(MinerPaymentModel.block_number == block_number)
.delete()
)
db_session.commit()
def write_miner_payments(
db_session,
miner_payments: List[MinerPayment],
) -> None:
models = [
MinerPaymentModel(**json.loads(miner_payment.json()))
for miner_payment in miner_payments
]
db_session.bulk_save_objects(models)
db_session.commit()