diff options
Diffstat (limited to 'webclient/room/room-controller.js')
| -rw-r--r-- | webclient/room/room-controller.js | 214 |
1 files changed, 214 insertions, 0 deletions
diff --git a/webclient/room/room-controller.js b/webclient/room/room-controller.js new file mode 100644 index 0000000000..f3836c536b --- /dev/null +++ b/webclient/room/room-controller.js @@ -0,0 +1,214 @@ +angular.module('RoomController', []) +.controller('RoomController', ['$scope', '$http', '$timeout', '$routeParams', '$location', 'matrixService', + function($scope, $http, $timeout, $routeParams, $location, matrixService) { + 'use strict'; + $scope.room_id = $routeParams.room_id; + $scope.room_alias = matrixService.getRoomIdToAliasMapping($scope.room_id); + $scope.state = { + user_id: matrixService.config().user_id, + events_from: "START" + }; + $scope.messages = []; + $scope.members = {}; + $scope.stopPoll = false; + + $scope.userIDToInvite = ""; + + var shortPoll = function() { + $http.get(matrixService.config().homeserver + matrixService.prefix + "/events", { + "params": { + "access_token": matrixService.config().access_token, + "from": $scope.state.events_from, + "timeout": 5000 + }}) + .then(function(response) { + console.log("Got response from "+$scope.state.events_from+" to "+response.data.end); + $scope.state.events_from = response.data.end; + + for (var i = 0; i < response.data.chunk.length; i++) { + var chunk = response.data.chunk[i]; + if (chunk.room_id == $scope.room_id && chunk.type == "m.room.message") { + if ("membership_target" in chunk.content) { + chunk.user_id = chunk.content.membership_target; + } + $scope.messages.push(chunk); + $timeout(function() { + window.scrollTo(0, document.body.scrollHeight); + },0); + } + else if (chunk.room_id == $scope.room_id && chunk.type == "m.room.member") { + updateMemberList(chunk); + } + else if (chunk.type === "m.presence") { + updatePresence(chunk); + } + } + if ($scope.stopPoll) { + console.log("Stopping polling."); + } + else { + $timeout(shortPoll, 0); + } + }, function(response) { + $scope.feedback = "Can't stream: " + JSON.stringify(response); + if ($scope.stopPoll) { + console.log("Stopping polling."); + } + else { + $timeout(shortPoll, 2000); + } + }); + }; + + var updateMemberList = function(chunk) { + var isNewMember = !(chunk.target_user_id in $scope.members); + if (isNewMember) { + $scope.members[chunk.target_user_id] = chunk; + // get their display name and profile picture and set it to their + // member entry in $scope.members. We HAVE to use $timeout with 0 delay + // to make this function run AFTER the current digest cycle, else the + // response may update a STALE VERSION of the member list (manifesting + // as no member names appearing, or appearing sporadically). + $scope.$evalAsync(function() { + matrixService.getDisplayName(chunk.target_user_id).then( + function(response) { + var member = $scope.members[chunk.target_user_id]; + if (member !== undefined) { + console.log("Updated displayname "+chunk.target_user_id+" to " + response.displayname); + member.displayname = response.displayname; + } + } + ); + matrixService.getProfilePictureUrl(chunk.target_user_id).then( + function(response) { + var member = $scope.members[chunk.target_user_id]; + if (member !== undefined) { + console.log("Updated image for "+chunk.target_user_id+" to " + response.avatar_url); + member.avatar_url = response.avatar_url; + } + } + ); + }); + } + else { + // selectively update membership else it will nuke the picture and displayname too :/ + var member = $scope.members[chunk.target_user_id]; + member.content.membership = chunk.content.membership; + } + } + + var updatePresence = function(chunk) { + if (!(chunk.content.user_id in $scope.members)) { + console.log("updatePresence: Unknown member for chunk " + JSON.stringify(chunk)); + return; + } + var member = $scope.members[chunk.content.user_id]; + + if ("state" in chunk.content) { + var ONLINE = 2; + var AWAY = 1; + var OFFLINE = 0; + if (chunk.content.state === ONLINE) { + member.presenceState = "online"; + } + else if (chunk.content.state === OFFLINE) { + member.presenceState = "offline"; + } + else if (chunk.content.state === AWAY) { + member.presenceState = "away"; + } + } + + // this may also contain a new display name or avatar url, so check. + if ("displayname" in chunk.content) { + member.displayname = chunk.content.displayname; + } + + if ("avatar_url" in chunk.content) { + member.avatar_url = chunk.content.avatar_url; + } + } + + $scope.send = function() { + if ($scope.textInput == "") { + return; + } + + // Send the text message + var promise; + // FIXME: handle other commands too + if ($scope.textInput.indexOf("/me") == 0) { + promise = matrixService.sendEmoteMessage($scope.room_id, $scope.textInput.substr(4)); + } + else { + promise = matrixService.sendTextMessage($scope.room_id, $scope.textInput); + } + + promise.then( + function() { + console.log("Sent message"); + $scope.textInput = ""; + }, + function(reason) { + $scope.feedback = "Failed to send: " + reason; + }); + }; + + $scope.onInit = function() { + // $timeout(function() { document.getElementById('textInput').focus() }, 0); + console.log("onInit"); + + // Join the room + matrixService.join($scope.room_id).then( + function() { + console.log("Joined room"); + // Now start reading from the stream + $timeout(shortPoll, 0); + + // Get the current member list + matrixService.getMemberList($scope.room_id).then( + function(response) { + for (var i = 0; i < response.chunk.length; i++) { + var chunk = response.chunk[i]; + updateMemberList(chunk); + } + }, + function(reason) { + $scope.feedback = "Failed get member list: " + reason; + } + ); + }, + function(reason) { + $scope.feedback = "Can't join room: " + reason; + }); + }; + + $scope.inviteUser = function(user_id) { + + matrixService.invite($scope.room_id, user_id).then( + function() { + console.log("Invited."); + $scope.feedback = "Request for invitation succeeds"; + }, + function(reason) { + $scope.feedback = "Failure: " + reason; + }); + }; + + $scope.leaveRoom = function() { + + matrixService.leave($scope.room_id).then( + function(response) { + console.log("Left room "); + $location.path("rooms"); + }, + function(reason) { + $scope.feedback = "Failed to leave room: " + reason; + }); + }; + + $scope.$on('$destroy', function(e) { + console.log("onDestroyed: Stopping poll."); + $scope.stopPoll = true; + }); +}]); |