utility.js

import { FILE_TABLE }  from './fileTable';
import { config } from './config';
import { EventHandler } from './eventHandler';
import {Actions} from './actions';
import {DEV, ROOT} from './header';
import debug from './debug';
import {requestFile} from './connection';
var FullPath = require('fullpath');

export var diffFileTable = (receivedFileTable) => {
  var isUpdated = false;
  debug.log("In Diff Algo: ", DEV);

  //File Does not exist
  receivedFileTable.map((obj)=>{
    // obj.F_ID
    var isPresent = false;
    FILE_TABLE.GLOBAL.forEach(function(myObj) {
      if(myObj.F_ID == obj.F_ID){
        debug.log(obj, "is present", DEV);
        isPresent = true;
      }
    });
    var inDeletedBy = ((obj.DELETED_BY.filter((val) => { return val == config.my_addr })).length == 0) ? false:true;
    if(!isPresent && !inDeletedBy){
      //If file is not present then add
      //TODO: implement a check if your ip address already exists in the NODE_LIST
      obj.NODE_LIST.push(config.my_addr);
      if(obj.DELETED){
        obj.DELETED_BY.push(config.my_addr);
      }
      FILE_TABLE.GLOBAL.push(obj);
      isUpdated = true;
    }else{
        //Replace the nodelist of my local file entry row with the updated entry row nodelist


        FILE_TABLE.GLOBAL.forEach(function(myObj) {
          if(myObj.F_ID == obj.F_ID && obj.DELETED && !myObj.DELETED){
            myObj.DELETED = true;
            myObj.DELETED_BY.push(config.my_addr);
            arrayUnique(myObj.DELETED_BY);
            isUpdated = true;
          }
          if(myObj.F_ID == obj.F_ID && !areEqual(myObj.NODE_LIST,obj.NODE_LIST)){
            myObj.NODE_LIST = arrayUnique(obj.NODE_LIST.concat(myObj.NODE_LIST));
            isUpdated = true;
          }
          if(myObj.F_ID == obj.F_ID && !areEqual(myObj.DELETED_BY,obj.DELETED_BY)){
            myObj.DELETED_BY = arrayUnique(obj.DELETED_BY.concat(myObj.DELETED_BY));
            isUpdated = true;
          }
        });


    }
  });




  //If GLOBAL File Table is updated then broadcastEvent
  if(isUpdated){
    EventHandler.broadcastEvent('BRDCST_FILE_TBL', {});
    Actions.reflectChanges();
    syncFiles();
    Actions.actualDelete();
  }
}

export var syncFiles = () => {
  const fullPaths = new FullPath.Search({
	    'path': '/root',
	    'dirname': __dirname,
	    'type': 'both', //optional. If you don't specified this value, by default is set with 'files'
	    'allFiles': true //optional. If you don't specified this value, by default is set with false and the result was full path of files with .js and .json extension.
	});

  var local_files = [];
	for(var i = 0; i<fullPaths.pathFiles.length ; i++){
		var trunc = fullPaths.pathFiles[i].indexOf('root/');
		var path = fullPaths.pathFiles[i].substr(trunc);
    local_files.push('./' + path);
  }
  FILE_TABLE.GLOBAL.map((obj) => {
    var isPresent = false;

    debug.log("Comparing Files For Replication....", DEV);
    local_files.forEach((local_file_id) => {
      debug.log("Remote File: ", obj.F_ID, " Local File: " + local_file_id);
      if(obj.F_ID == local_file_id){
        debug.log(obj, "is present", DEV);
        debug.log(local_file_id + " does exist locally");
        isPresent = true;
      }
    });

    if(!isPresent && !obj.DELETED && !obj.DIRECTORY){
      var ip = '';
      if(obj.NODE_LIST[0] != config.my_addr){
           ip = obj.NODE_LIST[0];
      }else{
        ip = obj.NODE_LIST[1];
      }
      debug.log("Requesting file from ", ip, obj);
      requestFile(ip, obj.F_ID);
    }

  });



}

function arrayUnique(array) {
    var a = array.concat();
    for(var i=0; i<a.length; ++i) {
        for(var j=i+1; j<a.length; ++j) {
            if(a[i] === a[j])
                a.splice(j--, 1);
        }
    }

    return a;
}

export function areEqual(a, b) {
  if ( a.length != b.length) {
    return false;
  }
  return a.filter(function(i) {
    return !b.includes(i);
  }).length === 0;
}

function convertStringToBool(str){
  return ((str === "True") || (str === "true")) ? true:false;
}