fluffychat/lib/pangea/controllers/class_controller.dart

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

import 'package:fluffychat/pangea/constants/local.key.dart';
import 'package:fluffychat/pangea/constants/pangea_event_types.dart';
import 'package:fluffychat/pangea/controllers/pangea_controller.dart';
import 'package:fluffychat/pangea/extensions/client_extension/client_extension.dart';
import 'package:fluffychat/pangea/extensions/pangea_room_extension/pangea_room_extension.dart';
import 'package:fluffychat/pangea/models/space_model.dart';
import 'package:fluffychat/pangea/utils/error_handler.dart';
import 'package:fluffychat/pangea/utils/firebase_analytics.dart';
import 'package:fluffychat/pangea/utils/space_code.dart';
import 'package:fluffychat/widgets/matrix.dart';
import 'package:flutter/foundation.dart';
import 'package:flutter/material.dart';
import 'package:flutter_gen/gen_l10n/l10n.dart';
import 'package:future_loading_dialog/future_loading_dialog.dart';
import 'package:matrix/matrix.dart';

import 'base_controller.dart';

class ClassController extends BaseController {
  late PangeaController _pangeaController;

  ClassController(PangeaController pangeaController) : super() {
    _pangeaController = pangeaController;
  }

  setActiveSpaceIdInChatListController(String? classId) {
    setState({"activeSpaceId": classId});
  }

  /// For all the spaces that the user is teaching, set the power levels
  /// to enable all other users to add child rooms to the space.
  void fixClassPowerLevels() {
    Future.wait(
      _pangeaController.matrixState.client.spacesImTeaching.map(
        (space) => space.setClassPowerLevels().catchError((err, s) {
          ErrorHandler.logError(e: err, s: s);
        }),
      ),
    );
  }

  Future<void> checkForClassCodeAndSubscription(BuildContext context) async {
    final String? classCode = _pangeaController.pStoreService.read(
      PLocalKey.cachedClassCodeToJoin,
      isAccountData: false,
    );

    if (classCode != null) {
      await joinClasswithCode(
        context,
        classCode,
      );
      await _pangeaController.pStoreService.delete(
        PLocalKey.cachedClassCodeToJoin,
        isAccountData: false,
      );
    }
  }

  Future<void> joinClasswithCode(BuildContext context, String classCode) async {
    final client = Matrix.of(context).client;
    try {
      final knockResponse = await client.httpClient.post(
        Uri.parse(
          '${client.homeserver}/_synapse/client/pangea/v1/knock_with_code',
        ),
        headers: {
          'Content-Type': 'application/json',
          'Authorization': 'Bearer ${client.accessToken}',
        },
        body: jsonEncode({'access_code': classCode}),
      );
      if (knockResponse.statusCode == 429) {
        SpaceCodeUtil.messageSnack(
          context,
          L10n.of(context)!.tooManyRequest,
        );
        return;
      }
      if (knockResponse.statusCode != 200) {
        SpaceCodeUtil.messageSnack(
          context,
          L10n.of(context)!.unableToFindClass,
        );
        return;
      }
      final knockResult = jsonDecode(knockResponse.body);
      final foundClasses = List<String>.from(knockResult['rooms']);
      final alreadyJoined = List<String>.from(knockResult['already_joined']);
      if (alreadyJoined.isNotEmpty) {
        SpaceCodeUtil.messageSnack(
          context,
          L10n.of(context)!.alreadyInClass,
        );
        return;
      }
      if (foundClasses.isEmpty) {
        SpaceCodeUtil.messageSnack(
          context,
          L10n.of(context)!.unableToFindClass,
        );
        return;
      }
      final chosenClassId = foundClasses.first;
      if (_pangeaController.matrixState.client.rooms
          .any((room) => room.id == chosenClassId)) {
        setActiveSpaceIdInChatListController(chosenClassId);
        SpaceCodeUtil.messageSnack(context, L10n.of(context)!.alreadyInClass);
        return;
      } else {
        await _pangeaController.pStoreService.save(
          PLocalKey.justInputtedCode,
          classCode,
          isAccountData: false,
        );
        await client.joinRoomById(chosenClassId);
        _pangeaController.pStoreService.delete(PLocalKey.justInputtedCode);
      }

      if (_pangeaController.matrixState.client.getRoomById(chosenClassId) ==
          null) {
        await _pangeaController.matrixState.client.waitForRoomInSync(
          chosenClassId,
          join: true,
        );
      }

      // If the room is full, leave
      final room =
          _pangeaController.matrixState.client.getRoomById(chosenClassId);
      if (room == null) {
        return;
      }
      final joinResult = await showFutureLoadingDialog(
        context: context,
        future: () async {
          if (await room.leaveIfFull()) {
            throw L10n.of(context)!.roomFull;
          }
        },
      );
      if (joinResult.error != null) {
        return;
      }

      setActiveSpaceIdInChatListController(chosenClassId);

      // add the user's analytics room to this joined space
      // so their teachers can join them via the space hierarchy
      final Room? joinedSpace =
          _pangeaController.matrixState.client.getRoomById(chosenClassId);

      // when possible, add user's analytics room the to space they joined
      joinedSpace?.addAnalyticsRoomsToSpace();

      // and invite the space's teachers to the user's analytics rooms
      joinedSpace?.inviteSpaceTeachersToAnalyticsRooms();
      GoogleAnalytics.joinClass(classCode);
      return;
    } catch (err) {
      SpaceCodeUtil.messageSnack(
        context,
        ErrorCopy(context, err).body,
      );
    }
    // P-EPIC
    // prereq - server needs ability to invite to private room. how?
    // does server api have ability with admin token?
    // is application service needed?
    // BE - check class code and if class code is correct, invite student to room
    // FE - look for invite from room and automatically accept
  }

  Future<void> addMissingRoomRules(String? roomId) async {
    if (roomId == null) return;
    final Room? room = _pangeaController.matrixState.client.getRoomById(roomId);
    if (room == null) return;

    if (room.isSpace && room.isRoomAdmin && room.pangeaRoomRules == null) {
      try {
        await _pangeaController.matrixState.client.setRoomStateWithKey(
          roomId,
          PangeaEventTypes.rules,
          '',
          PangeaRoomRules().toJson(),
        );
      } catch (err, stack) {
        debugger(when: kDebugMode);
        ErrorHandler.logError(e: err, s: stack);
      }
    }
  }
}