async def METHOD_NAME(
    mocker,
    session_factory: DbSessionFactory,
    mock_config: Config,
    fixture_message_directory: MessageDb,
):
    mock_ipfs_client = mocker.MagicMock()
    ipfs_stats = {
        "Hash": "QmPZrod87ceK4yVvXQzRexDcuDgmLxBiNJ1ajLjLoMx9sU",
        "Size": 0,
        "CumulativeSize": 4560,
        "Blocks": 2,
        "Type": "directory",
    }
    mock_ipfs_client.files.stat = mocker.AsyncMock(return_value=ipfs_stats)
    message = fixture_message_directory
    storage_engine = mocker.AsyncMock()
    storage_service = StorageService(
        storage_engine=storage_engine,
        ipfs_service=IpfsService(ipfs_client=mock_ipfs_client),
        node_cache=mocker.AsyncMock(),
    )
    store_message_handler = StoreMessageHandler(storage_service=storage_service)
    with session_factory() as session:
        await store_message_handler.fetch_related_content(
            session=session, message=message
        )
        session.commit()
    with session_factory() as session:
        stored_files = list((session.execute(select(StoredFileDb))).scalars())
    assert len(stored_files) == 1
    stored_file = stored_files[0]
    # Check the updates to the message content
    assert stored_file.hash == ipfs_stats["Hash"]
    assert stored_file.size == ipfs_stats["CumulativeSize"]
    assert stored_file.type == FileType.DIRECTORY
    assert not storage_engine.called