@@ -6,8 +6,8 @@ |
||
| 6 | 6 | $this->providePermission('trapdirector/config', $this->translate('Allow to create and modify traps services')); |
| 7 | 7 | |
| 8 | 8 | $this->provideConfigTab('config', array( |
| 9 | - 'title' => 'Configuration', |
|
| 10 | - 'url' => 'settings' |
|
| 9 | + 'title' => 'Configuration', |
|
| 10 | + 'url' => 'settings' |
|
| 11 | 11 | )); |
| 12 | 12 | |
| 13 | 13 | $section = $this->menuSection(N_('Traps'),array ( |
@@ -10,22 +10,22 @@ |
||
| 10 | 10 | 'url' => 'settings' |
| 11 | 11 | )); |
| 12 | 12 | |
| 13 | -$section = $this->menuSection(N_('Traps'),array ( |
|
| 13 | +$section=$this->menuSection(N_('Traps'), array( |
|
| 14 | 14 | 'icon' => 'filter', |
| 15 | 15 | 'url' => 'trapdirector' |
| 16 | 16 | )); |
| 17 | 17 | |
| 18 | -$section->add(N_('Status & Mibs'),array( |
|
| 18 | +$section->add(N_('Status & Mibs'), array( |
|
| 19 | 19 | 'url' => 'trapdirector/status/', |
| 20 | 20 | 'permission' => 'trapdirector/view' |
| 21 | 21 | )); |
| 22 | 22 | |
| 23 | -$section->add(N_('Received'),array( |
|
| 23 | +$section->add(N_('Received'), array( |
|
| 24 | 24 | 'url' => 'trapdirector/received/', |
| 25 | 25 | 'permission' => 'trapdirector/view' |
| 26 | 26 | )); |
| 27 | 27 | |
| 28 | -$section->add(N_('Handlers'),array( |
|
| 28 | +$section->add(N_('Handlers'), array( |
|
| 29 | 29 | 'url' => 'trapdirector/handler/', |
| 30 | 30 | 'permission' => 'trapdirector/config' |
| 31 | 31 | )); |
@@ -17,10 +17,10 @@ |
||
| 17 | 17 | class StatusCommand extends Command |
| 18 | 18 | { |
| 19 | 19 | /** |
| 20 | - * Get database counts |
|
| 21 | - * |
|
| 22 | - * Get number of traps, rules |
|
| 23 | - */ |
|
| 20 | + * Get database counts |
|
| 21 | + * |
|
| 22 | + * Get number of traps, rules |
|
| 23 | + */ |
|
| 24 | 24 | public function dbAction() |
| 25 | 25 | { |
| 26 | 26 | $db_prefix=$this->Config()->get('config', 'database_prefix'); |
@@ -24,21 +24,21 @@ |
||
| 24 | 24 | public function dbAction() |
| 25 | 25 | { |
| 26 | 26 | $db_prefix=$this->Config()->get('config', 'database_prefix'); |
| 27 | - $Config = new TrapModuleConfig($db_prefix); |
|
| 27 | + $Config=new TrapModuleConfig($db_prefix); |
|
| 28 | 28 | |
| 29 | 29 | try |
| 30 | 30 | { |
| 31 | 31 | |
| 32 | 32 | $dbresource=$this->Config()->get('config', 'database'); |
| 33 | - printf("DB name : %s\n",$dbresource); |
|
| 34 | - $dataBase = IcingaDbConnection::fromResourceName($dbresource)->getConnection(); |
|
| 33 | + printf("DB name : %s\n", $dbresource); |
|
| 34 | + $dataBase=IcingaDbConnection::fromResourceName($dbresource)->getConnection(); |
|
| 35 | 35 | |
| 36 | - $query = $dataBase->select()->from($Config->getTrapTableName(),array('COUNT(*)')); |
|
| 37 | - printf("Number of traps : %s\n", $dataBase->fetchOne($query) ); |
|
| 38 | - $query = $dataBase->select()->from($Config->getTrapDataTableName(),array('COUNT(*)')); |
|
| 39 | - printf("Number of trap objects : %s\n", $dataBase->fetchOne($query) ); |
|
| 40 | - $query = $dataBase->select()->from($Config->getTrapRuleName(),array('COUNT(*)')); |
|
| 41 | - printf("Number of rules : %s\n", $dataBase->fetchOne($query) ); |
|
| 36 | + $query=$dataBase->select()->from($Config->getTrapTableName(), array('COUNT(*)')); |
|
| 37 | + printf("Number of traps : %s\n", $dataBase->fetchOne($query)); |
|
| 38 | + $query=$dataBase->select()->from($Config->getTrapDataTableName(), array('COUNT(*)')); |
|
| 39 | + printf("Number of trap objects : %s\n", $dataBase->fetchOne($query)); |
|
| 40 | + $query=$dataBase->select()->from($Config->getTrapRuleName(), array('COUNT(*)')); |
|
| 41 | + printf("Number of rules : %s\n", $dataBase->fetchOne($query)); |
|
| 42 | 42 | |
| 43 | 43 | } |
| 44 | 44 | catch (Exception $e) |
@@ -40,8 +40,7 @@ |
||
| 40 | 40 | $query = $dataBase->select()->from($Config->getTrapRuleName(),array('COUNT(*)')); |
| 41 | 41 | printf("Number of rules : %s\n", $dataBase->fetchOne($query) ); |
| 42 | 42 | |
| 43 | - } |
|
| 44 | - catch (Exception $e) |
|
| 43 | + } catch (Exception $e) |
|
| 45 | 44 | { |
| 46 | 45 | printf('Error in DB : %s\n', $e->getMessage()); |
| 47 | 46 | } |
@@ -17,16 +17,16 @@ discard block |
||
| 17 | 17 | class TrapsCommand extends Command |
| 18 | 18 | { |
| 19 | 19 | /** |
| 20 | - * Delete old traps |
|
| 21 | - * |
|
| 22 | - * USAGE |
|
| 23 | - * |
|
| 24 | - * icingali trapdirector traps rotate [options] |
|
| 25 | - * |
|
| 26 | - * OPTIONS |
|
| 27 | - * |
|
| 28 | - * --days remove traps older than <n> days |
|
| 29 | - */ |
|
| 20 | + * Delete old traps |
|
| 21 | + * |
|
| 22 | + * USAGE |
|
| 23 | + * |
|
| 24 | + * icingali trapdirector traps rotate [options] |
|
| 25 | + * |
|
| 26 | + * OPTIONS |
|
| 27 | + * |
|
| 28 | + * --days remove traps older than <n> days |
|
| 29 | + */ |
|
| 30 | 30 | public function rotateAction() |
| 31 | 31 | { |
| 32 | 32 | $module=Icinga::app()->getModuleManager()->getModule($this->getModuleName()); |
@@ -56,13 +56,13 @@ discard block |
||
| 56 | 56 | } |
| 57 | 57 | |
| 58 | 58 | /** |
| 59 | - * Reset services to OK state if timeout is passed |
|
| 60 | - * |
|
| 61 | - * USAGE |
|
| 62 | - * |
|
| 63 | - * icingali trapdirector traps reset_services |
|
| 64 | - * |
|
| 65 | - */ |
|
| 59 | + * Reset services to OK state if timeout is passed |
|
| 60 | + * |
|
| 61 | + * USAGE |
|
| 62 | + * |
|
| 63 | + * icingali trapdirector traps reset_services |
|
| 64 | + * |
|
| 65 | + */ |
|
| 66 | 66 | public function resetOKAction() |
| 67 | 67 | { |
| 68 | 68 | $module=Icinga::app()->getModuleManager()->getModule($this->getModuleName()); |
@@ -30,16 +30,16 @@ discard block |
||
| 30 | 30 | public function rotateAction() |
| 31 | 31 | { |
| 32 | 32 | $module=Icinga::app()->getModuleManager()->getModule($this->getModuleName()); |
| 33 | - require_once($module->getBaseDir() .'/bin/trap_class.php'); |
|
| 33 | + require_once($module->getBaseDir().'/bin/trap_class.php'); |
|
| 34 | 34 | $icingaweb2_etc=$this->Config()->get('config', 'icingaweb2_etc'); |
| 35 | 35 | $debug_level=2; |
| 36 | - $trap = new Trap($icingaweb2_etc); |
|
| 37 | - $trap->setLogging($debug_level,'display'); |
|
| 36 | + $trap=new Trap($icingaweb2_etc); |
|
| 37 | + $trap->setLogging($debug_level, 'display'); |
|
| 38 | 38 | try |
| 39 | 39 | { |
| 40 | - $days = $this->params->get('days', '<default>'); |
|
| 40 | + $days=$this->params->get('days', '<default>'); |
|
| 41 | 41 | echo $this->screen->colorize("Deleting traps older than $days days\n", 'lightblue'); |
| 42 | - if ($days=='<default>') |
|
| 42 | + if ($days == '<default>') |
|
| 43 | 43 | { |
| 44 | 44 | $trap->eraseOldTraps(); |
| 45 | 45 | } |
@@ -51,7 +51,7 @@ discard block |
||
| 51 | 51 | } |
| 52 | 52 | catch (Exception $e) |
| 53 | 53 | { |
| 54 | - echo 'Error in updating : ' . $e->getMessage(); |
|
| 54 | + echo 'Error in updating : '.$e->getMessage(); |
|
| 55 | 55 | } |
| 56 | 56 | } |
| 57 | 57 | |
@@ -66,18 +66,18 @@ discard block |
||
| 66 | 66 | public function resetOKAction() |
| 67 | 67 | { |
| 68 | 68 | $module=Icinga::app()->getModuleManager()->getModule($this->getModuleName()); |
| 69 | - require_once($module->getBaseDir() .'/bin/trap_class.php'); |
|
| 69 | + require_once($module->getBaseDir().'/bin/trap_class.php'); |
|
| 70 | 70 | $icingaweb2_etc=$this->Config()->get('config', 'icingaweb2_etc'); |
| 71 | 71 | $debug_level=2; |
| 72 | - $trap = new Trap($icingaweb2_etc); |
|
| 73 | - $trap->setLogging($debug_level,'display'); |
|
| 72 | + $trap=new Trap($icingaweb2_etc); |
|
| 73 | + $trap->setLogging($debug_level, 'display'); |
|
| 74 | 74 | try |
| 75 | 75 | { |
| 76 | 76 | $trap->reset_services(); |
| 77 | 77 | } |
| 78 | 78 | catch (Exception $e) |
| 79 | 79 | { |
| 80 | - echo 'ERROR : '. $e->getMessage(); |
|
| 80 | + echo 'ERROR : '.$e->getMessage(); |
|
| 81 | 81 | } |
| 82 | 82 | } |
| 83 | 83 | |
@@ -42,14 +42,12 @@ discard block |
||
| 42 | 42 | if ($days=='<default>') |
| 43 | 43 | { |
| 44 | 44 | $trap->eraseOldTraps(); |
| 45 | - } |
|
| 46 | - else |
|
| 45 | + } else |
|
| 47 | 46 | { |
| 48 | 47 | $trap->eraseOldTraps($days); |
| 49 | 48 | } |
| 50 | 49 | |
| 51 | - } |
|
| 52 | - catch (Exception $e) |
|
| 50 | + } catch (Exception $e) |
|
| 53 | 51 | { |
| 54 | 52 | echo 'Error in updating : ' . $e->getMessage(); |
| 55 | 53 | } |
@@ -74,8 +72,7 @@ discard block |
||
| 74 | 72 | try |
| 75 | 73 | { |
| 76 | 74 | $trap->reset_services(); |
| 77 | - } |
|
| 78 | - catch (Exception $e) |
|
| 75 | + } catch (Exception $e) |
|
| 79 | 76 | { |
| 80 | 77 | echo 'ERROR : '. $e->getMessage(); |
| 81 | 78 | } |
@@ -62,8 +62,7 @@ discard block |
||
| 62 | 62 | if ($pid == 1) |
| 63 | 63 | { |
| 64 | 64 | $trap->setLogging($logLevel,'display'); |
| 65 | - } |
|
| 66 | - else |
|
| 65 | + } else |
|
| 67 | 66 | { // use default display TODO : if default is 'display' son process will be killed at first output.... |
| 68 | 67 | if ($pid != 0) |
| 69 | 68 | { |
@@ -72,8 +71,7 @@ discard block |
||
| 72 | 71 | fclose($file); |
| 73 | 72 | echo "OK : process $pid in bckground"; |
| 74 | 73 | return 0; |
| 75 | - } |
|
| 76 | - else |
|
| 74 | + } else |
|
| 77 | 75 | { // son process : close all file descriptors and go to a new session |
| 78 | 76 | fclose($file); |
| 79 | 77 | // $sid = posix_setsid(); |
@@ -83,8 +81,7 @@ discard block |
||
| 83 | 81 | try |
| 84 | 82 | { |
| 85 | 83 | $trap->update_mib_database(false,$forceCheck); |
| 86 | - } |
|
| 87 | - catch (Exception $e) |
|
| 84 | + } catch (Exception $e) |
|
| 88 | 85 | { |
| 89 | 86 | $trap->trapLog('Error in updating : ' . $e->getMessage(),2); |
| 90 | 87 | } |
@@ -101,8 +98,7 @@ discard block |
||
| 101 | 98 | $trap->update_mib_database(true,$forceCheck); |
| 102 | 99 | echo "Done\n"; |
| 103 | 100 | |
| 104 | - } |
|
| 105 | - catch (Exception $e) |
|
| 101 | + } catch (Exception $e) |
|
| 106 | 102 | { |
| 107 | 103 | echo 'Error in updating : ' . $e->getMessage(); |
| 108 | 104 | } |
@@ -144,8 +140,7 @@ discard block |
||
| 144 | 140 | $query = $db->select()->from($Config->getTrapRuleName(),array('COUNT(*)')); |
| 145 | 141 | echo "Number of rules : " . $db->fetchOne($query) ."\n"; |
| 146 | 142 | |
| 147 | - } |
|
| 148 | - catch (Exception $e) |
|
| 143 | + } catch (Exception $e) |
|
| 149 | 144 | { |
| 150 | 145 | echo 'Error in DB : ' . $e->getMessage(); |
| 151 | 146 | } |
@@ -20,77 +20,77 @@ discard block |
||
| 20 | 20 | class MibCommand extends Command |
| 21 | 21 | { |
| 22 | 22 | /** |
| 23 | - * Update mib database |
|
| 24 | - * |
|
| 25 | - * USAGE |
|
| 26 | - * |
|
| 27 | - * icingli trapdirector mib update |
|
| 28 | - * |
|
| 29 | - * OPTIONS |
|
| 30 | - * |
|
| 31 | - * --pid <file> : run in background with pid in <file> |
|
| 32 | - * |
|
| 33 | - * --verb : Set output log to verbose |
|
| 34 | - * |
|
| 35 | - * --force-check : force check of all traps & objects for change. (NOT IMPLEMENTED) |
|
| 36 | - */ |
|
| 23 | + * Update mib database |
|
| 24 | + * |
|
| 25 | + * USAGE |
|
| 26 | + * |
|
| 27 | + * icingli trapdirector mib update |
|
| 28 | + * |
|
| 29 | + * OPTIONS |
|
| 30 | + * |
|
| 31 | + * --pid <file> : run in background with pid in <file> |
|
| 32 | + * |
|
| 33 | + * --verb : Set output log to verbose |
|
| 34 | + * |
|
| 35 | + * --force-check : force check of all traps & objects for change. (NOT IMPLEMENTED) |
|
| 36 | + */ |
|
| 37 | 37 | public function updateAction() |
| 38 | 38 | { |
| 39 | - $background = $this->params->get('pid', null); |
|
| 40 | - $logLevel= $this->params->has('verb') ? 4 : 2; |
|
| 41 | - if ($this->params->has('force-check')) { echo "Not implemented"; return;} |
|
| 42 | - $forceCheck=$this->params->has('force-check')?True:False; |
|
| 43 | - $pid=1; |
|
| 44 | - if ($background != null) |
|
| 45 | - { |
|
| 46 | - $file=@fopen($background,'w'); |
|
| 47 | - if ($file == false) |
|
| 48 | - { |
|
| 49 | - echo 'Error : cannot open pid file '.$background; |
|
| 50 | - return 1; |
|
| 51 | - } |
|
| 52 | - $pid = pcntl_fork(); |
|
| 53 | - if ($pid == -1) { |
|
| 54 | - echo 'Error : Cannot fork process'; |
|
| 55 | - return 1; |
|
| 56 | - } |
|
| 57 | - } |
|
| 58 | - $module=Icinga::app()->getModuleManager()->getModule($this->getModuleName()); |
|
| 39 | + $background = $this->params->get('pid', null); |
|
| 40 | + $logLevel= $this->params->has('verb') ? 4 : 2; |
|
| 41 | + if ($this->params->has('force-check')) { echo "Not implemented"; return;} |
|
| 42 | + $forceCheck=$this->params->has('force-check')?True:False; |
|
| 43 | + $pid=1; |
|
| 44 | + if ($background != null) |
|
| 45 | + { |
|
| 46 | + $file=@fopen($background,'w'); |
|
| 47 | + if ($file == false) |
|
| 48 | + { |
|
| 49 | + echo 'Error : cannot open pid file '.$background; |
|
| 50 | + return 1; |
|
| 51 | + } |
|
| 52 | + $pid = pcntl_fork(); |
|
| 53 | + if ($pid == -1) { |
|
| 54 | + echo 'Error : Cannot fork process'; |
|
| 55 | + return 1; |
|
| 56 | + } |
|
| 57 | + } |
|
| 58 | + $module=Icinga::app()->getModuleManager()->getModule($this->getModuleName()); |
|
| 59 | 59 | require_once($module->getBaseDir() .'/bin/trap_class.php'); |
| 60 | 60 | $icingaweb2_etc=$this->Config()->get('config', 'icingaweb2_etc'); |
| 61 | 61 | $trap = new Trap($icingaweb2_etc); |
| 62 | 62 | if ($pid == 1) |
| 63 | 63 | { |
| 64 | - $trap->setLogging($logLevel,'display'); |
|
| 64 | + $trap->setLogging($logLevel,'display'); |
|
| 65 | 65 | } |
| 66 | 66 | else |
| 67 | 67 | { // use default display TODO : if default is 'display' son process will be killed at first output.... |
| 68 | - if ($pid != 0) |
|
| 69 | - { |
|
| 70 | - // father process |
|
| 71 | - fwrite($file,$pid); |
|
| 72 | - fclose($file); |
|
| 73 | - echo "OK : process $pid in bckground"; |
|
| 74 | - return 0; |
|
| 75 | - } |
|
| 76 | - else |
|
| 77 | - { // son process : close all file descriptors and go to a new session |
|
| 78 | - fclose($file); |
|
| 68 | + if ($pid != 0) |
|
| 69 | + { |
|
| 70 | + // father process |
|
| 71 | + fwrite($file,$pid); |
|
| 72 | + fclose($file); |
|
| 73 | + echo "OK : process $pid in bckground"; |
|
| 74 | + return 0; |
|
| 75 | + } |
|
| 76 | + else |
|
| 77 | + { // son process : close all file descriptors and go to a new session |
|
| 78 | + fclose($file); |
|
| 79 | 79 | // $sid = posix_setsid(); |
| 80 | - fclose(STDIN); |
|
| 81 | - fclose(STDOUT); |
|
| 82 | - fclose(STDERR); |
|
| 83 | - try |
|
| 84 | - { |
|
| 85 | - $trap->update_mib_database(false,$forceCheck); |
|
| 86 | - } |
|
| 87 | - catch (Exception $e) |
|
| 88 | - { |
|
| 89 | - $trap->trapLog('Error in updating : ' . $e->getMessage(),2); |
|
| 90 | - } |
|
| 91 | - unlink($background); |
|
| 92 | - return 0; |
|
| 93 | - } |
|
| 80 | + fclose(STDIN); |
|
| 81 | + fclose(STDOUT); |
|
| 82 | + fclose(STDERR); |
|
| 83 | + try |
|
| 84 | + { |
|
| 85 | + $trap->update_mib_database(false,$forceCheck); |
|
| 86 | + } |
|
| 87 | + catch (Exception $e) |
|
| 88 | + { |
|
| 89 | + $trap->trapLog('Error in updating : ' . $e->getMessage(),2); |
|
| 90 | + } |
|
| 91 | + unlink($background); |
|
| 92 | + return 0; |
|
| 93 | + } |
|
| 94 | 94 | |
| 95 | 95 | } |
| 96 | 96 | |
@@ -108,20 +108,20 @@ discard block |
||
| 108 | 108 | } |
| 109 | 109 | if ($pid != 1) |
| 110 | 110 | { |
| 111 | - unlink($background); |
|
| 111 | + unlink($background); |
|
| 112 | 112 | } |
| 113 | 113 | } |
| 114 | 114 | /** |
| 115 | - * purge all mib database NOT IMPLEMENTED |
|
| 116 | - * |
|
| 117 | - * USAGE |
|
| 118 | - * |
|
| 119 | - * icingli trapdirector mib purge --confirm yes |
|
| 120 | - * |
|
| 121 | - * OPTIONS |
|
| 122 | - * |
|
| 123 | - * --confirm yes : needed to execute purge |
|
| 124 | - */ |
|
| 115 | + * purge all mib database NOT IMPLEMENTED |
|
| 116 | + * |
|
| 117 | + * USAGE |
|
| 118 | + * |
|
| 119 | + * icingli trapdirector mib purge --confirm yes |
|
| 120 | + * |
|
| 121 | + * OPTIONS |
|
| 122 | + * |
|
| 123 | + * --confirm yes : needed to execute purge |
|
| 124 | + */ |
|
| 125 | 125 | public function purgeAction() |
| 126 | 126 | { |
| 127 | 127 | $db_prefix=$this->Config()->get('config', 'database_prefix'); |
@@ -36,39 +36,39 @@ discard block |
||
| 36 | 36 | */ |
| 37 | 37 | public function updateAction() |
| 38 | 38 | { |
| 39 | - $background = $this->params->get('pid', null); |
|
| 40 | - $logLevel= $this->params->has('verb') ? 4 : 2; |
|
| 41 | - if ($this->params->has('force-check')) { echo "Not implemented"; return;} |
|
| 42 | - $forceCheck=$this->params->has('force-check')?True:False; |
|
| 39 | + $background=$this->params->get('pid', null); |
|
| 40 | + $logLevel=$this->params->has('verb') ? 4 : 2; |
|
| 41 | + if ($this->params->has('force-check')) { echo "Not implemented"; return; } |
|
| 42 | + $forceCheck=$this->params->has('force-check') ?True:False; |
|
| 43 | 43 | $pid=1; |
| 44 | 44 | if ($background != null) |
| 45 | 45 | { |
| 46 | - $file=@fopen($background,'w'); |
|
| 46 | + $file=@fopen($background, 'w'); |
|
| 47 | 47 | if ($file == false) |
| 48 | 48 | { |
| 49 | 49 | echo 'Error : cannot open pid file '.$background; |
| 50 | 50 | return 1; |
| 51 | 51 | } |
| 52 | - $pid = pcntl_fork(); |
|
| 52 | + $pid=pcntl_fork(); |
|
| 53 | 53 | if ($pid == -1) { |
| 54 | 54 | echo 'Error : Cannot fork process'; |
| 55 | 55 | return 1; |
| 56 | 56 | } |
| 57 | 57 | } |
| 58 | 58 | $module=Icinga::app()->getModuleManager()->getModule($this->getModuleName()); |
| 59 | - require_once($module->getBaseDir() .'/bin/trap_class.php'); |
|
| 59 | + require_once($module->getBaseDir().'/bin/trap_class.php'); |
|
| 60 | 60 | $icingaweb2_etc=$this->Config()->get('config', 'icingaweb2_etc'); |
| 61 | - $trap = new Trap($icingaweb2_etc); |
|
| 61 | + $trap=new Trap($icingaweb2_etc); |
|
| 62 | 62 | if ($pid == 1) |
| 63 | 63 | { |
| 64 | - $trap->setLogging($logLevel,'display'); |
|
| 64 | + $trap->setLogging($logLevel, 'display'); |
|
| 65 | 65 | } |
| 66 | 66 | else |
| 67 | 67 | { // use default display TODO : if default is 'display' son process will be killed at first output.... |
| 68 | 68 | if ($pid != 0) |
| 69 | 69 | { |
| 70 | 70 | // father process |
| 71 | - fwrite($file,$pid); |
|
| 71 | + fwrite($file, $pid); |
|
| 72 | 72 | fclose($file); |
| 73 | 73 | echo "OK : process $pid in bckground"; |
| 74 | 74 | return 0; |
@@ -82,11 +82,11 @@ discard block |
||
| 82 | 82 | fclose(STDERR); |
| 83 | 83 | try |
| 84 | 84 | { |
| 85 | - $trap->update_mib_database(false,$forceCheck); |
|
| 85 | + $trap->update_mib_database(false, $forceCheck); |
|
| 86 | 86 | } |
| 87 | 87 | catch (Exception $e) |
| 88 | 88 | { |
| 89 | - $trap->trapLog('Error in updating : ' . $e->getMessage(),2); |
|
| 89 | + $trap->trapLog('Error in updating : '.$e->getMessage(), 2); |
|
| 90 | 90 | } |
| 91 | 91 | unlink($background); |
| 92 | 92 | return 0; |
@@ -98,13 +98,13 @@ discard block |
||
| 98 | 98 | { |
| 99 | 99 | echo "Update main mib database : \n"; |
| 100 | 100 | echo "# (trap found) C (trap already processed) . (every 2 seconds) : \n"; |
| 101 | - $trap->update_mib_database(true,$forceCheck); |
|
| 101 | + $trap->update_mib_database(true, $forceCheck); |
|
| 102 | 102 | echo "Done\n"; |
| 103 | 103 | |
| 104 | 104 | } |
| 105 | 105 | catch (Exception $e) |
| 106 | 106 | { |
| 107 | - echo 'Error in updating : ' . $e->getMessage(); |
|
| 107 | + echo 'Error in updating : '.$e->getMessage(); |
|
| 108 | 108 | } |
| 109 | 109 | if ($pid != 1) |
| 110 | 110 | { |
@@ -128,26 +128,26 @@ discard block |
||
| 128 | 128 | echo "Not implemented"; |
| 129 | 129 | // TODO : implement |
| 130 | 130 | return; |
| 131 | - $Config = new TrapModuleConfig($db_prefix); |
|
| 131 | + $Config=new TrapModuleConfig($db_prefix); |
|
| 132 | 132 | |
| 133 | 133 | try |
| 134 | 134 | { |
| 135 | 135 | |
| 136 | 136 | $dbresource=$this->Config()->get('config', 'database'); |
| 137 | 137 | echo "DB name : $dbresource\n"; |
| 138 | - $db = IcingaDbConnection::fromResourceName($dbresource)->getConnection(); |
|
| 138 | + $db=IcingaDbConnection::fromResourceName($dbresource)->getConnection(); |
|
| 139 | 139 | |
| 140 | - $query = $db->select()->from($Config->getTrapTableName(),array('COUNT(*)')); |
|
| 141 | - echo "Number of traps : " . $db->fetchOne($query) ."\n"; |
|
| 142 | - $query = $db->select()->from($Config->getTrapDataTableName(),array('COUNT(*)')); |
|
| 143 | - echo "Number of trap objects : " . $db->fetchOne($query) ."\n"; |
|
| 144 | - $query = $db->select()->from($Config->getTrapRuleName(),array('COUNT(*)')); |
|
| 145 | - echo "Number of rules : " . $db->fetchOne($query) ."\n"; |
|
| 140 | + $query=$db->select()->from($Config->getTrapTableName(), array('COUNT(*)')); |
|
| 141 | + echo "Number of traps : ".$db->fetchOne($query)."\n"; |
|
| 142 | + $query=$db->select()->from($Config->getTrapDataTableName(), array('COUNT(*)')); |
|
| 143 | + echo "Number of trap objects : ".$db->fetchOne($query)."\n"; |
|
| 144 | + $query=$db->select()->from($Config->getTrapRuleName(), array('COUNT(*)')); |
|
| 145 | + echo "Number of rules : ".$db->fetchOne($query)."\n"; |
|
| 146 | 146 | |
| 147 | 147 | } |
| 148 | 148 | catch (Exception $e) |
| 149 | 149 | { |
| 150 | - echo 'Error in DB : ' . $e->getMessage(); |
|
| 150 | + echo 'Error in DB : '.$e->getMessage(); |
|
| 151 | 151 | } |
| 152 | 152 | } |
| 153 | 153 | |
@@ -32,13 +32,13 @@ discard block |
||
| 32 | 32 | |
| 33 | 33 | public function setDefaultIDODB($idoDbName) |
| 34 | 34 | { |
| 35 | - $this->idoDbName=$idoDbName; |
|
| 36 | - return $this; |
|
| 35 | + $this->idoDbName=$idoDbName; |
|
| 36 | + return $this; |
|
| 37 | 37 | } |
| 38 | 38 | |
| 39 | - public function createElements(array $formData) |
|
| 40 | - { |
|
| 41 | - $this->addElement( |
|
| 39 | + public function createElements(array $formData) |
|
| 40 | + { |
|
| 41 | + $this->addElement( |
|
| 42 | 42 | 'select', |
| 43 | 43 | 'config_database', |
| 44 | 44 | array( |
@@ -72,14 +72,14 @@ discard block |
||
| 72 | 72 | ) |
| 73 | 73 | ); |
| 74 | 74 | $this->addElement( |
| 75 | - 'text', |
|
| 76 | - 'config_icingaweb2_etc', |
|
| 77 | - array( |
|
| 78 | - 'required' => true, |
|
| 79 | - 'label' => $this->translate('icingaweb2 config dir'), |
|
| 75 | + 'text', |
|
| 76 | + 'config_icingaweb2_etc', |
|
| 77 | + array( |
|
| 78 | + 'required' => true, |
|
| 79 | + 'label' => $this->translate('icingaweb2 config dir'), |
|
| 80 | 80 | 'value' => $this->icinga_base_path, |
| 81 | - ) |
|
| 82 | - ); |
|
| 81 | + ) |
|
| 82 | + ); |
|
| 83 | 83 | $retval=0; |
| 84 | 84 | $output=array(); |
| 85 | 85 | $snmptranslate=exec('which snmptranslate',$output,$retval); |
@@ -88,68 +88,68 @@ discard block |
||
| 88 | 88 | $snmptranslate='/usr/bin/snmptranslate'; |
| 89 | 89 | } |
| 90 | 90 | $this->addElement( |
| 91 | - 'text', |
|
| 92 | - 'config_snmptranslate', |
|
| 93 | - array( |
|
| 94 | - 'required' => true, |
|
| 95 | - 'label' => $this->translate('snmptranslate binary with path'), |
|
| 91 | + 'text', |
|
| 92 | + 'config_snmptranslate', |
|
| 93 | + array( |
|
| 94 | + 'required' => true, |
|
| 95 | + 'label' => $this->translate('snmptranslate binary with path'), |
|
| 96 | 96 | 'value' => $snmptranslate, |
| 97 | - ) |
|
| 98 | - ); |
|
| 97 | + ) |
|
| 98 | + ); |
|
| 99 | 99 | $this->addElement( |
| 100 | - 'text', |
|
| 101 | - 'config_snmptranslate_dirs', |
|
| 102 | - array( |
|
| 103 | - 'required' => true, |
|
| 104 | - 'label' => $this->translate('Path for mibs'), |
|
| 100 | + 'text', |
|
| 101 | + 'config_snmptranslate_dirs', |
|
| 102 | + array( |
|
| 103 | + 'required' => true, |
|
| 104 | + 'label' => $this->translate('Path for mibs'), |
|
| 105 | 105 | 'value' => $this->module_base_path.'/mibs', |
| 106 | - ) |
|
| 107 | - ); |
|
| 106 | + ) |
|
| 107 | + ); |
|
| 108 | 108 | $this->addElement( |
| 109 | - 'text', |
|
| 110 | - 'config_icingacmd', |
|
| 111 | - array( |
|
| 112 | - 'required' => true, |
|
| 113 | - 'label' => $this->translate('icingacmd with path'), |
|
| 109 | + 'text', |
|
| 110 | + 'config_icingacmd', |
|
| 111 | + array( |
|
| 112 | + 'required' => true, |
|
| 113 | + 'label' => $this->translate('icingacmd with path'), |
|
| 114 | 114 | 'value' => '/var/run/icinga2/cmd/icinga2.cmd', |
| 115 | - ) |
|
| 116 | - ); |
|
| 115 | + ) |
|
| 116 | + ); |
|
| 117 | 117 | $this->addElement( |
| 118 | - 'text', |
|
| 119 | - 'config_icingaAPI_host', |
|
| 120 | - array( |
|
| 121 | - 'required' => false, |
|
| 122 | - 'label' => $this->translate('icinga2 API Host IP'), |
|
| 123 | - 'value' => '', |
|
| 124 | - ) |
|
| 118 | + 'text', |
|
| 119 | + 'config_icingaAPI_host', |
|
| 120 | + array( |
|
| 121 | + 'required' => false, |
|
| 122 | + 'label' => $this->translate('icinga2 API Host IP'), |
|
| 123 | + 'value' => '', |
|
| 124 | + ) |
|
| 125 | 125 | ); |
| 126 | 126 | $this->addElement( |
| 127 | - 'text', |
|
| 128 | - 'config_icingaAPI_port', |
|
| 129 | - array( |
|
| 130 | - 'required' => false, |
|
| 131 | - 'label' => $this->translate('icinga2 API TCP Port'), |
|
| 132 | - 'value' => '5665', |
|
| 133 | - ) |
|
| 134 | - ); |
|
| 127 | + 'text', |
|
| 128 | + 'config_icingaAPI_port', |
|
| 129 | + array( |
|
| 130 | + 'required' => false, |
|
| 131 | + 'label' => $this->translate('icinga2 API TCP Port'), |
|
| 132 | + 'value' => '5665', |
|
| 133 | + ) |
|
| 134 | + ); |
|
| 135 | 135 | $this->addElement( |
| 136 | - 'text', |
|
| 137 | - 'config_icingaAPI_user', |
|
| 138 | - array( |
|
| 139 | - 'required' => false, |
|
| 140 | - 'label' => $this->translate('icinga2 API username'), |
|
| 141 | - 'value' => '', |
|
| 142 | - ) |
|
| 143 | - ); |
|
| 136 | + 'text', |
|
| 137 | + 'config_icingaAPI_user', |
|
| 138 | + array( |
|
| 139 | + 'required' => false, |
|
| 140 | + 'label' => $this->translate('icinga2 API username'), |
|
| 141 | + 'value' => '', |
|
| 142 | + ) |
|
| 143 | + ); |
|
| 144 | 144 | $this->addElement( |
| 145 | - 'text', |
|
| 146 | - 'config_icingaAPI_password', |
|
| 147 | - array( |
|
| 148 | - 'required' => false, |
|
| 149 | - 'label' => $this->translate('icinga2 API password'), |
|
| 150 | - 'value' => '', |
|
| 151 | - ) |
|
| 152 | - ); |
|
| 145 | + 'text', |
|
| 146 | + 'config_icingaAPI_password', |
|
| 147 | + array( |
|
| 148 | + 'required' => false, |
|
| 149 | + 'label' => $this->translate('icinga2 API password'), |
|
| 150 | + 'value' => '', |
|
| 151 | + ) |
|
| 152 | + ); |
|
| 153 | 153 | /*$this->addElement( |
| 154 | 154 | 'radio', |
| 155 | 155 | 'config_icinga2api_use', |
@@ -159,7 +159,7 @@ discard block |
||
| 159 | 159 | 'value' => array('Yes', 'No'),//array('1' => 'Yes', '0' => 'No'), |
| 160 | 160 | ) |
| 161 | 161 | );*/ |
| 162 | - // For Icinga2 API connexion |
|
| 162 | + // For Icinga2 API connexion |
|
| 163 | 163 | // $icinga2API=new Fieldset('Icinga2 API connection'); |
| 164 | 164 | /* $icinga2API_select=new radioBtn('icinga2API_use'); |
| 165 | 165 | $icinga2API_select->setLabel('Use icinga2 API instead of cmd file?'); |
@@ -169,30 +169,30 @@ discard block |
||
| 169 | 169 | ]); |
| 170 | 170 | $icinga2API->add($icinga2API_select); |
| 171 | 171 | $this->add($icinga2API); */ |
| 172 | - } |
|
| 172 | + } |
|
| 173 | 173 | |
| 174 | 174 | |
| 175 | - public function render(Zend_View_Interface $view = NULL) |
|
| 176 | - { |
|
| 175 | + public function render(Zend_View_Interface $view = NULL) |
|
| 176 | + { |
|
| 177 | 177 | |
| 178 | 178 | |
| 179 | - //return $html; |
|
| 180 | - return parent::render($view); |
|
| 181 | - } |
|
| 179 | + //return $html; |
|
| 180 | + return parent::render($view); |
|
| 181 | + } |
|
| 182 | 182 | |
| 183 | - /** |
|
| 184 | - * {@inheritdoc} |
|
| 185 | - */ |
|
| 186 | - public function onSuccess() |
|
| 187 | - { |
|
| 188 | - parent::onSuccess(); |
|
| 189 | - } |
|
| 183 | + /** |
|
| 184 | + * {@inheritdoc} |
|
| 185 | + */ |
|
| 186 | + public function onSuccess() |
|
| 187 | + { |
|
| 188 | + parent::onSuccess(); |
|
| 189 | + } |
|
| 190 | 190 | |
| 191 | - /** |
|
| 192 | - * {@inheritdoc} |
|
| 193 | - */ |
|
| 191 | + /** |
|
| 192 | + * {@inheritdoc} |
|
| 193 | + */ |
|
| 194 | 194 | public function save() |
| 195 | - { |
|
| 195 | + { |
|
| 196 | 196 | parent::save(); |
| 197 | 197 | } |
| 198 | 198 | } |
@@ -18,7 +18,7 @@ discard block |
||
| 18 | 18 | $this->setName('form_config_traps'); |
| 19 | 19 | $this->setSubmitLabel($this->translate('Save Changes')); |
| 20 | 20 | } |
| 21 | - public function setPaths($module_base_path,$icinga_base_path) |
|
| 21 | + public function setPaths($module_base_path, $icinga_base_path) |
|
| 22 | 22 | { |
| 23 | 23 | $this->module_base_path=$module_base_path; |
| 24 | 24 | $this->icinga_base_path=$icinga_base_path; |
@@ -82,7 +82,7 @@ discard block |
||
| 82 | 82 | ); |
| 83 | 83 | $retval=0; |
| 84 | 84 | $output=array(); |
| 85 | - $snmptranslate=exec('which snmptranslate',$output,$retval); |
|
| 85 | + $snmptranslate=exec('which snmptranslate', $output, $retval); |
|
| 86 | 86 | if ($retval != 0) |
| 87 | 87 | { |
| 88 | 88 | $snmptranslate='/usr/bin/snmptranslate'; |
@@ -172,7 +172,7 @@ discard block |
||
| 172 | 172 | } |
| 173 | 173 | |
| 174 | 174 | |
| 175 | - public function render(Zend_View_Interface $view = NULL) |
|
| 175 | + public function render(Zend_View_Interface $view=NULL) |
|
| 176 | 176 | { |
| 177 | 177 | |
| 178 | 178 | |
@@ -39,8 +39,8 @@ discard block |
||
| 39 | 39 | } |
| 40 | 40 | |
| 41 | 41 | /** |
| 42 | - * Trap detail page |
|
| 43 | - */ |
|
| 42 | + * Trap detail page |
|
| 43 | + */ |
|
| 44 | 44 | public function trapdetailAction() |
| 45 | 45 | { |
| 46 | 46 | |
@@ -141,22 +141,22 @@ discard block |
||
| 141 | 141 | */ |
| 142 | 142 | public function hostsAction() |
| 143 | 143 | { |
| 144 | - $this->checkReadPermission(); |
|
| 145 | - $this->prepareTabs()->activate('hosts'); |
|
| 144 | + $this->checkReadPermission(); |
|
| 145 | + $this->prepareTabs()->activate('hosts'); |
|
| 146 | 146 | |
| 147 | - $db = $this->getDb(); |
|
| 148 | - $this->getTrapHostListTable()->setConnection($db); |
|
| 147 | + $db = $this->getDb(); |
|
| 148 | + $this->getTrapHostListTable()->setConnection($db); |
|
| 149 | 149 | |
| 150 | - // Apply pagination limits |
|
| 151 | - $this->view->table=$this->applyPaginationLimits($this->getTrapHostListTable(),$this->getModuleConfig()->itemListDisplay()); |
|
| 150 | + // Apply pagination limits |
|
| 151 | + $this->view->table=$this->applyPaginationLimits($this->getTrapHostListTable(),$this->getModuleConfig()->itemListDisplay()); |
|
| 152 | 152 | |
| 153 | - // Set Filter |
|
| 154 | - //$postData=$this->getRequest()->getPost(); |
|
| 155 | - $filter=array(); |
|
| 156 | - $filter['q']=$this->params->get('q');//(isset($postData['q']))?$postData['q']:''; |
|
| 157 | - $filter['done']=$this->params->get('done'); |
|
| 158 | - $this->view->filter=$filter; |
|
| 159 | - $this->view->table->updateFilter(Url::fromRequest(),$filter); |
|
| 153 | + // Set Filter |
|
| 154 | + //$postData=$this->getRequest()->getPost(); |
|
| 155 | + $filter=array(); |
|
| 156 | + $filter['q']=$this->params->get('q');//(isset($postData['q']))?$postData['q']:''; |
|
| 157 | + $filter['done']=$this->params->get('done'); |
|
| 158 | + $this->view->filter=$filter; |
|
| 159 | + $this->view->table->updateFilter(Url::fromRequest(),$filter); |
|
| 160 | 160 | } |
| 161 | 161 | |
| 162 | 162 | public function deleteAction() |
@@ -176,12 +176,12 @@ discard block |
||
| 176 | 176 | return $this->getTabs()->add('traps', array( |
| 177 | 177 | 'label' => $this->translate('Traps'), |
| 178 | 178 | 'url' => $this->getModuleConfig()->urlPath() . '/received') |
| 179 | - ) |
|
| 180 | - ->add('hosts', array( |
|
| 181 | - 'label' => $this->translate('Hosts'), |
|
| 182 | - 'url' => $this->getModuleConfig()->urlPath() . '/received/hosts') |
|
| 183 | - ) |
|
| 184 | - ->add('delete', array( |
|
| 179 | + ) |
|
| 180 | + ->add('hosts', array( |
|
| 181 | + 'label' => $this->translate('Hosts'), |
|
| 182 | + 'url' => $this->getModuleConfig()->urlPath() . '/received/hosts') |
|
| 183 | + ) |
|
| 184 | + ->add('delete', array( |
|
| 185 | 185 | 'label' => $this->translate('Delete'), |
| 186 | 186 | 'url' => $this->getModuleConfig()->urlPath() . '/received/delete') |
| 187 | 187 | ); |
@@ -20,19 +20,19 @@ discard block |
||
| 20 | 20 | $this->checkReadPermission(); |
| 21 | 21 | $this->prepareTabs()->activate('traps'); |
| 22 | 22 | |
| 23 | - $db = $this->getDb(); |
|
| 23 | + $db=$this->getDb(); |
|
| 24 | 24 | $this->getTrapListTable()->setConnection($db); |
| 25 | 25 | |
| 26 | 26 | // Apply pagination limits |
| 27 | - $this->view->table=$this->applyPaginationLimits($this->getTrapListTable(),$this->getModuleConfig()->itemListDisplay()); |
|
| 27 | + $this->view->table=$this->applyPaginationLimits($this->getTrapListTable(), $this->getModuleConfig()->itemListDisplay()); |
|
| 28 | 28 | |
| 29 | 29 | // Set Filter |
| 30 | 30 | //$postData=$this->getRequest()->getPost(); |
| 31 | 31 | $filter=array(); |
| 32 | - $filter['q']=$this->params->get('q');//(isset($postData['q']))?$postData['q']:''; |
|
| 32 | + $filter['q']=$this->params->get('q'); //(isset($postData['q']))?$postData['q']:''; |
|
| 33 | 33 | $filter['done']=$this->params->get('done'); |
| 34 | 34 | $this->view->filter=$filter; |
| 35 | - $this->view->table->updateFilter(Url::fromRequest(),$filter); |
|
| 35 | + $this->view->table->updateFilter(Url::fromRequest(), $filter); |
|
| 36 | 36 | |
| 37 | 37 | //$this->view->filterEditor = $this->getTrapListTable()->getFilterEditor($this->getRequest()); |
| 38 | 38 | |
@@ -46,7 +46,7 @@ discard block |
||
| 46 | 46 | |
| 47 | 47 | $this->checkReadPermission(); |
| 48 | 48 | // set up tab |
| 49 | - $this->getTabs()->add('get',array( |
|
| 49 | + $this->getTabs()->add('get', array( |
|
| 50 | 50 | 'active' => true, |
| 51 | 51 | 'label' => $this->translate('Detailed status'), |
| 52 | 52 | 'url' => Url::fromRequest() |
@@ -56,11 +56,11 @@ discard block |
||
| 56 | 56 | $this->view->trapid=$trapid; |
| 57 | 57 | $queryArray=$this->getModuleConfig()->trapDetailQuery(); |
| 58 | 58 | |
| 59 | - $db = $this->getDb()->getConnection(); |
|
| 59 | + $db=$this->getDb()->getConnection(); |
|
| 60 | 60 | |
| 61 | 61 | // URL to add a handler |
| 62 | 62 | $this->view->addHandlerUrl=Url::fromPath( |
| 63 | - $this->getModuleConfig()->urlPath() . '/handler/add', |
|
| 63 | + $this->getModuleConfig()->urlPath().'/handler/add', |
|
| 64 | 64 | array('fromid' => $trapid)); |
| 65 | 65 | // *************** Get main data |
| 66 | 66 | // extract columns and titles; |
@@ -72,28 +72,28 @@ discard block |
||
| 72 | 72 | // Do DB query for trap. |
| 73 | 73 | try |
| 74 | 74 | { |
| 75 | - $query = $db->select() |
|
| 76 | - ->from($this->moduleConfig->getTrapTableName(),$elmts) |
|
| 77 | - ->where('id=?',$trapid); |
|
| 75 | + $query=$db->select() |
|
| 76 | + ->from($this->moduleConfig->getTrapTableName(), $elmts) |
|
| 77 | + ->where('id=?', $trapid); |
|
| 78 | 78 | $trapDetail=$db->fetchRow($query); |
| 79 | - if ( $trapDetail == null) throw new Exception('No traps was found with id = '.$trapid); |
|
| 79 | + if ($trapDetail == null) throw new Exception('No traps was found with id = '.$trapid); |
|
| 80 | 80 | } |
| 81 | 81 | catch (Exception $e) |
| 82 | 82 | { |
| 83 | - $this->displayExitError('Trap detail',$e->getMessage()); |
|
| 83 | + $this->displayExitError('Trap detail', $e->getMessage()); |
|
| 84 | 84 | return; |
| 85 | 85 | } |
| 86 | 86 | |
| 87 | 87 | // Store result in array (with Titles). |
| 88 | 88 | foreach ($queryArray as $key => $val) { |
| 89 | 89 | if ($key == 'timestamp') { |
| 90 | - $cval=strftime('%c',$trapDetail->$key); |
|
| 90 | + $cval=strftime('%c', $trapDetail->$key); |
|
| 91 | 91 | } else { |
| 92 | 92 | $cval=$trapDetail->$key; |
| 93 | 93 | } |
| 94 | - array_push($queryArray[$key],$cval); |
|
| 94 | + array_push($queryArray[$key], $cval); |
|
| 95 | 95 | } |
| 96 | - $this->view->rowset = $queryArray; |
|
| 96 | + $this->view->rowset=$queryArray; |
|
| 97 | 97 | |
| 98 | 98 | // ************** Check for additionnal data |
| 99 | 99 | |
@@ -105,17 +105,17 @@ discard block |
||
| 105 | 105 | } |
| 106 | 106 | try |
| 107 | 107 | { |
| 108 | - $query = $db->select() |
|
| 109 | - ->from($this->moduleConfig->getTrapDataTableName(),$data_elmts) |
|
| 110 | - ->where('trap_id=?',$trapid); |
|
| 108 | + $query=$db->select() |
|
| 109 | + ->from($this->moduleConfig->getTrapDataTableName(), $data_elmts) |
|
| 110 | + ->where('trap_id=?', $trapid); |
|
| 111 | 111 | $trapDetail=$db->fetchAll($query); |
| 112 | 112 | } |
| 113 | 113 | catch (Exception $e) |
| 114 | 114 | { |
| 115 | - $this->displayExitError('Trap detail',$e->getMessage()); |
|
| 115 | + $this->displayExitError('Trap detail', $e->getMessage()); |
|
| 116 | 116 | } |
| 117 | 117 | // TODO : code this in a better & simpler way |
| 118 | - if ($trapDetail == null ) |
|
| 118 | + if ($trapDetail == null) |
|
| 119 | 119 | { |
| 120 | 120 | $this->view->data=false; |
| 121 | 121 | } |
@@ -127,9 +127,9 @@ discard block |
||
| 127 | 127 | foreach ($trapDetail as $key => $val) |
| 128 | 128 | { |
| 129 | 129 | $trapval[$key]=array(); |
| 130 | - foreach (array_keys($queryArrayData) as $vkey ) |
|
| 130 | + foreach (array_keys($queryArrayData) as $vkey) |
|
| 131 | 131 | { |
| 132 | - array_push($trapval[$key],$val->$vkey); |
|
| 132 | + array_push($trapval[$key], $val->$vkey); |
|
| 133 | 133 | } |
| 134 | 134 | } |
| 135 | 135 | $this->view->data_val=$trapval; |
@@ -145,19 +145,19 @@ discard block |
||
| 145 | 145 | $this->checkReadPermission(); |
| 146 | 146 | $this->prepareTabs()->activate('hosts'); |
| 147 | 147 | |
| 148 | - $db = $this->getDb(); |
|
| 148 | + $db=$this->getDb(); |
|
| 149 | 149 | $this->getTrapHostListTable()->setConnection($db); |
| 150 | 150 | |
| 151 | 151 | // Apply pagination limits |
| 152 | - $this->view->table=$this->applyPaginationLimits($this->getTrapHostListTable(),$this->getModuleConfig()->itemListDisplay()); |
|
| 152 | + $this->view->table=$this->applyPaginationLimits($this->getTrapHostListTable(), $this->getModuleConfig()->itemListDisplay()); |
|
| 153 | 153 | |
| 154 | 154 | // Set Filter |
| 155 | 155 | //$postData=$this->getRequest()->getPost(); |
| 156 | 156 | $filter=array(); |
| 157 | - $filter['q']=$this->params->get('q');//(isset($postData['q']))?$postData['q']:''; |
|
| 157 | + $filter['q']=$this->params->get('q'); //(isset($postData['q']))?$postData['q']:''; |
|
| 158 | 158 | $filter['done']=$this->params->get('done'); |
| 159 | 159 | $this->view->filter=$filter; |
| 160 | - $this->view->table->updateFilter(Url::fromRequest(),$filter); |
|
| 160 | + $this->view->table->updateFilter(Url::fromRequest(), $filter); |
|
| 161 | 161 | } |
| 162 | 162 | |
| 163 | 163 | public function deleteAction() |
@@ -176,15 +176,15 @@ discard block |
||
| 176 | 176 | { |
| 177 | 177 | return $this->getTabs()->add('traps', array( |
| 178 | 178 | 'label' => $this->translate('Traps'), |
| 179 | - 'url' => $this->getModuleConfig()->urlPath() . '/received') |
|
| 179 | + 'url' => $this->getModuleConfig()->urlPath().'/received') |
|
| 180 | 180 | ) |
| 181 | 181 | ->add('hosts', array( |
| 182 | 182 | 'label' => $this->translate('Hosts'), |
| 183 | - 'url' => $this->getModuleConfig()->urlPath() . '/received/hosts') |
|
| 183 | + 'url' => $this->getModuleConfig()->urlPath().'/received/hosts') |
|
| 184 | 184 | ) |
| 185 | 185 | ->add('delete', array( |
| 186 | 186 | 'label' => $this->translate('Delete'), |
| 187 | - 'url' => $this->getModuleConfig()->urlPath() . '/received/delete') |
|
| 187 | + 'url' => $this->getModuleConfig()->urlPath().'/received/delete') |
|
| 188 | 188 | ); |
| 189 | 189 | } |
| 190 | 190 | |
@@ -211,14 +211,14 @@ discard block |
||
| 211 | 211 | $this->_helper->json(array('status'=>'Missing variables')); |
| 212 | 212 | return; |
| 213 | 213 | } |
| 214 | - if ($action =="count") |
|
| 214 | + if ($action == "count") |
|
| 215 | 215 | { |
| 216 | - $this->_helper->json(array('status'=>'OK','count'=>$this->countTrap($ip,$oid))); |
|
| 216 | + $this->_helper->json(array('status'=>'OK', 'count'=>$this->countTrap($ip, $oid))); |
|
| 217 | 217 | return; |
| 218 | 218 | } |
| 219 | - if ($action =="delete") |
|
| 219 | + if ($action == "delete") |
|
| 220 | 220 | { |
| 221 | - $this->_helper->json(array('status'=>'OK','count'=>$this->deleteTrap($ip,$oid))); |
|
| 221 | + $this->_helper->json(array('status'=>'OK', 'count'=>$this->deleteTrap($ip, $oid))); |
|
| 222 | 222 | return; |
| 223 | 223 | } |
| 224 | 224 | $this->_helper->json(array('status'=>'unknown action')); |
@@ -76,9 +76,10 @@ discard block |
||
| 76 | 76 | ->from($this->moduleConfig->getTrapTableName(),$elmts) |
| 77 | 77 | ->where('id=?',$trapid); |
| 78 | 78 | $trapDetail=$db->fetchRow($query); |
| 79 | - if ( $trapDetail == null) throw new Exception('No traps was found with id = '.$trapid); |
|
| 80 | - } |
|
| 81 | - catch (Exception $e) |
|
| 79 | + if ( $trapDetail == null) { |
|
| 80 | + throw new Exception('No traps was found with id = '.$trapid); |
|
| 81 | + } |
|
| 82 | + } catch (Exception $e) |
|
| 82 | 83 | { |
| 83 | 84 | $this->displayExitError('Trap detail',$e->getMessage()); |
| 84 | 85 | return; |
@@ -109,8 +110,7 @@ discard block |
||
| 109 | 110 | ->from($this->moduleConfig->getTrapDataTableName(),$data_elmts) |
| 110 | 111 | ->where('trap_id=?',$trapid); |
| 111 | 112 | $trapDetail=$db->fetchAll($query); |
| 112 | - } |
|
| 113 | - catch (Exception $e) |
|
| 113 | + } catch (Exception $e) |
|
| 114 | 114 | { |
| 115 | 115 | $this->displayExitError('Trap detail',$e->getMessage()); |
| 116 | 116 | } |
@@ -118,8 +118,7 @@ discard block |
||
| 118 | 118 | if ($trapDetail == null ) |
| 119 | 119 | { |
| 120 | 120 | $this->view->data=false; |
| 121 | - } |
|
| 122 | - else |
|
| 121 | + } else |
|
| 123 | 122 | { |
| 124 | 123 | $this->view->data=true; |
| 125 | 124 | // Store result in array. |
@@ -205,8 +204,7 @@ discard block |
||
| 205 | 204 | $ip=$postData['IP']; |
| 206 | 205 | $oid=$postData['OID']; |
| 207 | 206 | $action=$postData['action']; |
| 208 | - } |
|
| 209 | - else |
|
| 207 | + } else |
|
| 210 | 208 | { |
| 211 | 209 | $this->_helper->json(array('status'=>'Missing variables')); |
| 212 | 210 | return; |
@@ -55,15 +55,15 @@ discard block |
||
| 55 | 55 | } |
| 56 | 56 | // Test Database |
| 57 | 57 | $db_message=array( // index => ( message OK, message NOK, optional link if NOK ) |
| 58 | - 0 => array('Database configuration OK','',''), |
|
| 59 | - 1 => array('Database set in config.ini','No database in config.ini',''), |
|
| 60 | - 2 => array('Database exists in Icingaweb2 config','Database does not exist in Icingaweb2 : ', |
|
| 58 | + 0 => array('Database configuration OK', '', ''), |
|
| 59 | + 1 => array('Database set in config.ini', 'No database in config.ini', ''), |
|
| 60 | + 2 => array('Database exists in Icingaweb2 config', 'Database does not exist in Icingaweb2 : ', |
|
| 61 | 61 | Url::fromPath('config/resource')), |
| 62 | - 3 => array('Database credentials OK','Database does not exist/invalid credentials/no schema : ', |
|
| 62 | + 3 => array('Database credentials OK', 'Database does not exist/invalid credentials/no schema : ', |
|
| 63 | 63 | Url::fromPath('trapdirector/settings/createschema')), |
| 64 | - 4 => array('Schema is set','Schema is not set for ', |
|
| 64 | + 4 => array('Schema is set', 'Schema is not set for ', |
|
| 65 | 65 | Url::fromPath('trapdirector/settings/createschema')), |
| 66 | - 5 => array('Schema is up to date','Schema is outdated :', |
|
| 66 | + 5 => array('Schema is up to date', 'Schema is outdated :', |
|
| 67 | 67 | Url::fromPath('trapdirector/settings/updateschema')), |
| 68 | 68 | ); |
| 69 | 69 | |
@@ -74,13 +74,13 @@ discard block |
||
| 74 | 74 | { |
| 75 | 75 | case 2: |
| 76 | 76 | case 4: |
| 77 | - $db_message[$dberror[0]][1] .= $dberror[1]; |
|
| 77 | + $db_message[$dberror[0]][1].=$dberror[1]; |
|
| 78 | 78 | break; |
| 79 | 79 | case 3: |
| 80 | - $db_message[$dberror[0]][1] .= $dberror[1] . ', Message : ' . $dberror[2]; |
|
| 80 | + $db_message[$dberror[0]][1].=$dberror[1].', Message : '.$dberror[2]; |
|
| 81 | 81 | break; |
| 82 | 82 | case 5: |
| 83 | - $db_message[$dberror[0]][1] .= ' version '. $dberror[1] . ', version needed : ' .$dberror[2]; |
|
| 83 | + $db_message[$dberror[0]][1].=' version '.$dberror[1].', version needed : '.$dberror[2]; |
|
| 84 | 84 | break; |
| 85 | 85 | case 0: |
| 86 | 86 | case 1: |
@@ -92,18 +92,18 @@ discard block |
||
| 92 | 92 | |
| 93 | 93 | $dberror=$this->getIdoDb(true); // Get IDO DB in test mode |
| 94 | 94 | $this->view->ido_db_error=$dberror[0]; |
| 95 | - $this->view->ido_message='IDO Database : ' . $dberror[1]; |
|
| 95 | + $this->view->ido_message='IDO Database : '.$dberror[1]; |
|
| 96 | 96 | |
| 97 | 97 | //********* Test API |
| 98 | 98 | if ($this->Config()->get('config', 'icingaAPI_host') != '') |
| 99 | 99 | { |
| 100 | - $apitest=new Icinga2Api($this->Config()->get('config', 'icingaAPI_host'),$this->Config()->get('config', 'icingaAPI_port')); |
|
| 100 | + $apitest=new Icinga2Api($this->Config()->get('config', 'icingaAPI_host'), $this->Config()->get('config', 'icingaAPI_port')); |
|
| 101 | 101 | $apitest->setCredentials($this->Config()->get('config', 'icingaAPI_user'), $this->Config()->get('config', 'icingaAPI_password')); |
| 102 | 102 | try { |
| 103 | - list($this->view->apimessageError,$this->view->apimessage)=$apitest->test($this->getModuleConfig()::getapiUserPermissions()); |
|
| 103 | + list($this->view->apimessageError, $this->view->apimessage)=$apitest->test($this->getModuleConfig()::getapiUserPermissions()); |
|
| 104 | 104 | //$this->view->apimessageError=false; |
| 105 | 105 | } catch (RuntimeException $e) { |
| 106 | - $this->view->apimessage='API config : ' . $e->getMessage(); |
|
| 106 | + $this->view->apimessage='API config : '.$e->getMessage(); |
|
| 107 | 107 | $this->view->apimessageError=true; |
| 108 | 108 | } |
| 109 | 109 | } |
@@ -114,18 +114,18 @@ discard block |
||
| 114 | 114 | } |
| 115 | 115 | |
| 116 | 116 | //*********** Test snmptrapd alive and options |
| 117 | - list ($this->view->snmptrapdError, $this->view->snmptrapdMessage) = $this->checkSnmpTrapd(); |
|
| 117 | + list ($this->view->snmptrapdError, $this->view->snmptrapdMessage)=$this->checkSnmpTrapd(); |
|
| 118 | 118 | |
| 119 | 119 | // List DB in $ressources |
| 120 | - $resources = array(); |
|
| 121 | - $allowed = array('mysql', 'pgsql'); |
|
| 120 | + $resources=array(); |
|
| 121 | + $allowed=array('mysql', 'pgsql'); |
|
| 122 | 122 | foreach (ResourceFactory::getResourceConfigs() as $name => $resource) { |
| 123 | 123 | if ($resource->get('type') === 'db' && in_array($resource->get('db'), $allowed)) { |
| 124 | - $resources[$name] = $name; |
|
| 124 | + $resources[$name]=$name; |
|
| 125 | 125 | } |
| 126 | 126 | } |
| 127 | 127 | |
| 128 | - $this->view->tabs = $this->Module()->getConfigTabs()->activate('config'); |
|
| 128 | + $this->view->tabs=$this->Module()->getConfigTabs()->activate('config'); |
|
| 129 | 129 | |
| 130 | 130 | // Check standard Icingaweb2 path |
| 131 | 131 | $this->view->icingaEtcWarn=0; |
@@ -134,9 +134,9 @@ discard block |
||
| 134 | 134 | { |
| 135 | 135 | $output=array(); |
| 136 | 136 | |
| 137 | - exec('cat ' . $this->module->getBaseDir() .'/bin/trap_in.php | grep "\$icingaweb2_etc=" ',$output); |
|
| 137 | + exec('cat '.$this->module->getBaseDir().'/bin/trap_in.php | grep "\$icingaweb2_etc=" ', $output); |
|
| 138 | 138 | |
| 139 | - if (! preg_match('#"'. $icingaweb2_etc .'"#',$output[0])) |
|
| 139 | + if (!preg_match('#"'.$icingaweb2_etc.'"#', $output[0])) |
|
| 140 | 140 | { |
| 141 | 141 | $this->view->icingaEtcWarn=1; |
| 142 | 142 | $this->view->icingaweb2_etc=$icingaweb2_etc; |
@@ -144,23 +144,23 @@ discard block |
||
| 144 | 144 | } |
| 145 | 145 | |
| 146 | 146 | // Setup path for mini documentation |
| 147 | - $this->view->traps_in_config= PHP_BINARY . ' ' . $this->Module()->getBaseDir() . '/bin/trap_in.php'; |
|
| 147 | + $this->view->traps_in_config=PHP_BINARY.' '.$this->Module()->getBaseDir().'/bin/trap_in.php'; |
|
| 148 | 148 | |
| 149 | - $this->view->installer= $this->Module()->getBaseDir() . '/bin/installer.sh ' |
|
| 149 | + $this->view->installer=$this->Module()->getBaseDir().'/bin/installer.sh ' |
|
| 150 | 150 | . ' -c all ' |
| 151 | - . ' -d ' . $this->Module()->getBaseDir() |
|
| 152 | - . ' -p ' . PHP_BINARY |
|
| 153 | - . ' -a ' . exec('whoami') |
|
| 154 | - . ' -w ' . Icinga::app()->getConfigDir(); |
|
| 151 | + . ' -d '.$this->Module()->getBaseDir() |
|
| 152 | + . ' -p '.PHP_BINARY |
|
| 153 | + . ' -a '.exec('whoami') |
|
| 154 | + . ' -w '.Icinga::app()->getConfigDir(); |
|
| 155 | 155 | |
| 156 | 156 | // ******************* configuration form setup******************* |
| 157 | - $this->view->form = $form = new TrapsConfigForm(); |
|
| 157 | + $this->view->form=$form=new TrapsConfigForm(); |
|
| 158 | 158 | |
| 159 | 159 | // set default paths; |
| 160 | - $this->view->form->setPaths($this->Module()->getBaseDir(),Icinga::app()->getConfigDir()); |
|
| 160 | + $this->view->form->setPaths($this->Module()->getBaseDir(), Icinga::app()->getConfigDir()); |
|
| 161 | 161 | |
| 162 | 162 | // set default ido database |
| 163 | - $this->view->form->setDefaultIDODB($this->Config()->module('monitoring','backends')->get('icinga','resource')); |
|
| 163 | + $this->view->form->setDefaultIDODB($this->Config()->module('monitoring', 'backends')->get('icinga', 'resource')); |
|
| 164 | 164 | |
| 165 | 165 | // Make form handle request. |
| 166 | 166 | $form->setIniConfig($this->Config()) |
@@ -172,7 +172,7 @@ discard block |
||
| 172 | 172 | public function createschemaAction() |
| 173 | 173 | { |
| 174 | 174 | $this->checkModuleConfigPermission(); |
| 175 | - $this->getTabs()->add('create_schema',array( |
|
| 175 | + $this->getTabs()->add('create_schema', array( |
|
| 176 | 176 | 'active' => true, |
| 177 | 177 | 'label' => $this->translate('Create Schema'), |
| 178 | 178 | 'url' => Url::fromRequest() |
@@ -193,7 +193,7 @@ discard block |
||
| 193 | 193 | $dbName=$this->Config()->get('config', 'database'); |
| 194 | 194 | |
| 195 | 195 | try { |
| 196 | - $dbResource = ResourceFactory::getResourceConfig($dbName); |
|
| 196 | + $dbResource=ResourceFactory::getResourceConfig($dbName); |
|
| 197 | 197 | $dbType=$dbResource->get('db'); |
| 198 | 198 | switch ($dbType) { |
| 199 | 199 | case 'mysql': |
@@ -205,34 +205,34 @@ discard block |
||
| 205 | 205 | default: |
| 206 | 206 | throw new ConfigurationError('Unsuported database : '.$dbType); |
| 207 | 207 | } |
| 208 | - } catch (ConfigurationError $e ) |
|
| 208 | + } catch (ConfigurationError $e) |
|
| 209 | 209 | { |
| 210 | - printf("Database configuration error : %s",$e->getMessage()); |
|
| 210 | + printf("Database configuration error : %s", $e->getMessage()); |
|
| 211 | 211 | return; |
| 212 | 212 | } |
| 213 | 213 | printf('<pre>'); |
| 214 | - require_once $this->Module()->getBaseDir() .'/bin/trap_class.php'; |
|
| 214 | + require_once $this->Module()->getBaseDir().'/bin/trap_class.php'; |
|
| 215 | 215 | |
| 216 | 216 | $icingaweb2_etc=$this->Config()->get('config', 'icingaweb2_etc'); |
| 217 | 217 | $debug_level=4; |
| 218 | - $Trap = new Trap($icingaweb2_etc); |
|
| 219 | - $Trap->setLogging($debug_level,'display'); |
|
| 218 | + $Trap=new Trap($icingaweb2_etc); |
|
| 219 | + $Trap->setLogging($debug_level, 'display'); |
|
| 220 | 220 | |
| 221 | 221 | $prefix=$this->Config()->get('config', 'database_prefix'); |
| 222 | 222 | // schema file : <path>/SQL/schema_v<verion>.<dbtype> |
| 223 | - $schema=$this->Module()->getBaseDir() . |
|
| 224 | - '/SQL/schema_v'. $this->getModuleConfig()->getDbCurVersion() . '.' . $dbFileExt; |
|
| 223 | + $schema=$this->Module()->getBaseDir(). |
|
| 224 | + '/SQL/schema_v'.$this->getModuleConfig()->getDbCurVersion().'.'.$dbFileExt; |
|
| 225 | 225 | |
| 226 | - $Trap->create_schema($schema,$prefix); |
|
| 226 | + $Trap->create_schema($schema, $prefix); |
|
| 227 | 227 | echo '</pre>'; |
| 228 | 228 | } |
| 229 | - echo '<br><br>Return to <a href="' . Url::fromPath('trapdirector/settings') .'" class="link-button icon-wrench"> settings page </a>'; |
|
| 229 | + echo '<br><br>Return to <a href="'.Url::fromPath('trapdirector/settings').'" class="link-button icon-wrench"> settings page </a>'; |
|
| 230 | 230 | } |
| 231 | 231 | |
| 232 | 232 | public function updateschemaAction() |
| 233 | 233 | { |
| 234 | 234 | $this->checkModuleConfigPermission(); |
| 235 | - $this->getTabs()->add('get',array( |
|
| 235 | + $this->getTabs()->add('get', array( |
|
| 236 | 236 | 'active' => true, |
| 237 | 237 | 'label' => $this->translate('Update Schema'), |
| 238 | 238 | 'url' => Url::fromRequest() |
@@ -241,7 +241,7 @@ discard block |
||
| 241 | 241 | |
| 242 | 242 | $dberror=$this->getDb(true); // Get DB in test mode |
| 243 | 243 | |
| 244 | - echo 'Return to <a href="' . Url::fromPath('trapdirector/settings') .'" class="link-button icon-wrench"> settings page </a><br><br>'; |
|
| 244 | + echo 'Return to <a href="'.Url::fromPath('trapdirector/settings').'" class="link-button icon-wrench"> settings page </a><br><br>'; |
|
| 245 | 245 | |
| 246 | 246 | if ($dberror[0] == 0) |
| 247 | 247 | { |
@@ -254,40 +254,40 @@ discard block |
||
| 254 | 254 | return; |
| 255 | 255 | } |
| 256 | 256 | // setup |
| 257 | - require_once($this->Module()->getBaseDir() .'/bin/trap_class.php'); |
|
| 257 | + require_once($this->Module()->getBaseDir().'/bin/trap_class.php'); |
|
| 258 | 258 | $icingaweb2_etc=$this->Config()->get('config', 'icingaweb2_etc'); |
| 259 | 259 | $debug_level=4; |
| 260 | - $Trap = new Trap($icingaweb2_etc); |
|
| 260 | + $Trap=new Trap($icingaweb2_etc); |
|
| 261 | 261 | |
| 262 | 262 | |
| 263 | 263 | $prefix=$this->Config()->get('config', 'database_prefix'); |
| 264 | - $updateSchema=$this->Module()->getBaseDir() . '/SQL/'; |
|
| 264 | + $updateSchema=$this->Module()->getBaseDir().'/SQL/'; |
|
| 265 | 265 | |
| 266 | 266 | $target_version=$dberror[2]; |
| 267 | 267 | |
| 268 | 268 | if ($this->params->get('msgok') == null) { |
| 269 | 269 | // Check for messages and display if any |
| 270 | 270 | echo "Upgrade databse is going to start.<br>Don't forget to backup your database before update<br>"; |
| 271 | - $Trap->setLogging(2,'syslog'); |
|
| 272 | - $message = $Trap->update_schema($updateSchema,$target_version,$prefix,true); |
|
| 271 | + $Trap->setLogging(2, 'syslog'); |
|
| 272 | + $message=$Trap->update_schema($updateSchema, $target_version, $prefix, true); |
|
| 273 | 273 | if ($message != '') |
| 274 | 274 | { |
| 275 | 275 | echo 'Note :<br><pre>'; |
| 276 | 276 | echo $message; |
| 277 | 277 | echo '</pre>'; |
| 278 | 278 | echo '<br>'; |
| 279 | - echo '<a class="link-button" style="font-size:large;font-weight:bold" href="' . Url::fromPath('trapdirector/settings/updateschema') .'?msgok=1">Click here to update</a>'; |
|
| 279 | + echo '<a class="link-button" style="font-size:large;font-weight:bold" href="'.Url::fromPath('trapdirector/settings/updateschema').'?msgok=1">Click here to update</a>'; |
|
| 280 | 280 | echo '<br>'; |
| 281 | 281 | return; |
| 282 | 282 | } |
| 283 | 283 | } |
| 284 | 284 | |
| 285 | - $Trap->setLogging($debug_level,'display'); |
|
| 285 | + $Trap->setLogging($debug_level, 'display'); |
|
| 286 | 286 | |
| 287 | - echo 'Updating schema to '. $target_version . ': <br>'; |
|
| 287 | + echo 'Updating schema to '.$target_version.': <br>'; |
|
| 288 | 288 | echo '<pre>'; |
| 289 | 289 | |
| 290 | - $Trap->update_schema($updateSchema,$target_version,$prefix); |
|
| 290 | + $Trap->update_schema($updateSchema, $target_version, $prefix); |
|
| 291 | 291 | echo '</pre>'; |
| 292 | 292 | } |
| 293 | 293 | |
@@ -295,26 +295,26 @@ discard block |
||
| 295 | 295 | { |
| 296 | 296 | $psOutput=array(); |
| 297 | 297 | // First check is someone is listening to port 162. As not root, we can't have pid... |
| 298 | - exec('netstat -an |grep -E "udp.*:162"',$psOutput); |
|
| 298 | + exec('netstat -an |grep -E "udp.*:162"', $psOutput); |
|
| 299 | 299 | if (count($psOutput) == 0) |
| 300 | 300 | { |
| 301 | - return array(1,'Port UDP/162 is not open : snmptrapd must not be started'); |
|
| 301 | + return array(1, 'Port UDP/162 is not open : snmptrapd must not be started'); |
|
| 302 | 302 | } |
| 303 | 303 | $psOutput=array(); |
| 304 | - exec('ps fax |grep snmptrapd |grep -v grep',$psOutput); |
|
| 304 | + exec('ps fax |grep snmptrapd |grep -v grep', $psOutput); |
|
| 305 | 305 | if (count($psOutput) == 0) |
| 306 | 306 | { |
| 307 | - return array(1,"UDP/162 : OK, but no snmptrapd process (?)"); |
|
| 307 | + return array(1, "UDP/162 : OK, but no snmptrapd process (?)"); |
|
| 308 | 308 | } |
| 309 | 309 | // Assume there is only one line... TODO : see if there is a better way to do this |
| 310 | - $line = preg_replace('/^.*snmptrapd /','',$psOutput[0]); |
|
| 311 | - if (!preg_match('/-n/',$line)) |
|
| 312 | - return array(1,'snmptrapd has no -n option : '.$line); |
|
| 313 | - if (!preg_match('/-O[^ ]*n/',$line)) |
|
| 314 | - return array(1,'snmptrapd has no -On option : '.$line); |
|
| 315 | - if (!preg_match('/-O[^ ]*e/',$line)) |
|
| 316 | - return array(1,'snmptrapd has no -Oe option : '.$line); |
|
| 310 | + $line=preg_replace('/^.*snmptrapd /', '', $psOutput[0]); |
|
| 311 | + if (!preg_match('/-n/', $line)) |
|
| 312 | + return array(1, 'snmptrapd has no -n option : '.$line); |
|
| 313 | + if (!preg_match('/-O[^ ]*n/', $line)) |
|
| 314 | + return array(1, 'snmptrapd has no -On option : '.$line); |
|
| 315 | + if (!preg_match('/-O[^ ]*e/', $line)) |
|
| 316 | + return array(1, 'snmptrapd has no -Oe option : '.$line); |
|
| 317 | 317 | |
| 318 | - return array(0,'snmptrapd listening to UDP/162, options : '.$line); |
|
| 318 | + return array(0, 'snmptrapd listening to UDP/162, options : '.$line); |
|
| 319 | 319 | } |
| 320 | 320 | } |
@@ -22,37 +22,37 @@ discard block |
||
| 22 | 22 | public function indexAction() |
| 23 | 23 | { |
| 24 | 24 | |
| 25 | - // CHeck permissions : display tests in any case, but no configuration. |
|
| 25 | + // CHeck permissions : display tests in any case, but no configuration. |
|
| 26 | 26 | $this->view->configPermission=$this->checkModuleConfigPermission(1); |
| 27 | 27 | // But check read permission |
| 28 | 28 | $this->checkReadPermission(); |
| 29 | 29 | // Get message : sent on configuration problems detected by controllers |
| 30 | 30 | $dberrorMsg=$this->params->get('dberror'); |
| 31 | 31 | if ($dberrorMsg != '') |
| 32 | - $this->view->errorDetected=$dberrorMsg; |
|
| 33 | - $dberrorMsg=$this->params->get('idodberror'); |
|
| 34 | - if ($dberrorMsg != '') |
|
| 35 | - $this->view->errorDetected=$dberrorMsg; |
|
| 32 | + $this->view->errorDetected=$dberrorMsg; |
|
| 33 | + $dberrorMsg=$this->params->get('idodberror'); |
|
| 34 | + if ($dberrorMsg != '') |
|
| 35 | + $this->view->errorDetected=$dberrorMsg; |
|
| 36 | 36 | |
| 37 | - $this->view->configErrorDetected == NULL; // Displayed error on various conifugration errors. |
|
| 37 | + $this->view->configErrorDetected == NULL; // Displayed error on various conifugration errors. |
|
| 38 | 38 | |
| 39 | - // Test if configuration exists, if not create for installer script |
|
| 39 | + // Test if configuration exists, if not create for installer script |
|
| 40 | 40 | //$emptyConfig=0; |
| 41 | - if ($this->Config()->isEmpty() == true) |
|
| 42 | - { |
|
| 43 | - $this->Config()->setSection('config'); // Set base config section. |
|
| 44 | - try |
|
| 45 | - { |
|
| 46 | - $this->Config()->saveIni(); |
|
| 47 | - $this->view->configErrorDetected='Configuration is empty : you can run install script with parameters (see Automatic installation below)'; |
|
| 41 | + if ($this->Config()->isEmpty() == true) |
|
| 42 | + { |
|
| 43 | + $this->Config()->setSection('config'); // Set base config section. |
|
| 44 | + try |
|
| 45 | + { |
|
| 46 | + $this->Config()->saveIni(); |
|
| 47 | + $this->view->configErrorDetected='Configuration is empty : you can run install script with parameters (see Automatic installation below)'; |
|
| 48 | 48 | //$emptyConfig=1; |
| 49 | - } |
|
| 50 | - catch (Exception $e) |
|
| 51 | - { |
|
| 52 | - $this->view->configErrorDetected=$e->getMessage(); |
|
| 53 | - } |
|
| 49 | + } |
|
| 50 | + catch (Exception $e) |
|
| 51 | + { |
|
| 52 | + $this->view->configErrorDetected=$e->getMessage(); |
|
| 53 | + } |
|
| 54 | 54 | |
| 55 | - } |
|
| 55 | + } |
|
| 56 | 56 | // Test Database |
| 57 | 57 | $db_message=array( // index => ( message OK, message NOK, optional link if NOK ) |
| 58 | 58 | 0 => array('Database configuration OK','',''), |
@@ -97,20 +97,20 @@ discard block |
||
| 97 | 97 | //********* Test API |
| 98 | 98 | if ($this->Config()->get('config', 'icingaAPI_host') != '') |
| 99 | 99 | { |
| 100 | - $apitest=new Icinga2Api($this->Config()->get('config', 'icingaAPI_host'),$this->Config()->get('config', 'icingaAPI_port')); |
|
| 101 | - $apitest->setCredentials($this->Config()->get('config', 'icingaAPI_user'), $this->Config()->get('config', 'icingaAPI_password')); |
|
| 102 | - try { |
|
| 103 | - list($this->view->apimessageError,$this->view->apimessage)=$apitest->test($this->getModuleConfig()::getapiUserPermissions()); |
|
| 104 | - //$this->view->apimessageError=false; |
|
| 105 | - } catch (RuntimeException $e) { |
|
| 106 | - $this->view->apimessage='API config : ' . $e->getMessage(); |
|
| 107 | - $this->view->apimessageError=true; |
|
| 108 | - } |
|
| 100 | + $apitest=new Icinga2Api($this->Config()->get('config', 'icingaAPI_host'),$this->Config()->get('config', 'icingaAPI_port')); |
|
| 101 | + $apitest->setCredentials($this->Config()->get('config', 'icingaAPI_user'), $this->Config()->get('config', 'icingaAPI_password')); |
|
| 102 | + try { |
|
| 103 | + list($this->view->apimessageError,$this->view->apimessage)=$apitest->test($this->getModuleConfig()::getapiUserPermissions()); |
|
| 104 | + //$this->view->apimessageError=false; |
|
| 105 | + } catch (RuntimeException $e) { |
|
| 106 | + $this->view->apimessage='API config : ' . $e->getMessage(); |
|
| 107 | + $this->view->apimessageError=true; |
|
| 108 | + } |
|
| 109 | 109 | } |
| 110 | 110 | else |
| 111 | 111 | { |
| 112 | - $this->view->apimessage='API parameters not configured'; |
|
| 113 | - $this->view->apimessageError=true; |
|
| 112 | + $this->view->apimessage='API parameters not configured'; |
|
| 113 | + $this->view->apimessageError=true; |
|
| 114 | 114 | } |
| 115 | 115 | |
| 116 | 116 | //*********** Test snmptrapd alive and options |
@@ -125,33 +125,33 @@ discard block |
||
| 125 | 125 | } |
| 126 | 126 | } |
| 127 | 127 | |
| 128 | - $this->view->tabs = $this->Module()->getConfigTabs()->activate('config'); |
|
| 128 | + $this->view->tabs = $this->Module()->getConfigTabs()->activate('config'); |
|
| 129 | 129 | |
| 130 | 130 | // Check standard Icingaweb2 path |
| 131 | 131 | $this->view->icingaEtcWarn=0; |
| 132 | 132 | $icingaweb2_etc=$this->Config()->get('config', 'icingaweb2_etc'); |
| 133 | 133 | if ($icingaweb2_etc != "/etc/icingaweb2/" && $icingaweb2_etc != '') |
| 134 | 134 | { |
| 135 | - $output=array(); |
|
| 135 | + $output=array(); |
|
| 136 | 136 | |
| 137 | - exec('cat ' . $this->module->getBaseDir() .'/bin/trap_in.php | grep "\$icingaweb2_etc=" ',$output); |
|
| 137 | + exec('cat ' . $this->module->getBaseDir() .'/bin/trap_in.php | grep "\$icingaweb2_etc=" ',$output); |
|
| 138 | 138 | |
| 139 | - if (! preg_match('#"'. $icingaweb2_etc .'"#',$output[0])) |
|
| 140 | - { |
|
| 141 | - $this->view->icingaEtcWarn=1; |
|
| 142 | - $this->view->icingaweb2_etc=$icingaweb2_etc; |
|
| 143 | - } |
|
| 139 | + if (! preg_match('#"'. $icingaweb2_etc .'"#',$output[0])) |
|
| 140 | + { |
|
| 141 | + $this->view->icingaEtcWarn=1; |
|
| 142 | + $this->view->icingaweb2_etc=$icingaweb2_etc; |
|
| 143 | + } |
|
| 144 | 144 | } |
| 145 | 145 | |
| 146 | 146 | // Setup path for mini documentation |
| 147 | 147 | $this->view->traps_in_config= PHP_BINARY . ' ' . $this->Module()->getBaseDir() . '/bin/trap_in.php'; |
| 148 | 148 | |
| 149 | 149 | $this->view->installer= $this->Module()->getBaseDir() . '/bin/installer.sh ' |
| 150 | - . ' -c all ' |
|
| 151 | - . ' -d ' . $this->Module()->getBaseDir() |
|
| 152 | - . ' -p ' . PHP_BINARY |
|
| 153 | - . ' -a ' . exec('whoami') |
|
| 154 | - . ' -w ' . Icinga::app()->getConfigDir(); |
|
| 150 | + . ' -c all ' |
|
| 151 | + . ' -d ' . $this->Module()->getBaseDir() |
|
| 152 | + . ' -p ' . PHP_BINARY |
|
| 153 | + . ' -a ' . exec('whoami') |
|
| 154 | + . ' -w ' . Icinga::app()->getConfigDir(); |
|
| 155 | 155 | |
| 156 | 156 | // ******************* configuration form setup******************* |
| 157 | 157 | $this->view->form = $form = new TrapsConfigForm(); |
@@ -196,19 +196,19 @@ discard block |
||
| 196 | 196 | $dbResource = ResourceFactory::getResourceConfig($dbName); |
| 197 | 197 | $dbType=$dbResource->get('db'); |
| 198 | 198 | switch ($dbType) { |
| 199 | - case 'mysql': |
|
| 200 | - $dbFileExt='sql'; |
|
| 201 | - break; |
|
| 202 | - case 'pgsql': |
|
| 203 | - $dbFileExt='pgsql'; |
|
| 204 | - break; |
|
| 205 | - default: |
|
| 206 | - throw new ConfigurationError('Unsuported database : '.$dbType); |
|
| 199 | + case 'mysql': |
|
| 200 | + $dbFileExt='sql'; |
|
| 201 | + break; |
|
| 202 | + case 'pgsql': |
|
| 203 | + $dbFileExt='pgsql'; |
|
| 204 | + break; |
|
| 205 | + default: |
|
| 206 | + throw new ConfigurationError('Unsuported database : '.$dbType); |
|
| 207 | 207 | } |
| 208 | 208 | } catch (ConfigurationError $e ) |
| 209 | 209 | { |
| 210 | - printf("Database configuration error : %s",$e->getMessage()); |
|
| 211 | - return; |
|
| 210 | + printf("Database configuration error : %s",$e->getMessage()); |
|
| 211 | + return; |
|
| 212 | 212 | } |
| 213 | 213 | printf('<pre>'); |
| 214 | 214 | require_once $this->Module()->getBaseDir() .'/bin/trap_class.php'; |
@@ -232,11 +232,11 @@ discard block |
||
| 232 | 232 | public function updateschemaAction() |
| 233 | 233 | { |
| 234 | 234 | $this->checkModuleConfigPermission(); |
| 235 | - $this->getTabs()->add('get',array( |
|
| 236 | - 'active' => true, |
|
| 237 | - 'label' => $this->translate('Update Schema'), |
|
| 238 | - 'url' => Url::fromRequest() |
|
| 239 | - )); |
|
| 235 | + $this->getTabs()->add('get',array( |
|
| 236 | + 'active' => true, |
|
| 237 | + 'label' => $this->translate('Update Schema'), |
|
| 238 | + 'url' => Url::fromRequest() |
|
| 239 | + )); |
|
| 240 | 240 | // check if needed |
| 241 | 241 | |
| 242 | 242 | $dberror=$this->getDb(true); // Get DB in test mode |
@@ -245,15 +245,15 @@ discard block |
||
| 245 | 245 | |
| 246 | 246 | if ($dberror[0] == 0) |
| 247 | 247 | { |
| 248 | - echo 'Schema already exists and is up to date<br>'; |
|
| 249 | - return; |
|
| 248 | + echo 'Schema already exists and is up to date<br>'; |
|
| 249 | + return; |
|
| 250 | 250 | } |
| 251 | 251 | if ($dberror[0] != 5) |
| 252 | 252 | { |
| 253 | - echo 'Database does not exists or is not setup correctly<br>'; |
|
| 254 | - return; |
|
| 253 | + echo 'Database does not exists or is not setup correctly<br>'; |
|
| 254 | + return; |
|
| 255 | 255 | } |
| 256 | - // setup |
|
| 256 | + // setup |
|
| 257 | 257 | require_once($this->Module()->getBaseDir() .'/bin/trap_class.php'); |
| 258 | 258 | $icingaweb2_etc=$this->Config()->get('config', 'icingaweb2_etc'); |
| 259 | 259 | $debug_level=4; |
@@ -266,20 +266,20 @@ discard block |
||
| 266 | 266 | $target_version=$dberror[2]; |
| 267 | 267 | |
| 268 | 268 | if ($this->params->get('msgok') == null) { |
| 269 | - // Check for messages and display if any |
|
| 270 | - echo "Upgrade databse is going to start.<br>Don't forget to backup your database before update<br>"; |
|
| 271 | - $Trap->setLogging(2,'syslog'); |
|
| 272 | - $message = $Trap->update_schema($updateSchema,$target_version,$prefix,true); |
|
| 273 | - if ($message != '') |
|
| 274 | - { |
|
| 275 | - echo 'Note :<br><pre>'; |
|
| 276 | - echo $message; |
|
| 277 | - echo '</pre>'; |
|
| 278 | - echo '<br>'; |
|
| 279 | - echo '<a class="link-button" style="font-size:large;font-weight:bold" href="' . Url::fromPath('trapdirector/settings/updateschema') .'?msgok=1">Click here to update</a>'; |
|
| 280 | - echo '<br>'; |
|
| 281 | - return; |
|
| 282 | - } |
|
| 269 | + // Check for messages and display if any |
|
| 270 | + echo "Upgrade databse is going to start.<br>Don't forget to backup your database before update<br>"; |
|
| 271 | + $Trap->setLogging(2,'syslog'); |
|
| 272 | + $message = $Trap->update_schema($updateSchema,$target_version,$prefix,true); |
|
| 273 | + if ($message != '') |
|
| 274 | + { |
|
| 275 | + echo 'Note :<br><pre>'; |
|
| 276 | + echo $message; |
|
| 277 | + echo '</pre>'; |
|
| 278 | + echo '<br>'; |
|
| 279 | + echo '<a class="link-button" style="font-size:large;font-weight:bold" href="' . Url::fromPath('trapdirector/settings/updateschema') .'?msgok=1">Click here to update</a>'; |
|
| 280 | + echo '<br>'; |
|
| 281 | + return; |
|
| 282 | + } |
|
| 283 | 283 | } |
| 284 | 284 | |
| 285 | 285 | $Trap->setLogging($debug_level,'display'); |
@@ -293,28 +293,28 @@ discard block |
||
| 293 | 293 | |
| 294 | 294 | private function checkSnmpTrapd() |
| 295 | 295 | { |
| 296 | - $psOutput=array(); |
|
| 297 | - // First check is someone is listening to port 162. As not root, we can't have pid... |
|
| 298 | - exec('netstat -an |grep -E "udp.*:162"',$psOutput); |
|
| 299 | - if (count($psOutput) == 0) |
|
| 300 | - { |
|
| 301 | - return array(1,'Port UDP/162 is not open : snmptrapd must not be started'); |
|
| 302 | - } |
|
| 303 | - $psOutput=array(); |
|
| 304 | - exec('ps fax |grep snmptrapd |grep -v grep',$psOutput); |
|
| 305 | - if (count($psOutput) == 0) |
|
| 306 | - { |
|
| 307 | - return array(1,"UDP/162 : OK, but no snmptrapd process (?)"); |
|
| 308 | - } |
|
| 309 | - // Assume there is only one line... TODO : see if there is a better way to do this |
|
| 310 | - $line = preg_replace('/^.*snmptrapd /','',$psOutput[0]); |
|
| 311 | - if (!preg_match('/-n/',$line)) |
|
| 312 | - return array(1,'snmptrapd has no -n option : '.$line); |
|
| 313 | - if (!preg_match('/-O[^ ]*n/',$line)) |
|
| 314 | - return array(1,'snmptrapd has no -On option : '.$line); |
|
| 315 | - if (!preg_match('/-O[^ ]*e/',$line)) |
|
| 316 | - return array(1,'snmptrapd has no -Oe option : '.$line); |
|
| 296 | + $psOutput=array(); |
|
| 297 | + // First check is someone is listening to port 162. As not root, we can't have pid... |
|
| 298 | + exec('netstat -an |grep -E "udp.*:162"',$psOutput); |
|
| 299 | + if (count($psOutput) == 0) |
|
| 300 | + { |
|
| 301 | + return array(1,'Port UDP/162 is not open : snmptrapd must not be started'); |
|
| 302 | + } |
|
| 303 | + $psOutput=array(); |
|
| 304 | + exec('ps fax |grep snmptrapd |grep -v grep',$psOutput); |
|
| 305 | + if (count($psOutput) == 0) |
|
| 306 | + { |
|
| 307 | + return array(1,"UDP/162 : OK, but no snmptrapd process (?)"); |
|
| 308 | + } |
|
| 309 | + // Assume there is only one line... TODO : see if there is a better way to do this |
|
| 310 | + $line = preg_replace('/^.*snmptrapd /','',$psOutput[0]); |
|
| 311 | + if (!preg_match('/-n/',$line)) |
|
| 312 | + return array(1,'snmptrapd has no -n option : '.$line); |
|
| 313 | + if (!preg_match('/-O[^ ]*n/',$line)) |
|
| 314 | + return array(1,'snmptrapd has no -On option : '.$line); |
|
| 315 | + if (!preg_match('/-O[^ ]*e/',$line)) |
|
| 316 | + return array(1,'snmptrapd has no -Oe option : '.$line); |
|
| 317 | 317 | |
| 318 | - return array(0,'snmptrapd listening to UDP/162, options : '.$line); |
|
| 318 | + return array(0,'snmptrapd listening to UDP/162, options : '.$line); |
|
| 319 | 319 | } |
| 320 | 320 | } |
@@ -28,11 +28,13 @@ discard block |
||
| 28 | 28 | $this->checkReadPermission(); |
| 29 | 29 | // Get message : sent on configuration problems detected by controllers |
| 30 | 30 | $dberrorMsg=$this->params->get('dberror'); |
| 31 | - if ($dberrorMsg != '') |
|
| 32 | - $this->view->errorDetected=$dberrorMsg; |
|
| 31 | + if ($dberrorMsg != '') { |
|
| 32 | + $this->view->errorDetected=$dberrorMsg; |
|
| 33 | + } |
|
| 33 | 34 | $dberrorMsg=$this->params->get('idodberror'); |
| 34 | - if ($dberrorMsg != '') |
|
| 35 | - $this->view->errorDetected=$dberrorMsg; |
|
| 35 | + if ($dberrorMsg != '') { |
|
| 36 | + $this->view->errorDetected=$dberrorMsg; |
|
| 37 | + } |
|
| 36 | 38 | |
| 37 | 39 | $this->view->configErrorDetected == NULL; // Displayed error on various conifugration errors. |
| 38 | 40 | |
@@ -46,8 +48,7 @@ discard block |
||
| 46 | 48 | $this->Config()->saveIni(); |
| 47 | 49 | $this->view->configErrorDetected='Configuration is empty : you can run install script with parameters (see Automatic installation below)'; |
| 48 | 50 | //$emptyConfig=1; |
| 49 | - } |
|
| 50 | - catch (Exception $e) |
|
| 51 | + } catch (Exception $e) |
|
| 51 | 52 | { |
| 52 | 53 | $this->view->configErrorDetected=$e->getMessage(); |
| 53 | 54 | } |
@@ -106,8 +107,7 @@ discard block |
||
| 106 | 107 | $this->view->apimessage='API config : ' . $e->getMessage(); |
| 107 | 108 | $this->view->apimessageError=true; |
| 108 | 109 | } |
| 109 | - } |
|
| 110 | - else |
|
| 110 | + } else |
|
| 111 | 111 | { |
| 112 | 112 | $this->view->apimessage='API parameters not configured'; |
| 113 | 113 | $this->view->apimessageError=true; |
@@ -184,8 +184,7 @@ discard block |
||
| 184 | 184 | if ($dberror[0] == 0) |
| 185 | 185 | { |
| 186 | 186 | printf('Schema already exists'); |
| 187 | - } |
|
| 188 | - else |
|
| 187 | + } else |
|
| 189 | 188 | { |
| 190 | 189 | printf('Creating schema : <br>'); |
| 191 | 190 | |
@@ -308,12 +307,15 @@ discard block |
||
| 308 | 307 | } |
| 309 | 308 | // Assume there is only one line... TODO : see if there is a better way to do this |
| 310 | 309 | $line = preg_replace('/^.*snmptrapd /','',$psOutput[0]); |
| 311 | - if (!preg_match('/-n/',$line)) |
|
| 312 | - return array(1,'snmptrapd has no -n option : '.$line); |
|
| 313 | - if (!preg_match('/-O[^ ]*n/',$line)) |
|
| 314 | - return array(1,'snmptrapd has no -On option : '.$line); |
|
| 315 | - if (!preg_match('/-O[^ ]*e/',$line)) |
|
| 316 | - return array(1,'snmptrapd has no -Oe option : '.$line); |
|
| 310 | + if (!preg_match('/-n/',$line)) { |
|
| 311 | + return array(1,'snmptrapd has no -n option : '.$line); |
|
| 312 | + } |
|
| 313 | + if (!preg_match('/-O[^ ]*n/',$line)) { |
|
| 314 | + return array(1,'snmptrapd has no -On option : '.$line); |
|
| 315 | + } |
|
| 316 | + if (!preg_match('/-O[^ ]*e/',$line)) { |
|
| 317 | + return array(1,'snmptrapd has no -Oe option : '.$line); |
|
| 318 | + } |
|
| 317 | 319 | |
| 318 | 320 | return array(0,'snmptrapd listening to UDP/162, options : '.$line); |
| 319 | 321 | } |
@@ -12,7 +12,7 @@ |
||
| 12 | 12 | |
| 13 | 13 | public function indexAction() |
| 14 | 14 | { |
| 15 | - $this->getTabs()->add('get',array( |
|
| 15 | + $this->getTabs()->add('get', array( |
|
| 16 | 16 | 'active' => true, |
| 17 | 17 | 'label' => $this->translate('Error'), |
| 18 | 18 | 'url' => Url::fromRequest() |
@@ -21,13 +21,13 @@ discard block |
||
| 21 | 21 | protected $lastHost; |
| 22 | 22 | // Filters |
| 23 | 23 | |
| 24 | - protected $filter; |
|
| 25 | - protected $enforcedFilters = array(); |
|
| 26 | - protected $searchColumns = array(); |
|
| 24 | + protected $filter; |
|
| 25 | + protected $enforcedFilters = array(); |
|
| 26 | + protected $searchColumns = array(); |
|
| 27 | 27 | |
| 28 | 28 | protected function getTitles() { |
| 29 | 29 | // TODO : check moduleconfig is set |
| 30 | - return $this->moduleConfig->getTrapHostListTitles(); |
|
| 30 | + return $this->moduleConfig->getTrapHostListTitles(); |
|
| 31 | 31 | } |
| 32 | 32 | |
| 33 | 33 | // ****************** Render table in html |
@@ -35,45 +35,45 @@ discard block |
||
| 35 | 35 | // Host grouping |
| 36 | 36 | protected function renderHostIfNew($IP,$hostname) |
| 37 | 37 | { |
| 38 | - $view = $this->getView(); |
|
| 38 | + $view = $this->getView(); |
|
| 39 | 39 | |
| 40 | - if ($this->lastHost === $IP) { |
|
| 41 | - return; |
|
| 42 | - } |
|
| 40 | + if ($this->lastHost === $IP) { |
|
| 41 | + return; |
|
| 42 | + } |
|
| 43 | 43 | |
| 44 | - if ($this->lastHost === null) |
|
| 45 | - { |
|
| 46 | - $htm = "<thead>\n <tr>\n"; |
|
| 47 | - } else { |
|
| 48 | - $htm = "</tbody>\n<thead>\n <tr>\n"; |
|
| 49 | - } |
|
| 44 | + if ($this->lastHost === null) |
|
| 45 | + { |
|
| 46 | + $htm = "<thead>\n <tr>\n"; |
|
| 47 | + } else { |
|
| 48 | + $htm = "</tbody>\n<thead>\n <tr>\n"; |
|
| 49 | + } |
|
| 50 | 50 | |
| 51 | - if ($this->columnCount === null) |
|
| 52 | - { |
|
| 53 | - $this->columnCount = count($this->getTitles()); |
|
| 54 | - } |
|
| 51 | + if ($this->columnCount === null) |
|
| 52 | + { |
|
| 53 | + $this->columnCount = count($this->getTitles()); |
|
| 54 | + } |
|
| 55 | 55 | |
| 56 | - $htm .= '<th colspan="' . $this->columnCount . '">' . $view->escape($IP); |
|
| 57 | - if ($hostname != null) |
|
| 58 | - { |
|
| 59 | - $htm .= ' ('.$hostname.')'; |
|
| 60 | - } |
|
| 61 | - $htm .= '</th>' . "\n"; |
|
| 62 | - if ($this->lastHost === null) { |
|
| 63 | - $htm .= " </tr>\n"; |
|
| 64 | - } else { |
|
| 65 | - $htm .= " </tr>\n</thead>\n"; |
|
| 66 | - } |
|
| 56 | + $htm .= '<th colspan="' . $this->columnCount . '">' . $view->escape($IP); |
|
| 57 | + if ($hostname != null) |
|
| 58 | + { |
|
| 59 | + $htm .= ' ('.$hostname.')'; |
|
| 60 | + } |
|
| 61 | + $htm .= '</th>' . "\n"; |
|
| 62 | + if ($this->lastHost === null) { |
|
| 63 | + $htm .= " </tr>\n"; |
|
| 64 | + } else { |
|
| 65 | + $htm .= " </tr>\n</thead>\n"; |
|
| 66 | + } |
|
| 67 | 67 | |
| 68 | - $this->lastHost = $IP; |
|
| 68 | + $this->lastHost = $IP; |
|
| 69 | 69 | |
| 70 | - return $htm . "<tbody>\n"; |
|
| 70 | + return $htm . "<tbody>\n"; |
|
| 71 | 71 | } |
| 72 | 72 | |
| 73 | - public function __toString() |
|
| 74 | - { |
|
| 75 | - return $this->render(); |
|
| 76 | - } |
|
| 73 | + public function __toString() |
|
| 74 | + { |
|
| 75 | + return $this->render(); |
|
| 76 | + } |
|
| 77 | 77 | |
| 78 | 78 | public function render() |
| 79 | 79 | { |
@@ -139,9 +139,9 @@ discard block |
||
| 139 | 139 | |
| 140 | 140 | } |
| 141 | 141 | |
| 142 | - public function count() |
|
| 143 | - { |
|
| 144 | - $db=$this->db(); |
|
| 142 | + public function count() |
|
| 143 | + { |
|
| 144 | + $db=$this->db(); |
|
| 145 | 145 | |
| 146 | 146 | $query = $this->getBaseQuery(); |
| 147 | 147 | $this->applyFiltersToQuery($query); |
@@ -149,16 +149,16 @@ discard block |
||
| 149 | 149 | |
| 150 | 150 | return count($values); |
| 151 | 151 | |
| 152 | - //return $db->fetchOne($query); |
|
| 153 | - } |
|
| 152 | + //return $db->fetchOne($query); |
|
| 153 | + } |
|
| 154 | 154 | |
| 155 | - public function getPaginator() |
|
| 156 | - { |
|
| 157 | - $paginator = new Paginator(); |
|
| 158 | - $paginator->setQuery($this); |
|
| 155 | + public function getPaginator() |
|
| 156 | + { |
|
| 157 | + $paginator = new Paginator(); |
|
| 158 | + $paginator->setQuery($this); |
|
| 159 | 159 | |
| 160 | - return $paginator; |
|
| 161 | - } |
|
| 160 | + return $paginator; |
|
| 161 | + } |
|
| 162 | 162 | |
| 163 | 163 | // ****************** DB connection and query |
| 164 | 164 | |
@@ -168,24 +168,24 @@ discard block |
||
| 168 | 168 | |
| 169 | 169 | $query = $this->getBaseQuery(); |
| 170 | 170 | $this->applyFiltersToQuery($query); |
| 171 | - if ($this->hasLimit() || $this->hasOffset()) { |
|
| 172 | - $query->limit($this->getLimit(), $this->getOffset()); |
|
| 173 | - } |
|
| 171 | + if ($this->hasLimit() || $this->hasOffset()) { |
|
| 172 | + $query->limit($this->getLimit(), $this->getOffset()); |
|
| 173 | + } |
|
| 174 | 174 | |
| 175 | 175 | return $db->fetchAll($query); |
| 176 | 176 | } |
| 177 | 177 | |
| 178 | - public function getBaseQuery() |
|
| 179 | - { |
|
| 178 | + public function getBaseQuery() |
|
| 179 | + { |
|
| 180 | 180 | $db=$this->db(); |
| 181 | 181 | $query = $db->select()->from( |
| 182 | - $this->moduleConfig->getTrapTableName(), |
|
| 183 | - $this->moduleConfig->getTrapHostListDisplayColumns() |
|
| 184 | - )->group(array('t.source_ip','t.source_name','t.trap_oid')) |
|
| 185 | - ->order('t.source_ip'); |
|
| 182 | + $this->moduleConfig->getTrapTableName(), |
|
| 183 | + $this->moduleConfig->getTrapHostListDisplayColumns() |
|
| 184 | + )->group(array('t.source_ip','t.source_name','t.trap_oid')) |
|
| 185 | + ->order('t.source_ip'); |
|
| 186 | 186 | |
| 187 | - return $query; |
|
| 188 | - } |
|
| 187 | + return $query; |
|
| 188 | + } |
|
| 189 | 189 | |
| 190 | 190 | // ****************** Filters |
| 191 | 191 | |
@@ -215,39 +215,39 @@ discard block |
||
| 215 | 215 | $this->filter_done=(isset($filter['done']))?$this->filter_done=$filter['done']:0; |
| 216 | 216 | } |
| 217 | 217 | |
| 218 | - protected function getSearchColumns() |
|
| 219 | - { |
|
| 220 | - return $this->getColumns(); |
|
| 221 | - } |
|
| 218 | + protected function getSearchColumns() |
|
| 219 | + { |
|
| 220 | + return $this->getColumns(); |
|
| 221 | + } |
|
| 222 | 222 | |
| 223 | 223 | public function getColumns() |
| 224 | 224 | { |
| 225 | 225 | return $this->moduleConfig->getTrapListDisplayColumns(); |
| 226 | 226 | } |
| 227 | 227 | |
| 228 | - public function setFilter($filter) |
|
| 229 | - { |
|
| 230 | - $this->filter = $filter; |
|
| 231 | - return $this; |
|
| 232 | - } |
|
| 228 | + public function setFilter($filter) |
|
| 229 | + { |
|
| 230 | + $this->filter = $filter; |
|
| 231 | + return $this; |
|
| 232 | + } |
|
| 233 | 233 | |
| 234 | 234 | public function getFilterEditor(Request $request) |
| 235 | - { |
|
| 236 | - $filterEditor = Widget::create('filterEditor') |
|
| 237 | - ->setColumns(array_keys($this->getColumns())) |
|
| 238 | - ->setSearchColumns(array_keys($this->getSearchColumns())) |
|
| 239 | - ->preserveParams('limit', 'sort', 'dir', 'view', 'backend') |
|
| 240 | - ->ignoreParams('page') |
|
| 241 | - ->handleRequest($request); |
|
| 235 | + { |
|
| 236 | + $filterEditor = Widget::create('filterEditor') |
|
| 237 | + ->setColumns(array_keys($this->getColumns())) |
|
| 238 | + ->setSearchColumns(array_keys($this->getSearchColumns())) |
|
| 239 | + ->preserveParams('limit', 'sort', 'dir', 'view', 'backend') |
|
| 240 | + ->ignoreParams('page') |
|
| 241 | + ->handleRequest($request); |
|
| 242 | 242 | |
| 243 | - $filter = $filterEditor->getFilter(); |
|
| 244 | - $this->setFilter($filter); |
|
| 243 | + $filter = $filterEditor->getFilter(); |
|
| 244 | + $this->setFilter($filter); |
|
| 245 | 245 | |
| 246 | - return $filterEditor; |
|
| 247 | - } |
|
| 246 | + return $filterEditor; |
|
| 247 | + } |
|
| 248 | 248 | |
| 249 | - protected function applyFiltersToQuery($query) |
|
| 250 | - { |
|
| 249 | + protected function applyFiltersToQuery($query) |
|
| 250 | + { |
|
| 251 | 251 | |
| 252 | 252 | $sql=''; |
| 253 | 253 | if ($this->filter_query != '') |
@@ -268,8 +268,8 @@ discard block |
||
| 268 | 268 | $sql.="(status != 'done')"; |
| 269 | 269 | } |
| 270 | 270 | if ($sql != '') $query->where($sql); |
| 271 | - return $query; |
|
| 272 | - } |
|
| 271 | + return $query; |
|
| 272 | + } |
|
| 273 | 273 | |
| 274 | 274 | } |
| 275 | 275 | |
@@ -256,7 +256,9 @@ discard block |
||
| 256 | 256 | $first=1; |
| 257 | 257 | foreach($this->moduleConfig->getTrapListSearchColumns() as $column) |
| 258 | 258 | { |
| 259 | - if ($first==0) $sql.=' OR '; |
|
| 259 | + if ($first==0) { |
|
| 260 | + $sql.=' OR '; |
|
| 261 | + } |
|
| 260 | 262 | $first=0; |
| 261 | 263 | $sql.=" ".$column." LIKE '%".$this->filter_query."%' "; |
| 262 | 264 | } |
@@ -264,10 +266,14 @@ discard block |
||
| 264 | 266 | } |
| 265 | 267 | if ($this->filter_done == 1) |
| 266 | 268 | { |
| 267 | - if ($sql != '') $sql.=' AND '; |
|
| 269 | + if ($sql != '') { |
|
| 270 | + $sql.=' AND '; |
|
| 271 | + } |
|
| 268 | 272 | $sql.="(status != 'done')"; |
| 269 | 273 | } |
| 270 | - if ($sql != '') $query->where($sql); |
|
| 274 | + if ($sql != '') { |
|
| 275 | + $query->where($sql); |
|
| 276 | + } |
|
| 271 | 277 | return $query; |
| 272 | 278 | } |
| 273 | 279 | |
@@ -22,8 +22,8 @@ discard block |
||
| 22 | 22 | // Filters |
| 23 | 23 | |
| 24 | 24 | protected $filter; |
| 25 | - protected $enforcedFilters = array(); |
|
| 26 | - protected $searchColumns = array(); |
|
| 25 | + protected $enforcedFilters=array(); |
|
| 26 | + protected $searchColumns=array(); |
|
| 27 | 27 | |
| 28 | 28 | protected function getTitles() { |
| 29 | 29 | // TODO : check moduleconfig is set |
@@ -33,9 +33,9 @@ discard block |
||
| 33 | 33 | // ****************** Render table in html |
| 34 | 34 | |
| 35 | 35 | // Host grouping |
| 36 | - protected function renderHostIfNew($IP,$hostname) |
|
| 36 | + protected function renderHostIfNew($IP, $hostname) |
|
| 37 | 37 | { |
| 38 | - $view = $this->getView(); |
|
| 38 | + $view=$this->getView(); |
|
| 39 | 39 | |
| 40 | 40 | if ($this->lastHost === $IP) { |
| 41 | 41 | return; |
@@ -43,31 +43,31 @@ discard block |
||
| 43 | 43 | |
| 44 | 44 | if ($this->lastHost === null) |
| 45 | 45 | { |
| 46 | - $htm = "<thead>\n <tr>\n"; |
|
| 46 | + $htm="<thead>\n <tr>\n"; |
|
| 47 | 47 | } else { |
| 48 | - $htm = "</tbody>\n<thead>\n <tr>\n"; |
|
| 48 | + $htm="</tbody>\n<thead>\n <tr>\n"; |
|
| 49 | 49 | } |
| 50 | 50 | |
| 51 | 51 | if ($this->columnCount === null) |
| 52 | 52 | { |
| 53 | - $this->columnCount = count($this->getTitles()); |
|
| 53 | + $this->columnCount=count($this->getTitles()); |
|
| 54 | 54 | } |
| 55 | 55 | |
| 56 | - $htm .= '<th colspan="' . $this->columnCount . '">' . $view->escape($IP); |
|
| 56 | + $htm.='<th colspan="'.$this->columnCount.'">'.$view->escape($IP); |
|
| 57 | 57 | if ($hostname != null) |
| 58 | 58 | { |
| 59 | - $htm .= ' ('.$hostname.')'; |
|
| 59 | + $htm.=' ('.$hostname.')'; |
|
| 60 | 60 | } |
| 61 | - $htm .= '</th>' . "\n"; |
|
| 61 | + $htm.='</th>'."\n"; |
|
| 62 | 62 | if ($this->lastHost === null) { |
| 63 | - $htm .= " </tr>\n"; |
|
| 63 | + $htm.=" </tr>\n"; |
|
| 64 | 64 | } else { |
| 65 | - $htm .= " </tr>\n</thead>\n"; |
|
| 65 | + $htm.=" </tr>\n</thead>\n"; |
|
| 66 | 66 | } |
| 67 | 67 | |
| 68 | - $this->lastHost = $IP; |
|
| 68 | + $this->lastHost=$IP; |
|
| 69 | 69 | |
| 70 | - return $htm . "<tbody>\n"; |
|
| 70 | + return $htm."<tbody>\n"; |
|
| 71 | 71 | } |
| 72 | 72 | |
| 73 | 73 | public function __toString() |
@@ -78,62 +78,62 @@ discard block |
||
| 78 | 78 | public function render() |
| 79 | 79 | { |
| 80 | 80 | $data=$this->getTable(); |
| 81 | - $view = $this->getView(); |
|
| 82 | - $this->columnCount = count($this->getTitles()); |
|
| 81 | + $view=$this->getView(); |
|
| 82 | + $this->columnCount=count($this->getTitles()); |
|
| 83 | 83 | $this->lastHost=null; |
| 84 | 84 | // Table start |
| 85 | - $htm = '<table class="simple common-table table-row-selectable">'; |
|
| 85 | + $htm='<table class="simple common-table table-row-selectable">'; |
|
| 86 | 86 | |
| 87 | 87 | // Titles |
| 88 | - $htm .= "<thead>\n <tr>\n"; |
|
| 89 | - $titles = $this->getTitles(); |
|
| 88 | + $htm.="<thead>\n <tr>\n"; |
|
| 89 | + $titles=$this->getTitles(); |
|
| 90 | 90 | foreach ($titles as $title) |
| 91 | 91 | { |
| 92 | - $htm .= ' <th>' . $view->escape($view->translate($title)) . "</th>\n"; |
|
| 92 | + $htm.=' <th>'.$view->escape($view->translate($title))."</th>\n"; |
|
| 93 | 93 | } |
| 94 | - $htm .= " </tr>\n</thead>\n"; |
|
| 94 | + $htm.=" </tr>\n</thead>\n"; |
|
| 95 | 95 | |
| 96 | 96 | // Rows |
| 97 | - $htm .= "<tbody>\n"; |
|
| 97 | + $htm.="<tbody>\n"; |
|
| 98 | 98 | |
| 99 | 99 | foreach ($data as $row) |
| 100 | 100 | { |
| 101 | 101 | |
| 102 | - $firstCol = true; |
|
| 102 | + $firstCol=true; |
|
| 103 | 103 | // Put host header |
| 104 | - $source_name=(property_exists($row,'source_name'))?$row->source_name:null; |
|
| 105 | - $htm .= $this->renderHostIfNew($row->source_ip,$source_name); |
|
| 104 | + $source_name=(property_exists($row, 'source_name')) ? $row->source_name : null; |
|
| 105 | + $htm.=$this->renderHostIfNew($row->source_ip, $source_name); |
|
| 106 | 106 | |
| 107 | 107 | |
| 108 | 108 | // Render row |
| 109 | - $htm .= '<tr '.' >'; |
|
| 110 | - foreach ( $titles as $rowkey => $title) |
|
| 109 | + $htm.='<tr '.' >'; |
|
| 110 | + foreach ($titles as $rowkey => $title) |
|
| 111 | 111 | { |
| 112 | 112 | // Check missing value |
| 113 | 113 | if (property_exists($row, $rowkey)) |
| 114 | 114 | { |
| 115 | - $val = ($rowkey=='last_sent') ? strftime('%c',$row->$rowkey) : $row->$rowkey; |
|
| 115 | + $val=($rowkey == 'last_sent') ? strftime('%c', $row->$rowkey) : $row->$rowkey; |
|
| 116 | 116 | } else { |
| 117 | - $val = '-'; |
|
| 117 | + $val='-'; |
|
| 118 | 118 | } |
| 119 | 119 | if ($firstCol === true) { // Put link in first column for trap detail. |
| 120 | - $htm .= '<td>' |
|
| 120 | + $htm.='<td>' |
|
| 121 | 121 | . $view->qlink( |
| 122 | 122 | $view->escape($val), |
| 123 | 123 | Url::fromPath( |
| 124 | - $this->moduleConfig->urlPath() . '/received', |
|
| 124 | + $this->moduleConfig->urlPath().'/received', |
|
| 125 | 125 | array('q' => $row->trap_oid) |
| 126 | 126 | ) |
| 127 | 127 | ) |
| 128 | 128 | . '</td>'; |
| 129 | 129 | } else { |
| 130 | - $htm .= '<td>' . $view->escape($val) . '</td>'; |
|
| 130 | + $htm.='<td>'.$view->escape($val).'</td>'; |
|
| 131 | 131 | } |
| 132 | 132 | $firstCol=false; |
| 133 | 133 | } |
| 134 | - $htm .= "<tr>\n"; |
|
| 134 | + $htm.="<tr>\n"; |
|
| 135 | 135 | } |
| 136 | - $htm .= "</tbody></table>\n"; |
|
| 136 | + $htm.="</tbody></table>\n"; |
|
| 137 | 137 | //$htm .= "Filter : " . $this->filter."<br>\n"; |
| 138 | 138 | return $htm; |
| 139 | 139 | |
@@ -143,7 +143,7 @@ discard block |
||
| 143 | 143 | { |
| 144 | 144 | $db=$this->db(); |
| 145 | 145 | |
| 146 | - $query = $this->getBaseQuery(); |
|
| 146 | + $query=$this->getBaseQuery(); |
|
| 147 | 147 | $this->applyFiltersToQuery($query); |
| 148 | 148 | $values=$db->fetchAll($query); |
| 149 | 149 | |
@@ -154,7 +154,7 @@ discard block |
||
| 154 | 154 | |
| 155 | 155 | public function getPaginator() |
| 156 | 156 | { |
| 157 | - $paginator = new Paginator(); |
|
| 157 | + $paginator=new Paginator(); |
|
| 158 | 158 | $paginator->setQuery($this); |
| 159 | 159 | |
| 160 | 160 | return $paginator; |
@@ -166,7 +166,7 @@ discard block |
||
| 166 | 166 | { |
| 167 | 167 | $db=$this->db(); |
| 168 | 168 | |
| 169 | - $query = $this->getBaseQuery(); |
|
| 169 | + $query=$this->getBaseQuery(); |
|
| 170 | 170 | $this->applyFiltersToQuery($query); |
| 171 | 171 | if ($this->hasLimit() || $this->hasOffset()) { |
| 172 | 172 | $query->limit($this->getLimit(), $this->getOffset()); |
@@ -178,10 +178,10 @@ discard block |
||
| 178 | 178 | public function getBaseQuery() |
| 179 | 179 | { |
| 180 | 180 | $db=$this->db(); |
| 181 | - $query = $db->select()->from( |
|
| 181 | + $query=$db->select()->from( |
|
| 182 | 182 | $this->moduleConfig->getTrapTableName(), |
| 183 | 183 | $this->moduleConfig->getTrapHostListDisplayColumns() |
| 184 | - )->group(array('t.source_ip','t.source_name','t.trap_oid')) |
|
| 184 | + )->group(array('t.source_ip', 't.source_name', 't.trap_oid')) |
|
| 185 | 185 | ->order('t.source_ip'); |
| 186 | 186 | |
| 187 | 187 | return $query; |
@@ -192,7 +192,7 @@ discard block |
||
| 192 | 192 | protected $filter_Handler; |
| 193 | 193 | protected $filter_query=''; |
| 194 | 194 | protected $filter_done=''; |
| 195 | - protected $filter_query_list=array('q','done'); |
|
| 195 | + protected $filter_query_list=array('q', 'done'); |
|
| 196 | 196 | public function renderFilterHTML() |
| 197 | 197 | { |
| 198 | 198 | $htm=' <form id="filter" name="mainFilter" |
@@ -202,17 +202,17 @@ discard block |
||
| 202 | 202 | $htm.='<input type="text" name="q" title="Search is simple! Try to combine multiple words" |
| 203 | 203 | placeholder="Search..." class="search" value="'.$this->filter_query.'">'; |
| 204 | 204 | $htm.='<input type="checkbox" id="checkbox_done" name="done" value="1" class="autosubmit" '; |
| 205 | - if ($this->filter_done == 1) { $htm.=' checked ';} |
|
| 205 | + if ($this->filter_done == 1) { $htm.=' checked '; } |
|
| 206 | 206 | $htm.='> <label for="checkbox_done">Hide processed traps</label>'; |
| 207 | 207 | $htm.='</form>'; |
| 208 | 208 | return $htm; |
| 209 | 209 | } |
| 210 | 210 | |
| 211 | - public function updateFilter($handler,$filter) |
|
| 211 | + public function updateFilter($handler, $filter) |
|
| 212 | 212 | { |
| 213 | 213 | $this->filter_Handler=$handler->remove($this->filter_query_list)->__toString(); |
| 214 | - $this->filter_query=(isset($filter['q']))?$this->filter_query=$filter['q']:''; |
|
| 215 | - $this->filter_done=(isset($filter['done']))?$this->filter_done=$filter['done']:0; |
|
| 214 | + $this->filter_query=(isset($filter['q'])) ? $this->filter_query=$filter['q'] : ''; |
|
| 215 | + $this->filter_done=(isset($filter['done'])) ? $this->filter_done=$filter['done'] : 0; |
|
| 216 | 216 | } |
| 217 | 217 | |
| 218 | 218 | protected function getSearchColumns() |
@@ -227,20 +227,20 @@ discard block |
||
| 227 | 227 | |
| 228 | 228 | public function setFilter($filter) |
| 229 | 229 | { |
| 230 | - $this->filter = $filter; |
|
| 230 | + $this->filter=$filter; |
|
| 231 | 231 | return $this; |
| 232 | 232 | } |
| 233 | 233 | |
| 234 | 234 | public function getFilterEditor(Request $request) |
| 235 | 235 | { |
| 236 | - $filterEditor = Widget::create('filterEditor') |
|
| 236 | + $filterEditor=Widget::create('filterEditor') |
|
| 237 | 237 | ->setColumns(array_keys($this->getColumns())) |
| 238 | 238 | ->setSearchColumns(array_keys($this->getSearchColumns())) |
| 239 | 239 | ->preserveParams('limit', 'sort', 'dir', 'view', 'backend') |
| 240 | 240 | ->ignoreParams('page') |
| 241 | 241 | ->handleRequest($request); |
| 242 | 242 | |
| 243 | - $filter = $filterEditor->getFilter(); |
|
| 243 | + $filter=$filterEditor->getFilter(); |
|
| 244 | 244 | $this->setFilter($filter); |
| 245 | 245 | |
| 246 | 246 | return $filterEditor; |
@@ -254,9 +254,9 @@ discard block |
||
| 254 | 254 | { |
| 255 | 255 | $sql.='('; |
| 256 | 256 | $first=1; |
| 257 | - foreach($this->moduleConfig->getTrapListSearchColumns() as $column) |
|
| 257 | + foreach ($this->moduleConfig->getTrapListSearchColumns() as $column) |
|
| 258 | 258 | { |
| 259 | - if ($first==0) $sql.=' OR '; |
|
| 259 | + if ($first == 0) $sql.=' OR '; |
|
| 260 | 260 | $first=0; |
| 261 | 261 | $sql.=" ".$column." LIKE '%".$this->filter_query."%' "; |
| 262 | 262 | } |