import datetime as dt

import pytest
from aleph_message.models import Chain, ItemHash, ItemType, MessageType
from configmanager import Config
from message_test_helpers import process_pending_messages
from more_itertools import one
from sqlalchemy import select

from aleph.db.accessors.files import count_file_pins, get_file
from aleph.db.accessors.messages import get_forgotten_message, get_message_status
from aleph.db.accessors.posts import get_post
from aleph.db.models import (
    FilePinDb,
    GracePeriodFilePinDb,
    MessageDb,
    MessageFilePinDb,
    MessageStatusDb,
    PendingMessageDb,
    StoredFileDb,
)
from aleph.handlers.content.aggregate import AggregateMessageHandler
from aleph.handlers.content.forget import ForgetMessageHandler
from aleph.handlers.content.post import PostMessageHandler
from aleph.handlers.content.store import StoreMessageHandler
from aleph.handlers.content.vm import VmMessageHandler
from aleph.jobs.process_pending_messages import PendingMessageProcessor
from aleph.toolkit.timestamp import timestamp_to_datetime
from aleph.types.channel import Channel
from aleph.types.db_session import DbSessionFactory
from aleph.types.files import FileType
from aleph.types.message_processing_result import ProcessedMessage, RejectedMessage
from aleph.types.message_status import MessageStatus


@pytest.fixture
def forget_handler(mocker) -> ForgetMessageHandler:
    vm_handler = VmMessageHandler()
    content_handlers = {
        MessageType.aggregate: AggregateMessageHandler(),
        MessageType.instance: vm_handler,
        MessageType.post: PostMessageHandler(
            balances_addresses=["nope"],
            balances_post_type="no-balances-in-tests",
            credit_balances_addresses=["nope"],
            credit_balances_post_types=["no-balances-in-tests"],
            credit_balances_channels=["nope"],
        ),
        MessageType.program: vm_handler,
        MessageType.store: StoreMessageHandler(
            storage_service=mocker.AsyncMock(), grace_period=24
        ),
    }
    return ForgetMessageHandler(content_handlers=content_handlers)


@pytest.mark.asyncio
async def test_forget_post_message(
    session_factory: DbSessionFactory,
    message_processor: PendingMessageProcessor,
    mock_config: Config,
):
    target_message_dict = {
        "chain": "ETH",
        "channel": "TEST",
        "sender": "0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106",
        "type": "POST",
        "time": 1652786281.9810653,
        "item_type": "inline",
        "item_content": '{"address":"0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106","time":1652786281.980474,"content":{"body":"This message will be destroyed"},"type":"test"}',
        "item_hash": "fc1e7b1edc2348eb78303fb1342e31e5ad3820249629032d37f8223e754a5f8e",
        "signature": "0xdd8f7061d3c8e7019110b6dc0697c71ae8da5295e26f1d20c265bcb78fc616a05d3927f72888a459c048a297ff17c748ad3803e5f95bf000e3e4c0feba350e101c",
        "content": {
            "address": "0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106",
            "time": 1652786281.980474,
            "content": {"body": "This message will be destroyed"},
            "type": "test",
        },
    }
    forget_message_dict = {
        "chain": "ETH",
        "channel": "TEST",
        "sender": "0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106",
        "type": "FORGET",
        "time": 1652786534.1139255,
        "item_type": "inline",
        "item_content": '{"address":"0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106","time":1652786534.1138077,"hashes":["fc1e7b1edc2348eb78303fb1342e31e5ad3820249629032d37f8223e754a5f8e"]}',
        "item_hash": "431a0d2f79ecfa859949d2a09f67068ce7ebd4eb777d179ad958be6c79abc66b",
        "signature": "0x409cdef65af51d6a508a1fdc56c0baa6d1abac7f539ab5f290e3245c522a4c766b930c4196d9f5d8c8c94a4d36c4b65bf04a2773f058f03803b9b0bca2fd85a51b",
        "content": {
            "address": "0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106",
            "time": 1652786534.1138077,
            "hashes": [
                "fc1e7b1edc2348eb78303fb1342e31e5ad3820249629032d37f8223e754a5f8e"
            ],
        },
    }

    pending_message = PendingMessageDb.from_message_dict(
        target_message_dict, reception_time=dt.datetime(2022, 1, 1), fetched=True
    )
    pending_forget_message = PendingMessageDb.from_message_dict(
        forget_message_dict, reception_time=dt.datetime(2022, 1, 2), fetched=True
    )

    with session_factory() as session:
        target_message_result = one(
            await process_pending_messages(
                message_processor=message_processor,
                pending_messages=[pending_message],
                session=session,
            )
        )
        assert isinstance(target_message_result, ProcessedMessage)
        target_message = target_message_result.message

        # Sanity check
        post = get_post(session=session, item_hash=ItemHash(target_message.item_hash))
        assert post

        # Now process, the forget message
        forget_message_result = one(
            await process_pending_messages(
                message_processor=message_processor,
                pending_messages=[pending_forget_message],
                session=session,
            )
        )

        assert isinstance(forget_message_result, ProcessedMessage)
        forget_message = forget_message_result.message

        target_message_status = get_message_status(
            session=session, item_hash=ItemHash(target_message.item_hash)
        )
        assert target_message_status
        assert target_message_status.status == MessageStatus.FORGOTTEN

        forget_message_status = get_message_status(
            session=session, item_hash=ItemHash(forget_message.item_hash)
        )
        assert forget_message_status
        assert forget_message_status.status == MessageStatus.PROCESSED

        forgotten_message = get_forgotten_message(
            session=session, item_hash=ItemHash(target_message.item_hash)
        )
        assert forgotten_message

        # Check that the post was deleted
        post = get_post(session=session, item_hash=ItemHash(target_message.item_hash))
        assert post is None


