fluffychat/lib/pangea/controllers/practice_activity_generation_controller.dart

import 'dart:async';
import 'dart:convert';
import 'dart:developer';

import 'package:fluffychat/pangea/config/environment.dart';
import 'package:fluffychat/pangea/constants/pangea_event_types.dart';
import 'package:fluffychat/pangea/controllers/pangea_controller.dart';
import 'package:fluffychat/pangea/enum/activity_type_enum.dart';
import 'package:fluffychat/pangea/enum/construct_type_enum.dart';
import 'package:fluffychat/pangea/extensions/pangea_room_extension/pangea_room_extension.dart';
import 'package:fluffychat/pangea/matrix_event_wrappers/pangea_message_event.dart';
import 'package:fluffychat/pangea/matrix_event_wrappers/practice_activity_event.dart';
import 'package:fluffychat/pangea/models/practice_activities.dart/message_activity_request.dart';
import 'package:fluffychat/pangea/models/practice_activities.dart/multiple_choice_activity_model.dart';
import 'package:fluffychat/pangea/models/practice_activities.dart/practice_activity_model.dart';
import 'package:fluffychat/pangea/network/requests.dart';
import 'package:fluffychat/pangea/network/urls.dart';
import 'package:flutter/foundation.dart';
import 'package:http/http.dart';
import 'package:matrix/matrix.dart';

/// Represents an item in the completion cache.
class _RequestCacheItem {
  MessageActivityRequest req;

  Future<PracticeActivityEvent?> practiceActivityEvent;

  _RequestCacheItem({
    required this.req,
    required this.practiceActivityEvent,
  });
}

/// Controller for handling activity completions.
class PracticeGenerationController {
  static final Map<int, _RequestCacheItem> _cache = {};
  Timer? _cacheClearTimer;

  late PangeaController _pangeaController;

  PracticeGenerationController(PangeaController pangeaController) {
    _pangeaController = pangeaController;
    _initializeCacheClearing();
  }

  void _initializeCacheClearing() {
    const duration = Duration(minutes: 2);
    _cacheClearTimer = Timer.periodic(duration, (Timer t) => _clearCache());
  }

  void _clearCache() {
    _cache.clear();
  }

  void dispose() {
    _cacheClearTimer?.cancel();
  }

  Future<PracticeActivityEvent?> _sendAndPackageEvent(
    PracticeActivityModel model,
    PangeaMessageEvent pangeaMessageEvent,
  ) async {
    final Event? activityEvent = await pangeaMessageEvent.room.sendPangeaEvent(
      content: model.toJson(),
      parentEventId: pangeaMessageEvent.eventId,
      type: PangeaEventTypes.pangeaActivity,
    );

    if (activityEvent == null) {
      return null;
    }

    return PracticeActivityEvent(
      event: activityEvent,
      timeline: pangeaMessageEvent.timeline,
    );
  }

  Future<PracticeActivityModel> _fetch({
    required String accessToken,
    required MessageActivityRequest requestModel,
  }) async {
    final Requests request = Requests(
      choreoApiKey: Environment.choreoApiKey,
      accessToken: accessToken,
    );
    final Response res = await request.post(
      url: PApiUrls.messageActivityGeneration,
      body: requestModel.toJson(),
    );

    if (res.statusCode == 200) {
      final Map<String, dynamic> json = jsonDecode(utf8.decode(res.bodyBytes));

      final response = PracticeActivityModel.fromJson(json);

      return response;
    } else {
      debugger(when: kDebugMode);
      throw Exception('Failed to convert speech to text');
    }
  }

  Future<PracticeActivityEvent?> getPracticeActivity(
    MessageActivityRequest req,
    PangeaMessageEvent event,
  ) async {
    final int cacheKey = req.hashCode;

    if (_cache.containsKey(cacheKey)) {
      return _cache[cacheKey]!.practiceActivityEvent;
    } else {
      //TODO - send request to server/bot, either via API or via event of type pangeaActivityReq
      // for now, just make and send the event from the client
      final PracticeActivityModel activity = await _fetch(
        accessToken: _pangeaController.userController.accessToken,
        requestModel: req,
      );

      final Future<PracticeActivityEvent?> eventFuture =
          _sendAndPackageEvent(activity, event);

      _cache[cacheKey] =
          _RequestCacheItem(req: req, practiceActivityEvent: eventFuture);

      return _cache[cacheKey]!.practiceActivityEvent;
    }
  }

  PracticeActivityModel _dummyModel(PangeaMessageEvent event) =>
      PracticeActivityModel(
        tgtConstructs: [
          ConstructIdentifier(lemma: "be", type: ConstructTypeEnum.vocab),
        ],
        activityType: ActivityTypeEnum.multipleChoice,
        langCode: event.messageDisplayLangCode,
        msgId: event.eventId,
        multipleChoice: MultipleChoice(
          question: "What is a synonym for 'happy'?",
          choices: ["sad", "angry", "joyful", "tired"],
          answer: "joyful",
          spanDisplayDetails: null,
        ),
      );
}