fluffychat/lib/pages/new_group/new_group.dart

import 'dart:typed_data';

import 'package:file_picker/file_picker.dart';
import 'package:fluffychat/pages/new_group/new_group_view.dart';
import 'package:fluffychat/pangea/constants/bot_mode.dart';
import 'package:fluffychat/pangea/controllers/pangea_controller.dart';
import 'package:fluffychat/pangea/extensions/pangea_room_extension/pangea_room_extension.dart';
import 'package:fluffychat/pangea/models/chat_topic_model.dart';
import 'package:fluffychat/pangea/models/lemma.dart';
import 'package:fluffychat/pangea/pages/class_settings/p_class_widgets/room_capacity_button.dart';
import 'package:fluffychat/pangea/utils/bot_name.dart';
import 'package:fluffychat/pangea/utils/class_chat_power_levels.dart';
import 'package:fluffychat/pangea/utils/firebase_analytics.dart';
import 'package:fluffychat/pangea/widgets/class/add_space_toggles.dart';
import 'package:fluffychat/pangea/widgets/conversation_bot/conversation_bot_settings.dart';
import 'package:fluffychat/widgets/matrix.dart';
import 'package:flutter/material.dart';
import 'package:flutter_gen/gen_l10n/l10n.dart';
import 'package:go_router/go_router.dart';
import 'package:matrix/matrix.dart' as sdk;

class NewGroup extends StatefulWidget {
  // #Pangea
  final String? spaceId;

  const NewGroup({
    super.key,
    this.spaceId,
  });
  // Pangea#

  @override
  NewGroupController createState() => NewGroupController();
}

class NewGroupController extends State<NewGroup> {
  TextEditingController nameController = TextEditingController();

  bool publicGroup = false;
  bool groupCanBeFound = true;

  Uint8List? avatar;

  Uri? avatarUrl;

  Object? error;

  bool loading = false;

  // #Pangea
  PangeaController pangeaController = MatrixState.pangeaController;
  final GlobalKey<AddToSpaceState> addToSpaceKey = GlobalKey<AddToSpaceState>();
  final GlobalKey<ConversationBotSettingsState> addConversationBotKey =
      GlobalKey<ConversationBotSettingsState>();
  final GlobalKey<RoomCapacityButtonState> addCapacityKey =
      GlobalKey<RoomCapacityButtonState>();

  ChatTopic chatTopic = ChatTopic.empty;

  void setVocab(List<Lemma> vocab) => setState(() => chatTopic.vocab = vocab);

  String? get activeSpaceId =>
      GoRouterState.of(context).uri.queryParameters['spaceId'];
  // Pangea#

  void setPublicGroup(bool b) => setState(() => publicGroup = b);

  void setGroupCanBeFound(bool b) => setState(() => groupCanBeFound = b);

  void selectPhoto() async {
    final photo = await FilePicker.platform.pickFiles(
      type: FileType.image,
      allowMultiple: false,
      withData: true,
    );

    setState(() {
      avatarUrl = null;
      avatar = photo?.files.singleOrNull?.bytes;
    });
  }

  void submitAction([_]) async {
    // #Pangea
    if (nameController.text.isEmpty) {
      ScaffoldMessenger.of(context).showSnackBar(
        SnackBar(
          content: Text(L10n.of(context)!.emptyChatNameWarning),
        ),
      );
      return;
    }
    // Pangea#
    final client = Matrix.of(context).client;

    try {
      setState(() {
        loading = true;
        error = null;
      });

      final avatar = this.avatar;
      avatarUrl ??= avatar == null ? null : await client.uploadContent(avatar);

      if (!mounted) return;

      // #Pangea
      // validate init bot options
      if (addConversationBotKey.currentState?.formKey.currentState != null) {
        final isValid = addConversationBotKey
            .currentState!.formKey.currentState!
            .validate();
        if (isValid == false) {
          setState(() {
            error = L10n.of(context)!
                .conversationBotCustomZone_customSystemPromptEmptyError;
            loading = false;
          });
          return;
        }
      }
      addConversationBotKey.currentState?.updateAllBotOptions();
      final addBot = addConversationBotKey.currentState?.addBot ?? false;
      if (addBot) {
        final botOptions = addConversationBotKey.currentState!.botOptions;
        if (botOptions.mode == BotMode.custom) {
          if (botOptions.customSystemPrompt == null ||
              botOptions.customSystemPrompt!.isEmpty) {
            setState(() {
              error = L10n.of(context)!
                  .conversationBotCustomZone_customSystemPromptEmptyError;
              loading = false;
            });
            return;
          }
        } else if (botOptions.mode == BotMode.textAdventure) {
          if (botOptions.textAdventureGameMasterInstructions == null ||
              botOptions.textAdventureGameMasterInstructions!.isEmpty) {
            setState(() {
              error = L10n.of(context)!
                  .conversationBotCustomZone_instructionSystemPromptEmptyError;
              loading = false;
            });
            return;
          }
        }
      }
      // Pangea#

      final roomId = await client.createGroupChat(
        // #Pangea
        // visibility:
        //     publicGroup ? sdk.Visibility.public : sdk.Visibility.private,
        // preset: publicGroup
        //     ? sdk.CreateRoomPreset.publicChat
        //     : sdk.CreateRoomPreset.privateChat,
        preset: sdk.CreateRoomPreset.publicChat,
        powerLevelContentOverride:
            await ClassChatPowerLevels.powerLevelOverrideForClassChat(
          context,
          addToSpaceKey.currentState!.parent,
        ),
        invite: [
          if (addConversationBotKey.currentState?.addBot ?? false)
            BotName.byEnvironment,
        ],
        // Pangea#
        groupName: nameController.text.isNotEmpty ? nameController.text : null,
        initialState: [
          if (avatar != null)
            sdk.StateEvent(
              type: sdk.EventTypes.RoomAvatar,
              content: {'url': avatarUrl.toString()},
            ),
          // #Pangea
          if (addConversationBotKey.currentState?.addBot ?? false)
            addConversationBotKey.currentState!.botOptions.toStateEvent,
          // Pangea#
        ],
      );
      if (!mounted) return;
      if (publicGroup && groupCanBeFound) {
        await client.setRoomVisibilityOnDirectory(
          roomId,
          visibility: sdk.Visibility.public,
        );
      }
      // #Pangea
      GoogleAnalytics.createChat(roomId);
      await addToSpaceKey.currentState!.addSpaces(roomId);

      final capacity = addCapacityKey.currentState?.capacity;
      final room = client.getRoomById(roomId);
      if (capacity != null && room != null) {
        room.updateRoomCapacity(capacity);
      }
      // Pangea#
      context.go('/rooms/$roomId/invite');
    } catch (e, s) {
      sdk.Logs().d('Unable to create group', e, s);
      setState(() {
        error = e;
        loading = false;
      });
    }
  }

  //#Pangea
  @override
  void initState() {
    Future.delayed(Duration.zero, () {
      chatTopic.langCode =
          pangeaController.languageController.userL2?.langCode ??
              pangeaController.pLanguageStore.targetOptions.first.langCode;
      setState(() {});
    });

    super.initState();
  }
  //Pangea#

  @override
  Widget build(BuildContext context) => NewGroupView(this);
}