@pytest.mark.asyncio
async def test_forget_store_message(
    session_factory: DbSessionFactory,
    message_processor: PendingMessageProcessor,
    mock_config: Config,
    fixture_product_prices_aggregate_in_db,
    fixture_settings_aggregate_in_db,
):
    file_hash = "5ccdd7bccfbc5955e2e40166dd0cdea0b093154fd87bc2bea57e7c768cde2f21"

    pending_message = PendingMessageDb(
        item_hash="f6fc4884e3ec3624bd3f60a3c37abf83a130777086061b1a373e659f2bab4d06",
        chain=Chain.ETH,
        sender="0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106",
        signature="0x7b87c29388a7a452353f9cae8718b66158fb5bdc93f032964226745ee04919092550791b93f79e5ee1981f2d9d6e5ac0cae0d28b68bb63fe0fcbd79015a6f3ea1b",
        type=MessageType.store,
        time=timestamp_to_datetime(1652794362.573859),
        item_type=ItemType.inline,
        item_content='{"address":"0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106","time":1652794362.5736332,"item_type":"storage","item_hash":"5ccdd7bccfbc5955e2e40166dd0cdea0b093154fd87bc2bea57e7c768cde2f21","mime_type":"text/plain"}',
        channel=Channel("TEST"),
        retries=0,
        next_attempt=dt.datetime(2023, 1, 1),
        check_message=True,
        fetched=True,
        reception_time=dt.datetime(2022, 1, 1),
    )

    pending_forget_message = PendingMessageDb(
        item_hash="5e40c8e2197e0678b5fba9cb1679e3a80fa6aeaa1a440d94f059525295fa32d3",
        chain=Chain.ETH,
        sender="0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106",
        signature="0xc342e671be10894bf707b86c3f7538cdb7e4bb5760e234f8d07f8b3dfde015492337bd8756f169e37ac691b74c765415e96b6e1813238912e10ea54cc003887d1b",
        type=MessageType.forget,
        time=timestamp_to_datetime(1652794384.3102906),
        item_type=ItemType.inline,
        item_content='{"address":"0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106","time":1652794384.3101473,"hashes":["f6fc4884e3ec3624bd3f60a3c37abf83a130777086061b1a373e659f2bab4d06"]}',
        channel=Channel("TEST"),
        retries=0,
        next_attempt=dt.datetime(2023, 1, 2),
        check_message=True,
        fetched=True,
        reception_time=dt.datetime(2022, 1, 2),
    )

    storage_engine = message_processor.message_handler.storage_service.storage_engine
    await storage_engine.write(
        filename=file_hash,
        content=b"Test",
    )

    with session_factory() as session:
        target_message_result = one(
            await process_pending_messages(
                message_processor=message_processor,
                pending_messages=[pending_message],
                session=session,
            )
        )
        assert isinstance(target_message_result, ProcessedMessage)

        # Sanity check
        nb_references = count_file_pins(session=session, file_hash=file_hash)
        assert nb_references == 1

        forget_message_result = one(
            await process_pending_messages(
                message_processor=message_processor,
                pending_messages=[pending_forget_message],
                session=session,
            )
        )
        assert isinstance(forget_message_result, ProcessedMessage)

        # Check that the file is pinned with a grace period
        file = get_file(session=session, file_hash=file_hash)
        assert file
        assert file.pins

        assert len(file.pins) == 1
        assert isinstance(file.pins[0], GracePeriodFilePinDb)


