/**
*@NApiVersion 2.x
*@NScriptType Restlet
*Author: Dimitri
*/

/* ***************
  * Description *
  ***************
  This endpoint was established to perform the following tasks for the NetSuite SSSync:
  2 - post | This function runs the search identified by the searchID parameter to be used by NetSuiteSSSync
*/

require(['N/search' , 'N/log'],
function(search, log) {

   function post(input) {

       // var message = ReceiveMessage(input);

       var message = {searchID: 2833}

       if(message.searchID) {

           var response = {columns: [], data: []};
           var results, columns;

           try
           {
               results = search.load({id: message.searchID}).run();
               columns = results.columns;

               log.debug('results', results);

               for(var i = 0; i < columns.length; i++) {
                   var row = columns[i];

                   if(row.label) {
                       response.columns.push(row.label);
                   } else {
                       response.columns.push(row.name);
                   }
               }
           }
           catch (error) {
               log.error('Failed to load search ' + message.searchID, error)
               return {};
           }

           var index = 0;
           do
           {
               var values = results.getRange({start: index, end: index + 1000});
               index += 1000;

               for(var i = 0; i < values.length; i++) {
                   var row = [];
                   for(var j = 0; j < columns.length; j++) {
                       try {
                           var data = values[i].getText(columns[j]);
                           if(data.length > 0)
                           {
                               row.push(data);
                           }
                           else
                           {
                               row.push(values[i].getValue(columns[j]));
                           }
                       }
                       catch (error) {
                           row.push(values[i].getValue(columns[j]));
                       }
                   }
                   response.data.push(row);
               }
           } while(values.length == 1000)

           log.debug('response', response)
           // return SendMessage(response);
       }
       else {
           log.error('Unauthorized Access', 'Someone tried to execute a PUT request');
       }

       return {};
   }

   function ReceiveMessage(message)
   {
     return JSON.parse(CryptoJS.AES.decrypt(message.data, 'NFX76OqsFFMz8JbQx1ratzBfphADV3z16tRb8CkLynFCMgdKqCZ4B5I8XhoUYJW', { mode: CryptoJS.mode.CBC, padding: CryptoJS.pad.Pkcs7, iv: 'fj7tPrrvKmcllG4G' }).toString(CryptoJS.enc.Utf8));
   }

   function SendMessage(data)
   {
     var message = {data: CryptoJS.AES.encrypt(JSON.stringify(data), 'NFX76OqsFFMz8JbQx1ratzBfphADV3z16tRb8CkLynFCMgdKqCZ4B5I8XhoUYJW', { mode: CryptoJS.mode.CBC, padding: CryptoJS.pad.Pkcs7, iv: 'fj7tPrrvKmcllG4G' }).toString()};
     return JSON.stringify(message);
   }

   function logError(func, err) {
       var errorText = err.code ? JSON.stringify(err.code) : err.toString();
       log.error({
           title: 'ITEM - ' + func,
           details: errorText
       });
   }

   // return {
   //     post: post,
   // };

   post();

});