modules/Connectors/controller.php

   1 <?php
   2 if(!defined('sugarEntry') || !sugarEntry) die('Not A Valid Entry Point');
   3
   4 /*********************************************************************************
   5  * SugarCRM Community Edition is a customer relationship management program developed by
   6  * SugarCRM, Inc. Copyright (C) 2004-2011 SugarCRM Inc.
   7  *
   8  * This program is free software; you can redistribute it and/or modify it under
   9  * the terms of the GNU Affero General Public License version 3 as published by the
  10  * Free Software Foundation with the addition of the following permission added
  11  * to Section 15 as permitted in Section 7(a): FOR ANY PART OF THE COVERED WORK
  12  * IN WHICH THE COPYRIGHT IS OWNED BY SUGARCRM, SUGARCRM DISCLAIMS THE WARRANTY
  13  * OF NON INFRINGEMENT OF THIRD PARTY RIGHTS.
  14  *
  15  * This program is distributed in the hope that it will be useful, but WITHOUT
  16  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
  17  * FOR A PARTICULAR PURPOSE.  See the GNU Affero General Public License for more
  18  * details.
  19  *
  20  * You should have received a copy of the GNU Affero General Public License along with
  21  * this program; if not, see http://www.gnu.org/licenses or write to the Free
  22  * Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
  23  * 02110-1301 USA.
  24  *
  25  * You can contact SugarCRM, Inc. headquarters at 10050 North Wolfe Road,
  26  * SW2-130, Cupertino, CA 95014, USA. or at email address contact@sugarcrm.com.
  27  *
  28  * The interactive user interfaces in modified source and object code versions
  29  * of this program must display Appropriate Legal Notices, as required under
  30  * Section 5 of the GNU Affero General Public License version 3.
  31  *
  32  * In accordance with Section 7(b) of the GNU Affero General Public License version 3,
  33  * these Appropriate Legal Notices must retain the display of the "Powered by
  34  * SugarCRM" logo. If the display of the logo is not reasonably feasible for
  35  * technical reasons, the Appropriate Legal Notices must display the words
  36  * "Powered by SugarCRM".
  37  ********************************************************************************/
  38
  39 require_once('include/connectors/sources/SourceFactory.php');
  40 require_once('include/connectors/ConnectorFactory.php');
  41 require_once('include/MVC/Controller/SugarController.php');
  42
  43 class ConnectorsController extends SugarController {
  44
  45         var $admin_actions = array('ConnectorSettings', 'DisplayProperties', 'MappingProperties', 'ModifyMapping', 'ModifyDisplay', 'ModifyProperties',
  46                                    'ModifySearch', 'SearchProperties', 'SourceProperties',
  47                                    'SavedModifyDisplay', 'SaveModifyProperties', 'SaveModifySearch');
  48
  49
  50         function process() {
  51                 if(!is_admin($GLOBALS['current_user']) && in_array($this->action, $this->admin_actions)) {
  52                         $this->hasAccess = false;
  53                 }
  54                 parent::process();
  55         }
  56
  57
  58         /**
  59          * When the user clicks the Search button, the form is posted back here and this action sets the
  60          * search parameters in the session.  Once this call returns, the tabs will then call RetrieveSource to load
  61          * the data that was saved in the session.
  62          *
  63          */
  64         function action_SetSearch(){
  65                 if(empty($_REQUEST)) {
  66                    return;
  67                 }
  68
  69                 $this->view = 'ajax';
  70                 require_once('include/connectors/utils/ConnectorUtils.php');
  71         $searchdefs = ConnectorUtils::getSearchDefs();
  72                 $merge_module = $_REQUEST['merge_module'];
  73                 $record_id = $_REQUEST['record'];
  74                 $searchDefs = isset($searchdefs) ? $searchdefs : array();
  75                 unset($_SESSION['searchDefs'][$merge_module][$record_id]);
  76                 $sMap = array();
  77
  78                 $search_source = $_REQUEST['source_id'];
  79                 $source_instance = ConnectorFactory::getInstance($search_source);
  80                 $source_map = $source_instance->getModuleMapping($merge_module);
  81                 $module_fields = array();
  82                 foreach($_REQUEST as $search_term => $val){
  83                         if(!empty($source_map[$search_term])){
  84                                 $module_fields[$source_map[$search_term]] = $val;
  85                         }
  86                 }
  87
  88                 foreach($module_fields as $search_term => $val){
  89                         foreach($searchDefs as $source => $modules){
  90                                 if(empty($sMap[$source])){
  91                                         $instance = ConnectorFactory::getInstance($source);
  92                                         $sMap[$source] = array_flip($instance->getModuleMapping($merge_module));
  93                                 }
  94
  95                                 if(!empty($sMap[$source][$search_term])){
  96                                         $source_key = $sMap[$source][$search_term];
  97                                         $_SESSION['searchDefs'][$merge_module][$record_id][$source][$source_key] = $val;
  98                         }
  99                 }
 100                 }
 101         }
 102
 103         /**
 104          * This action it meant to handle the hover action on the listview.
 105          *
 106          */
 107         function action_RetrieveSourceDetails() {
 108                 $this->view = 'ajax';
 109                 $source_id = $_REQUEST['source_id'];
 110         $record_id = $_REQUEST['record_id'];
 111
 112         if(empty($source_id) || empty($record_id)) {
 113            //display error here
 114            return;
 115         }
 116         $source = ConnectorFactory::getInstance($source_id);
 117         $module = $_SESSION['merge_module'];
 118
 119                 $result = $source->fillBean(array('id' => $record_id), $module);
 120                 require_once('include/connectors/utils/ConnectorUtils.php');
 121         $connector_strings = ConnectorUtils::getConnectorStrings($source_id);
 122
 123         $fields = $source->getModuleMapping($module);
 124                 $fieldDefs = $source->getFieldDefs();
 125                 $str = '';
 126
 127                 foreach($fields as $key=>$field){
 128
 129                         $label = $field;
 130                         if(isset($fieldDefs[$key])) {
 131                            $label = isset($connector_strings[$fieldDefs[$key]['vname']]) ? $connector_strings[$fieldDefs[$key]['vname']] : $label;
 132                         }
 133
 134                         $val = $result->$field;
 135                         if(!empty($val)){
 136                            if(strlen($val) > 50) {
 137                                   $val = substr($val, 0, 47) . '...';
 138                            }
 139                            $str .= $label . ': ' .  $val.'<br/>';
 140                         }
 141                 }
 142                 global $theme;
 143                 $json = getJSONobj();
 144                 $retArray = array();
 145
 146                 $retArray['body'] = !empty($str) ? str_replace(array("\rn", "\r", "\n"), array('','','<br />'), $str) : $GLOBALS['mod_strings']['ERROR_NO_ADDITIONAL_DETAIL'];
 147                 $retArray['caption'] = "<div style='float:left'>{$GLOBALS['app_strings']['LBL_ADDITIONAL_DETAILS']}</div>";
 148             $retArray['width'] = (empty($results['width']) ? '300' : $results['width']);
 149             $retArray['theme'] = $theme;
 150             echo 'result = ' . $json->encode($retArray);
 151         }
 152
 153
 154         function action_GetSearchForm(){
 155         $this->view = 'ajax';
 156                 if(!empty($_REQUEST['source_id'])){
 157                         //get the search fields and return the search form
 158
 159                         $ss = new Sugar_Smarty();
 160                     require_once('include/connectors/utils/ConnectorUtils.php');
 161             $searchdefs = ConnectorUtils::getSearchDefs();
 162                         $merge_module = $_REQUEST['merge_module'];
 163                         $seed = loadBean($merge_module);
 164                         $_searchDefs = isset($searchdefs) ? $searchdefs : array();
 165                         $_trueFields = array();
 166                         $source = $_REQUEST['source_id'];
 167
 168                         $searchLabels = ConnectorUtils::getConnectorStrings($source);
 169                         $record = $_REQUEST['record'];
 170                         $sourceObj = SourceFactory::getSource($source);
 171                         $field_defs = $sourceObj->getFieldDefs();
 172
 173                     if(!empty($_searchDefs[$source][$merge_module])) {
 174                                 foreach($_searchDefs[$source][$merge_module] as $key) {
 175                                         if(!empty($_SESSION['searchDefs'][$merge_module][$record][$source][$key])){
 176                                                 $_trueFields[$key]['value'] = $_SESSION['searchDefs'][$merge_module][$record][$source][$key];
 177                                         }else{
 178                                                 $_trueFields[$key]['value'] = '';
 179                                         }
 180                                         if(!empty($field_defs[$key]) && isset($searchLabels[$field_defs[$key]['vname']])){
 181                                                 $_trueFields[$key]['label'] = $searchLabels[$field_defs[$key]['vname']];
 182                                         }else{
 183                                                 $_trueFields[$key]['label'] = $key;
 184                                         }
 185                                   }//foreach
 186                         }//fi
 187
 188                         $ss->assign('mod', $GLOBALS['mod_strings']);
 189                         $ss->assign('search_fields', $_trueFields);
 190                         $ss->assign('source_id', $source);
 191                         $ss->assign('fields', $seed->field_defs);
 192                         $ss->assign('module', $merge_module);
 193                         $ss->assign('RECORD', $record);
 194                         $ss->assign('APP', $GLOBALS['app_strings']);
 195                         $ss->assign('MOD', $GLOBALS['mod_strings']);
 196                         echo $ss->fetch('modules/Connectors/tpls/search_form.tpl');
 197                 }
 198         }
 199
 200
 201         function pre_save(){}
 202         function post_save(){}
 203
 204
 205     function action_CallConnectorFunc() {
 206         $this->view = 'ajax';
 207         $json = getJSONobj();
 208
 209         if(!empty($_REQUEST['source_id']))
 210         {
 211             $source_id = $_REQUEST['source_id'];
 212             require_once('include/connectors/sources/SourceFactory.php');
 213             $source = SourceFactory::getSource($source_id);
 214
 215             $method = 'ext_'.$_REQUEST['source_func'];
 216             if ( method_exists($source,$method) ) {
 217                 echo $json->encode($source->$method($_REQUEST));
 218             } else {
 219                 echo $json->encode(array('error'=>true,'errorMessage'=>'Could Not Find Function: '.$method.' in class: '.get_class($source)));
 220             }
 221         }
 222         else
 223         {
 224             echo $json->encode(array('error'=>true,'errorMessage'=>'Source Id is not specified.'));
 225         }
 226     }
 227
 228         function action_CallRest() {
 229                 $this->view = 'ajax';
 230
 231                 if(false === ($result=@file_get_contents($_REQUEST['url']))) {
 232            echo '';
 233                 } else if(!empty($_REQUEST['xml'])){
 234                    $values = array();
 235                    $p = xml_parser_create();
 236                    xml_parse_into_struct($p, $result, $values);
 237                    xml_parser_free($p);
 238                    $json = getJSONobj();
 239                    echo $json->encode($values);
 240                 } else {
 241                    echo $result;
 242                 }
 243         }
 244
 245         function action_CallSoap() {
 246             $this->view = 'ajax';
 247             $source_id = $_REQUEST['source_id'];
 248             $module = $_REQUEST['module_id'];
 249             $return_params = explode(',', $_REQUEST['fields']);
 250             require_once('include/connectors/ConnectorFactory.php');
 251             $component = ConnectorFactory::getInstance($source_id);
 252             $beans = $component->fillBeans($_REQUEST, $module);
 253                 if(!empty($beans) && !empty($return_params)) {
 254                     $results = array();
 255                         $count = 0;
 256                         foreach($beans as $bean) {
 257                                 foreach($return_params as $field) {
 258                                         $results[$count][$field] = $bean->$field;
 259                                 }
 260                                 $count++;
 261                         }
 262                     $json = getJSONobj();
 263                     echo $json->encode($results);
 264             } else {
 265                 echo '';
 266             }
 267         }
 268
 269
 270         function action_DefaultSoapPopup() {
 271                 $this->view = 'ajax';
 272             $source_id = $_REQUEST['source_id'];
 273             $module = $_REQUEST['module_id'];
 274             $id = $_REQUEST['record_id'];
 275             $mapping = $_REQUEST['mapping'];
 276
 277             $mapping = explode(',', $mapping);
 278             //Error checking
 279
 280             //Load bean
 281             $bean = loadBean($module);
 282             $bean->retrieve($id);
 283
 284             require_once('include/connectors/ConnectorFactory.php');
 285             $component = ConnectorFactory::getInstance($source_id);
 286             //Create arguments
 287             $args = array();
 288             $field_defs = $bean->getFieldDefinitions();
 289             foreach($field_defs as $id=>$field) {
 290                     if(!empty($bean->$id)) {
 291                        $args[$id] = $bean->$id;
 292                     }
 293             }
 294
 295             $beans = $component->fillBeans($args, $module);
 296                 if(!empty($beans) && !empty($mapping)) {
 297                     $results = array();
 298                         $count = 0;
 299                         foreach($beans as $bean) {
 300                                 foreach($mapping as $field) {
 301                                         $results[$count][$field] = $bean->$field;
 302                                 }
 303                                 $count++;
 304                         }
 305                     $json = getJSONobj();
 306                     echo $json->encode($results);
 307             } else {
 308                 $GLOBALS['log']->error($GLOBALS['app_strings']['ERR_MISSING_MAPPING_ENTRY_FORM_MODULE']);
 309                 echo '';
 310             }
 311         }
 312
 313         function action_SaveModifyProperties() {
 314                 require_once('include/connectors/sources/SourceFactory.php');
 315                 $sources = array();
 316                 $properties = array();
 317                 foreach($_REQUEST as $name=>$value) {
 318                         if(preg_match("/^source[0-9]+$/", $name, $matches)) {
 319                         $source_id = $value;
 320                         $properties = array();
 321                                 foreach($_REQUEST as $arg=>$val) {
 322                                         if(preg_match("/^{$source_id}_(.*?)$/", $arg, $matches2)) {
 323                                            $properties[$matches2[1]] = $val;
 324                                         }
 325                                         }
 326                                         $source = SourceFactory::getSource($source_id);
 327                                         if(!empty($properties)) {
 328                                             $source->setProperties($properties);
 329                                             $source->saveConfig();
 330                                         }
 331                         }
 332                 }
 333
 334                 require_once('include/connectors/utils/ConnectorUtils.php');
 335                 ConnectorUtils::updateMetaDataFiles();
 336             // BEGIN SUGAR INT
 337             if(empty($_REQUEST['from_unit_test'])) {
 338             // END SUGAR INT
 339             header("Location: index.php?action=ConnectorSettings&module=Connectors");
 340             // BEGIN SUGAR INT
 341             }
 342             // END SUGAR INT
 343         }
 344
 345         function action_SaveModifyDisplay() {
 346                         if(empty($_REQUEST['display_sources'])) {
 347                            return;
 348                         }
 349
 350                         require_once('include/connectors/utils/ConnectorUtils.php');
 351                         require_once('include/connectors/sources/SourceFactory.php');
 352
 353                         $connectors = ConnectorUtils::getConnectors();
 354                         $connector_keys = array_keys($connectors);
 355
 356                         $modules_sources = ConnectorUtils::getDisplayConfig();
 357                         if ( !is_array($modules_sources) ) {
 358                             $modules_sources = (array) $modules_sources;
 359                         }
 360
 361                         $sources = array();
 362                         $values = array();
 363                         $new_modules_sources = array();
 364
 365                         if(!empty($_REQUEST['display_values'])) {
 366                                 $display_values = explode(',', $_REQUEST['display_values']);
 367                             foreach($display_values as $value) {
 368                                     $entry = explode(':', $value);
 369                                     $new_modules_sources[$entry[1]][$entry[0]] = $entry[0];
 370                             }
 371                         }
 372
 373                         //These are the sources that were modified.
 374                         //We only update entries for these sources that have been changed
 375                     $display_sources = explode(',', $_REQUEST['display_sources']);
 376                     foreach($display_sources as $source) {
 377                             $sources[$source] = $source;
 378                     } //foreach
 379
 380                     $removedModules = array();
 381
 382             //Unset entries that have all sources removed
 383                 foreach($modules_sources as $module=>$source_entries) {
 384                      foreach($source_entries as $source_id) {
 385                              if(!empty($sources[$source_id]) && empty($new_modules_sources[$module][$source_id])) {
 386                                 unset($modules_sources[$module][$source_id]);
 387                                 $removedModules[$module] = true;
 388                              }
 389                      }
 390                 }
 391                 $removedModules = array_keys($removedModules);
 392                 foreach($removedModules as $key){
 393                         if(empty($new_modules_sources[$key])){
 394                                 ConnectorUtils::cleanMetaDataFile($key);
 395                         }
 396                 }
 397
 398                     //Update based on new_modules_sources
 399                     foreach($new_modules_sources as $module=>$enabled_sources) {
 400                          //If the module is not in $modules_sources add it there
 401                          if(empty($modules_sources[$module])) {
 402                                 $modules_sources[$module] = $enabled_sources;
 403                          } else {
 404                                 foreach($enabled_sources as $source_id) {
 405                                             if(empty($modules_sources[$module][$source_id])) {
 406                                                $modules_sources[$module][$source_id] = $source_id;
 407                                             }
 408                                 } //foreach
 409                          }
 410                     } //foreach
 411
 412                         //Should we just remove entries where all sources are disabled?
 413                     $unset_modules = array();
 414                     foreach($modules_sources as $module=>$mapping) {
 415                         if(empty($mapping)) {
 416                            $unset_modules[] = $module;
 417                         }
 418                     }
 419
 420                     foreach($unset_modules as $mod) {
 421                         unset($modules_sources[$mod]);
 422                     }
 423
 424                         if(!write_array_to_file('modules_sources', $modules_sources, CONNECTOR_DISPLAY_CONFIG_FILE)) {
 425                    //Log error and return empty array
 426                    $GLOBALS['log']->fatal("Cannot write \$modules_sources to " . CONNECTOR_DISPLAY_CONFIG_FILE);
 427                     }
 428
 429                     $sources_modules = array();
 430                     foreach($modules_sources as $module=>$source_entries) {
 431                         foreach($source_entries as $id) {
 432                                     $sources_modules[$id][$module] = $module;
 433                         }
 434                     }
 435
 436
 437             //Now update the searchdefs and field mapping entries accordingly
 438             require('modules/Connectors/metadata/searchdefs.php');
 439             $originalSearchDefs = $searchdefs;
 440                         $connectorSearchDefs = ConnectorUtils::getSearchDefs();
 441
 442                         $searchdefs = array();
 443             foreach($sources_modules as $source_id=>$modules) {
 444                     foreach($modules as $module) {
 445                                         $searchdefs[$source_id][$module] = !empty($connectorSearchDefs[$source_id][$module]) ? $connectorSearchDefs[$source_id][$module] : (!empty($originalSearchDefs[$source_id][$module]) ? $originalSearchDefs[$source_id][$module] : array());
 446                     }
 447             }
 448
 449                         //Write the new searchdefs out
 450                     if(!write_array_to_file('searchdefs', $searchdefs, 'custom/modules/Connectors/metadata/searchdefs.php')) {
 451                        $GLOBALS['log']->fatal("Cannot write file custom/modules/Connectors/metadata/searchdefs.php");
 452                     }
 453
 454                     //Unset the $_SESSION['searchDefs'] variable
 455                     if (isset($_SESSION['searchDefs'])) {
 456                             unset($_SESSION['searchDefs']);
 457                     }
 458
 459
 460
 461                     //Clear mapping file if needed (this happens when all modules are removed from a source
 462                         foreach($sources as $id) {
 463                             if(empty($sources_modules[$source])) {
 464                                 //Now write the new mapping entry to the custom folder
 465                                             $dir = $connectors[$id]['directory'];
 466                                                 if(!preg_match('/^custom\//', $dir)) {
 467                                                    $dir = 'custom/' . $dir;
 468                                                 }
 469
 470                                             if(!file_exists("{$dir}")) {
 471                                            mkdir_recursive("{$dir}");
 472                                         }
 473
 474                         $fakeMapping = array('beans'=>array());
 475                                             if(!write_array_to_file('mapping', $fakeMapping, "{$dir}/mapping.php")) {
 476                                                $GLOBALS['log']->fatal("Cannot write file {$dir}/mapping.php");
 477                                             }
 478                         $s = SourceFactory::getSource($id);
 479                         $s->saveMappingHook($fakeMapping);
 480                             } //if
 481                     } //foreach
 482
 483                     //Now update the field mapping entries
 484                     foreach($sources_modules as $id=>$modules) {
 485                                     $source = SourceFactory::getSource($id);
 486                                     $mapping = $source->getMapping();
 487                                     $mapped_modules = array_keys($mapping['beans']);
 488
 489                             foreach($mapped_modules as $module) {
 490                            if(empty($sources_modules[$id][$module])) {
 491                                   unset($mapping['beans'][$module]);
 492                            }
 493                     }
 494
 495                     //Remove modules from the mapping entries
 496                     foreach($modules as $module) {
 497                                                         if(empty($mapping['beans'][$module])) {
 498                                                                 $originalMapping = $source->getOriginalMapping();
 499                                                                 if(empty($originalMapping['beans'][$module])) {
 500                                                                     $defs = $source->getFieldDefs();
 501                                                                     $keys = array_keys($defs);
 502                                                                     $new_mapping_entry = array();
 503                                                                     foreach($keys as $key) {
 504                                                                             $new_mapping_entry[$key] = '';
 505                                                                     }
 506                                                                     $mapping['beans'][$module] = $new_mapping_entry;
 507                                                                 } else {
 508                                                                         $mapping['beans'][$module] = $originalMapping['beans'][$module];
 509                                                                 }
 510                                                         } //if
 511
 512                     } //foreach
 513
 514                                     //Now write the new mapping entry to the custom folder
 515                                     $dir = $connectors[$id]['directory'];
 516                                         if(!preg_match('/^custom\//', $dir)) {
 517                                            $dir = 'custom/' . $dir;
 518                                         }
 519
 520                                     if(!file_exists("{$dir}")) {
 521                                    mkdir_recursive("{$dir}");
 522                                 }
 523
 524                                     if(!write_array_to_file('mapping', $mapping, "{$dir}/mapping.php")) {
 525                                        $GLOBALS['log']->fatal("Cannot write file {$dir}/mapping.php");
 526                                     }
 527                     $source->saveMappingHook($mapping);
 528
 529                     } //foreach
 530
 531                     // save eapm configs
 532                     foreach($connectors as $connector_name => $data) {
 533                         if(isset($sources[$connector_name]) && !empty($data["eapm"])) {
 534                             // if we touched it AND it has EAPM data
 535                             $connectors[$connector_name]["eapm"]["enabled"] = !empty($_REQUEST[$connector_name."_external"]);
 536                         }
 537                     }
 538                     ConnectorUtils::saveConnectors($connectors);
 539
 540                     ConnectorUtils::updateMetaDataFiles();
 541                     // BEGIN SUGAR INT
 542                     if(empty($_REQUEST['from_unit_test'])) {
 543                     // END SUGAR INT
 544                     header("Location: index.php?action=ConnectorSettings&module=Connectors");
 545                     // BEGIN SUGAR INT
 546                     }
 547                     // END SUGAR INT
 548         }
 549
 550
 551
 552
 553         /**
 554          * action_SaveModifyMapping
 555          */
 556         function action_SaveModifyMapping() {
 557                 $mapping_sources = !empty($_REQUEST['mapping_sources']) ? explode(',', $_REQUEST['mapping_sources']) : array();
 558                 $mapping_values = !empty($_REQUEST['mapping_values']) ? explode(',', $_REQUEST['mapping_values']) : array();
 559
 560                 //Build the source->module->fields mapping
 561                 $source_modules_fields = array();
 562                 foreach($mapping_values as $id) {
 563                             $parts = explode(':', $id);
 564                             $key_vals = explode('=', $parts[2]);
 565                             //Note the strtolwer call... we are lowercasing the key values
 566                             $source_modules_fields[$parts[0]][$parts[1]][strtolower($key_vals[0])] = $key_vals[1];
 567                 } //foreach
 568
 569                 foreach($mapping_sources as $source_id) {
 570                             if(empty($source_modules_fields[$source_id])) {
 571                                    $source = SourceFactory::getSource($source_id);
 572                                    $mapping = $source->getMapping();
 573                                    foreach($mapping['beans'] as $module=>$entry) {
 574                                   $source_modules_fields[$source_id][$module] = array();
 575                                    }
 576                             }
 577                 } //foreach
 578
 579
 580
 581
 582                 require_once('include/connectors/utils/ConnectorUtils.php');
 583                 $source_entries = ConnectorUtils::getConnectors();
 584
 585                 require_once('include/connectors/sources/SourceFactory.php');
 586                 foreach($source_modules_fields as $id=>$mapping_entry) {
 587                             //Insert the id mapping
 588                             foreach($mapping_entry as $module=>$entry) {
 589                                 $mapping_entry[$module]['id'] = 'id';
 590                             }
 591
 592                             $source = SourceFactory::getSource($id);
 593                             $mapping = $source->getMapping();
 594                             $mapping['beans'] = $mapping_entry;
 595
 596                             //Now write the new mapping entry to the custom folder
 597                             $dir = $source_entries[$id]['directory'];
 598                                 if(!preg_match('/^custom\//', $dir)) {
 599                                    $dir = 'custom/' . $dir;
 600                                 }
 601
 602                             if(!file_exists("{$dir}")) {
 603                            mkdir_recursive("{$dir}");
 604                         }
 605
 606                             if(!write_array_to_file('mapping', $mapping, "{$dir}/mapping.php")) {
 607                                $GLOBALS['log']->fatal("Cannot write file {$dir}/mapping.php");
 608                             }
 609                 $source->saveMappingHook($mapping);
 610                 }
 611
 612                 //Rewrite the metadata files
 613                 ConnectorUtils::updateMetaDataFiles();
 614
 615             // BEGIN SUGAR INT
 616                 if(empty($_REQUEST['from_unit_test'])) {
 617                 // END SUGAR INT
 618         header("Location: index.php?action=ConnectorSettings&module=Connectors");
 619             // BEGIN SUGAR INT
 620                 }
 621                 // END SUGAR INT
 622         }
 623
 624
 625         function action_RunTest() {
 626             $this->view = 'ajax';
 627             $source_id = $_REQUEST['source_id'];
 628             $source = SourceFactory::getSource($source_id);
 629             $properties = array();
 630             foreach($_REQUEST as $name=>$value) {
 631                     if(preg_match("/^{$source_id}_(.*?)$/", $name, $matches)) {
 632                        $properties[$matches[1]] = $value;
 633                     }
 634             }
 635             $source->setProperties($properties);
 636             $source->saveConfig();
 637
 638             //Call again and call init
 639             $source = SourceFactory::getSource($source_id);
 640             $source->init();
 641
 642             global $mod_strings;
 643
 644             try {
 645                     if($source->isRequiredConfigFieldsForButtonSet() && $source->test()) {
 646                       echo $mod_strings['LBL_TEST_SOURCE_SUCCESS'];
 647                     } else {
 648                       echo $mod_strings['LBL_TEST_SOURCE_FAILED'];
 649                     }
 650             } catch (Exception $ex) {
 651                 $GLOBALS['log']->fatal($ex->getMessage());
 652                 echo $ex->getMessage();
 653             }
 654         }
 655
 656
 657         /**
 658          * action_RetrieveSources
 659          * Returns a JSON encoded format of the Connectors that are configured for the system
 660          *
 661          */
 662         function action_RetrieveSources() {
 663                 require_once('include/connectors/utils/ConnectorUtils.php');
 664                 $this->view = 'ajax';
 665                 $sources = ConnectorUtils:: getConnectors();
 666                 $results = array();
 667                 foreach($sources as $id=>$entry) {
 668                             $results[$id] = !empty($entry['name']) ? $entry['name'] : $id;
 669                 }
 670             $json = getJSONobj();
 671             echo $json->encode($results);
 672         }
 673
 674 }
 675 ?>