@pytest.mark.asyncio
async def test_forget_forget_message(
    session_factory: DbSessionFactory,
    message_processor: PendingMessageProcessor,
    mock_config: Config,
):
    """
    Checks that users cannot forget a FORGET message.

    * The target message should remain in the DB as a processed message
    * The FORGET message should be rejected.
    """

    target_message = MessageDb(
        item_hash="e3b24727335e34016247c0d37e2b0203bb8c2d76deddafc1700b4cf0e13845c5",
        chain=Chain.ETH,
        sender="0xB68B9D4f3771c246233823ed1D3Add451055F9Ef",
        signature="0xabfa661aab1a9f58955940ea213387de4773f8b1f244c2236cd4ac5ba7bf2ba902e17074bc4b289ba200807bb40951f4249668b055dc15af145b8842ecfad0601c",
        item_type=ItemType.storage,
        type=MessageType.forget,
        item_content=None,
        content={
            "address": "0xB68B9D4f3771c246233823ed1D3Add451055F9Ef",
            "time": 1645794065.439,
            "hashes": ["QmTQPocJ8n3r7jhwYxmCDR5bJ4SNsEhdVm8WwkNbGctgJF"],
            "reason": "None",
        },
        size=154,
        time=timestamp_to_datetime(1645794065.439),
        channel=Channel("TEST"),
    )

    pending_forget_message = PendingMessageDb(
        item_hash="884dd713e94fa0350239b67e65eecaa54361df8af0e3f6d0e42e0f8de059e15a",
        chain=Chain.ETH,
        sender="0xB68B9D4f3771c246233823ed1D3Add451055F9Ef",
        signature="0x7dc7a45aab12d78367c085799d06ef2e98fce31f76ca06975ce570fe4d92008f66f307bf68ed3ca450d04d4e779776ca13a1e7851cb48915bd390389ae4afd1b1c",
        type=MessageType.forget,
        time=timestamp_to_datetime(1639058312.376),
        item_type=ItemType.inline,
        item_content='{"address":"0xB68B9D4f3771c246233823ed1D3Add451055F9Ef","time":1639058312.376,"hashes":["e3b24727335e34016247c0d37e2b0203bb8c2d76deddafc1700b4cf0e13845c5"],"reason":"None"}',
        channel=Channel("TEST"),
        retries=0,
        next_attempt=dt.datetime(2023, 1, 1),
        check_message=True,
        fetched=True,
        reception_time=dt.datetime(2022, 1, 2),
    )

    with session_factory() as session:
        session.add(target_message)
        session.add(
            MessageStatusDb(
                item_hash=target_message.item_hash,
                status=MessageStatus.PROCESSED,
                reception_time=dt.datetime(2022, 1, 1),
            )
        )
        session.commit()

        processed_message_results = list(
            await process_pending_messages(
                message_processor=message_processor,
                pending_messages=[pending_forget_message],
                session=session,
            )
        )

        # The message should have been rejected
        for result in processed_message_results:
            assert isinstance(result, RejectedMessage)

        target_message_status = get_message_status(
            session=session, item_hash=ItemHash(target_message.item_hash)
        )
        assert target_message_status
        assert target_message_status.status == MessageStatus.PROCESSED

        forget_message_status = get_message_status(
            session=session, item_hash=ItemHash(pending_forget_message.item_hash)
        )
        assert forget_message_status
        assert forget_message_status.status == MessageStatus.REJECTED


