from funkwhale_api.favorites import activities, serializers
from funkwhale_api.federation.serializers import APIActorSerializer
from funkwhale_api.music.serializers import TrackActivitySerializer


def test_get_favorite_activity_url(settings, factories):
    user = factories["users.User"](with_actor=True)
    favorite = factories["favorites.TrackFavorite"](actor=user.actor)
    user_url = favorite.actor.user.get_activity_url()
    expected = f"{user_url}/favorites/tracks/{favorite.pk}"
    assert favorite.get_activity_url() == expected


def test_activity_favorite_serializer(factories):
    user = factories["users.User"](with_actor=True)
    favorite = factories["favorites.TrackFavorite"](actor=user.actor)
    actor = APIActorSerializer(favorite.actor).data
    field = serializers.serializers.DateTimeField()
    expected = {
        "type": "Like",
        "local_id": favorite.pk,
        "id": favorite.get_activity_url(),
        "actor": actor,
        "object": TrackActivitySerializer(favorite.track).data,
        "published": field.to_representation(favorite.creation_date),
    }

    data = serializers.TrackFavoriteActivitySerializer(favorite).data

    assert data == expected


def test_track_favorite_serializer_is_connected(activity_registry):
    conf = activity_registry["favorites.TrackFavorite"]
    assert conf["serializer"] == serializers.TrackFavoriteActivitySerializer


def test_track_favorite_serializer_instance_activity_consumer(activity_registry):
    conf = activity_registry["favorites.TrackFavorite"]
    consumer = activities.broadcast_track_favorite_to_instance_activity
    assert consumer in conf["consumers"]


def test_broadcast_track_favorite_to_instance_activity(factories, mocker):
    p = mocker.patch("funkwhale_api.common.channels.group_send")
    user = factories["users.User"](with_actor=True)
    favorite = factories["favorites.TrackFavorite"](actor=user.actor)
    data = serializers.TrackFavoriteActivitySerializer(favorite).data
    consumer = activities.broadcast_track_favorite_to_instance_activity
    message = {"type": "event.send", "text": "", "data": data}
    consumer(data=data, obj=favorite)
    p.assert_called_once_with("instance_activity", message)


def test_broadcast_track_favorite_to_instance_activity_private(factories, mocker):
    p = mocker.patch("funkwhale_api.common.channels.group_send")
    user = factories["users.User"](privacy_level="me")
    user.create_actor()
    favorite = factories["favorites.TrackFavorite"](actor=user.actor)
    data = serializers.TrackFavoriteActivitySerializer(favorite).data
    consumer = activities.broadcast_track_favorite_to_instance_activity
    consumer(data=data, obj=favorite)
    p.assert_not_called()