开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > SNMP编程 > 查看源码
manager.pm
资源名称：net-snmp-5.2.2.rar　[点击查看]
上传用户：wxp200602
上传日期：2007-10-30
资源大小：4028k
文件大小：36k
源码类别：

SNMP编程

开发平台：

Unix_Linux

manager.pm：源码内容
  1. package NetSNMP::manager;
  3. use strict ();
  4. use Apache::Constants qw(:common);
  5. use CGI qw(:standard delete_all);
  6. use SNMP ();
  7. use DBI ();
  8. use NetSNMP::manager::displaytable qw(displaytable displaygraph);
  10. # globals
  11. $NetSNMP::manager::hostname = 'localhost';          # Host that serves the mSQL Database
  12. $NetSNMP::manager::dbname = 'snmp';                 # mySQL Database name
  13. $NetSNMP::manager::user = 'root';
  14. # $NetSNMP::manager::pass = "password";
  15. $NetSNMP::manager::imagebase = "/home/hardaker/src/snmp/manager"; # <=== CHANGE ME ====
  16. $NetSNMP::manager::redimage = "/graphics/red.gif";
  17. $NetSNMP::manager::greenimage = "/graphics/green.gif";
  18. #$NetSNMP::manager::verbose = 1;
  19. $NetSNMP::manager::tableparms  = "border=1 bgcolor="#c0c0e0"";
  20. $NetSNMP::manager::headerparms = "border=1 bgcolor="#b0e0b0"";
  22. # init the snmp library
  23. $SNMP::save_descriptions=1;
  24. #SNMP::init_mib();
  26. %NetSNMP::manager::myorder = qw(id 0 oidindex 1 host 2 updated 3);
  28. sub handler {
  29.     my $r = shift;
  30.     Apache->request($r);
  32.     # get info from handler
  33.     my $hostname = $r->dir_config('hostname') || $NetSNMP::manager::hostname;
  34.     my $dbname = $r->dir_config('dbname') || $NetSNMP::manager::dbname;
  35.     my $sqluser = $r->dir_config('user') || $NetSNMP::manager::user;
  36.     my $pass = $r->dir_config('pass') || $NetSNMP::manager::pass;
  37.     my $verbose = $r->dir_config('verbose') || $NetSNMP::manager::verbose;
  39. #===========================================================================
  40. #  Global defines
  41. #===========================================================================
  43. my ($dbh, $query, $remuser);
  45. $remuser = $ENV{'REMOTE_USER'};
  46. $remuser = "guest" if (!defined($remuser) || $remuser eq "");
  48. #===========================================================================
  49. # Connect to the mSQL database with the appropriate driver
  50. #===========================================================================
  51. ($dbh = DBI->connect("DBI:mysql:database=$dbname;host=$hostname", $sqluser, $pass))
  52.     or die "tConnect not ok: $DBI::errstrn";
  54. #===========================================================================
  55. # stats Images, for inclusion on another page. (ie, slashdot user box)
  56. #===========================================================================
  57. if (my $group = param('groupstat')) {
  58.     $r->content_type("image/gif");
  59.     $r->send_http_header();
  60.     my $cur = getcursor($dbh, "select host from usergroups as ug, hostgroups as hg where ug.groupname = '$group' and hg.groupname = '$group' and user = '$remuser'");
  61.     while (my $row = $cur->fetchrow_hashref ) {
  62. if (checkhost($dbh, $group, $row->{'host'})) {
  63.     open(I, "$NetSNMP::manager::imagebase$NetSNMP::manager::redimage");
  64.     while(read(I, $_, 4096)) { print; }
  65.     close(I);
  66. }
  67.     }
  68.     open(I, "$NetSNMP::manager::imagebase$NetSNMP::manager::greenimage");
  69.     while(read(I, $_, 4096)) { print; }
  70.     close(I);
  71.     return OK();
  72. }
  75. sub date_format {
  76.     my $time = shift;
  77.     my @out = localtime($time);
  78.     my $ret = $out[4] . "-" . $out[3] . "-" . $out[5] . " " . $out[2] . " " . $out[1];
  79. #    print STDERR "$time: $retn";
  80.     return $ret;
  81. }
  84. #
  85. # Graphing of historical data
  86. #
  87. if ((param('displaygraph') || param('dograph')) && param('table')) {
  88.     my $host = param('host');
  89.     my $group = param('group');
  90.     if (!isuser($dbh, $remuser, $group)) {
  91. $r->content_type("image/png");
  92. $r->send_http_header();
  93. print "Unauthorized access to that group ($group)n";
  94. return Exit($dbh, $group);
  95.     }    
  96.     my $table = param('table');
  97.     my @columns;
  99.     if (!param('dograph')) {
  100. $r->content_type("text/html");
  101. $r->send_http_header();
  102. print "<body bgcolor="#ffffff">n";
  103. print "<form>n";
  104. print "<table border=1><tr><td>n";
  106. print "<table>n";
  107. print "<tr align=top><th></th><th>Select indexes<br>to graph</th></tr>n";
  109. my $handle = getcursor($dbh, "SELECT sql_small_result distinct(oidindex) FROM $table where host = '$host'");
  110. my @cols;
  111. while (  $row = $handle->fetchrow_hashref ) {
  112.     print "<tr><td>$row->{oidindex}</td><td><input type=checkbox value=1 name=" . 'graph_' . displaytable::to_unique_key($row->{'oidindex'}) . "></td></tr>n";
  113. }
  114. print "</table>n";
  116. print "</td><td>n";
  118. print "<table>n";
  119. print "<tr align=top><th></th><th>Select Columns<br>to graph</th></tr>n";
  120. my $handle = getcursor($dbh, "SELECT * FROM $table limit 1");
  121. my $row = $handle->fetchrow_hashref;
  122. map { print "<tr><td>$_</td><td><input type=checkbox value=1 name=column_" . displaytable::to_unique_key($_) . "></td></tr>n"; } keys(%$row);
  123. print "</table>n";
  125. print "</td></tr></table>n";
  127. print "<br>Graph as a Rate: <input type=checkbox value=1 name=graph_as_rate><br>n";
  128. print "<br>Maximum Y Value: <input type=text value=inf name=max_y><br>n";
  129. print "<br>Minimum Y Value: <input type=text value=-inf name=min_y><br>n";
  131. print "<input type=hidden name=table value="$table">n";
  132. print "<input type=hidden name=host value="$host">n";
  133. print "<input type=hidden name=dograph value=1>n";
  134. print "<input type=hidden name=group value="$group">n";
  135. print "<input type=submit name="Make Graph">n";
  137. print "</form>n";
  139. my $handle = getcursor($dbh, "SELECT distinct(oidindex) FROM $table where host = '$host' order by oidindex");
  140. return Exit($dbh, $group);
  141.     }
  142.     if (param('graph_all_data')) {
  143. $clause = "host = '$host'";
  144.     } else {
  145. my $handle = getcursor($dbh, "SELECT distinct(oidindex) FROM $table where host = '$host'");
  146. $clause = "where (";
  147. while (  $row = $handle->fetchrow_hashref ) {
  148. #     print STDERR "graph test: " . $row->{'oidindex'} . "=" . "graph_" . displaytable::to_unique_key($row->{'oidindex'}) . "=" . param("graph_" . displaytable::to_unique_key($row->{'oidindex'})) . "n";
  149.     if (param("graph_" . displaytable::to_unique_key($row->{'oidindex'}))) {
  150. $clause .= " or oidindex = " . $row->{'oidindex'} . "";
  151.     }
  152. }
  154. my $handle = getcursor($dbh, "SELECT * FROM $table limit 1");
  155. my $row = $handle->fetchrow_hashref;
  156. map { push @columns, $_ if (param('column_' . displaytable::to_unique_key($_))) } keys(%$row);
  158. $clause .= ")";
  159. $clause =~ s/( or /(/;
  160. if ($clause =~ /()/ || $#columns == -1) {
  161.     $r->content_type("text/html");
  162.     $r->send_http_header();
  163.     print "<body bgcolor="#ffffff">n";
  164.     print "<h1>No Data to Graph</h1>n";
  165.     print STDERR "No data to graph: $clause, $#columnsn";
  166.     return Exit($dbh, "$group");
  167. }
  168. $clause .= " and host = '$host'";
  169.     }
  171. #    print STDERR "graphing clause: $clausen";
  173.     # all is ok, display the graph
  175.     $r->content_type("image/png");
  176.     $r->send_http_header();
  178.     print STDERR "graphing clause: $clause, columns: ", join(", ",@columns), "n";
  179.     my @args;
  180.     push (@args, '-rate', '60') if (param('graph_as_rate'));
  181.     push (@args, '-max', param('max_y')) if (param('max_y') && param('max_y') =~ /^[-.d]+$/);
  182.     push (@args, '-min', param('min_y')) if (param('min_y') && param('min_y') =~ /^[-.d]+$/);
  184.     my $ret = 
  185.     displaygraph($dbh, $table,
  186. #  '-xcol', "date_format(updated,'%m-%d-%y %h:%i')",
  187.  '-xcol', "unix_timestamp(updated)",
  188.  '-pngparms', [
  189.      'x_labels_vertical', '1',
  190.      'x_tick_number', 6,
  191.      'x_number_format', &date_format,
  192.      'y_label', 'Count/Min',
  193.      'title', $table,
  194. #      'y_min_value', 0,
  195.  ],
  196.  '-clauses', "$clause order by updated",
  197.  @args,
  198.  '-columns', @columns,
  199.  '-indexes', ['oidindex']);
  200.     print STDERR "$ret rows graphedn";
  201.     return OK();
  202. }
  204. #===========================================================================
  205. # Start HTML.
  206. #===========================================================================
  207. $r->content_type("text/html");
  208. $r->send_http_header();
  209. print "<body bgcolor="#ffffff">n";
  210. print "<h1>UCD-SNMP Management Console</h1>n";
  211. print "<hr>n";
  213. #===========================================================================
  214. # Display mib related data information
  215. #===========================================================================
  216. if (param('displayinfo')) {
  217.     makemibtable(param('displayinfo'));
  218.     return Exit($dbh, "");
  219. }
  221. #===========================================================================
  222. # Display a generic sql table of any kind (debugging).
  223. #===========================================================================
  224. # if (my $disptable = param('displaytable')) {
  225. #     if (param('editable') == 1) {
  226. #  print "<form submit=dont>n";
  227. #  displaytable($disptable, -editable, 1);
  228. #  print "</form>n";
  229. #     } else {
  230. #  displaytable($disptable);
  231. #     }
  232. #     return Exit($dbh,  "");
  233. # }
  235. #===========================================================================
  236. # Get host and group from CGI query.
  237. #===========================================================================
  238. my $host = param('host');
  239. my $group = param('group');
  241. #===========================================================================
  242. # Editable user information
  243. #===========================================================================
  245. if (param('setuponcall')) {
  246.     print "<title>oncall schedule for user: $remuser</title>n";
  247.     print "<h2>oncall schedule for user: $remuser</h2>n";
  248.     print "<p>Please select your oncall schedule and mailing addresses for your groups below:";
  249.     if (!isexpert($remuser)) {
  250. print "<ul>n";
  251.         print "<li>Values for the days/hours fields can be comma seperated lists of hours/days/ranges.  EG: hours: 7-18,0-4.n";
  252. print "</ul>n";
  253.     }
  254.     print "<form method=post><input type=hidden name=setuponcall value=1>n";
  255.     displaytable($dbh, 'oncall',
  256.     '-clauses',"where user = '$remuser' order by groupname",
  257.     '-select','id, user, groupname, email, pager, days, hours',
  258.     '-selectorder', 1,
  259.     '-notitle', 1,
  260.     '-editable', 1,
  261.     '-indexes', ['id','user','groupname'],
  262.     '-CGI', $CGI::Q
  263.     );
  264.     print "<input type=submit value="submit changes">n";
  265.     print "</form>n";
  266.     return Exit($dbh, $group);
  267. }
  269. #===========================================================================
  270. # show the list of groups a user belongs to.
  271. #===========================================================================
  272. if (!defined($group)) {
  273.     my @groups = getgroupsforuser($dbh, $remuser);
  274.     print "<title>Net-SNMP Group List</title>n";
  275.     print "<h2>Host groupings you may access:</h2>n";
  276.     if (!isexpert($remuser)) {
  277. print "<ul>n";
  278. print "<li>Click on a group to operate or view the hosts in that group.n";
  279. print "<li>Click on a red status light below to list the problems found.n";
  280. print "</ul>n";
  281.     }
  283.     if ($#groups > 0) {
  284. displaytable($dbh, 'usergroups', 
  285.      '-clauses', "where (user = '$remuser')",
  286.      '-select', 'distinct groupname',
  287.      '-notitle', 1,
  288.      '-printonly', ['groupname'],
  289.      '-datalink', sub { my $q = self_url();
  290. my $key = shift;
  291. my $h = shift;
  292. return if ($key ne "groupname");
  293. return addtoken($q,"group=$h");
  294.     },
  295.      '-beginhook', 
  296.      sub { 
  297.  my $q = self_url();
  298.  my($dbh, $junk, $data) = @_;
  299.  if (!defined($data)) {
  300.      print "<th>Status</th>";
  301.      return;
  302.  }
  303.  my ($cur, $row);
  304.  $cur = getcursor($dbh, "select host from hostgroups where groupname = '$data->{groupname}'");
  305.  while (  $row = $cur->fetchrow_hashref ) {
  306.      if (checkhost($dbh, $data->{'groupname'}, 
  307.    $row->{'host'})) {
  308.  print "<td><a href="" . addtoken($q,"group=$data->{groupname}&summarizegroup=1") . ""><img border=0 src=$NetSNMP::manager::redimage></a></td>n";
  309.  return;
  310.      }
  311.  }
  312.  print "<td><img src=$NetSNMP::manager::greenimage></td>n";
  313.      }
  314.      );
  315. $dbh->disconnect();
  316. return Exit($dbh,  $group);
  317.     } else {
  318. if ($#groups == -1) {
  319.     print "You are not configured to use the Net-SNMP-manager, please contact your system administrator.";
  320.     return Exit($dbh,  $group);
  321. }
  322. $group = $groups[0];
  323.     }
  324. }
  326. #===========================================================================
  327. # reject un-authorized people accessing a certain group
  328. #===========================================================================
  329. if (!isuser($dbh, $remuser, $group)) {
  330.     print "Unauthorized access to that group ($group)n";
  331.     return Exit($dbh, $group);
  332. }    
  334. #===========================================================================
  335. # add a new host to a group
  336. #===========================================================================
  337. if (defined(my $newhost = param('newhost'))) {
  338.     if (isadmin($dbh, $remuser, $group)) {
  339. if ($dbh->do("select * from hostgroups where host = '$newhost' and groupname = '$group'") eq "0E0") {
  340.     $dbh->do("insert into hostgroups(host,groupname) values('$newhost','$group')") ;
  341. } else {
  342.     print "<b>ERROR: host $newhost already in $group</b>n";
  343. }
  344. CGI::delete('newhost');
  345.     }
  346. }
  348. #===========================================================================
  349. # display setup configuration for a group
  350. #===========================================================================
  351. if (defined(param('setupgroup'))) {
  352.     if (isadmin($dbh, $remuser, $group)) {
  353. setupgroup($dbh, $group);
  354.     } else {
  355. print "<h2>You're not able to perform setup operations for group $groupn";
  356.     }
  357.     return Exit($dbh, $group);
  358. }
  360. #===========================================================================
  361. # save configuration information submitted about a group
  362. #===========================================================================
  363. if (defined(param('setupgroupsubmit')) && 
  364.     isadmin($dbh, $remuser, $group)) {
  365.     setupgroupsubmit($dbh, $group);
  366.     delete_all();
  367.     param(-name => 'group', -value => $group);
  368.     print "<a href="" . self_url() . "">Entries submitted</a>";
  369.     return Exit($dbh, $group);
  370. }
  372. #===========================================================================
  373. # user preferences
  374. #===========================================================================
  375. if (defined(param('userprefs'))) {
  376.     setupuserpreferences($dbh, $remuser, $group);
  377.     return Exit($dbh, $group);
  378. }
  380. #===========================================================================
  381. # save submitted user preferences
  382. #===========================================================================
  383. if (defined(param('setupuserprefssubmit')) && 
  384.     isadmin($dbh, $remuser, $group)) {
  385.     setupusersubmit($dbh, $remuser, $group);
  386.     delete_all();
  387.     param(-name => 'group', -value => $group);
  388.     print "<a href="" . self_url() . "">Entries submitted</a>";
  389.     return Exit($dbh, $group);
  390. }
  392. #===========================================================================
  393. # summarize problems in a group
  394. #===========================================================================
  395. if (defined(param('summarizegroup'))) {
  396.     print "<title>group problem summary: $group</title>n";
  397.     print "<h2>The following is a list of problems in the group "$group":</h2>n";
  398.     summarizeerrors($dbh, "where groupname = '$group'");
  399.     return Exit($dbh, $group);
  400. }
  402. #===========================================================================
  403. # summarize problems on a host
  404. #===========================================================================
  405. if (defined($host) && defined(param('summarizehost'))) {
  406.     print "<title>host summary: $host</title>n";
  407.     print "<h2>The following is a list of problems for the host "$host":</h2>n";
  408.     summarizeerrors($dbh, "where groupname = '$group' and host = '$host'");
  409.     return Exit($dbh, $group);
  410. }
  412. #===========================================================================
  413. # display a list of hosts in a group
  414. #===========================================================================
  415. if (!defined($host)) {
  416.     print "<title>Net-SNMP Host $host</title>n";
  417.     print "<h2>Hosts in the group "$group":</h2>n";
  418.     if (!isexpert($remuser)) {
  419. print "<ul>n";
  420. if (isadmin($dbh, $remuser, $group)) {
  421.     my $q = self_url();
  422.     $q =~ s/?.*//;
  423.             print "<li>Make sure you <a href="" . addtoken($q,"group=$group&setupgroup=1") . "">set up the host</a> for the SNMP tables you want to monitor.n";
  424.         }
  425. print "<li>Click on a hostname to operate on or view the information tables associated with that group.n";
  426. print "<li>Click on a red status light below to list the problems found in with a particular host.n";
  427. print "</ul>n";
  428.     }
  429.     displaytable($dbh, 'hostgroups', 
  430.  '-notitle',0,
  431.  '-clauses', "where (groupname = '$group')",
  432.  '-select', 'distinct host, sysObjectId, sysDescr, sysUpTime, versionTag',
  433.  '-datalink', sub { my $q = self_url();
  434.     my $key = shift;
  435.     my $h = shift;
  436.     return if ($key ne "host");
  437.     return addtoken($q,"host=$h");
  438. },
  439.  '-beginhook', 
  440.  sub { 
  441.      my $q = self_url();
  442.      my($dbh, $junk, $data) = @_;
  443.      if (!defined($data)) {
  444.  print "<th>Status</th>";
  445.  return;
  446.      }
  447.      if (checkhost($dbh, $group, $data->{'host'})) {
  448.  print "<td><a href="" . addtoken($q,"group=$group&summarizehost=1&host=$data->{host}") . ""><img border=0 src=$NetSNMP::manager::redimage></a></td>n";
  449.      } else {
  450.  print "<td><img src=$NetSNMP::manager::greenimage></td>n";
  451.      }
  452.  }
  453.  );
  454.     if (isadmin($dbh, $remuser, $group)) {
  455. addhostentryform($group);
  456. my $q = self_url();
  457. $q =~ s/?.*//;
  458. print "<a href="" . addtoken($q,"group=$group&setupgroup=1") . "">setup group $group</a>n";
  459.     }
  460.     return Exit($dbh, $group);
  461. }
  463. #===========================================================================
  464. # setup the host's history records
  465. #===========================================================================
  466. if (param('setuphost')) {
  467.     print "<title>Net-SNMP history setup for host: $host</title>n";
  468.     print "<h2>Net-SNMP history setup for the host: "$host"</h2>n";
  469.     print "<p>Enter the number of days to keep the data for a given table for the host "$host":n";
  470.     if (!isexpert($remuser)) {
  471. print "<ul>n";
  472.         print "<li>Numbers must be greater than or equal to 1 to enable history logging.n";
  473. print "</ul>n";
  474.     }
  475.     print "<form method=post><input type=hidden name=setuphost value=1><input type=hidden name=host value="$host"><input type=hidden name=group value="$group">n";
  476.     displaytable($dbh, 'hosttables',
  477.     '-clauses',"where host = '$host' and groupname = '$group'",
  478.     '-select','groupname, host, tablename, keephistory',
  479.     '-selectorder', 1,
  480.     '-notitle', 1,
  481.     '-editable', 1,
  482.     '-indexes', ['groupname','host','tablename'],
  483.     '-CGI', $CGI::Q
  484.     );
  485.     print "<input type=submit value="submit changes">n";
  486.     print "</form>n";
  487.     return Exit($dbh, $group);
  488. }
  490. #===========================================================================
  491. # display a huge table of history about something
  492. #===========================================================================
  493. if (param('displayhistory')) {
  494.     if (!isuser($dbh, $remuser, $group)) {
  495.         print "Unauthorized access to that group ($group)n";
  496.         return Exit($dbh, $group);
  497.     }
  498.     displaytable($dbh, param('table'), 
  499.     '-clauses', "where (host = '$host')",
  500.     '-dolink', &linktodisplayinfo,
  501.     '-dontdisplaycol', "select * from userprefs where user = '$remuser' and groupname = '$group' and tablename = ? and columnname = ? and displayit = 'N'"
  502.     );
  503.     return Exit($dbh, $group);
  504. }
  506. #===========================================================================
  507. # display inforamation about a host
  508. #  optionally add new collection tables
  509. #===========================================================================
  510. showhost($dbh, $host, $group, $remuser);
  511. if (isadmin($dbh, $remuser, $group)) {
  512.     if (param('newtables')) {
  513.      my $x = param('newtables');
  514.      $x =~ s/,/ /g;
  515.      if (/[^ws]/) {
  516.          print "<br>Illegal table names in addition list: $x<br>n" 
  517.      } else {
  518.     my @x = split(/s+/,$x);
  519.     foreach my $i (@x) {
  520. $dbh->do("insert into hosttables(host, groupname, tablename, keephistory) values('$host','$group','$i','0')");
  521.     }
  522.          print "<br>adding: ",join(", ",@x),"<br>n";
  523.      }
  524.     } else {
  525.         print "<br>Add new MIB Tables or Groups that you want to collect for this host: <form><input type=hidden name=host value="$host"><input type=hidden name=group value="$group"><input name="newtables" type=text><br><input type=submit value="add tables"></form>n";
  526.     }
  527.     my $q = self_url();
  528.     $q =~ s/?.*//;
  529.     print "<a href="" . addtoken($q, "setuphost=1&host=$host&group=$group") . "">setup host $host</a>n";
  530. }
  531. return Exit($dbh, $group);
  533. #===========================================================================
  534. # END of handler
  535. #===========================================================================
  537. }
  539. # add a token to a url string.  Use either a ? or an & depending on
  540. # existence of ?.
  541. sub addtoken {
  542.     my $url = shift;
  543.     my $token = shift;
  544.     return "$url&$token" if ($url =~ /?/);
  545.     return "$url?$token";
  546. }
  548. #
  549. # summarizeerrors(DB-HANDLE, CLAUSE):
  550. #   summarize the list of errors in a given CLAUSE
  551. #
  552. sub summarizeerrors {
  553.     my $dbh = shift;
  554.     my $clause = shift;
  555.     $clause = "where" if ($clause eq "");
  556.     my $clause2 = $clause;
  557.     $clause2 =~ s/ host / hosterrors.host /;
  559.     # Major errors
  560.     displaytable($dbh, 'hosterrors, hostgroups',  # , hostgroups
  561.  '-select', "hosterrors.host as host, errormsg",
  562.  '-notitle', 1,
  563.  '-title', "Fatal Errors",
  564.  '-clauses', "$clause2 and hosterrors.host = hostgroups.host",
  565.  '-beginhook', sub {
  566.      if ($#_ < 2) {
  567.  #doing header;
  568.  print "<td></td>";
  569.      } else {
  570.  print "<td><img src="$NetSNMP::manager::redimage"></td>n";
  571.      }});
  573.     my $tabletop = "<br><table $NetSNMP::manager::tableparms><tr $NetSNMP::manager::headerparms><th><b>Host</b></th><th><b>Table</b></th><th><b>Description</b></th></tr>n";
  574.     my $donetop = 0;
  575.     my $cursor = 
  576. getcursor($dbh, "SELECT * FROM hosttables $clause");
  578.     while (my $row = $cursor->fetchrow_hashref ) {
  580. my $exprs = getcursor($dbh, "SELECT * FROM errorexpressions where (tablename = '$row->{tablename}')");
  582. while (my  $expr = $exprs->fetchrow_hashref ) {
  583.     my $errors = getcursor($dbh, "select * from $row->{tablename} where $expr->{expression} and host = '$row->{host}'");
  584.     while (my  $error = $errors->fetchrow_hashref ) {
  585. print $tabletop if ($donetop++ == 0);
  586. print "<tr><td>$row->{host}</td><td>$row->{tablename}</td><td>$expr->{returnfield}: $error->{$expr->{returnfield}}</td></tr>";
  587.     }
  588. }
  589.     }
  590.     print "</table>";
  591. }
  593. #
  594. # getcursor(CMD):
  595. #    genericlly get a cursor for a given sql command, displaying and
  596. #    printing errors where necessary.
  597. #
  598. sub getcursor {
  599.     my $dbh = shift;
  600.     my $cmd = shift;
  601.     my $cursor;
  602.     ( $cursor = $dbh->prepare( $cmd ))
  603. or print "nnot ok: $DBI::errstrn";
  604.     ( $cursor->execute )
  605. or print( "tnot ok: $DBI::errstrn" );
  606.     return $cursor;
  607. }
  609. #
  610. # mykeysort($a, $b)
  611. #    sorts $a and $b against the order in the mib or against the hard
  612. #    coded special list.
  613. #
  614. sub mykeysort {
  615.     my $a = $displaytable::a;
  616.     my $b = $displaytable::b;
  617.     my $mb = $SNMP::MIB{SNMP::translateObj($b)};
  618.     my $ma = $SNMP::MIB{SNMP::translateObj($a)};
  620.     return $NetSNMP::manager::myorder{$a} <=> $NetSNMP::manager::myorder{$b} if ((defined($NetSNMP::manager::myorder{$a}) || !defined($ma->{'subID'})) && (defined($NetSNMP::manager::myorder{$b}) || !defined($mb->{'subID'})));
  621.     return 1 if (defined($NetSNMP::manager::myorder{$b}) || !defined($mb->{'subID'}));
  622.     return -1 if (defined($NetSNMP::manager::myorder{$a}) || !defined($ma->{'subID'}));
  624.     $ma->{'subID'} <=> $mb->{'subID'};
  625. }
  627. #
  628. # checkhost(GROUP, HOST):
  629. #    if anything in a host is an error, as defined by the
  630. #    errorexpressions table, return 1, else 0
  631. #
  632. sub checkhost {
  633.     my $dbh = shift;
  634.     my $group = shift;
  635.     my $host = shift;
  636.     my ($tblh);
  638.     return 2 if ($dbh->do("select * from hosterrors where host = '$host'") ne "0E0");
  640.     # get a list of tables we want to display
  641.     $tblh = getcursor($dbh, "SELECT * FROM hosttables where (host = '$host' and groupname = '$group')");
  643.     # table data
  644.     my($exprs, $tablelist);
  645.     while ( $tablelist = $tblh->fetchrow_hashref ) {
  646. $exprs = getcursor($dbh, "SELECT * FROM errorexpressions where (tablename = '$tablelist->{tablename}')");
  647. while(my $expr = $exprs->fetchrow_hashref) {
  648.     if ($dbh->do("select * from $tablelist->{tablename} where $expr->{expression} and host = '$host'") ne "0E0") {
  649. return 1;
  650.     }
  651. }
  652.     }
  653.     return 0;
  654. }
  656. #
  657. #  showhost(HOST):
  658. #
  659. #    display all the tables monitored for a given host (in a group).
  660. #
  661. sub showhost {
  662.     my $dbh = shift;
  663.     my $host = shift;
  664.     my $group = shift;
  665.     my $remuser = shift;
  666.     my $q = self_url();
  667.     $q =~ s/?.*//;
  668.     # host header
  669.     print "<title>Net-SNMP manager report for host: $host</title>n";
  670.     print "<h2>Monitored information for the host $host</h2>n";
  671.     if (!isexpert($remuser)) {
  672. print "<ul>n";
  673. print "<li>Click on a column name for information about the data in that column.n";
  674. print "<li>Click on a column name or table name for information about the data in the table.n";
  675. print "<li>If you are <a href="" . addtoken($q, "setuphost=1&host=$host&group=$group") . "">collecting past history</a> for a data set, links will appear below the table that allow you to view and/or graph the historic data.n";
  676. print "</ul>n";
  677.     }
  679.     # does the host have a serious error?
  681.     my $errlist = getcursor($dbh, "SELECT * FROM hosterrors where (host = '$host')");
  682.     if ( $dbh->do("SELECT * FROM hosterrors where (host = '$host')") ne "0E0") {
  683. displaytable($dbh, 'hosterrors', 
  684.      '-clauses', "where (host = '$host')",
  685.      '-dontdisplaycol', "select * from userprefs where user = '$remuser' and groupname = '$group' and tablename = ? and columnname = ? and displayit = 'N'",
  686.      '-beginhook', sub {
  687.  if ($#_ < 2) {
  688.      #doing header;
  689.      print "<td></td>";
  690.  } else {
  691.      print "<td><img src="$NetSNMP::manager::redimage"></td>n";
  692.  }});
  693.     }
  695.     # get a list of tables we want to display
  696.     my $tblh = getcursor($dbh, "SELECT * FROM hosttables where (host = '$host' and groupname = '$group')");
  698.     # table data
  699.     my($tablelist);
  700.     while (  $tablelist = $tblh->fetchrow_hashref ) {
  702. displaytable($dbh, $tablelist->{'tablename'},
  703.      '-clauses', "where (host = '$host') order by oidindex",
  704.      '-dontdisplaycol', "select * from userprefs where user = '$remuser' and groupname = '$group' and tablename = ? and columnname = ? and displayit = 'N'",
  705.      '-sort', &mykeysort,
  706.      '-dolink', &linktodisplayinfo,
  707.      '-beginhook', &printredgreen);
  708. if ($tablelist->{'keephistory'}) {
  709.     my $q = self_url();
  710.     $q =~ s/?.*//;
  711.     print "history: ";
  712.     print "<a href="" . addtoken($q, "displayhistory=1&host=$host&group=$group&table=$tablelist->{'tablename'}hist") . "">[table]</a>n";
  713.     print "<a href="" . addtoken($q, "displaygraph=1&host=$host&group=$group&table=$tablelist->{'tablename'}hist") . "">[graph]</a>n";
  714.     print "<br>n";
  715. }
  716.     }
  717. }
  719. #
  720. #  linktodisplayinfo(STRING):
  721. #
  722. #    returns a url to the appropriate displayinfo link if STRING is a
  723. #    mib node.
  724. #
  725. sub linktodisplayinfo {
  726.     return if (exists($NetSNMP::manager::myorder{shift}));
  727.     return self_url() . "&displayinfo=" . shift;
  728. }
  730. # printredgreen(TABLENAME, DATA):
  731. #
  732. #   display a red or a green dot in a table dependent on the table's
  733. #   values and associated expression
  734. #
  735. #   DATA is NULL when in a header row (displaying header names).
  736. #
  737. sub printredgreen {
  738.     my $dbh = shift;
  739.     my $tablename = shift;
  740.     my $data = shift;
  741.     my ($exprs, $expr, $img);
  743.     if (!defined($data)) {
  744. #doing header;
  745. print "<td></td>";
  746. return;
  747.     }
  749.     my $cmd = "SELECT * FROM errorexpressions where (tablename = '$tablename')";
  750.     print " $cmdn" if ($NetSNMP::manager::verbose);
  751.     ( $exprs = $dbh->prepare( $cmd ) )
  752. or die "nnot ok: $DBI::errstrn";
  753.     ( $exprs->execute )
  754. or print( "tnot ok: $DBI::errstrn" );
  756.     $img = $NetSNMP::manager::greenimage;
  757.     while($expr = $exprs->fetchrow_hashref) {
  758. if ($dbh->do("select oidindex from $tablename where host = '$data->{host}' and oidindex = '$data->{oidindex}' and $expr->{expression}") ne "0E0") {
  759.     $img = $NetSNMP::manager::redimage;
  760. }
  761.     }
  762.     print "<td><img src=$img></td>";
  763. }
  765. #
  766. # display information about a given mib node as a table.
  767. #
  768. sub makemibtable {
  769.     my $dispinfo = shift;
  770.     # display information about a data type in a table
  771.     my $mib = $SNMP::MIB{SNMP::translateObj($dispinfo)};
  772.     print "<table $NetSNMP::manager::tableparms><tr><td>n";
  773.     foreach my $i (qw(label type access status units hint moduleID description enums)) {
  774. #    foreach my $i (keys(%$mib)) {
  775. next if (!defined($$mib{$i}) || $$mib{$i} eq "");
  776. next if (ref($$mib{$i}) eq "HASH" && $#{keys(%{$$mib{$i}})} == -1);
  777. print "<tr><td>$i</td><td>";
  778. if (ref($$mib{$i}) eq "HASH") {
  779.     print "<table $NetSNMP::manager::tableparms><tr><td>n";
  780.     foreach my $j (sort { $$mib{$i}{$a} <=> $$mib{$i}{$b} } keys(%{$$mib{$i}})) {
  781.   print "<tr><td>$$mib{$i}{$j}</td><td>$j</td></tr>";
  782.     }
  783.     print "</table>n";
  784. } else {
  785.     print "$$mib{$i}";
  786. }
  787. print "</td></tr>n";
  788.     }
  789.     print "</table>n";
  790. }
  792. # given a user, get all the groups he belongs to.
  793. sub getgroupsforuser {
  794.     my (@ret, $cursor, $row);
  795.     my ($dbh, $remuser) = @_;
  796.     ( $cursor = $dbh->prepare( "SELECT * FROM usergroups where (user = '$remuser')"))
  797. or die "nnot ok: $DBI::errstrn";
  798.     ( $cursor->execute )
  799. or print( "tnot ok: $DBI::errstrn" );
  801.     while (  $row = $cursor->fetchrow_hashref ) {
  802. push(@ret, $row->{'groupname'});
  803.     }
  804.     @ret;
  805. }
  807. # given a host, get all the groups it belongs to.
  808. sub gethostsforgroup {
  809.     my (@ret, $cursor, $row);
  810.     my ($dbh, $group) = @_;
  811.     ( $cursor = $dbh->prepare( "SELECT * FROM hostgroups where (groupname = '$group')"))
  812. or die "nnot ok: $DBI::errstrn";
  813.     ( $cursor->execute )
  814. or print( "tnot ok: $DBI::errstrn" );
  816.     while (  $row = $cursor->fetchrow_hashref ) {
  817. push(@ret, $row->{'host'});
  818.     }
  819.     @ret;
  820. }
  822. # display the host add entry box
  823. sub addhostentryform {
  824.     my $group = shift;
  825.     print "<form method="get" action="" . self_url() . "">n";
  826.     print "Add a new host to the group "$group": <input type="text" name="newhost"><br>";
  827.     print "<input type="hidden" name="group" value="$group">";
  828.     print "<input type=submit value="Add Hosts">n";
  829.     print "</form>";
  830. }
  832. #is an expert user?
  833. sub isexpert {
  834.     return 0;
  835. }
  837. #is remuser a admin?
  838. sub isadmin {
  839.     my ($dbh, $remuser, $group) = @_;
  840.     return 0 if (!defined($remuser) || !defined($group));
  841.     return 1 if ($dbh->do("select * from usergroups where user = '$remuser' and groupname = '$group' and isadmin = 'Y'") ne "0E0");
  842.     return 0;
  843. }
  845. #is user a member of this group?
  846. sub isuser {
  847.     my ($dbh, $remuser, $group) = @_;
  848.     return 0 if (!defined($remuser) || !defined($group));
  849.     return 1 if ($dbh->do("select * from usergroups where user = '$remuser' and groupname = '$group'") ne "0E0");
  850.     return 0;
  851. }
  853. # displayconfigarray(HOSTS, NAMES, CONFIG):
  854. #
  855. #   displays an array of generic check buttons to turn on/off certain
  856. #   variables.
  857. sub displayconfigarray {
  858.     my $dbh = shift;
  859.     my $hosts = shift;
  860.     my $names = shift;
  861.     my %config = @_;
  863.     my $cmd;
  864.     if ($config{'-check'}) {
  865. ( $cmd = $dbh->prepare( $config{'-check'} ) )
  866.     or die "nnot ok: $DBI::errstrn";
  867.     }
  869.     print "<table $NetSNMP::manager::tableparms>n";
  870.     print "<tr><td></td>";
  871.     my ($i, $j);
  872.     foreach $j (@$names) {
  873. my $nj = $j;
  874. $nj = $j->[0] if ($config{'-arrayrefs'} || $config{'-arrayref2'});
  875. print "<td>$nj</td>";
  876.     }
  877.     foreach my $i (@$hosts) {
  878. my $ni = $i;
  879. $ni = $i->[0] if ($config{'-arrayrefs'} || $config{'-arrayref1'});
  880. print "<tr><td>$ni</td>";
  881. foreach $j (@$names) {
  882.     my $nj = $j;
  883.     $nj = $j->[0] if ($config{'-arrayrefs'} || $config{'-arrayref2'});
  884.     my $checked = "checked" if (defined($cmd) && $cmd->execute($ni,$nj) ne "0E0");
  885.     print "<td><input type=checkbox $checked value=y name=" . $config{prefix} . $ni . $nj . "></td>n";
  886. }
  887. print "</tr>n";
  888.     }
  889.     print "</tr>";
  890.     print "</table>";
  891. }
  893. sub adddefaulttables {
  894.     my ($dbh, $names) = @_;
  895.     my $row;
  896.     # add in known expression tables.
  897.     my $handle = getcursor($dbh, "SELECT * FROM errorexpressions");
  899.     expr: 
  900.     while($row = $handle->fetchrow_hashref) {
  901. foreach $i (@$names) {
  902.     if ($i->[0] eq $row->{tablename}) {
  903. next expr;
  904.     }
  905. }
  906. push @$names, [$row->{tablename}];
  907.     }
  908. }
  910. #
  911. # display the setup information page for a given group.
  912. #
  913. sub setupgroup {
  914.     my $dbh = shift;
  915.     my $group = shift;
  916.     
  917.     my ($hosts, $names) = gethostandgroups($dbh, $group);
  918.     adddefaulttables($dbh, $names);
  920.     print "<form method="post" action="" . self_url() . "">n";
  921.     print "<input type=hidden text="setupgroupsubmit" value="y">";
  922.     displayconfigarray($dbh, $hosts, $names, 
  923.        -arrayrefs, 1,
  924.        -check, "select * from hosttables where (host = ? and tablename = ? and groupname = '$group')");
  925.     print "<input type=hidden name=group value="$group">n";
  926.     print "<input type=submit value=submit name="setupgroupsubmit">n";
  927.     print "</form>";
  928. }
  930. # a wrapper around fetching arrays of everything in a table.
  931. sub getarrays {
  932.     my $dbh = shift;
  933.     my $table = shift;
  934.     my %config = @_;
  935.     my $selectwhat = $config{'-select'} || "*";
  936.     my $handle;
  937.     
  938.     $handle = getcursor($dbh, "SELECT $selectwhat FROM $table $config{-clauses}");
  939.     return $handle->fetchall_arrayref;
  940. }
  942. #
  943. # get a list of all tablenames and hostnames for a given group.
  944. #
  945. sub gethostandgroups {
  946.     my $dbh = shift;
  947.     my $group = shift;
  948.     my ($tbnms);
  950.     my $names = getarrays($dbh, 'hosttables', 
  951.   "-select", 'distinct tablename',
  952.   "-clauses", "where groupname = '$group'");
  954.     my $hosts = getarrays($dbh, 'hostgroups', 
  955.   "-select", 'distinct host',
  956.   "-clauses", "where groupname = '$group'");
  957.     
  958.     return ($hosts, $names);
  959. }
  961. sub setupgroupsubmit {
  962.     my $dbh = shift;
  963.     my $group = shift;
  964.     
  965.     my ($hosts, $names) = gethostandgroups($dbh, $group);
  966.     adddefaulttables($dbh, $names);
  968.     foreach my $i (@$hosts) {
  969. $dbh->do("delete from hosttables where host = '${$i}[0]' and groupname = '$group'");
  970.     }
  971.     my $rep = $dbh->prepare("insert into hosttables(host,tablename,groupname) values(?,?,'$group')");
  973.     foreach my $i (@$hosts) {
  974. foreach my $j (@$names) {
  975.     if (param("${$i}[0]" . "${$j}[0]")) {
  976. print "test: ","${$i}[0] : ${$j}[0]<br>n";
  977. $rep->execute("${$i}[0]", "${$j}[0]") || print "$! $DBI::errstr<br>n";
  978.             }
  979. }
  980.     }
  981.     
  982. }
  984. #
  985. # save user pref data submitted by the user
  986. #
  987. sub setupusersubmit {
  988.     my ($dbh, $remuser, $group) = @_;
  989.     my $tables = getarrays($dbh, 'hosttables', 
  990.    "-select", 'distinct tablename',
  991.    "-clauses", "where groupname = '$group'");
  992.     
  993.     $dbh->do("delete from userprefs where user = '$remuser' and groupname = '$group'");
  994.     my $rep = $dbh->prepare("insert into userprefs(user, groupname, tablename, columnname, displayit) values('$remuser', '$group', ?, ?, 'N')");
  996.     my ($i, $j);
  997.     foreach my $i (@$tables) {
  998. my $sth = $dbh->prepare("select * from ${$i}[0] where 1 = 0");
  999. $sth->execute();
  1001. foreach $j (@{$sth->{NAME}}) {
  1002.     if (param("${$i}[0]" . "$j")) {
  1003. $rep->execute("${$i}[0]", "$j");
  1004.     }
  1005. }
  1006.     }
  1007. }
  1009. sub Exit {
  1010.     my ($dbh, $group) = @_;
  1011.     my $tq = self_url();
  1012.     $tq =~ s/?.*//;
  1013.     print "<hr>n";
  1014.     print "<a href="$tq">[TOP]</a>n";
  1015.     print "<a href="$tq?userprefs=1&group=$group">[display options]</a>n";
  1016.     print "<a href="$tq?setuponcall=1">[setup oncall schedule]</a>n";
  1017.     if (defined($group)) {
  1018. print "<a href="$tq?group=$group">[group: $group]</a>n";
  1019. print "<a href="$tq?group=$group&summarizegroup=1">[summarize errors]</a>n";
  1020.     }
  1021.     $dbh->disconnect() if (defined($dbh));
  1022.     return OK();
  1023. #    exit shift;
  1024. }
  1026. #
  1027. # setup user preferences by displaying a configuration array of
  1028. # checkbuttons for each table.
  1029. #
  1030. sub setupuserpreferences {
  1031.     my ($dbh, $remuser, $group) = @_;
  1032.     my $tables = getarrays($dbh, 'hosttables', 
  1033.    "-select", 'distinct tablename',
  1034.    "-clauses", "where groupname = '$group'");
  1036.     print "<h3>Select the columns from the tables that you want to <b>hide</b> below and click on submit:</h3>n";
  1037.     print "<form method="post" action="" . self_url() . "">n";
  1039.     my ($i, $j);
  1040.     foreach my $i (@$tables) {
  1041. my $sth = $dbh->prepare("select * from ${$i}[0] where 1 = 0");
  1042. $sth->execute();
  1043. displayconfigarray($dbh, [${$i}[0]], $sth->{NAME},
  1044.    -check, "select * from userprefs where (tablename = ? and columnname = ? and user = '$remuser' and groupname = '$group' and displayit = 'N')");
  1045.     print "<br>n";
  1046.     }
  1047.     print "<input type=hidden name=group value="$group">n";
  1048.     print "<input type=submit value=submit name="setupuserprefssubmit">n";
  1049.     print "</form>";
  1050. }