@pytest.mark.asyncio
async def test_forget_store_multi_users(
    session_factory: DbSessionFactory,
    message_processor: PendingMessageProcessor,
    mock_config: Config,
):
    """
    Tests that a file stored by two different users is not deleted if one of the users
    deletes the content with a FORGET message.

    * User 1 should be able to forget his own STORE message
    * The message from user 2 storing the same file should be unaffected
    * The file should still be present in local storage
    * The reference to the file from user 2 should still be present in the DB.
    """

    file_hash = "05a123fe17aa6addeef5a97d1665878d10f076d84309d5ae674d4bb292b484c3"
    file_size = 220916
    file_content = b"Test forget STORE multi-users"

    store_message_user1 = MessageDb(
        item_hash="50635384e43c7af6b3297f6571644c30f3f07ac681bfd14b9c556c63e661a69e",
        chain=Chain.ETH,
        sender="0x971300C78A38e0F85E60A3b04ae3fA70b4276B64",
        signature="0x71263de6b8d1ea4c0b028f5892287505f6ee73dfa165d1455ca665ffdf5318955345c193a5df2f5c4eb2185947689d7bf5be36155b00711572fec5f27764625c1b",
        item_type=ItemType.storage,
        type=MessageType.store,
        item_content=None,
        content={
            "address": "0x971300C78A38e0F85E60A3b04ae3fA70b4276B64",
            "time": 1651757380.8522494,
            "item_type": "storage",
            "item_hash": file_hash,
            "size": file_size,
            "content_type": "file",
        },
        size=230,
        time=timestamp_to_datetime(1646123806),
        channel=Channel("TESTS_FORGET"),
    )

    store_message_user2 = MessageDb(
        item_hash="dbe8199004b052108ec19618f43af1d2baf5c04974d0aec1c4de2d02c44a2483",
        chain=Chain.ETH,
        sender="0xaC033C1cA5C49Eff98A1D9a56BeDBC4840010BA4",
        signature="0x4c9ef501e1e4f4b0a05c1eebfa1063837a82788f80deeb59808d25ff481c855157dd65102eaa365e33c7572a78d551cf25075f49d00ebb60c8506c0a6647ab761b",
        item_type=ItemType.storage,
        type=MessageType.store,
        item_content=None,
        content={
            "address": "0xaC033C1cA5C49Eff98A1D9a56BeDBC4840010BA4",
            "time": 1651757416.2203836,
            "item_type": "storage",
            "item_hash": file_hash,
            "size": file_size,
            "content_type": "file",
        },
        size=230,
        time=timestamp_to_datetime(1646123806),
        channel=Channel("TESTS_FORGET"),
    )

    pending_forget_message = PendingMessageDb(
        item_hash="0223e74dbae53b45da6a443fa18fd2a25f88677c82ed2de93f17ab24f78f58cf",
        chain=Chain.ETH,
        sender="0x971300C78A38e0F85E60A3b04ae3fA70b4276B64",
        signature="0x6682e797c424c8e5def6758867e25f08279afc3e976dbaaefdb9f650eee18d26595fc4e2f18fd4cdd853558140ecbb824e0ea8d221e12267862903fa904fabee1c",
        type=MessageType.forget,
        time=timestamp_to_datetime(1639058312.376),
        item_type=ItemType.inline,
        item_content='{"address": "0x971300C78A38e0F85E60A3b04ae3fA70b4276B64", "time": 1651757583.4974332, "hashes": ["50635384e43c7af6b3297f6571644c30f3f07ac681bfd14b9c556c63e661a69e"], "reason": "I do not like this file"}',
        channel=Channel("TESTS_FORGET"),
        retries=0,
        next_attempt=dt.datetime(2023, 1, 1),
        check_message=True,
        fetched=True,
        reception_time=dt.datetime(2022, 1, 2),
    )

    storage_engine = message_processor.message_handler.storage_service.storage_engine
    await storage_engine.write(filename=file_hash, content=file_content)

    with session_factory() as session:
        # Add messages, file references, etc
        session.add(store_message_user1)
        session.add(store_message_user2)
        session.add(
            MessageStatusDb(
                item_hash=store_message_user1.item_hash,
                status=MessageStatus.PROCESSED,
                reception_time=dt.datetime(2022, 1, 1),
            )
        )
        session.add(
            MessageStatusDb(
                item_hash=store_message_user2.item_hash,
                status=MessageStatus.PROCESSED,
                reception_time=dt.datetime(2022, 1, 2),
            )
        )
        session.add(
            StoredFileDb(
                hash=file_hash,
                size=file_size,
                type=FileType.FILE,
            )
        )
        session.add(
            MessageFilePinDb(
                file_hash=file_hash,
                owner=store_message_user1.sender,
                item_hash=store_message_user1.item_hash,
                created=store_message_user1.time,
            )
        )
        session.add(
            MessageFilePinDb(
                file_hash=file_hash,
                owner=store_message_user2.sender,
                item_hash=store_message_user2.item_hash,
                created=store_message_user2.time,
            )
        )

        # Process the FORGET message
        forget_message_result = one(
            await process_pending_messages(
                message_processor=message_processor,
                pending_messages=[pending_forget_message],
                session=session,
            )
        )
        assert isinstance(forget_message_result, ProcessedMessage)

        message1_status = get_message_status(
            session=session, item_hash=ItemHash(store_message_user1.item_hash)
        )
        assert message1_status
        assert message1_status.status == MessageStatus.FORGOTTEN

        # Check that the second message and its linked objects are still there
        message2_status = get_message_status(
            session=session, item_hash=ItemHash(store_message_user2.item_hash)
        )
        assert message2_status
        assert message2_status.status == MessageStatus.PROCESSED
        file_pin = session.execute(
            select(FilePinDb).where(FilePinDb.file_hash == file_hash)
        ).scalar_one()
        assert file_pin.item_hash == store_message_user2.item_hash
        assert file_pin.owner == store_message_user2.sender

        # Check that the file is still there
        content = await storage_engine.read(filename=file_hash)
        assert content == file_content


