FileExplorerController.js

"use strict";

var angular = require ('angular');

var settings = require ('settings');
require ('debug').enable (settings.debug);
var debug = require ('debug')('wyliodrin:lacy:FileExplorerController');

var path = require ('path');

var _ = require ('lodash');

var $ = require ('jquery');

var mixpanel = require ('mixpanel');

debug ('Loading');

module.exports = function ()
{

	var app = angular.module ('wyliodrinApp');

	app.controller('FileExplorerController', function($scope, $timeout, $mdDialog, $wydevice, $translate){
		debug ('Registering');

		$scope.translatevars={};
		$scope.translatevars.empty = $translate.instant('Empty_folder');
		$scope.translatevars.loading = $translate.instant('Loading');
		$scope.translatevars.new_folder = $translate.instant('New_folder');

		$scope.files = [];
		$scope.cwd = "";
		$scope.treeData = [];
		$scope.showHidden = false;
		$scope.selectedRight = {};

		$scope.showPopupDelete = 0;
		$scope.showPopupRename = 0;
		$scope.showPopupNewFolder = 0;
		$scope.showPopupError = 0;
		$scope.showPopupUpload = 0;
		$scope.showPopupDownload = 0;

		$scope.contentPopupRename = "";
		$scope.contentPopupNewFolder = "";
		$scope.contentPopupError = "";

		$scope.MAXPACKET = 32*1024;
		$scope.uploadvars={};
		$scope.downloadvars={};


		mixpanel.track ('File Explorer', {
			category: $wydevice.device.category
		});
		var that = this;



		var message = function (t, p)
		{
			//change dir
			if (t === 'fe1')
			{
				$timeout (function ()
				{
					$scope.selectedRight = {}; //force deselectation

					if (p[0] == "ERROR")
					{
						$scope.contentPopupError = $translate.instant('FEinexistent_folder');
						$scope.showPopupError = 1;
						//ne ducem inapoi
						$scope.cwd = $scope.cwd.slice(0,$scope.cwd.lastIndexOf("/"));
						if ($scope.cwd === "")
							//inseamna ca am ajuns la root
						{
							$scope.cwd = "/"; 
						}
						$wydevice.send ('fe', {a:'ls',b:$scope.cwd});
					}
					else
					{
						if ($scope.cwd != "/")
						{
							$scope.files = [{'name':'.. (Go up)','isup':true,'isdir':false,'isfile':false,'islink':false}];
							$scope.files = $scope.files.concat(p);
						}
						else
						{
							$scope.files = p;
						}
						//make the right side be the same as the left
						var treeHeight = $('.tree-classic-remote').height();
        				$('.on-the-right').css('height', treeHeight);  
					}	
				});
			}
			//get home
			if (t === 'fe2')
			{
				$timeout (function ()
				{
					$scope.cwd = p;
					//am primit homeul, continui
					that.refresh();
				});
			}
			//download
			if (t === 'fe3')
			{
				$timeout (function ()
				{

					var temp = new Buffer(p.f);
					if (typeof $scope.downloadvars.c === 'undefined')
					{
						$scope.downloadvars.c = temp;
					}
					else
					{
						$scope.downloadvars.c = Buffer.concat([$scope.downloadvars.c,temp]);
					}
					$scope.downloadvars.d = p.all; //file size on the board

					if (typeof $scope.downloadvars.call === 'undefined')
					{

						chrome.fileSystem.chooseEntry(
						{
							type: 'saveFile',
							suggestedName: $scope.downloadvars.b,
						}, 
						function(fileEntry) 
						{
							if(chrome.runtime.lastError) 
							{

							}
							if (!fileEntry) 
							{
								//in case of popup when cancel before chosing download folder
								/*$timeout ( function()
								{
									$scope.contentPopupError = $translate.instant('FEfile_write');
								 	$scope.showPopupError = 1;
							 	});*/
							 	return;
							}

							$scope.downloadvars.call=fileEntry;
							$scope.showPopupDownload = 1;
							//redundant rezolva
							if (p.end)
							{
								var toArrayBuffer = function(buffer) {
								    var ab = new ArrayBuffer(buffer.length);
								    var view = new Uint8Array(ab);
								    for (var i = 0; i < buffer.length; ++i) {
								        view[i] = buffer[i];
								    }
								    return ab;
								};
								var vasile = toArrayBuffer($scope.downloadvars.c);

								$scope.downloadvars.call.createWriter(function(fileWriter) 
								{
						 			fileWriter.onerror = function (error)
							 		{
							 			$scope.contentPopupError = $translate.instant('FEfile_write');
							 			$scope.showPopupError = 1;
							 			//console.log ('Filewriter error ' + error);
							 		};
							 		fileWriter.write (new Blob ([vasile], {type:''}), function (error)
						 			{
						 				$scope.contentPopupError = $translate.instant('FEfile_write');
						 				$scope.showPopupError = 1;
						 				//console.log ('Error on write '+ error);
						 			});
							 	});
							 	$scope.showPopupDownload = 0;
							 	$scope.downloadvars={};
							}
							else
							{
								that.download($scope.downloadvars.a,$scope.downloadvars.b,p.i);
							}
							//redundant, rezolva

						});
					}
					else
					{	if($scope.showPopupDownload === 1 )
						{
							if (p.end)
							{
								var toArrayBuffer = function(buffer) {
								    var ab = new ArrayBuffer(buffer.length);
								    var view = new Uint8Array(ab);
								    for (var i = 0; i < buffer.length; ++i) {
								        view[i] = buffer[i];
								    }
								    return ab;
								};
								var vasile = toArrayBuffer($scope.downloadvars.c);

								$scope.downloadvars.call.createWriter(function(fileWriter) 
								{
						 			fileWriter.onerror = function (error)
							 		{
							 			$scope.contentPopupError = $translate.instant('FEfile_write');
							 			$scope.showPopupError = 1;
							 			//console.log ('Filewriter error ' + error);
							 		};
							 		fileWriter.write (new Blob ([vasile], {type:''}), function (error)
						 			{
						 				$scope.contentPopupError = $translate.instant('FEfile_write');
						 				$scope.showPopupError = 1;
						 				//console.log ('Error on write '+ error);
						 			});
							 	});
							 	$scope.showPopupDownload = 0;
							 	$scope.downloadvars={};
							}
							else
							{
								that.download($scope.downloadvars.a,$scope.downloadvars.b,p.i);
							}
						}
						else
						{
							//that.delete({folder:$scope.uploadvars.a,file:$scope.uploadvars.b});
							//delete local file
							$scope.downloadvars = {};
						}
					}
				});
			}
						 	
			//tree and tree forced from right
			if (t === 'fe4' || t === 'fe5')
			{
				$timeout (function ()
				{


					function search_tree (loc)
					{
						var list_loc = that.splitPath(loc);
						return search_tree_aux(list_loc,$scope.treeData);
					}

					function search_tree_aux (list_loc,tree)
					{

						var current = list_loc.shift();
						var result = tree.find(function (child)
						{
							return (child.name == current && child.d == 1);
						});

						if (list_loc.length === 0){
							return result;
						}
						else{
							return search_tree_aux(list_loc,result.children);
						}
					}

					function check_children (lista, place)
					{
						var final=[];

						lista.forEach (function (child)
						{
							child.so = !child.d;
							child.name = path.basename(child.p);

							var real_place;
							if (place != "/")
							{
								real_place = place.children.find(function(sub)
								{
									return (sub.name == child.name);
								});
							}

							if (place == "/" || 
								place.children[0].isunvisited === true || 
								real_place === undefined)
							{
								child.visited = 0;

								if (child.d === false)
								{
									child.children=[];
								}
								else
								{
									child.children=[{'name':$scope.translatevars.loading,'children':[],'isspecial':true, 'isunvisited':true }]; //fara d si p
								}
							}
							else
							{
								child.visited = real_place.visited;

								if (child.d === false)
								{
									child.children=[];
								}
								else
								{
									child.children=real_place.children;
								}
							}
							final.push(child);

						});
						return final;
					}



					if (p.a[0] == "ERROR")
					{
						//nu ai drepturi de a accesa
						search_tree(p.p).children=[{'name':$scope.translatevars.empty,'children':[],'isspecial':true}];
					}
					else
					{
						if (p.a.length === 0)
						{
							//folderul e gol
							search_tree(p.p).children=[{'name':$scope.translatevars.empty,'children':[],'isspecial':true}];
						}
						else
						{
							if (p.p == "/")
							{
								$scope.treeData = check_children(p.a,"/"); //put it directly
							}
							else
							{
								var place = search_tree(p.p);
								place.children = check_children(p.a,place);
								$scope.selected_node.visited = 1;
								if (t === 'fe5') //forced by right-side to go to there
								{
									$scope.expanded_nodes.push(place);
									$scope.selected_node = place;
								}
							}

						}
					}
				});
			}
			//error messages from newfolder del rename
			if (t === 'fe6')
			{
				$timeout (function ()
				{
					if (p.a === 'newf')
					{
						$scope.contentPopupError = $translate.instant('FEnew_folder');
						if (p.e === 'EEXIST')
						{
							$scope.contentPopupError += $translate.instant('FEexists');
						}
						else if (p.e === 'EACCES')
						{
							$scope.contentPopupError += $translate.instant('FEwrite_permission');
						}
						else
						{
							$scope.contentPopupError += $translate.instant('FEunknown');
						}
					}
					else if (p.a === 'del')
					{
						$scope.contentPopupError = $translate.instant('FEdelete');
						if (p.e === 'EACCES')
						{
							$scope.contentPopupError += $translate.instant('FEdelete_permission');
						}
						else
						{
							$scope.contentPopupError += $translate.instant('FEunknown');
						}
					}
					else if (p.a === 'ren')
					{
						$scope.contentPopupError = $translate.instant('FErename');
						if (p.e === 'EEXIST')
						{
							$scope.contentPopupError += $translate.instant('FEexists');
						}
						else if (p.e === 'ENOENT')
						{
							$scope.contentPopupError += $translate.instant('FEnot_exists');
						}
						else if (p.e === 'EACCES')
						{
							$scope.contentPopupError += $translate.instant('FErename_permission');
						}
						else
						{
							$scope.contentPopupError += $translate.instant('FEunknown');
						}
					}
					else if (p.a === 'up')
					{
						$scope.contentPopupError = $translate.instant('FEupload');
						$scope.showPopupUpload = 0;
						$scope.uploadvars = {};
						if (p.e === 'EACCES')
						{
							$scope.contentPopupError += $translate.instant('FEwrite_permission');
						}
						else if (p.e === 'EEXIST')
						{
							$scope.contentPopupError += $translate.instant('FEexists');
						}
						else
						{
							$scope.contentPopupError += $translate.instant('FEunknown');
						}
					}
					else if (p.a === 'down')
					{
						$scope.contentPopupError = $translate.instant('FEdownload');
						$scope.showPopupDownload = 0;
						$scope.downloadvars = {};
						if (p.e === 'EACCES')
						{
							$scope.contentPopupError += $translate.instant('FEread_permission');
						}
						else if (p.e === 'ENOENT')
						{
							$scope.contentPopupError += $translate.instant('FEnot_exists');
						}
						else
						{
							$scope.contentPopupError += $translate.instant('FEunknown');
						}
					}
					else
					{
						$scope.contentPopupError = $translate.instant('FEunknown');
					}


					$scope.showPopupError = 1;
				});
			}
			//ls tree and right
			if (t === 'fe7')
			{
				$timeout (function ()
				{
					if (p.a == 'up')
					{
						$scope.showPopupUpload = 0;
						$scope.uploadvars = {};
					}
					that.refresh();
				});
			}
			//upload in chunks
			if (t === 'fe8')
			{
				$timeout (function ()
				{
					if ($scope.showPopupUpload === 1)
					{
						that.uploadChunk();
					}
					else
					{
						that.delete({folder:$scope.uploadvars.a,file:$scope.uploadvars.b});
						$scope.uploadvars = {};
						
					}
				});
			}
		};

		this.splitPath = function(loc)
		{
			var list_loc=[];
			//unshift is oposite of push
			while (loc != "/")
			{
				list_loc.unshift(path.basename(loc));
				loc = path.dirname(loc);
			}
			return list_loc;
		};

		
		this.getChildren = function(node, expanded)
		{
			if (expanded == 1)
			{
				$wydevice.send ('fe', {a:'tree',b:node.p});
			}
			else
			{
				//if contracting be sure to delete all other instances
				var final = [];
				_.each($scope.expanded_nodes, function(exp)
				{
					if (exp.p !== node.p)
					{
						final.push(exp);
					}
				});
				$scope.expanded_nodes = final;
			}
		};

		this.absolutecd = function(node)
		{
			if (node.d)
			{
				$scope.cwd = node.p;
				this.list();
			}
			else
			{
				if (!node.isspecial)
				{
					this.download(path.dirname(node.p),node.name);
				}
			}
		};

		$scope.expanded_nodes = [];
		$scope.selected_node = {};
		$scope.tree_orderby = ['so','name'];

		$scope.tree_predicate = ".";
		$scope.tree_comparator = function(actual,expected)
		{
			if ($scope.showHidden)
			{
				return true;
			}
			else
			{
				/*if (actual !== null && typeof actual === 'object' && actual.name && actual.name.startsWith(".")){
					console.log("actual");
					console.log(actual);
				}*/
				if (actual !== null && typeof actual === 'object' && actual.name && (!actual.name.startsWith(".")))
				{
					return true;
				}
				else
				{
					return false;
				}
			}
		};

		$scope.treeOptions = {
		    nodeChildren: "children",
		    dirSelectable: true,
		    injectClasses: {
		        ul: "a1",
		        li: "a2",
		        liSelected: "a7",
		        iExpanded: "a3",
		        iCollapsed: "a4",
		        iLeaf: "a5",
		        label: "a6",
		        labelSelected: "a8"
		    }
		};


		$wydevice.on ('message', message);

		$wydevice.send ('fe', {a:'phd'});
		$wydevice.send ('fe', {a:'tree',b:'/'});

		function human_readable(number)
		{
			if (number>1000000000)
			{
				return (Math.round(number/10000000)/100).toString() + " GB";
			}
			else
			{
				if (number>1000000)
				{
					return (Math.round(number/10000)/100).toString() + " MB";
				}
				else
				{
					if (number>1000)
					{
						return (Math.round(number/10)/100).toString() + " KB";
					}
					else
					{
						return (Math.round(number*100)/100).toString() + " B";
					}
				}
			}
		}


		$scope.$watchCollection("files", function(){
			for (var i=0; i<$scope.files.length; i++)
			{
				$scope.files[i].size = human_readable($scope.files[i].size);
			}
		});


		this.hide = function(file)
		{
			if ($scope.showHidden)
			{
				return true;
			}
			else
			{
				if (file.isup)
				{
					return true;
				}
				if (file.name.startsWith("."))
				{
					return false;
				}
				else
				{
					return true;
				}
			}
		};




		this.cd = function(folder)
		{
			debug ('Changing to folder');
			if ($scope.cwd != "/")
			{
				$scope.cwd=$scope.cwd+"/"+folder;
			}
			else
			{
				$scope.cwd=$scope.cwd+folder;
			}
			//$scope.cwd = path.join($scope.cwd,folder)

			this.refresh();

		};

		this.list = function ()
		{
			//let only up be on screen
			$scope.files = [{'name':'.. (Go up)','isup':true,'isdir':false,'isfile':false,'islink':false}];
			$wydevice.send ('fe', {a:'ls',b:$scope.cwd});
		};

		this.refresh = function()
		{
			this.list();
			//tree part
			var list_loc = this.splitPath($scope.cwd);
			$wydevice.send ('fe', {a:'treeforce',b:list_loc});
			
		};

		this.up = function ()
		{
			if ($scope.cwd != "/"){

				debug ('Going up');
				//get rid of last folder entered
				$scope.cwd = $scope.cwd.slice(0,$scope.cwd.lastIndexOf("/"));
				if ($scope.cwd === "")
				{
					//reached root, only select, on tree
					$scope.cwd = "/"; 
					$scope.selected_node = {};
					this.list();
				}
				else
				{
					//not root, get tree for left
					this.refresh();
				}
			}
		};

		this.doubleclick = function(file)
		{
			if (file.isup)
			{
				this.up();
			}
			if (file.isdir)
			{
				this.cd(file.name);
			}
			if (file.isfile)
			{
				//download
				this.download($scope.cwd,file.name);
			}
		};


		this.click = function(file)
		{
			$scope.selectedRight = file;
		};

		this.isSelected = function(file)
		{
			if (file.isdir == $scope.selectedRight.isdir &&
				file.isfile == $scope.selectedRight.isfile &&
				file.islink == $scope.selectedRight.islink &&
				file.name == $scope.selectedRight.name &&
				file.size == $scope.selectedRight.size)

			{
				return true;
			}
			return false;
		};

		this.download = function(cwd,filename,index=0)
		{
			if (index === 0)
			{
				$scope.downloadvars.a = cwd;
				$scope.downloadvars.b = filename;
				//$scope.downloadvars.c = undefined;
				$scope.downloadvars.d = $scope.MAXPACKET; //variable for full file size; placeholder for now
			}
			$wydevice.send ('fe', {a:'down',b:cwd,c:filename,z:index,size:$scope.MAXPACKET});

		};

		this.upload = function()
		{
			if (!$scope.showPopupUpload){

				chrome.fileSystem.chooseEntry(
				{
					type: 'openFile'
				}, 
				function(fileEntry) {
					if(chrome.runtime.lastError) 
					{

					}
					if (!fileEntry) {
						debug ('File missing');
						return;
				 	}

				 	fileEntry.file(function(file) 
				 	{
						var fileReader = new FileReader ();
						fileReader.onload = function (value)
						{
							var rawData = value.target.result;
							var buffer = new Buffer( new Uint8Array(rawData) );

							$scope.showPopupUpload = 1;

							$scope.uploadvars.a = $scope.cwd;
							$scope.uploadvars.b = file.name;
							$scope.uploadvars.c = buffer;
							$scope.uploadvars.d = 0;
							that.uploadChunk();
							


						};
						fileReader.onerror = function (err)
						{
							debug (err);
							$scope.contentPopupError = $translate.instant('FEread_permission_local');
							$scope.showPopupError = 1;
						};
						fileReader.readAsArrayBuffer (file);
				 	});
				});
			}
		};

		this.uploadChunk = function()
		{
			var dir = $scope.uploadvars.a;
			var file = $scope.uploadvars.b;
			var buffer = $scope.uploadvars.c;
			var index = $scope.uploadvars.d;
			var t;
			var part;

			if (index === 0)
			{
				t = 'w';
			}
			else
			{
				t = 'a';
			}

			
			if (index + $scope.MAXPACKET < buffer.length) //there are more packets than this
			{
				part = buffer.slice(index,index + $scope.MAXPACKET);
				$wydevice.send ('fe', {a:'up',b:dir,c:file,d:part,t:t,end:false});
				$scope.uploadvars.d += $scope.MAXPACKET;
			}
			else
			{
				part = buffer.slice(index,buffer.length);
				$wydevice.send ('fe', {a:'up',b:dir,c:file,d:part,t:t,end:true});
			}
		};


		this.renameButton = function()
		{
			if(!_.isEmpty($scope.selectedRight) && !$scope.selectedRight.isup)
			{
				$scope.contentPopupRename=$scope.selectedRight.name;
				$scope.showPopupRename=1;
			}
		};
		this.renameButtonShow = function()
		{
			if(!_.isEmpty($scope.selectedRight) && !$scope.selectedRight.isup)
			{
				return true;
			}
		};
		this.rename = function(name)
		{
			$wydevice.send ('fe', {a:'ren',b:$scope.cwd,c:$scope.selectedRight.name,d:$scope.contentPopupRename});
			$scope.showPopupRename = 0;
		};


		this.deleteButton = function()
		{
			if(!_.isEmpty($scope.selectedRight) && !$scope.selectedRight.isup)
			{
				$scope.showPopupDelete=1;
			}
		};
		this.deleteButtonShow = function()
		{
			if(!_.isEmpty($scope.selectedRight) && !$scope.selectedRight.isup)
			{
				return true;
			}
		};
		this.delete = function(attr={})
		{
			if (!_.isEmpty(attr)){
				$wydevice.send ('fe', {a:'del',b:attr.folder,c:attr.file});
			}
			else
			{
				$wydevice.send ('fe', {a:'del',b:$scope.cwd,c:$scope.selectedRight.name});
				$scope.showPopupDelete = 0;
			}
		};

		this.downloadButtonShow = function()
		{
			if(!_.isEmpty($scope.selectedRight) && $scope.selectedRight.isfile)
			{
				return true;
			}
		};


		this.newFolderButton = function()
		{
			$scope.contentPopupNewFolder=$scope.translatevars.new_folder;
			$scope.showPopupNewFolder=1;
		};
		this.newFolder = function()
		{
			$wydevice.send ('fe', {a:'newf',b:$scope.cwd,c:$scope.contentPopupNewFolder});
			$scope.showPopupNewFolder = 0;
		};


		this.exit = function ()
		{
			debug ('Exiting');
			$mdDialog.hide ();
			$wydevice.removeListener ('message', message);
		};
	});
};