Update Tutorial model

source/models/Tutorial.js

@@ -8,7 +8,7 @@ var Sequelize = require ('sequelize');
 var User = require ('./User');
 var rest = require ('rest');
 var app = require ('../../app');
-//var Room = require('./Room');
+var Rooms = require('./Rooms');
 
 /**
  * Define tutorial model
@@ -108,6 +108,89 @@ tutorial.belongsToMany (User, {
 
 sequelize.sync ();
 
+/**
+ * Find tutorial by user ID and tutorial ID
+ * @param uid
+ * @param tid
+ * @returns {Promise}
+ */
+var findTutorial = function (uid, tid) {
+	return tutorial.findAndCountAll ({
+		where: {
+			id: tid
+		},
+		include: [{
+			model: User,
+			attributes: ['id'],
+			where: {id: uid}
+		}]
+	})
+};
+
+/**
+ * Find tutorial tutor's ID by tutorial ID
+ * @param tid
+ * @returns {Promise}
+ */
+var findTutorialTutorID = function (tid) {
+	return userTutorial.find (
+		{
+			attributes: ['userId'],
+			where: {
+				tutorialId: tid,
+				role: 'tutor'
+			}
+		}
+	);
+};
+
+/**
+ * Check if user is in tutorial
+ * @param uid
+ * @param tid
+ * @returns {Promise}
+ */
+var checkIfInTutorialUserList = function (uid, tid) {
+	return userTutorial.find (
+		{
+			where: {
+				tutorialId: tid,
+				userId: uid
+			}
+		}
+	);
+}
+
+/**
+ * Find and count all tutorials of one user
+ * @param uid
+ * @returns {Promise}
+ */
+var findAndCountAllTutorials = function (uid) {
+	return tutorial.findAndCountAll ({
+		include: [{
+			model: User,
+			attributes: ['id'],
+			where: {id: uid}
+		}]
+	});
+};
+
+/**
+ * Find and count all user in some tutorial
+ * @param tid
+ * @returns {Promise}
+ */
+var findAndCountAllUsersInTutorial = function(tid){
+	return User.findAndCountAll({
+		include:[{
+			model: tutorial,
+			where: {id: tid}
+		}],
+		attributes:['id','name','gender','email']
+	});
+};
+
 /**
  * Private function, fetch IVLE user modules, return promise
  * @param token
@@ -122,10 +205,141 @@ var fetchIVLEUserModules = function (token) {
  * @param token
  * @param course
  * @returns {Promise}
- *
+ */
 var fetchIVLETutorialGroups = function (token, course) {
 	return rest ('https://ivle.nus.edu.sg/API/Lapi.svc/GroupsByUserAndModule?APIKey=' + app.get ('api-key') + '&AuthToken=' + token + '&CourseID=' + course['ID'] + '&AcadYear=' + course['AcadYear'] + '&Semester=' + course['semester']).then (function (response) {
 		return {tutorialGroup: JSON.parse (response.entity).Results, course: course};
 	});
 }
-*/
+
+/**
+ * Force Synchronize user's IVLE account and import all data into system database
+ * @param uid
+ * @return Promise
+ */
+var forceSyncIVLE = function (uid) {
+	return new Promise (function (fulfill, reject) {
+		User.findOne ({
+			where: {
+				id: uid
+			},
+		}).then (function (user) {
+			return fetchIVLEUserModules (user.token).then (function (response) {
+				//console.log(JSON.parse(response.entity).Results);
+				//console.log(response);
+				return [response, JSON.parse (response.entity).Results, user];
+			});
+		}).spread (function (response, courses, user) {
+			//console.log(courses);
+			if (courses.length == 0 && (response.status.code != 200)) {
+				reject ('Sync Module Failed');
+			}
+			return Promise.all (courses.map (function (course) {
+				//console.log(course);
+				return fetchIVLETutorialGroups (user.token, course)
+			})).then (function (result) {
+				//console.log(result);
+				if (result.length == 0) {
+					return reject ('Sync Groups By User And Module Failed');
+				}
+				return [result, user];
+			});
+		}).spread (function (result, user) {
+			//create tutorial in this block
+			var groups = [];
+			for (var resultIndex in result) {
+				for (var groupIndex in result[resultIndex]['tutorialGroup']) {
+					if (result[resultIndex]['tutorialGroup'][groupIndex]['GroupTypeCode'] === 'T') {
+						var group = result[resultIndex]['tutorialGroup'][groupIndex];
+						group['CourseName'] = result[resultIndex]['course']['CourseName'];
+						group['Permission'] = result[resultIndex]['course']['Permission'];
+						groups.push (group);
+					}
+				}
+			}
+			return Promise.all (groups.map (function (group) {
+				return tutorial.findOrCreate ({
+					where: {
+						name: group['GroupName'],
+						courseid: group['CourseID']
+					},
+					defaults: {
+						grouptype: group['GroupType'],
+						coursecode: group['ModuleCode'],
+						coursename: group['CourseName'],
+						week: group['Week'],
+						day: group['Day'],
+						time: group['Time']
+					}
+				}).spread (function (tutorial, created) {
+					return tutorial;
+				});
+			})).then (function (tutorials) {
+				return {tutorials: tutorials, user: user, groups: groups};
+			}).catch(function(err){
+				reject ('Sync Failed: ' + err.stack);
+			})
+		}).then (function (result) {
+			//Add user tutorial relation in this block
+			var tutorials = result.tutorials;
+			var groups = result.groups;
+
+			if (tutorials.length != groups.length) {
+				return reject ('Database Error!');
+			}
+			var relations = [];
+			for (var groupIndex in groups) {
+				var relation = {};
+				relation['tutorial'] = tutorials[groupIndex];
+				relation['permission'] = groups[groupIndex]['Permission'];
+				relations.push (relation);
+			}
+			return Promise.all (relations.map (function (relation) {
+				//If room has not been created, create the room first
+				//console.log(relation['tutorial'].id);
+				var newroom = new Rooms.Room();
+				return Rooms.getLobby().findOrAddRoom(relation['tutorial'].id, newroom).then(function(room){
+					if (!room.get('default').get(result.user.id)){
+						var socketClient = new Rooms.SocketClient(result.user.name, result.user.id,null);
+						socketClient.regist(relation['tutorial'].id);
+					}
+					var role = 'student';
+					if (relation['permission'] === 'M') {
+						role = 'tutor';
+						room.tutors[result.user.id] = room.get('default').get(result.user.id);
+					}
+					return relation['tutorial'].addUser (result.user, {role: role});
+				});
+			}));
+		}).then (function (result) {
+			if (result) {
+				fulfill (true);
+			}
+		}).catch (function (err) {
+			reject ('Sync Failed: ' + err.stack);
+		})
+	});
+};
+
+/**
+ * Find all tutorial by user id
+ * @param uid
+ * @returns {Promise}
+ */
+var findTutorialSession = function (uid) {
+	return userTutorial.findAll ({
+		where: {
+			userId: uid
+		}
+	});
+};
+
+
+module.exports = tutorial;
+module.exports.forceSyncIVLE = forceSyncIVLE;
+module.exports.findTutorial = findTutorial;
+module.exports.findAndCountAllTutorials = findAndCountAllTutorials;
+module.exports.findTutorialSession = findTutorialSession;
+module.exports.findTutorialTutorID = findTutorialTutorID;
+module.exports.checkIfInTutorialUserList = checkIfInTutorialUserList;
+module.exports.findAndCountAllUsersInTutorial = findAndCountAllUsersInTutorial;