immich/mobile/lib/repositories/activity_api.repository.dart

import 'package:hooks_riverpod/hooks_riverpod.dart';
import 'package:immich_mobile/infrastructure/utils/user.converter.dart';
import 'package:immich_mobile/models/activities/activity.model.dart';
import 'package:immich_mobile/providers/api.provider.dart';
import 'package:immich_mobile/repositories/api.repository.dart';
import 'package:openapi/api.dart';

final activityApiRepositoryProvider = Provider(
  (ref) => ActivityApiRepository(ref.watch(apiServiceProvider).activitiesApi),
);

class ActivityApiRepository extends ApiRepository {
  final ActivitiesApi _api;

  ActivityApiRepository(this._api);

  Future<List<Activity>> getAll(String albumId, {String? assetId}) async {
    final response = await checkNull(_api.getActivities(albumId, assetId: assetId));
    return response.map(_toActivity).toList();
  }

  Future<Activity> create(String albumId, ActivityType type, {String? assetId, String? comment}) async {
    final dto = ActivityCreateDto(
      albumId: albumId,
      type: type == ActivityType.comment ? ReactionType.comment : ReactionType.like,
      assetId: assetId,
      comment: comment,
    );
    final response = await checkNull(_api.createActivity(dto));
    return _toActivity(response);
  }

  Future<void> delete(String id) {
    return checkNull(_api.deleteActivity(id));
  }

  Future<ActivityStats> getStats(String albumId, {String? assetId}) async {
    final response = await checkNull(_api.getActivityStatistics(albumId, assetId: assetId));
    return ActivityStats(comments: response.comments);
  }

  static Activity _toActivity(ActivityResponseDto dto) => Activity(
    id: dto.id,
    createdAt: dto.createdAt,
    type: dto.type == ReactionType.comment ? ActivityType.comment : ActivityType.like,
    user: UserConverter.fromSimpleUserDto(dto.user),
    assetId: dto.assetId,
    comment: dto.comment,
  );
}