async def METHOD_NAME(
    session_factory: DbSessionFactory, filename: str, raw: bool = True
) -> Sequence[Dict[str, Any]]:
    fixtures_dir = Path(__file__).parent / "fixtures"
    fixtures_file = fixtures_dir / filename
    with fixtures_file.open() as f:
        messages_json = json.load(f)
    messages = []
    tx_hashes = set()
    with session_factory() as session:
        for message_dict in messages_json:
            message_db = MessageDb.from_message_dict(message_dict)
            messages.append(message_db)
            session.add(message_db)
            for confirmation in message_dict.get("confirmations", []):
                if (tx_hash := confirmation["hash"]) not in tx_hashes:
                    chain_tx_db = ChainTxDb.from_dict(confirmation)
                    tx_hashes.add(tx_hash)
                    session.add(chain_tx_db)
                session.flush()
                session.execute(
                    insert(message_confirmations).values(
                        item_hash=message_db.item_hash, tx_hash=tx_hash
                    )
                )
        session.commit()
    return messages_json if raw else messages