|
|
|
@ -1,48 +1,40 @@
|
|
|
|
part of "client_extension.dart";
|
|
|
|
part of "client_extension.dart";
|
|
|
|
|
|
|
|
|
|
|
|
extension AnalyticsClientExtension on Client {
|
|
|
|
extension AnalyticsClientExtension on Client {
|
|
|
|
// get analytics room matching targetlanguage
|
|
|
|
/// Get the logged in user's analytics room matching
|
|
|
|
// if not present, create it and invite teachers of that language
|
|
|
|
/// a given langCode. If not present, create it.
|
|
|
|
// set description to let people know what the hell it is
|
|
|
|
|
|
|
|
Future<Room> _getMyAnalyticsRoom(String langCode) async {
|
|
|
|
Future<Room> _getMyAnalyticsRoom(String langCode) async {
|
|
|
|
await roomsLoading;
|
|
|
|
final Room? analyticsRoom = _analyticsRoomLocal(langCode);
|
|
|
|
// ensure room state events (room create,
|
|
|
|
|
|
|
|
// to check for analytics type) are loaded
|
|
|
|
|
|
|
|
for (final room in rooms) {
|
|
|
|
|
|
|
|
if (room.partial) await room.postLoad();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
final Room? analyticsRoom = analyticsRoomLocal(langCode);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (analyticsRoom != null) return analyticsRoom;
|
|
|
|
if (analyticsRoom != null) return analyticsRoom;
|
|
|
|
|
|
|
|
|
|
|
|
return _makeAnalyticsRoom(langCode);
|
|
|
|
return _makeAnalyticsRoom(langCode);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
//note: if langCode is null and user has >1 analyticsRooms then this could
|
|
|
|
/// Get local analytics room for a given langCode and
|
|
|
|
//return the wrong one. this is to account for when an exchange might not
|
|
|
|
/// optional userId (if not specified, uses current user).
|
|
|
|
//be in a class.
|
|
|
|
/// If user is invited to the room, joins the room.
|
|
|
|
Room? _analyticsRoomLocal(String? langCode, [String? userIdParam]) {
|
|
|
|
Room? _analyticsRoomLocal(String langCode, [String? userIdParam]) {
|
|
|
|
final Room? analyticsRoom = rooms.firstWhereOrNull((e) {
|
|
|
|
final Room? analyticsRoom = rooms.firstWhereOrNull((e) {
|
|
|
|
return e.isAnalyticsRoom &&
|
|
|
|
return e.isAnalyticsRoom &&
|
|
|
|
e.isAnalyticsRoomOfUser(userIdParam ?? userID!) &&
|
|
|
|
e.isAnalyticsRoomOfUser(userIdParam ?? userID!) &&
|
|
|
|
(langCode != null ? e.isMadeForLang(langCode) : true);
|
|
|
|
e.isMadeForLang(langCode);
|
|
|
|
});
|
|
|
|
});
|
|
|
|
if (analyticsRoom != null &&
|
|
|
|
if (analyticsRoom != null &&
|
|
|
|
analyticsRoom.membership == Membership.invite) {
|
|
|
|
analyticsRoom.membership == Membership.invite) {
|
|
|
|
debugger(when: kDebugMode);
|
|
|
|
debugger(when: kDebugMode);
|
|
|
|
analyticsRoom
|
|
|
|
analyticsRoom.join().onError(
|
|
|
|
.join()
|
|
|
|
|
|
|
|
.onError(
|
|
|
|
|
|
|
|
(error, stackTrace) =>
|
|
|
|
(error, stackTrace) =>
|
|
|
|
ErrorHandler.logError(e: error, s: stackTrace),
|
|
|
|
ErrorHandler.logError(e: error, s: stackTrace),
|
|
|
|
)
|
|
|
|
);
|
|
|
|
.then((value) => analyticsRoom.postLoad());
|
|
|
|
|
|
|
|
return analyticsRoom;
|
|
|
|
return analyticsRoom;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return analyticsRoom;
|
|
|
|
return analyticsRoom;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/// Creates an analytics room with the specified language code and returns the created room.
|
|
|
|
|
|
|
|
/// Additionally, the room is added to the user's spaces and all teachers are invited to the room.
|
|
|
|
|
|
|
|
///
|
|
|
|
|
|
|
|
/// If the room does not appear immediately after creation, this method waits for it to appear in sync.
|
|
|
|
|
|
|
|
/// Returns the created [Room] object.
|
|
|
|
Future<Room> _makeAnalyticsRoom(String langCode) async {
|
|
|
|
Future<Room> _makeAnalyticsRoom(String langCode) async {
|
|
|
|
final String roomID = await createRoom(
|
|
|
|
final String roomID = await createRoom(
|
|
|
|
creationContent: {
|
|
|
|
creationContent: {
|
|
|
|
@ -53,7 +45,6 @@ extension AnalyticsClientExtension on Client {
|
|
|
|
topic: "This room stores learning analytics for $userID.",
|
|
|
|
topic: "This room stores learning analytics for $userID.",
|
|
|
|
invite: [
|
|
|
|
invite: [
|
|
|
|
...(await myTeachers).map((e) => e.id),
|
|
|
|
...(await myTeachers).map((e) => e.id),
|
|
|
|
// BotName.localBot,
|
|
|
|
|
|
|
|
BotName.byEnvironment,
|
|
|
|
BotName.byEnvironment,
|
|
|
|
],
|
|
|
|
],
|
|
|
|
);
|
|
|
|
);
|
|
|
|
@ -66,14 +57,14 @@ extension AnalyticsClientExtension on Client {
|
|
|
|
|
|
|
|
|
|
|
|
// add this analytics room to all spaces so teachers can join them
|
|
|
|
// add this analytics room to all spaces so teachers can join them
|
|
|
|
// via the space hierarchy
|
|
|
|
// via the space hierarchy
|
|
|
|
await analyticsRoom?.addAnalyticsRoomToSpaces();
|
|
|
|
analyticsRoom?.addAnalyticsRoomToSpaces();
|
|
|
|
|
|
|
|
|
|
|
|
// and invite all teachers to new analytics room
|
|
|
|
// and invite all teachers to new analytics room
|
|
|
|
await analyticsRoom?.inviteTeachersToAnalyticsRoom();
|
|
|
|
analyticsRoom?.inviteTeachersToAnalyticsRoom();
|
|
|
|
return getRoomById(roomID)!;
|
|
|
|
return getRoomById(roomID)!;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// Get all my analytics rooms
|
|
|
|
/// Get all my analytics rooms
|
|
|
|
List<Room> get _allMyAnalyticsRooms => rooms
|
|
|
|
List<Room> get _allMyAnalyticsRooms => rooms
|
|
|
|
.where(
|
|
|
|
.where(
|
|
|
|
(e) => e.isAnalyticsRoomOfUser(userID!),
|
|
|
|
(e) => e.isAnalyticsRoomOfUser(userID!),
|
|
|
|
@ -83,76 +74,77 @@ extension AnalyticsClientExtension on Client {
|
|
|
|
// migration function to change analytics rooms' vsibility to public
|
|
|
|
// migration function to change analytics rooms' vsibility to public
|
|
|
|
// so they will appear in the space hierarchy
|
|
|
|
// so they will appear in the space hierarchy
|
|
|
|
Future<void> _updateAnalyticsRoomVisibility() async {
|
|
|
|
Future<void> _updateAnalyticsRoomVisibility() async {
|
|
|
|
final List<Future> makePublicFutures = [];
|
|
|
|
await Future.wait(
|
|
|
|
for (final Room room in allMyAnalyticsRooms) {
|
|
|
|
allMyAnalyticsRooms.map((room) async {
|
|
|
|
final visability = await getRoomVisibilityOnDirectory(room.id);
|
|
|
|
final visability = await getRoomVisibilityOnDirectory(room.id);
|
|
|
|
if (visability != Visibility.public) {
|
|
|
|
if (visability != Visibility.public) {
|
|
|
|
await setRoomVisibilityOnDirectory(
|
|
|
|
await setRoomVisibilityOnDirectory(
|
|
|
|
room.id,
|
|
|
|
room.id,
|
|
|
|
visibility: Visibility.public,
|
|
|
|
visibility: Visibility.public,
|
|
|
|
);
|
|
|
|
);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}),
|
|
|
|
await Future.wait(makePublicFutures);
|
|
|
|
);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// Add all the users' analytics room to all the spaces the student studies in
|
|
|
|
/// Add all the users' analytics room to all the spaces the user is studying in
|
|
|
|
// So teachers can join them via space hierarchy
|
|
|
|
/// so teachers can join them via space hierarchy.
|
|
|
|
// Will not always work, as there may be spaces where students don't have permission to add chats
|
|
|
|
/// Allows teachers to join analytics rooms without being invited.
|
|
|
|
// But allows teachers to join analytics rooms without being invited
|
|
|
|
void _addAnalyticsRoomsToAllSpaces() {
|
|
|
|
Future<void> _addAnalyticsRoomsToAllSpaces() async {
|
|
|
|
|
|
|
|
final List<Future> addFutures = [];
|
|
|
|
|
|
|
|
for (final Room room in allMyAnalyticsRooms) {
|
|
|
|
for (final Room room in allMyAnalyticsRooms) {
|
|
|
|
addFutures.add(room.addAnalyticsRoomToSpaces());
|
|
|
|
room.addAnalyticsRoomToSpaces();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
await Future.wait(addFutures);
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// Invite teachers to all my analytics room
|
|
|
|
/// Invite teachers to all my analytics room.
|
|
|
|
// Handles case when students cannot add analytics room to space(s)
|
|
|
|
/// Handles case when students cannot add analytics room to space(s)
|
|
|
|
// So teacher is still able to get analytics data for this student
|
|
|
|
/// so teacher is still able to get analytics data for this student
|
|
|
|
Future<void> _inviteAllTeachersToAllAnalyticsRooms() async {
|
|
|
|
void _inviteAllTeachersToAllAnalyticsRooms() {
|
|
|
|
final List<Future> inviteFutures = [];
|
|
|
|
for (final Room room in allMyAnalyticsRooms) {
|
|
|
|
for (final Room analyticsRoom in allMyAnalyticsRooms) {
|
|
|
|
room.inviteTeachersToAnalyticsRoom();
|
|
|
|
inviteFutures.add(analyticsRoom.inviteTeachersToAnalyticsRoom());
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
await Future.wait(inviteFutures);
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// Join all analytics rooms in all spaces
|
|
|
|
// Join all analytics rooms in all spaces
|
|
|
|
// Allows teachers to join analytics rooms without being invited
|
|
|
|
// Allows teachers to join analytics rooms without being invited
|
|
|
|
Future<void> _joinAnalyticsRoomsInAllSpaces() async {
|
|
|
|
Future<void> _joinAnalyticsRoomsInAllSpaces() async {
|
|
|
|
final List<Future> joinFutures = [];
|
|
|
|
for (final Room space in _spacesImTeaching) {
|
|
|
|
for (final Room space in (await _spacesImTeaching)) {
|
|
|
|
// Each call to joinAnalyticsRoomsInSpace calls getSpaceHierarchy, which has a
|
|
|
|
joinFutures.add(space.joinAnalyticsRoomsInSpace());
|
|
|
|
// strict rate limit. So we wait a second between each call to prevent a 429 error.
|
|
|
|
|
|
|
|
await Future.delayed(
|
|
|
|
|
|
|
|
const Duration(seconds: 1),
|
|
|
|
|
|
|
|
() => space.joinAnalyticsRoomsInSpace(),
|
|
|
|
|
|
|
|
);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
await Future.wait(joinFutures);
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// Join invited analytics rooms
|
|
|
|
/// Join invited analytics rooms.
|
|
|
|
// Checks for invites to any student analytics rooms
|
|
|
|
/// Checks for invites to any student analytics rooms.
|
|
|
|
// Handles case of analytics rooms that can't be added to some space(s)
|
|
|
|
/// Handles case of analytics rooms that can't be added to some space(s).
|
|
|
|
Future<void> _joinInvitedAnalyticsRooms() async {
|
|
|
|
void _joinInvitedAnalyticsRooms() {
|
|
|
|
final List<Room> allRooms = List.from(rooms);
|
|
|
|
Future.wait(
|
|
|
|
for (final Room room in allRooms) {
|
|
|
|
rooms
|
|
|
|
if (room.membership == Membership.invite && room.isAnalyticsRoom) {
|
|
|
|
.where(
|
|
|
|
try {
|
|
|
|
(room) =>
|
|
|
|
await room.join();
|
|
|
|
room.membership == Membership.invite && room.isAnalyticsRoom,
|
|
|
|
} catch (err) {
|
|
|
|
)
|
|
|
|
debugPrint("Failed to join analytics room ${room.id}");
|
|
|
|
.map(
|
|
|
|
}
|
|
|
|
(room) => room.join().catchError((err, s) {
|
|
|
|
}
|
|
|
|
ErrorHandler.logError(e: err, s: s);
|
|
|
|
}
|
|
|
|
}),
|
|
|
|
|
|
|
|
),
|
|
|
|
|
|
|
|
);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// helper function to join all relevant analytics rooms
|
|
|
|
/// Helper function to join all relevant analytics rooms
|
|
|
|
// and set up those rooms to be joined by relevant teachers
|
|
|
|
/// and set up those rooms to be joined by other users.
|
|
|
|
Future<void> _migrateAnalyticsRooms() async {
|
|
|
|
void _migrateAnalyticsRooms() {
|
|
|
|
await _updateAnalyticsRoomVisibility();
|
|
|
|
_updateAnalyticsRoomVisibility().then((_) {
|
|
|
|
await _addAnalyticsRoomsToAllSpaces();
|
|
|
|
_addAnalyticsRoomsToAllSpaces();
|
|
|
|
await _inviteAllTeachersToAllAnalyticsRooms();
|
|
|
|
_inviteAllTeachersToAllAnalyticsRooms();
|
|
|
|
await _joinInvitedAnalyticsRooms();
|
|
|
|
_joinInvitedAnalyticsRooms();
|
|
|
|
await _joinAnalyticsRoomsInAllSpaces();
|
|
|
|
_joinAnalyticsRoomsInAllSpaces();
|
|
|
|
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
Future<Map<String, DateTime?>> _allAnalyticsRoomsLastUpdated() async {
|
|
|
|
Future<Map<String, DateTime?>> _allAnalyticsRoomsLastUpdated() async {
|
|
|
|
|
ggurdin
1 year ago
committed by
GitHub