@pytest.mark.asyncio
async def test_forget_store_message_dependent(
    session_factory: DbSessionFactory,
    message_processor: PendingMessageProcessor,
    mock_config: Config,
    fixture_product_prices_aggregate_in_db,
    fixture_settings_aggregate_in_db,
):
    file_hash = "5ccdd7bccfbc5955e2e40166dd0cdea0b093154fd87bc2bea57e7c768cde2f21"

    code_message = PendingMessageDb(
        item_hash="f6fc4884e3ec3624bd3f60a3c37abf83a130777086061b1a373e659f2bab4d06",
        chain=Chain.ETH,
        sender="0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106",
        signature="0x7b87c29388a7a452353f9cae8718b66158fb5bdc93f032964226745ee04919092550791b93f79e5ee1981f2d9d6e5ac0cae0d28b68bb63fe0fcbd79015a6f3ea1b",
        type=MessageType.store,
        time=timestamp_to_datetime(1652794362.573859),
        item_type=ItemType.inline,
        item_content='{"address":"0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106","time":1652794362.5736332,"item_type":"storage","item_hash":"5ccdd7bccfbc5955e2e40166dd0cdea0b093154fd87bc2bea57e7c768cde2f21","mime_type":"text/plain"}',
        channel=Channel("TEST"),
        retries=0,
        next_attempt=dt.datetime(2023, 1, 1),
        check_message=True,
        fetched=True,
        reception_time=dt.datetime(2022, 1, 1),
    )

    runtime_hash = "QmXb4khKJJazpEuGVzchSy6yeJubGf8gy9Qjd4ZGSY6hXZ"
    runtime_message = PendingMessageDb(
        item_hash="63f07193e6ee9d207b7d1fcf8286f9aee34e6f12f101d2ec77c1229f92964696",
        chain=Chain.ETH,
        sender="0x101d8D16372dBf5f1614adaE95Ee5CCE61998Fc9",
        signature="0xb23a41e693ed1c8df444f22b711c5ff2f15875b3f67656910bfa8275ed34fd014855305602309ad4b060be255b7f4f926c543273e5e37f54d7d2567175d2b1921c",
        type=MessageType.store,
        time=timestamp_to_datetime(1713798108.26326),
        item_type=ItemType.inline,
        item_content='{"address":"0x101d8D16372dBf5f1614adaE95Ee5CCE61998Fc9","time":1713798108.26326,"item_type":"storage","item_hash":"QmXb4khKJJazpEuGVzchSy6yeJubGf8gy9Qjd4ZGSY6hXZ"}',
        channel=None,
        retries=0,
        next_attempt=dt.datetime(2023, 1, 1),
        check_message=True,
        fetched=True,
        reception_time=dt.datetime(2022, 1, 1),
    )

    program_message = PendingMessageDb(
        item_hash="81fe71c052eb17031d3273336e5bfc10b63eb5a3688e886d23d7a71940c8af1c",
        type=MessageType.program,
        chain=Chain.ETH,
        sender="0x49572dA92e54824ba64D8EAa9b3f9Ef8d0A8183c",
        signature="0x172f665a4a8fb31e1cdba49302278051a82185096bc941446db4fd21f83c0fa00bfeafaeb4d2e949c3f48cfc4a2d22f33b4312187aac5ea056a0bb42595d1a0b1b",
        item_type=ItemType.inline,
        time=timestamp_to_datetime(1736329132.262),
        item_content='{"address":"0x49572dA92e54824ba64D8EAa9b3f9Ef8d0A8183c","time":1736329132.262,"type":"vm-function","allow_amend":false,"code":{"encoding":"zip","entrypoint":"main:app","ref":"f6fc4884e3ec3624bd3f60a3c37abf83a130777086061b1a373e659f2bab4d06","use_latest":true},"metadata":{"name":"My program","description":"My program description"},"on":{"http":true,"persistent":false},"environment":{"reproducible":false,"internet":true,"aleph_api":true,"shared_cache":false},"resources":{"vcpus":1,"memory":128,"seconds":30},"runtime":{"ref":"63f07193e6ee9d207b7d1fcf8286f9aee34e6f12f101d2ec77c1229f92964696","use_latest":true,"comment":"Aleph Alpine Linux with Python 3.12"},"volumes":[],"variables":{},"payment":{"chain":"ETH","type":"hold"}}',
        channel=None,
        reception_time=timestamp_to_datetime(1736329150),
        fetched=True,
        check_message=True,
        retries=0,
        next_attempt=dt.datetime(2023, 1, 1),
    )

    pending_forget_message = PendingMessageDb(
        item_hash="5e40c8e2197e0678b5fba9cb1679e3a80fa6aeaa1a440d94f059525295fa32d3",
        chain=Chain.ETH,
        sender="0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106",
        signature="0xc342e671be10894bf707b86c3f7538cdb7e4bb5760e234f8d07f8b3dfde015492337bd8756f169e37ac691b74c765415e96b6e1813238912e10ea54cc003887d1b",
        type=MessageType.forget,
        time=timestamp_to_datetime(1652794384.3102906),
        item_type=ItemType.inline,
        item_content='{"address":"0x696879aE4F6d8DaDD5b8F1cbb1e663B89b08f106","time":1652794384.3101473,"hashes":["f6fc4884e3ec3624bd3f60a3c37abf83a130777086061b1a373e659f2bab4d06"]}',
        channel=Channel("TEST"),
        retries=0,
        next_attempt=dt.datetime(2023, 1, 2),
        check_message=True,
        fetched=True,
        reception_time=dt.datetime(2022, 1, 2),
    )

    storage_engine = message_processor.message_handler.storage_service.storage_engine
    await storage_engine.write(
        filename=file_hash,
        content=b"Test",
    )
    await storage_engine.write(
        filename=runtime_hash,
        content=b"Runtime",
    )

    with session_factory() as session:
        target_message_result = one(
            await process_pending_messages(
                message_processor=message_processor,
                pending_messages=[code_message],
                session=session,
            )
        )
        assert isinstance(target_message_result, ProcessedMessage)

        target_message_result1 = one(
            await process_pending_messages(
                message_processor=message_processor,
                pending_messages=[runtime_message],
                session=session,
            )
        )
        assert isinstance(target_message_result1, ProcessedMessage)

        target_message_result2 = one(
            await process_pending_messages(
                message_processor=message_processor,
                pending_messages=[program_message],
                session=session,
            )
        )

        assert isinstance(target_message_result2, ProcessedMessage)

        # Sanity check
        nb_references = count_file_pins(session=session, file_hash=file_hash)
        assert nb_references == 1

        forget_message_result = one(
            await process_pending_messages(
                message_processor=message_processor,
                pending_messages=[pending_forget_message],
                session=session,
            )
        )
        assert isinstance(forget_message_result, RejectedMessage)
        assert forget_message_result.error_code == 503

        # Check that the file continues pinned with a grace period
        nb_references = count_file_pins(session=session, file_hash=file_hash)
        assert nb_references == 1
