summary refs log tree commit diff
path: root/syweb/webclient/room/room-controller.js
diff options
context:
space:
mode:
authorKegan Dougal <kegan@matrix.org>2014-11-17 11:03:58 +0000
committerKegan Dougal <kegan@matrix.org>2014-11-17 11:04:10 +0000
commitda6df07a9dd9e3e5db51313e56f24660bbb37062 (patch)
tree0afe98fb2a20ef8c38814e43bcb1dfeb1e33d191 /syweb/webclient/room/room-controller.js
parentAdd clearRooms() to wipe data when you logout. (diff)
downloadsynapse-da6df07a9dd9e3e5db51313e56f24660bbb37062.tar.xz
SYWEB-152: Remove room join logic from RoomController and put it in eventHandlerService.joinRoom.
Diffstat (limited to 'syweb/webclient/room/room-controller.js')
-rw-r--r--syweb/webclient/room/room-controller.js173
1 files changed, 39 insertions, 134 deletions
diff --git a/syweb/webclient/room/room-controller.js b/syweb/webclient/room/room-controller.js
index fdd10d7c9a..df05a8e573 100644
--- a/syweb/webclient/room/room-controller.js
+++ b/syweb/webclient/room/room-controller.js
@@ -26,7 +26,6 @@ angular.module('RoomController', ['ngSanitize', 'matrixFilter', 'mFileInput', 'a
 
     // Room ids. Computed and resolved in onInit
     $scope.room_id = undefined;
-    $scope.room_alias = undefined;
 
     $scope.state = {
         user_id: matrixService.config().user_id,
@@ -157,13 +156,8 @@ angular.module('RoomController', ['ngSanitize', 'matrixFilter', 'mFileInput', 'a
     $scope.$on(eventHandlerService.MEMBER_EVENT, function(ngEvent, event, isLive) {
         // if there is a live event affecting us
         if (isLive && event.room_id === $scope.room_id && event.state_key === $scope.state.user_id) {
-            if ($scope.state.waiting_for_joined_event) {
-                // The user has successfully joined the room, we can getting data for this room
-                $scope.state.waiting_for_joined_event = false;
-                onInit3();
-            }
             // if someone else changed our state..
-            else if (event.user_id !== $scope.state.user_id && "invite" !== event.content.membership && "join" !== event.content.membership) {    
+            if (event.user_id !== $scope.state.user_id && "invite" !== event.content.membership && "join" !== event.content.membership) {    
                 if ("ban" === event.content.membership) {
                     $scope.state.permission_denied = "You have been banned by " + mUserDisplayNameFilter(event.user_id);
                 }
@@ -343,145 +337,56 @@ angular.module('RoomController', ['ngSanitize', 'matrixFilter', 'mFileInput', 'a
     $scope.onInit = function() {
         console.log("onInit");
 
-        // Try to find out the room ID to load.
+        // Extract the room identifier being loaded
         var room_id_or_alias;
         if ($routeParams.room_id_or_alias) { // provided in the url
             room_id_or_alias = decodeURIComponent($routeParams.room_id_or_alias);
         }
+        
+        eventHandlerService.joinRoom(room_id_or_alias).then(function(roomId) {
+            $scope.room_id = roomId;
+            $scope.room = modelService.getRoom($scope.room_id);
+            
+            var messages = $scope.room.events;
 
-        if (room_id_or_alias && '!' === room_id_or_alias[0]) {
-            // it's a room ID since they start with !
-            $scope.room_id = room_id_or_alias;
-            $scope.room_alias = modelService.getRoomIdToAliasMapping($scope.room_id);
-            onInit2();
-        }
-        else {
-            if (room_id_or_alias && '#' === room_id_or_alias[0]) {
-                $scope.room_alias = room_id_or_alias;
+            if (0 === messages.length
+            || (1 === messages.length && "m.room.member" === messages[0].type && "invite" === messages[0].content.membership && $scope.state.user_id === messages[0].state_key)) {
+                // If we just joined a room, we won't have this history from initial sync, so we should try to paginate it anyway    
+                $scope.state.first_pagination = true;
             }
-            else  {
-                // Else get the room alias by hand from the URL
-                // ie: extract #public:localhost:8080 from http://127.0.0.1:8000/#/room/#public:localhost:8080
-                if (3 === location.hash.split("#").length) {
-                    $scope.room_alias = "#" + location.hash.split("#")[2];
-                }
-                else {
-                    // In case of issue, go to the default page
-                    console.log("Error: cannot extract room alias");
-                    $location.url("/");
-                    return;
-                }
+            else {
+                // There is no need to do a 1st pagination (initialSync provided enough to fill a page)
+                $scope.state.first_pagination = false;
             }
             
-            // Need a room ID required in Matrix API requests
-            console.log("Resolving alias: " + $scope.room_alias);
-            matrixService.resolveRoomAlias($scope.room_alias).then(function(response) {
-                $scope.room_id = response.data.room_id;
-                console.log("   -> Room ID: " + $scope.room_id);
-
-                // Now, we can go on
-                onInit2();
-            },
-            function () {
-                // In case of issue, go to the default page
-                console.log("Error: cannot resolve room alias");
-                $location.url("/");
-            });
-        }
-    };
-    
-    var onInit2 = function() {
-        $scope.room = modelService.getRoom($scope.room_id);
-        
-        // Scroll down as soon as possible so that we point to the last message
-        // if it already exists in memory
-        scrollToBottom(true);
-
-        // Make sure the initialSync has been before going further
-        eventHandlerService.waitForInitialSyncCompletion().then(
-            function() {
-                console.log("initialSync is complete.");
-                var needsToJoin = true;
-                
-                // The room members is available in the data fetched by initialSync
-                if ($scope.room) {
-                    var messages = $scope.room.events;
-
-                    if (0 === messages.length
-                    || (1 === messages.length && "m.room.member" === messages[0].type && "invite" === messages[0].content.membership && $scope.state.user_id === messages[0].state_key)) {
-                        // If we just joined a room, we won't have this history from initial sync, so we should try to paginate it anyway    
-                        $scope.state.first_pagination = true;
-                    }
-                    else {
-                        // There is no need to do a 1st pagination (initialSync provided enough to fill a page)
-                        $scope.state.first_pagination = false;
-                    }
+            // Make recents highlight the current room
+            recentsService.setSelectedRoomId($scope.room_id);
+            
+            updatePresenceTimes();
 
-                    var members = $scope.room.current_room_state.members;
+            // Allow pagination
+            $scope.state.can_paginate = true;
 
-                    // Check if the user has already join the room
-                    if ($scope.state.user_id in members) {
-                        if ("join" === members[$scope.state.user_id].event.content.membership) {
-                            needsToJoin = false;
-                        }
-                    }
-                }
-                
-                // Do we to join the room before starting?
-                if (needsToJoin) {
-                    $scope.state.waiting_for_joined_event = true;
-                    matrixService.join($scope.room_id).then(
-                        function() {
-                            // TODO: factor out the common housekeeping whenever we try to join a room or alias
-                            matrixService.roomState($scope.room_id).then(
-                                function(response) {
-                                    eventHandlerService.handleEvents(response.data, false, true);
-                                },
-                                function(error) {
-                                    console.error("Failed to get room state for: " + $scope.room_id);
-                                }
-                            );                                        
-                            
-                            // onInit3 will be called once the joined m.room.member event is received from the events stream
-                            // This avoids to get the joined information twice in parallel:
-                            //    - one from the events stream
-                            //    - one from the pagination because the pagination window covers this event ts
-                            console.log("Joined room "+$scope.room_id);
-                        },
-                        function(reason) {
-                            console.log("Can't join room: " + JSON.stringify(reason));
-                            // FIXME: what if it wasn't a perms problem?
-                            $scope.state.permission_denied = "You do not have permission to join this room";
-                        });
-                }
-                else {
-                    onInit3();
-                }
+            // Do a first pagination only if it is required (e.g. we've JUST joined a room and have no messages to display.)
+            // FIXME: Should be no more require when initialSync/{room_id} will be available
+            if ($scope.state.first_pagination) {
+                paginate(MESSAGES_PER_PAGINATION);
             }
-        );
-    };
-
-    var onInit3 = function() {
-        console.log("onInit3");
-
-        // Make recents highlight the current room
-        recentsService.setSelectedRoomId($scope.room_id);
-        
-        updatePresenceTimes();
-
-        // Allow pagination
-        $scope.state.can_paginate = true;
-
-        // Do a first pagination only if it is required
-        // FIXME: Should be no more require when initialSync/{room_id} will be available
-        if ($scope.state.first_pagination) {
-            paginate(MESSAGES_PER_PAGINATION);
-        }
-        else {
-            // There are already messages, go to the last message
+            
+            // Scroll down as soon as possible so that we point to the last message
+            // if it already exists in memory
             scrollToBottom(true);
-        }
-    }; 
+        },
+        function(err) {
+            if (err.data.errcode === "M_FORBIDDEN") {
+                $scope.state.permission_denied = "You do not have permission to join this room";
+            }
+            else {
+                console.log("Error: cannot join room: "+JSON.stringify(err));
+                $location.url("/");
+            }
+        });
+    };
 
     $scope.leaveRoom = function() {