;
close PROFILE;
if (@xml) {
my %profile = ();
eval {
%profile = StorProc->parse_profile_xml( join('', @xml) );
};
if ($@) {
chomp $@;
push @errors, "
$_: $@";
}
else {
push @files, $_;
$description{$_} = $profile{description};
}
}
}
}
}
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->wizard_doc( 'Import Profiles', $docs{'profile_importer'} );
$form .= Forms->form_files( $folder, \@files, \%description, $tab++ );
$form .= Forms->display_hidden( 'Import folder:', 'folder', $folder, $docs{'import_folder'} );
$form .= Forms->checkbox( 'Overwrite existing objects?', 'overwrite', '', '', '', $tab++ );
$form .= Forms->form_file( $tab++ );
$form .= Forms->hidden( \%hidden );
my %remove = ( 'name' => 'remove', 'value' => 'Remove' );
my %import = ( 'name' => 'import', 'value' => 'Import' );
if (@files) {
$form .= Forms->form_bottom_buttons( \%import, \%remove, \%upload, \%close, $tab++ );
}
else {
$form .= Forms->form_bottom_buttons( \%upload, \%close, $tab++ );
}
}
elsif ( $obj_view eq 'status' ) {
$form .= Forms->header( $page_title, $session_id, $top_menu );
$form .= Forms->form_top( "Profile Importer", '' );
if ( $messages[0] =~ /error/i ) {
push @messages, "Please make the necessary corrections and try again.";
}
$form .= Forms->profile_import_status( \@messages );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%close, $tab++ );
}
return $form;
}
#
############################################################################
# Manage Host
#
# FIX LATER: Should this be modified and also called from host_profile() instead of the existing code?
sub apply_host_profile($@) {
my $profile = shift;
my @hosts = @_;
my $name = $profile->{'name'};
my $cnt = 0;
my $apply_parents = $query->param('apply_parents');
my $apply_hostgroups = $query->param('apply_hostgroups');
my $apply_escalations = $query->param('apply_escalations');
my $apply_contactgroups = $query->param('apply_contactgroups');
my $apply_variables = $query->param('apply_variables');
my $apply_detail = $query->param('apply_detail');
my $apply_host_externals = $query->param('apply_host_externals');
my $apply_services = $query->param('apply_services');
my %where = ( 'hostprofile_id' => $profile->{'hostprofile_id'} );
my @profiles = StorProc->fetch_list_where( 'profile_host_profile_service', 'serviceprofile_id', \%where );
unless (@hosts) {
push @errors, "No hosts provided to apply host profile \"$name\" to.";
}
unless (@errors) {
my %hosts = ();
foreach my $host (@hosts) {
$hosts{$host} = 1;
}
my @distinct_hosts = keys %hosts;
foreach my $hid (@distinct_hosts) {
if ($apply_parents) {
my $result = StorProc->delete_all( 'host_parent', 'host_id', $hid );
if ( $result =~ /^Error/ ) { push @errors, $result }
my %w = ( 'hostprofile_id' => $profile->{'hostprofile_id'} );
my @parents = StorProc->fetch_list_where( 'profile_parent', 'host_id', \%w );
foreach my $pid (@parents) {
## Because this is a bulk operation against independently established lists of hosts,
## we simply ignore an attempt to apply a parent to the same host, rather than complain
## about it. This adaptive action should make the host profile easier to use in practice.
unless ( $pid == $hid ) {
my @vals = ( $hid, $pid );
my $result = StorProc->insert_obj( 'host_parent', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
if ($apply_hostgroups) {
my $result = StorProc->delete_all( 'hostgroup_host', 'host_id', $hid );
if ( $result =~ /^Error/ ) { push @errors, $result }
my %w = ( 'hostprofile_id' => $profile->{'hostprofile_id'} );
my @hostgroups = StorProc->fetch_list_where( 'profile_hostgroup', 'hostgroup_id', \%w );
foreach my $hgid (@hostgroups) {
my @vals = ( $hgid, $hid );
my $result = StorProc->insert_obj( 'hostgroup_host', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
if ($apply_contactgroups) {
my %w = ( 'host_id' => $hid );
my $result = StorProc->delete_one_where( 'contactgroup_host', \%w );
if ( $result =~ /^Error/ ) { push @errors, $result }
%w = ( 'hostprofile_id' => $profile->{'hostprofile_id'} );
my @contactgroups = StorProc->fetch_list_where( 'contactgroup_host_profile', 'contactgroup_id', \%w );
foreach my $cgid (@contactgroups) {
my @vals = ( $cgid, $hid );
my $result = StorProc->insert_obj( 'contactgroup_host', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
if ( $apply_services eq 'replace' ) {
my $result = StorProc->delete_all( 'serviceprofile_host', 'host_id', $hid );
if ( $result =~ /^Error/ ) { push @errors, $result }
foreach my $spid (@profiles) {
my @vals = ( $spid, $hid );
my $result = StorProc->insert_obj( 'serviceprofile_host', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
else {
foreach my $spid (@profiles) {
my %w = ( 'serviceprofile_id' => $spid, 'host_id' => $hid );
my %p = StorProc->fetch_one_where( 'serviceprofile_host', \%w );
unless ( $p{'host_id'} ) {
my @vals = ( $spid, $hid );
my $result = StorProc->insert_obj( 'serviceprofile_host', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
}
if ($apply_escalations) {
my %vals = (
'host_escalation_id' => $profile->{'host_escalation_id'},
'service_escalation_id' => $profile->{'service_escalation_id'}
);
foreach my $hid (@distinct_hosts) {
my $result = StorProc->update_obj( 'hosts', 'host_id', $hid, \%vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
if ($apply_detail) {
my %vals = ( 'hosttemplate_id' => $profile->{'host_template_id'} );
foreach my $hid (@distinct_hosts) {
my $result = StorProc->update_obj( 'hosts', 'host_id', $hid, \%vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
my @errs = StorProc->host_profile_apply( $profile->{'hostprofile_id'}, \@distinct_hosts, !$apply_detail, !$apply_variables );
if (@errs) { push( @errors, @errs ) }
## FIX THIS: Compare this application of hostextinfo_id to what happens inside
## StorProc->host_profile_apply(). Why are we overriding that setting?
## FIX MINOR: just drop these lines, as they seem to be redundant
if (0) {
## FIX MAJOR: we are updating the wrong hosts here: this affects all hosts with the specified host profile,
## when we should be looping and only updating @distinct_hosts
%vals = ( 'hostextinfo_id' => $profile->{'host_extinfo_id'} );
my $result = StorProc->update_obj( 'hosts', 'hostprofile_id', $profile->{'hostprofile_id'}, \%vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ($apply_variables) {
my @errs = StorProc->host_profile_apply( $profile->{'hostprofile_id'}, \@distinct_hosts, !$apply_detail, !$apply_variables );
if (@errs) { push( @errors, @errs ) }
}
if ($apply_host_externals) {
if ($enable_externals) {
# FIX LATER: There is still a lot of nested database access here. That might be very slow to execute with
# a large configuration. See if we can optimize by pulling complete copies of certain tables back from the
# database before we start looping, then just access those local copies within the loop structure here.
my %w = ( 'hostprofile_id' => $profile->{'hostprofile_id'} );
my @externals = StorProc->fetch_list_where( 'external_host_profile', 'external_id', \%w );
foreach my $hid (@distinct_hosts) {
if ( $apply_services eq 'replace' ) {
my $result = StorProc->delete_all( 'external_host', 'host_id', $hid );
if ( $result =~ /^Error/ ) { push @errors, $result }
foreach my $ext (@externals) {
my %external = StorProc->fetch_one( 'externals', 'external_id', $ext );
my @vals = ( $ext, $hid, $external{'display'}, \'0+0' );
$result = StorProc->insert_obj( 'external_host', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
if ( $apply_services eq 'merge' ) {
foreach my $ext (@externals) {
my %where = (
'external_id' => $ext,
'host_id' => $hid
);
my @host_externals = StorProc->fetch_list_where( 'external_host', 'modified', \%where );
if (@host_externals) {
if ($host_externals[0] == 0) {
my %external = StorProc->fetch_one( 'externals', 'external_id', $ext );
my %values = ( 'data' => $external{'display'}, 'modified' => \'0+0' );
my $result = StorProc->update_obj_where( 'external_host', \%values, \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
else {
my %external = StorProc->fetch_one( 'externals', 'external_id', $ext );
my @vals = ( $ext, $hid, $external{'display'}, \'0+0' );
my $result = StorProc->insert_obj( 'external_host', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
}
}
}
# FIX MAJOR: Ought we to also pass a user-selectable $apply_service_externals flag here, to
# control whether service externals within services within the host profile are applied? And
# should we modify the StorProc->service_profile_apply() routine to ensure that we perhaps do
# different things for replace and merge actions, with respect to such service externals?
my $err;
( $cnt, $err ) = StorProc->service_profile_apply( \@profiles, $apply_services, \@distinct_hosts );
if ($err) { push( @errors, @{$err} ) }
}
return $cnt;
}
sub manage_host() {
my @views = (
'host_detail', 'host_profile', 'service_profiles', 'parents',
'hostgroups', 'escalation_trees', 'host_externals', 'host_external_detail',
'services', 'service_detail', 'service_check', 'service_dependencies',
'service_externals', 'service_external_detail'
);
foreach my $v (@views) {
if ( $query->param($v) ) { $obj_view = $v }
}
my $by = 'name';
my $name = $query->param('name');
my $host = $query->param('host');
unless ($name) { $by = 'address' }
my $form = undef;
my $message = undef;
my $required = undef;
my $results = undef;
my $test_results = undef;
$hidden{'form_service'} = $query->param('form_service');
%properties = defined($name) ? StorProc->fetch_host( $name, $by ) : ();
push @errors, @{ $properties{'errors'} } if defined $properties{'errors'};
if ( $query->param('close') || $query->param('continue') ) {
$obj_view = 'close';
}
elsif ( $query->param('apply') ) {
if ( $obj_view eq 'host_profile' ) {
my $host_profile = $query->param('profile_host');
my $hostprofile_id;
my %values = ();
my %hp = ();
if ( !$host_profile || $host_profile eq '-- no host profile --' ) {
$hostprofile_id = '';
}
else {
%hp = StorProc->fetch_one( 'profiles_host', 'name', $host_profile );
$hostprofile_id = $hp{'hostprofile_id'};
}
$hidden{'hostprofile_id'} = $hostprofile_id;
%values = ( 'hostprofile_id' => $hostprofile_id );
my $result = StorProc->update_obj( 'hosts', 'host_id', $properties{'host_id'}, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
my @hosts = ( $properties{'host_id'} );
my $cnt = apply_host_profile( \%hp, @hosts );
unless (@errors) {
$obj_view = 'host_profile_saved_apply';
$hidden{'host_id'} = $properties{'host_id'};
$hidden{'name'} = $name;
$message = "Changes to \"$name\" accepted; $cnt service" . ( $cnt == 1 ? '' : 's' ) . " applied.";
}
}
elsif ( $obj_view eq 'service_profiles' ) {
my @service_profiles = $query->param('profiles_service');
my $services = $query->param('apply_services');
my @profiles = ();
my %retained_services = ();
my %where = ( 'host_id' => $properties{'host_id'} );
my @h_spids = StorProc->fetch_list_where( 'serviceprofile_host', 'serviceprofile_id', \%where );
my %h_spids = ();
@h_spids{@h_spids} = (1) x @h_spids;
if ($services eq 'replace') {
$services = 'modify';
my $host_profile_id = $properties{'hostprofile_id'};
my %profile_service_ids = ();
my %w = ( 'hostprofile_id' => $host_profile_id );
my @hp_spids = StorProc->fetch_list_where( 'profile_host_profile_service', 'serviceprofile_id', \%w );
foreach my $hp_spid (@hp_spids) {
my %w = ( 'serviceprofile_id' => $hp_spid );
my @snids = StorProc->fetch_list_where( 'serviceprofile', 'servicename_id', \%w );
@profile_service_ids{@snids} = (1) x @snids;
}
my %hp_spids = ();
@hp_spids{@hp_spids} = (1) x @hp_spids;
foreach my $h_spid (@h_spids) {
if ( not $hp_spids{$h_spid} ) {
my %w = ( 'serviceprofile_id' => $h_spid, 'host_id' => $properties{'host_id'} );
my $result = StorProc->delete_one_where( 'serviceprofile_host', \%w );
if ( $result =~ /^Error/ ) { push @errors, $result }
delete $h_spids{$h_spid};
}
}
my %where = ( 'host_id' => $properties{'host_id'} );
my @snids = StorProc->fetch_list_where( 'services', 'servicename_id', \%where );
foreach my $snid (@snids) {
$retained_services{$snid} = 1 if $profile_service_ids{$snid};
}
}
foreach my $spname (@service_profiles) {
my %sp = StorProc->fetch_one( 'profiles_service', 'name', $spname );
push @profiles, $sp{'serviceprofile_id'};
if ( not $h_spids{ $sp{'serviceprofile_id'} } ) {
my @vals = ( $sp{'serviceprofile_id'}, $properties{'host_id'} );
my $result = StorProc->insert_obj( 'serviceprofile_host', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
my @hosts = ( $properties{'host_id'} );
my ( $cnt, $err ) = StorProc->service_profile_apply( \@profiles, $services, \@hosts, \%retained_services );
if ($err) { push( @errors, @{$err} ) }
unless (@errors) {
$obj_view = 'service_profiles_saved_apply';
$hidden{'host_id'} = $properties{'host_id'};
$hidden{'name'} = $name;
$message = "Changes to \"$name\" accepted; $cnt service" . ( $cnt == 1 ? '' : 's' ) . " applied.";
}
}
else {
my $host_id = $query->param('host_id');
my $hostprofile_id = $query->param('hostprofile_id');
my $serviceprofile_id = $query->param('serviceprofile_id');
my %sp = StorProc->fetch_one( 'profiles_service', 'serviceprofile_id', $serviceprofile_id );
my %w = ( 'hostprofile_id' => $hostprofile_id );
my @externals = StorProc->fetch_list_where( 'external_host_profile', 'external_id', \%w );
my $result = StorProc->delete_all( 'external_host', 'host_id', $host_id );
if ( $result =~ /^Error/ ) { push @errors, $result }
# Is this a dead branch of the code? I cannot seem to find how to navigate here in the UI.
foreach my $ext (@externals) {
my %e = StorProc->fetch_one( 'externals', 'external_id', $ext );
my @vals = ( $ext, $host_id, $e{'display'}, \'0+0' );
$result = StorProc->insert_obj( 'external_host', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
%w = ( 'serviceprofile_id' => $serviceprofile_id );
my @services = StorProc->fetch_list_where( 'serviceprofile', 'servicename_id', \%w );
$result = StorProc->delete_all( 'services', 'host_id', $host_id );
if ( $result =~ /^Error/ ) { push @errors, $result }
foreach my $sid (@services) {
my %sn = StorProc->fetch_one( 'service_names', 'servicename_id', $sid );
%w = ( 'servicename_id' => $sid );
@externals = StorProc->fetch_list_where( 'external_service_names', 'external_id', \%w );
my @vals =
( \undef, $host_id, $sid, $sn{'template'}, $sn{'extinfo'}, $sn{'escalation'}, '1', $sn{'check_comand'}, $sn{'command_line'}, '', '' );
my $service_id = StorProc->insert_obj_id( 'services', \@vals, 'service_id' );
if ( $service_id =~ /^Error/ ) { push @errors, $service_id }
if ( $sn{'dependency'} ) {
@vals = ( \undef, $service_id, $host_id, $host_id, $sn{'template'}, '' );
$result = StorProc->insert_obj( 'service_dependency', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
foreach my $ext (@externals) {
my %e = StorProc->fetch_one( 'externals', 'external_id', $ext );
@vals = ( $ext, $host_id, $service_id, $e{'display'}, \'0+0' );
$result = StorProc->insert_obj( 'external_service', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
}
elsif ( $query->param('test_command') ) {
my $arg_string = $query->param('command_line');
my $command = $query->param('command');
my $service_name = $query->param('service_name');
my %cmd = StorProc->fetch_one( 'commands', 'name', $command );
$test_results .= StorProc->test_command( $command, $cmd{'command_line'}, $host, $arg_string, $monarch_home, $service_name, $nagios_ver );
}
elsif ( $query->param('add_instance') ) {
my $check_command = $query->param('command');
my $args = $query->param('command_line');
$args =~ s/^$check_command//;
my $service_id = $query->param('service_id');
my $inst = $query->param('inst');
my $range_from = $query->param('range_from');
my $range_to = $query->param('range_to');
my %instances = StorProc->get_service_instances($service_id);
$range_from =~ s/^\s+|\s+$//g;
$range_to =~ s/^\s+|\s+$//g;
if ( $range_to =~ /^\d+$/
&& $range_from =~ /^\d+$/
&& $range_from <= $range_to )
{
for ( my $i = $range_from ; $i <= $range_to ; $i++ ) {
unless ( $instances{"_$i"} ) {
my $inst = "_$i";
my @vals = ( \undef, $service_id, $inst, '1', $args );
my $result = StorProc->insert_obj( 'service_instance', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
elsif ($inst) {
$inst =~ s/^\s+|\s+$//g;
if ( $instances{$inst} ) {
@errors = ( "Instance \"$inst\" already exists. Instance names must be unique." );
}
else {
my @vals = ( \undef, $service_id, $inst, '1', $args );
my $result = StorProc->insert_obj( 'service_instance', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ($range_to) {
@errors = ('Check values. The range of values must be numeric, and the last value cannot be less than the first.');
}
}
elsif ( $query->param('remove_instance') ) {
my @rem_instances = $query->param('rem_inst');
foreach my $inst (@rem_instances) {
my $result = StorProc->delete_all( 'service_instance', 'instance_id', $inst );
if ( $result =~ /^Error/ ) { push @errors, $result }
my $service_name = $query->param('service_name');
my $inst_name = $query->param("instance_$inst");
my $service_inst = "$service_name$inst_name";
my %where = ( 'host' => $name, 'service' => $service_inst );
$result = StorProc->delete_one_where( 'host_service', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $query->param('external_add') ) {
my $external_name = $query->param('external');
my $service_id = $query->param('service_id');
my $host_id = $query->param('id');
my $type = $query->param('type');
my %w = ( 'name' => $external_name, 'type' => $type );
my %e = StorProc->fetch_one_where( 'externals', \%w );
if ($e{'external_id'} ne '') {
if ( $type eq 'service' ) {
my @vals = ( $e{'external_id'}, $host_id, $service_id, $e{'display'}, \'0+0' );
my $result = StorProc->insert_obj( 'external_service', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my @vals = ( $e{'external_id'}, $host_id, $e{'display'}, \'0+0' );
my $result = StorProc->insert_obj( 'external_host', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
elsif ( $query->param('save') || $query->param('mark') || $query->param('reset') ) {
if ( $obj_view eq 'host_detail' ) {
my %data = parse_query( 'host_templates', 'host_overrides' );
my $alias = StorProc->sanitize_string( $query->param('alias') );
my $address = StorProc->sanitize_string( $query->param('address') );
my $notes = $query->param('notes');
my $host_template = $query->param('template');
my $extinfo = $query->param('extended_info');
my $checks_enabled = $query->param('checks_enabled');
my $coords2d = StorProc->sanitize_string( $query->param('coords2d') );
my $coords3d = StorProc->sanitize_string( $query->param('coords3d') );
if (defined $notes) {
$notes = StorProc->sanitize_string_but_keep_newlines($notes);
$notes =~ s/\n/
/g;
}
if ( $alias && $address && $host_template ) {
my %values = ( 'alias' => $alias, 'address' => $address, 'notes' => $notes );
my %t = StorProc->fetch_one( 'host_templates', 'name', $host_template );
$values{'hosttemplate_id'} = $t{'hosttemplate_id'};
my %e = StorProc->fetch_one( 'extended_host_info_templates', 'name', $extinfo );
$values{'hostextinfo_id'} = $e{'hostextinfo_id'};
my $result = StorProc->update_obj( 'hosts', 'host_id', $properties{'host_id'}, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
my %w = ( 'host_id' => $properties{'host_id'} );
$result = StorProc->delete_one_where( 'extended_info_coords', \%w );
if ( $result =~ /^Error/ ) { push @errors, $result }
my $data = '';
if ( defined($coords2d) && $coords2d ne '' ) {
$coords2d =~ s{]]>}{]]]]>}g;
$data .= "\n \n ";
}
if ( defined($coords3d) && $coords3d ne '' ) {
$coords3d =~ s{]]>}{]]]]>}g;
$data .= "\n \n ";
}
if ($data) {
$data = "\n" . $data . "\n";
my @vals = ( $properties{'host_id'}, $data );
$result = StorProc->insert_obj( 'extended_info_coords', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
my %where = ( 'host_id' => $properties{'host_id'} );
$result = StorProc->delete_one_where( 'host_overrides', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
if ( $data{'check_period'}
|| $data{'notification_period'}
|| $data{'check_command'}
|| $data{'event_handler'}
|| $data{'data'} )
{
my @values = (
$properties{'host_id'}, $data{'check_period'}, $data{'notification_period'},
$data{'check_command'}, $data{'event_handler'}, $data{'data'}
);
my $result = StorProc->insert_obj( 'host_overrides', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
if ( $query->param('contactgroup_override') ) {
my %where = ( 'host_id' => $properties{'host_id'} );
my $result = StorProc->delete_one_where( 'contactgroup_host', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my %where = ( 'host_id' => $properties{'host_id'} );
my $result = StorProc->delete_one_where( 'contactgroup_host', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
my @mems = $query->param('contactgroup');
foreach (@mems) {
my %cg = StorProc->fetch_one( 'contactgroups', 'name', $_ );
my @vals = ( $cg{'contactgroup_id'}, $properties{'host_id'} );
$result = StorProc->insert_obj( 'contactgroup_host', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
unless (@errors) {
$obj_view = 'saved';
$message = "Changes to \"$name\" accepted.";
}
}
else {
push @errors, "Required: alias, address, and host template";
$required = 1;
}
}
elsif ( $obj_view eq 'escalation_trees' ) {
my $host_escalation = $query->param('host_escalation');
my $service_escalation = $query->param('service_escalation');
my %w = ( 'name' => $host_escalation, 'type' => 'host' );
my %he = StorProc->fetch_one_where( 'escalation_trees', \%w );
%w = ( 'name' => $service_escalation, 'type' => 'service' );
my %se = StorProc->fetch_one_where( 'escalation_trees', \%w );
my %values = (
'host_escalation_id' => $he{'tree_id'},
'service_escalation_id' => $se{'tree_id'}
);
my $result = StorProc->update_obj( 'hosts', 'host_id', $properties{'host_id'}, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
unless (@errors) {
$obj_view = 'saved';
$message = "Changes to \"$name\" accepted.";
}
}
elsif ( $obj_view eq 'parents' ) {
my @parents = $query->param('members');
foreach my $parent (@parents) {
if ( $parent eq $name ) {
push @errors, "A host cannot be its own parent.";
last;
}
}
unless (@errors) {
my %w = ( 'host_id' => $properties{'host_id'} );
my $result = StorProc->delete_one_where( 'host_parent', \%w );
if ( $result =~ /^Error/ ) { push @errors, $result }
foreach my $parent (@parents) {
if ( !$parent ) { next }
my %h = StorProc->fetch_one( 'hosts', 'name', $parent );
my @vals = ( $properties{'host_id'}, $h{'host_id'} );
my $result = StorProc->insert_obj( 'host_parent', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
unless (@errors) {
$obj_view = 'saved';
$message = 'Changes to parentage accepted.';
}
}
elsif ( $obj_view eq 'hostgroups' ) {
my %w = ( 'host_id' => $properties{'host_id'} );
my $result = StorProc->delete_one_where( 'hostgroup_host', \%w );
if ( $result =~ /^Error/ ) { push @errors, $result }
my @hostgroups = $query->param('members');
foreach my $hg (@hostgroups) {
if ( !$hg ) { next }
my %h = StorProc->fetch_one( 'hostgroups', 'name', $hg );
my @vals = ( $h{'hostgroup_id'}, $properties{'host_id'} );
my $result = StorProc->insert_obj( 'hostgroup_host', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
unless (@errors) {
$obj_view = 'saved';
$message = "Changes to \"$name\" hostgroups accepted.";
}
}
elsif ( $obj_view eq 'host_external_detail' ) {
my $data = $query->param('detail');
my $external_id = $query->param('external_id');
my $host_external = $query->param('host_external');
my %values = ();
if ( $query->param('save') ) {
$values{'data'} = $data;
$values{'modified'} = 1;
}
elsif ( $query->param('mark') ) {
$values{'modified'} = 1;
}
elsif ( $query->param('reset') ) {
# In a reset operation, we update the data field with generic content from the
# unanchored host external, instead of using data from the user's screen.
my %external = StorProc->fetch_one( 'externals', 'external_id', $external_id );
$values{'data'} = $external{'display'};
# '0+0' is treated by Perl as true, but by MySQL as zero (it is apparently able
# to convert the string to an expression and evaluate it). This is what we need
# to sidestep the clumsy and inappropriate code in StorProc->update_obj_where()
# that recodes plain zeros as NULLs. We need to force a true zero in the database
# to indicate that this value is really defined.
$values{'modified'} = \'0+0';
}
my %where = (
'external_id' => $external_id,
'host_id' => $properties{'host_id'}
);
my $result = StorProc->update_obj_where( 'external_host', \%values, \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
unless (@errors) {
$obj_view = 'saved';
$message = "Changes to \"$host_external\" external accepted.";
}
}
elsif ( $obj_view eq 'service_external_detail' ) {
my $data = $query->param('detail');
my $external_id = $query->param('external_id');
my $service_name = $query->param('service_name');
my $service_id = $query->param('service_id');
my $service_external = $query->param('service_external');
$hidden{'service_name'} = $service_name;
$hidden{'service_id'} = $service_id;
my %values = ();
if ( $query->param('save') ) {
$values{'data'} = $data;
$values{'modified'} = 1;
}
elsif ( $query->param('mark') ) {
$values{'modified'} = 1;
}
elsif ( $query->param('reset') ) {
# In a reset operation, we update the data field with generic content from the
# unanchored service external, instead of using data from the user's screen.
my %external = StorProc->fetch_one( 'externals', 'external_id', $external_id );
$values{'data'} = $external{'display'};
# '0+0' is treated by Perl as true, but by MySQL as zero (it is apparently able
# to convert the string to an expression and evaluate it). This is what we need
# to sidestep the clumsy and inappropriate code in StorProc->update_obj_where()
# that recodes plain zeros as NULLs. We need to force a true zero in the database
# to indicate that this value is really defined.
$values{'modified'} = \'0+0';
}
my %where = (
'external_id' => $external_id,
'host_id' => $properties{'host_id'},
'service_id' => $service_id
);
my $result = StorProc->update_obj_where( 'external_service', \%values, \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
unless (@errors) {
$obj_view = 'saved';
$message = "Changes to \"$service_external\" external accepted.";
}
}
elsif ( $obj_view eq 'service_detail' ) {
my %values = ();
my $service_name = $query->param('service_name');
my $service_id = $query->param('service_id');
my $notes = $query->param('notes');
if (defined $notes) {
$notes = StorProc->sanitize_string_but_keep_newlines($notes);
$notes =~ s/\n/
/g;
}
$hidden{'service_name'} = $service_name;
$hidden{'service_id'} = $service_id;
my %s = StorProc->fetch_one( 'service_names', 'name', $service_name );
my $ext_info = $query->param('ext_info');
my %x = StorProc->fetch_one( 'extended_service_info_templates', 'name', $ext_info );
my $escalation = $query->param('escalation');
my %e = StorProc->fetch_one( 'escalation_trees', 'name', $escalation );
my $template = $query->param('template');
my %t = StorProc->fetch_one( 'service_templates', 'name', $template );
my %data = parse_query( 'service_overrides', 'service_overrides' );
my %vals = (
'notes' => $notes,
'serviceextinfo_id' => $x{'serviceextinfo_id'},
'escalation_id' => $e{'tree_id'},
'servicetemplate_id' => $t{'servicetemplate_id'}
);
my $result = StorProc->update_obj( 'services', 'service_id', $service_id, \%vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
my %where = ( 'service_id' => $properties{'service_id'} );
$result = StorProc->delete_one_where( 'service_overrides', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
if ( $data{'check_period'}
|| $data{'notification_period'}
|| $data{'event_handler'}
|| $data{'data'} )
{
my @values = ( $service_id, $data{'check_period'}, $data{'notification_period'}, $data{'event_handler'}, $data{'data'} );
my $result = StorProc->insert_obj( 'service_overrides', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
%where = ( 'service_id' => $service_id );
$result = StorProc->delete_one_where( 'contactgroup_service', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
unless ( $query->param('contactgroup_override') ) {
my @mems = $query->param('contactgroup');
foreach (@mems) {
my %cg = StorProc->fetch_one( 'contactgroups', 'name', $_ );
my @vals = ( $cg{'contactgroup_id'}, $service_id );
$result = StorProc->insert_obj( 'contactgroup_service', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
unless (@errors) {
$obj_view = 'saved';
$message = "Changes to \"$service_name\" accepted.";
}
}
elsif ( $obj_view eq 'service_check' ) {
my $service_name = $query->param('service_name');
my $service_id = $query->param('service_id');
$hidden{'service_name'} = $service_name;
$hidden{'service_id'} = $service_id;
my $check_command = $query->param('command');
my $command_line = $query->param('command_line');
my %instances_org = StorProc->get_service_instances_names( $hidden{'service_id'} );
my %instances = ();
foreach my $qname ( $query->param ) {
if ( $qname =~ /args_(\d+)/ ) {
$instances{$1}{'args'} = $query->param($qname);
}
elsif ( $qname =~ /status_(\d+)/ ) {
$instances{$1}{'status'} = 1;
}
elsif ( $qname =~ /instance_(\d+)/ ) {
$instances{$1}{'instance'} = $query->param($qname);
}
}
my %duplicates = ();
foreach my $inst ( keys %instances ) {
if ( $duplicates{ $instances{$inst}{'instance'} } ) {
push @errors, "Instance \"$duplicates{$instances{$inst}{'instance'}}\" already exists. Instance names must be unique.";
}
else {
$duplicates{ $instances{$inst}{'instance'} } = $instances{$inst}{'instance'};
}
}
unless (@errors) {
foreach my $inst ( keys %instances ) {
if ( $instances{$inst}{'instance'} ) {
my %vals = (
'name' => $instances{$inst}{'instance'},
'status' => $instances{$inst}{'status'},
'arguments' => $instances{$inst}{'args'}
);
my $result = StorProc->update_obj( 'service_instance', 'instance_id', $inst, \%vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
unless ( $instances_org{$inst}{'name'} eq $instances{$inst}{'instance'} ) {
my $service_name = $query->param('service_name');
my $inst_name = $query->param("instance_$inst");
my $service_inst = "$service_name$instances_org{$inst}{'name'}";
my %where = ( 'host' => $name, 'service' => $service_inst );
$result = StorProc->delete_one_where( 'host_service', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
}
unless (@errors) {
if ( $query->param('inherit') ) {
my $required = $query->param('required');
unless ($required) {
my %vals = ( 'check_command' => '', 'command_line' => '' );
my $result = StorProc->update_obj( 'services', 'service_id', $service_id, \%vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
push @errors, "The service check is not defined on a template so it must be defined here.";
}
}
else {
my %check = StorProc->fetch_one( 'commands', 'name', $check_command );
my %vals = (
'check_command' => $check{'command_id'},
'command_line' => $command_line
);
my $result = StorProc->update_obj( 'services', 'service_id', $service_id, \%vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
unless (@errors) {
$obj_view = 'saved';
$message = "Changes to \"$service_name\" accepted.";
}
}
}
elsif ( $query->param('add_dependency') ) {
my $dep_template = $query->param('dep_template');
my $service_name = $query->param('service_name');
my $service_id = $query->param('service_id');
$hidden{'service_name'} = $service_name;
$hidden{'service_id'} = $service_id;
my $parent = $query->param('depend_on_host');
my %p = StorProc->fetch_one( 'hosts', 'name', $parent );
my %d = StorProc->fetch_one( 'service_dependency_templates', 'name', $dep_template );
my %w = (
'service_id' => $service_id,
'host_id' => $properties{'host_id'},
'depend_on_host_id' => $p{'host_id'},
'template' => $d{'id'}
);
my %check_dep = StorProc->fetch_one_where( 'service_dependency', \%w );
if ( $dep_template && $service_id && $parent ) {
unless ( $check_dep{'id'} ) {
my @values = ( \undef, $service_id, $properties{'host_id'}, $p{'host_id'}, $d{'id'}, '' );
my $result = StorProc->insert_obj( 'service_dependency', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
push @errors, "Already defined. Check existing dependencies.";
}
}
}
elsif ( $obj_view eq 'confirm_delete_service' || ( defined($submit) && $submit eq 'remove_service' ) ) {
if ( $query->param('cancel') ) {
$obj_view = 'services';
}
else {
my $remove_dependency = $query->param('remove_dependency');
if ($remove_dependency) {
my $generic = $query->param('generic');
my $dep_id = $query->param('dependency_id');
$dep_id =~ s/\D//g;
my $table = $generic ? 'servicename_dependency' : 'service_dependency';
my $result = StorProc->delete_all( $table, 'id', $dep_id );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
my $service_id = $query->param('service_id');
my %s = StorProc->fetch_one( 'services', 'service_id', $service_id );
my %sn = StorProc->fetch_one( 'service_names', 'servicename_id', $s{'servicename_id'} );
my %h = StorProc->fetch_one( 'hosts', 'name', $name );
my %host_service_deps = StorProc->get_dependent_host_services( $s{'servicename_id'}, $h{'host_id'} );
my %generic_service_deps = StorProc->get_dependent_services( $s{'servicename_id'}, $h{'host_id'} );
if (!$query->param('delete') && ($remove_dependency || %host_service_deps || %generic_service_deps) ) {
$obj_view = 'confirm_delete_service';
$hidden{'obj_view'} = $obj_view;
$hidden{'service_id'} = $service_id;
$form .= Forms->form_top( 'Confirm Host Service Delete', '' );
$form .= Forms->display_hidden( 'Host name:', 'name', $name );
$form .= Forms->display_hidden( 'Service name:', 'service_name', $sn{'name'} );
if (%host_service_deps) {
my $message = "The following host services depend on this host service:";
$form .= Forms->wizard_doc( 'Dependent Host Services', $message );
$form .= Forms->dependency_list( $name, 'hosts', $service_id, $session_id, \%host_service_deps, 'dependent' );
}
if (%generic_service_deps) {
my $message = "The following services depend on this host service:";
$form .= Forms->wizard_doc( 'Dependent Services', $message );
$form .= Forms->dependency_list( $name, 'hosts', $service_id, $session_id, \%generic_service_deps,
'dependent', 'generic' );
}
my $message = '';
if (%host_service_deps || %generic_service_deps) {
$message .= qq(Deleting this host service will remove all the dependencies listed above, all at once.
);
}
$message .= qq(Are you sure you want to remove service \"$sn{'name'}\" from host \"$name\"?
);
$form .= Forms->wizard_doc( 'Confirm Delete', $message );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%delete, \%cancel, $tab++ );
}
else {
foreach my $id (keys %host_service_deps) {
my $result = StorProc->delete_all( 'service_dependency', 'id', $id );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
foreach my $id (keys %generic_service_deps) {
my $result = StorProc->delete_all( 'servicename_dependency', 'id', $id );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
my $result = StorProc->delete_all( 'services', 'service_id', $service_id );
if ( $result =~ /^Error/ ) { push @errors, $result }
## FIX LATER: deleting from host_service should probably be delayed until Commit time
my %where = ( 'service' => $sn{'name'}, 'host' => $name );
$result = StorProc->delete_one_where( 'host_service', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
$obj_view = 'services';
$refresh_left = 1;
}
}
}
elsif ( $query->param('remove_dependency') ) {
my $dep_id = $query->param('dependency_id');
$dep_id =~ s/\D//g;
my $result = StorProc->delete_all( 'service_dependency', 'id', $dep_id );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
elsif ( $query->param('rename') ) {
my $new_name = $query->param('new_name');
if ($new_name) {
$new_name =~ s/^\s+|\s+$//g;
my %n = StorProc->fetch_one( 'hosts', 'name', $new_name );
if ( $name =~ /$new_name/i ) { delete $n{'name'} }
if ( $n{'name'} ) {
$obj_view = 'rename';
push @errors, "Cannot rename. Another host has name \"$new_name\".";
}
else {
my %values = ( 'name' => $new_name );
my $result = StorProc->update_obj( 'hosts', 'name', $name, \%values );
if ( $result =~ /^Error/ ) {
push @errors, $result;
$obj_view = 'rename';
}
else {
$result = StorProc->delete_all( 'host_service', 'host', $name );
if ( $result =~ /^Error/ ) { push @errors, $result }
$name = $new_name;
%properties = StorProc->fetch_host($name);
push @errors, @{ $properties{'errors'} } if defined $properties{'errors'};
$obj_view = 'host_detail';
$refresh_left = 1;
}
}
}
else {
$obj_view = 'rename';
}
}
elsif ( defined($submit) && $submit eq 'Add Service(s)' ) {
my @services = $query->param('add_service');
my %where = ();
my %service_names = ();
my %service_name_hash = StorProc->fetch_list_hash_array( 'service_names', \%where );
foreach my $service_id ( keys %service_name_hash ) {
$service_names{ $service_name_hash{$service_id}[1] }{'id'} = $service_id;
$service_names{ $service_name_hash{$service_id}[1] }{'template'} = $service_name_hash{$service_id}[3];
$service_names{ $service_name_hash{$service_id}[1] }{'check_command'} = $service_name_hash{$service_id}[4];
$service_names{ $service_name_hash{$service_id}[1] }{'command_line'} = $service_name_hash{$service_id}[5];
$service_names{ $service_name_hash{$service_id}[1] }{'escalation'} = $service_name_hash{$service_id}[6];
$service_names{ $service_name_hash{$service_id}[1] }{'extinfo'} = $service_name_hash{$service_id}[7];
}
my %service_name_overrides = ();
my %service_name_override_hash = StorProc->fetch_list_hash_array( 'servicename_overrides', \%where );
foreach my $service_id ( keys %service_name_hash ) {
$service_name_overrides{$service_id}{'check_period'} = $service_name_override_hash{$service_id}[1];
$service_name_overrides{$service_id}{'notification_period'} = $service_name_override_hash{$service_id}[2];
$service_name_overrides{$service_id}{'event_handler'} = $service_name_override_hash{$service_id}[3];
if ( $service_name_override_hash{$service_id}[4] ) {
$service_name_overrides{$service_id}{'data'} = $service_name_override_hash{$service_id}[4];
}
else {
$service_name_overrides{$service_id}{'data'} = qq(
);
}
}
my %service_name_dependency = ();
my %service_name_dependency_hash = StorProc->fetch_list_hash_array( 'servicename_dependency', \%where );
foreach my $id ( keys %service_name_dependency_hash ) {
$service_name_dependency{ $service_name_dependency_hash{$id}[1] }{$id}{'host'} = $service_name_dependency_hash{$id}[2];
$service_name_dependency{ $service_name_dependency_hash{$id}[1] }{$id}{'template'} = $service_name_dependency_hash{$id}[3];
}
my %externals = ();
my %externals_hash = StorProc->fetch_list_hash_array( 'externals', \%where );
foreach my $id ( keys %externals_hash ) {
$externals{$id} = $externals_hash{$id}[4];
}
my %service_name_externals = ();
my %service_name_externals_hash = StorProc->fetch_list_hash_array( 'external_service_names', \%where );
foreach my $id ( keys %service_name_externals_hash ) {
$service_name_externals{ $service_name_externals_hash{$id}[1] }{$id} = $id;
}
foreach my $service_name (@services) {
if ($service_name) {
my @values = (
\undef, $properties{'host_id'},
$service_names{$service_name}{'id'}, $service_names{$service_name}{'template'},
$service_names{$service_name}{'extinfo'}, $service_names{$service_name}{'escalation'},
'1', $service_names{$service_name}{'check_command'},
$service_names{$service_name}{'command_line'}, '',
''
);
my $id = StorProc->insert_obj_id( 'services', \@values, 'service_id' );
if ( $id =~ /^Error/ ) {
push @errors, $id;
}
else {
@values = (
$id,
$service_name_overrides{ $service_names{$service_name}{'id'} }{'check_period'},
$service_name_overrides{ $service_names{$service_name}{'id'} }{'notification_period'},
$service_name_overrides{ $service_names{$service_name}{'id'} }{'event_handler'},
$service_name_overrides{ $service_names{$service_name}{'id'} }{'data'}
);
my $result = StorProc->insert_obj( 'service_overrides', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
my $service_id = $id;
my $servicename_id = $service_names{$service_name}{'id'};
%where = ( 'service_id' => $service_id );
$result = StorProc->delete_one_where( 'contactgroup_service', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
%where = ( 'servicename_id' => $servicename_id );
my @cgids = StorProc->fetch_list_where( 'contactgroup_service_name', 'contactgroup_id', \%where );
foreach (@cgids) {
my @vals = ( $_, $service_id );
$result = StorProc->insert_obj( 'contactgroup_service', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
foreach my $dependency_id ( keys %{ $service_name_dependency{ $service_names{$service_name}{'id'} } } ) {
my $depend_on_host = $properties{'host_id'};
if ( $service_name_dependency{ $service_names{$service_name}{'id'} }{$dependency_id}{'host'} ) {
$depend_on_host = $service_name_dependency{ $service_names{$service_name}{'id'} }{$dependency_id}{'host'};
}
@values = (
\undef, $id, $properties{'host_id'}, $depend_on_host,
$service_name_dependency{ $service_names{$service_name}{'id'} }{$dependency_id}{'template'}, ''
);
$result = StorProc->insert_obj( 'service_dependency', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
foreach my $external_id ( keys %{ $service_name_externals{ $service_names{$service_name}{'id'} } } ) {
@values = ( $external_id, $properties{'host_id'}, $id, $externals{$external_id}, \'0+0' );
$result = StorProc->insert_obj( 'external_service', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
}
}
elsif ($query->param('delete')
|| $query->param('confirm_delete_host')
|| (defined( $query->param('task') ) && $query->param('task') eq 'No') )
{
if ( $query->param('confirm_delete_host') ) {
## FIX MINOR: Should the contactgroup_host deletion happen by an automatic cascade delete instead?
## What about equivalent contactgroup_service deletions?
my %where = ( 'host_id' => $properties{'host_id'} );
my $result = StorProc->delete_one_where( 'contactgroup_host', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
$result = StorProc->delete_all( 'hosts', 'name', $name );
if ( $result =~ /^Error/ ) {
push @errors, $result;
$obj_view = 'host_detail';
}
else {
$result = StorProc->delete_all( 'host_service', 'host', $name );
if ( $result =~ /^Error/ ) { push @errors, $result }
$obj_view = 'deleted';
$refresh_left = 1;
}
}
elsif ( defined( $query->param('task') ) && $query->param('task') eq 'No' ) {
$obj_view = 'host_detail';
}
else {
$obj_view = 'delete_host';
}
}
elsif ( $query->param('delete') || $query->param('confirm_delete_service') ) {
# FIX MINOR: this entire section may be inaccessible and obsolete
my $service_name = $query->param('service_name');
if ( $query->param('confirm_delete_service') ) {
my %where = ( 'name' => $service_name, 'host_name' => $name );
my %sid = StorProc->fetch_one_where( 'services', \%where );
# FIX LATER: why is this commented out? is it handled already by a cascade delete?
# %where = ('service_id' => $sid{'service_id'});
# my $result = StorProc->delete_one_where('contactgroup_service',\%where);
# if ($result =~ /^Error/) { push @errors, $result }
my $result = StorProc->delete_all( 'services', 'service_id', $sid{'service_id'} );
if ( $result =~ /^Error/ ) { push @errors, $result }
# FIX MAJOR: also delete from the host_service table, as above?
$obj_view = 'Service List';
}
elsif ( $query->param('task') eq 'No' ) {
$obj_view = 'Service List';
}
else {
$hidden{'name'} = $name;
$hidden{'obj_view'} = $obj_view;
$hidden{'submit'} = 'service_delete';
$hidden{'service_name'} = $service_name;
my $message = qq(Are you sure you want to remove service \"$service_name\" from host \"$name\"?);
$form .= Forms->are_you_sure( 'Confirm Delete', $message, 'confirm_delete_service', \%hidden );
}
}
else {
my $got_obj = 0;
foreach my $param ( $query->param ) {
if ( $param =~ /remove_external_(\d+)/ ) {
my $eid = $1;
if ( $obj_view eq 'host_externals' ) {
my %where = (
'host_id' => $properties{'host_id'},
'external_id' => $eid
);
my $result = StorProc->delete_one_where( 'external_host', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my $service_id = $query->param('service_id');
my %where = ( 'service_id' => $service_id, 'external_id' => $eid );
my $result = StorProc->delete_one_where( 'external_service', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $param eq 'select_external' ) {
if ( $obj_view eq 'host_externals' ) {
$properties{'external'} = $query->param('select_external');
my %e = StorProc->fetch_one( 'externals', 'name', $properties{'external'} );
$properties{'external_id'} = $e{'external_id'};
$obj_view = 'host_external_detail';
$got_obj = 1;
}
else {
$properties{'external'} = $query->param('select_external');
my %e = StorProc->fetch_one( 'externals', 'name', $properties{'external'} );
$properties{'external_id'} = $e{'external_id'};
$obj_view = 'service_external_detail';
$got_obj = 1;
}
}
}
}
delete $hidden{'task'};
delete $hidden{'obj_view'};
%save = ( 'name' => 'save', 'value' => 'Save' );
unless ($obj_view) { $obj_view = 'host_detail' }
$hidden{'obj_view'} = $obj_view;
$form .= Forms->header( $page_title, $session_id, $top_menu, '', $refresh_left );
if ( $obj_view eq 'host_detail' ) {
my %docs = Doc->manage_hosts_vitals();
$form .=
Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'}, $hidden{'selected'}, $hidden{'form_service'} );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->text_box( 'Alias:', 'alias', $properties{'alias'}, $textsize{'alias'}, $required, $docs{'alias'}, '', $tab++ );
$form .=
Forms->text_box( 'Address:', 'address', $properties{'address'}, $textsize{'address'}, $required, $docs{'address'}, '', $tab++ );
my $notes = $properties{'notes'};
$notes =~ s/
/\n/ig if defined $notes;
my $lines = (( () = split( /\n/, (defined($notes) ? $notes : ''), 20 ) ) || 1) + 1;
$form .= Forms->text_area( 'Notes:', 'notes', $notes, $lines, '74%', '', $docs{'notes'}, '', $tab++ );
$form .= build_host_template($name);
my @members = StorProc->fetch_list( 'extended_host_info_templates', 'name' );
push @members, 'remove_extended_info';
$form .= Forms->list_box( 'Extended host info template:',
'extended_info', \@members, $properties{'ext_info'}, '', $docs{'extinfo'}, '', $tab++ );
$form .= Forms->text_box( '2d status coords:', 'coords2d', $properties{'coords2d'}, '10', '', $docs{'coords2d'}, '', $tab++ );
$form .= Forms->text_box( '3d status coords:', 'coords3d', $properties{'coords3d'}, '15', '', $docs{'coords3d'}, '', $tab++ );
$hidden{'name'} = $name;
$form .= Forms->hidden( \%hidden );
if ( $auth_delete{$obj} ) {
$form .= Forms->form_bottom_buttons( \%save, \%delete, \%rename, $tab++ );
}
else {
$form .= Forms->form_bottom_buttons( \%save, \%rename, $tab++ );
}
}
elsif ( $obj_view eq 'host_profile' ) {
my %docs = Doc->manage_hosts_host_profile();
my @service_ids = ();
my $host_profile = $query->param('profile_host');
$form .=
Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'}, $hidden{'selected'}, $hidden{'form_service'} );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->wizard_doc( 'Host profile', $docs{'how_to'} );
my $host_profile_id = undef;
my %profile = ();
if ($host_profile) {
%profile = StorProc->fetch_one( 'profiles_host', 'name', $host_profile );
$host_profile_id = $profile{'hostprofile_id'};
}
else {
%profile = StorProc->fetch_one( 'profiles_host', 'hostprofile_id', $properties{'hostprofile_id'} );
$host_profile_id = $properties{'hostprofile_id'};
$host_profile = $profile{'name'};
}
unless ($host_profile) { $host_profile = '' }
my @host_profiles = ('-- no host profile --');
my @profiles = StorProc->fetch_list( 'profiles_host', 'name' );
push( @host_profiles, @profiles );
$form .= Forms->list_box_submit( 'Host profile:', 'profile_host', \@host_profiles, $host_profile, '', $docs{'host_profile'}, $tab++ );
my %host_profile_service_profiles = ();
my %w = ( 'hostprofile_id' => $host_profile_id );
my @spids = StorProc->fetch_list_where( 'profile_host_profile_service', 'serviceprofile_id', \%w );
foreach my $spid (@spids) {
my %sp = StorProc->fetch_one( 'profiles_service', 'serviceprofile_id', $spid );
$host_profile_service_profiles{ $sp{'name'} } = 1;
}
my @host_profile_service_profiles = sort keys %host_profile_service_profiles;
$form .= Forms->form_message( 'Service profiles from this host profile:', \@host_profile_service_profiles, 'row1', undef, undef, '25%' );
my @other_service_profiles = ();
%w = ( 'host_id' => $properties{'host_id'} );
@spids = StorProc->fetch_list_where( 'serviceprofile_host', 'serviceprofile_id', \%w );
foreach my $spid (@spids) {
my %sp = StorProc->fetch_one( 'profiles_service', 'serviceprofile_id', $spid );
push @other_service_profiles, $sp{'name'} if not $host_profile_service_profiles{ $sp{'name'} };
}
@other_service_profiles = sort @other_service_profiles;
$form .= Forms->form_message( 'Other existing service profiles assigned to this host:', \@other_service_profiles, 'row1', undef, undef, '25%' );
if ( $host_profile && $host_profile ne '-- no host profile --' ) {
my %w = ( 'hostprofile_id' => $host_profile_id );
my @spids = StorProc->fetch_list_where( 'profile_host_profile_service', 'serviceprofile_id', \%w );
foreach my $spid (@spids) {
my %w = ( 'serviceprofile_id' => $spid );
my @sids = StorProc->fetch_list_where( 'serviceprofile', 'servicename_id', \%w );
push( @service_ids, @sids );
}
}
my %services = ();
my %where = ( 'host_id' => $properties{'host_id'} );
my @services = StorProc->fetch_list_where( 'services', 'service_id', \%where );
foreach my $sid (@services) {
my $service_name = StorProc->get_service_name($sid);
$service_name =~ s/\s/+/g;
$services{$service_name} = $sid;
}
my @existing_services = sort keys %services;
my @profile_services = ();
my %seen = ();
foreach my $sid (@service_ids) {
unless ( $seen{$sid} ) {
$seen{$sid} = 1;
my %s = StorProc->fetch_one( 'service_names', 'servicename_id', $sid );
if ( $s{'name'} ) { push @profile_services, $s{'name'} }
}
}
@profile_services = sort @profile_services;
$form .= Forms->form_message( 'Existing services for this host:', \@existing_services, 'row1', undef, undef, '25%' );
$form .= Forms->form_message( "Services from this host profile's service profiles:",
\@profile_services, 'row1', undef, undef, '25%' );
$profile{'apply_services'} = 'merge';
$form .= Forms->apply_select( $view, \%profile, $nagios_ver, $auth_modify{'externals'}, $tab++ );
$hidden{'name'} = $name;
$form .= Forms->hidden( \%hidden );
my %apply = ( 'name' => 'apply', 'value' => 'Assign and Apply' );
$form .= Forms->form_bottom_buttons( \%apply, $tab++ );
}
elsif ( $obj_view eq 'service_profiles' ) {
my %docs = Doc->manage_hosts_service_profiles();
my @service_ids = ();
my @service_profiles = $query->param('profiles_service');
my $profiles_updated = $query->param('profiles_updated');
$form .= Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'},
$hidden{'selected'}, $hidden{'form_service'} );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->wizard_doc( 'Service profiles', $docs{'how_to'} );
my %h = StorProc->fetch_one( 'profiles_host', 'hostprofile_id', $properties{'hostprofile_id'} );
my $host_profile_id = $properties{'hostprofile_id'};
my $host_profile = $h{'name'};
unless ($host_profile) { $host_profile = '' }
$form .= Forms->display_hidden( 'Host profile:', '', $host_profile, $docs{'host_profile'} );
my %existing_service_profiles = ();
my %where = ( 'host_id' => $properties{'host_id'} );
my @spids = StorProc->fetch_list_where( 'serviceprofile_host', 'serviceprofile_id', \%where );
foreach my $spid (@spids) {
my %sp = StorProc->fetch_one( 'profiles_service', 'serviceprofile_id', $spid );
$existing_service_profiles{ $sp{'name'} } = 1;
}
my @profile_service_ids = ();
my %host_profile_service_profiles = ();
my %w = ( 'hostprofile_id' => $host_profile_id );
@spids = StorProc->fetch_list_where( 'profile_host_profile_service', 'serviceprofile_id', \%w );
foreach my $spid (@spids) {
my %sp = StorProc->fetch_one( 'profiles_service', 'serviceprofile_id', $spid );
$host_profile_service_profiles{ $sp{'name'} } = 1 if $existing_service_profiles{ $sp{'name'} };
my %w = ( 'serviceprofile_id' => $spid );
my @sids = StorProc->fetch_list_where( 'serviceprofile', 'servicename_id', \%w );
push( @profile_service_ids, @sids );
}
my @host_profile_service_profiles = sort keys %host_profile_service_profiles;
$form .= Forms->form_message( 'Existing service profiles from this host profile:',
\@host_profile_service_profiles, 'row1', undef, undef, '25%' );
if ($profiles_updated) {
foreach my $spname (@service_profiles) {
my %sp = StorProc->fetch_one( 'profiles_service', 'name', $spname );
my %w = ( 'serviceprofile_id' => $sp{'serviceprofile_id'} );
my @sids = StorProc->fetch_list_where( 'serviceprofile', 'servicename_id', \%w );
push( @service_ids, @sids );
}
}
else {
my %w = ( 'host_id' => $properties{'host_id'} );
my @spids = StorProc->fetch_list_where( 'serviceprofile_host', 'serviceprofile_id', \%w );
foreach my $spid (@spids) {
my %sp = StorProc->fetch_one( 'profiles_service', 'serviceprofile_id', $spid );
if ( not $host_profile_service_profiles{ $sp{'name'} } ) {
push @service_profiles, $sp{'name'};
my %w = ( 'serviceprofile_id' => $spid );
my @sids = StorProc->fetch_list_where( 'serviceprofile', 'servicename_id', \%w );
push( @service_ids, @sids );
}
}
}
my @nonmembers = StorProc->fetch_list( 'profiles_service', 'name' );
$form .= Forms->members_submit( 'Service profiles to be directly assigned and applied to this host:',
'profiles_service', \@service_profiles, \@nonmembers, '', '5', 1, $docs{'service_profile'}, '', $tab++ );
my %services = ();
%where = ( 'host_id' => $properties{'host_id'} );
my @services = StorProc->fetch_list_where( 'services', 'service_id', \%where );
foreach my $sid (@services) {
my $service_name = StorProc->get_service_name($sid);
$service_name =~ s/\s/+/g; # why?
$services{$service_name} = $sid;
}
my @existing_services = sort keys %services;
my @host_profile_services = ();
my %seen = ();
foreach my $sid (@profile_service_ids) {
unless ( $seen{$sid} ) {
$seen{$sid} = 1;
my %s = StorProc->fetch_one( 'service_names', 'servicename_id', $sid );
if ( $s{'name'} && $services{ $s{'name'} } ) { push @host_profile_services, $s{'name'} }
}
}
@host_profile_services = sort @host_profile_services;
my @profile_services = ();
%seen = ();
foreach my $sid (@service_ids) {
unless ( $seen{$sid} ) {
$seen{$sid} = 1;
my %s = StorProc->fetch_one( 'service_names', 'servicename_id', $sid );
if ( $s{'name'} ) { push @profile_services, $s{'name'} }
}
}
@profile_services = sort @profile_services;
$form .= Forms->form_message( "Existing services from this host profile's service profiles:",
\@host_profile_services, 'row1', undef, undef, '25%' );
$form .= Forms->form_message( 'Existing services for this host:', \@existing_services, 'row1', undef, undef, '25%' );
$form .= Forms->form_message( 'Services from the chosen service profiles:', \@profile_services, 'row1', undef, undef, '25%' );
my %selected = ();
$selected{'apply_services'} = 'merge';
$form .= Forms->apply_select( 'direct_profiles', \%selected, $nagios_ver, $auth_modify{'externals'}, $tab++ );
$hidden{'name'} = $name;
$hidden{'profiles_updated'} = 1;
$form .= Forms->hidden( \%hidden );
my %apply = ( 'name' => 'apply', 'value' => 'Assign and Apply' );
$form .= Forms->form_bottom_buttons( \%apply, $tab++ );
}
elsif ( $obj_view eq 'parents' ) {
my %docs = Doc->manage_hosts_parents();
$form .=
Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'}, $hidden{'selected'}, $hidden{'form_service'} );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
my @members = @{ $properties{'parents'} };
my @nonmembers = StorProc->fetch_list( 'hosts', 'name' );
foreach my $index ( 0 .. $#nonmembers ) {
if ( $nonmembers[$index] eq $properties{'name'} ) {
splice( @nonmembers, $index, 1 );
last;
}
}
$form .= Forms->members( 'Parents:', 'members', \@members, \@nonmembers, '', '', $docs{'parents'}, '', $tab++ );
$hidden{'name'} = $name;
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%save, $tab++ );
}
elsif ( $obj_view eq 'escalation_trees' ) {
my %docs = Doc->manage_hosts_escalations();
my $host_escalation = $query->param('host_escalation');
my $service_escalation = $query->param('service_escalation');
unless ($host_escalation) {
my %w = ( 'tree_id' => $properties{'host_escalation_id'} );
my %t = StorProc->fetch_one_where( 'escalation_trees', \%w );
$host_escalation = $t{'name'};
}
unless ($service_escalation) {
my %w = ( 'tree_id' => $properties{'service_escalation_id'} );
my %t = StorProc->fetch_one_where( 'escalation_trees', \%w );
$service_escalation = $t{'name'};
}
$form .=
Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'}, $hidden{'selected'}, $hidden{'form_service'} );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->wizard_doc( 'Escalation Trees', $docs{'escalations'} );
my %where = ( 'type' => 'host' );
my @members = ();
@members = ('-- remove escalation tree --') if ($host_escalation && $host_escalation ne '-- no host escalation trees --');
push( @members, StorProc->fetch_list_where( 'escalation_trees', 'name', \%where ) );
$form .= Forms->list_box_submit( 'Host escalation tree:',
'host_escalation', \@members, $host_escalation, '', $docs{'host_escalation_tree'}, $tab++ );
if ($host_escalation && $host_escalation ne '-- no host escalation trees --' && $host_escalation ne '-- remove escalation tree --') {
my ( $ranks, $templates ) = StorProc->get_tree_detail($host_escalation);
my %ranks = %{$ranks};
my %templates = %{$templates};
$form .= Forms->escalation_tree( \%ranks, \%templates, 'escalations' );
}
%where = ( 'type' => 'service' );
@members = ();
@members = ('-- remove escalation tree --') if ($service_escalation && $service_escalation ne '-- no service escalation trees --');
push( @members, StorProc->fetch_list_where( 'escalation_trees', 'name', \%where ) );
$form .= Forms->list_box_submit( 'Service escalation tree:',
'service_escalation', \@members, $service_escalation, '', $docs{'service_escalation_tree'}, $tab++ );
if ($service_escalation && $service_escalation ne '-- no service escalation trees --' && $service_escalation ne '-- remove escalation tree --') {
my ( $ranks, $templates ) = StorProc->get_tree_detail($service_escalation);
my %ranks = %{$ranks};
my %templates = %{$templates};
$form .= Forms->escalation_tree( \%ranks, \%templates, 'escalations' );
}
$hidden{'name'} = $name;
my %save = ( 'name' => 'save', 'value' => 'Save' );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%save, $tab++ );
}
elsif ( $obj_view eq 'hostgroups' ) {
my %docs = Doc->manage_hosts_hostgroups();
$form .=
Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'}, $hidden{'selected'}, $hidden{'form_service'} );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
my @members = StorProc->get_host_hostgroups($name);
my @nonmembers = StorProc->fetch_list( 'hostgroups', 'name' );
$form .= Forms->members( 'Hostgroups:', 'members', \@members, \@nonmembers, '', '', $docs{'hostgroups'}, '', $tab++ );
$hidden{'name'} = $name;
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%save, $tab++ );
}
elsif ( $obj_view eq 'services' ) {
my %docs = Doc->manage_hosts_services();
$form .=
Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'}, $hidden{'selected'}, $hidden{'form_service'} );
my %services = ();
my %where = ( 'host_id' => $properties{'host_id'} );
my @services = StorProc->fetch_list_where( 'services', 'service_id', \%where );
foreach my $sid (@services) {
my $service_name = StorProc->get_service_name($sid);
$service_name =~ s/\s/+/g;
$services{$service_name} = $sid;
}
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->wizard_doc( 'Services', $docs{'services'} );
if (@messages) {
$form .= Forms->form_message( 'Status:', \@messages, 'msg' );
}
my @service_names = StorProc->fetch_list( 'service_names', 'name' );
my @service_list = ();
foreach my $s (@service_names) {
$s =~ s/\s/+/g;
unless ( $services{$s} ) { $s =~ s/\+/ /g; push @service_list, $s }
}
@service_list = sort @service_list;
$form .= Forms->service_list( $session_id, $name, \%services, \@service_list, $hidden{'selected'} );
$hidden{'name'} = $name;
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons();
}
elsif ( $obj_view eq 'host_externals' ) {
$form .=
Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'}, $hidden{'selected'}, $hidden{'form_service'} );
my %externals = ();
my %modified = ();
my %where = ( 'host_id' => $properties{'host_id'} );
my @externals = StorProc->fetch_list_where( 'external_host', 'external_id', \%where );
foreach my $eid (@externals) {
my %e = StorProc->fetch_one( 'externals', 'external_id', $eid );
$externals{ $e{'name'} } = $eid;
my %where = (
'external_id' => $eid,
'host_id' => $properties{'host_id'}
);
my %external = StorProc->fetch_one_where( 'external_host', \%where );
$modified { $e{'name'} } = $external{'modified'};
}
if (@errors) { $form .= Forms->form_errors( \@errors ) }
if (@messages) {
$form .= Forms->form_message( 'Status:', \@messages, 'msg' );
}
my %w = ( 'type' => 'host' );
my @external_names = StorProc->fetch_list_where( 'externals', 'name', \%w );
my @external_list = ();
foreach my $s (@external_names) {
unless ( $externals{$s} ) { push @external_list, $s }
}
@external_list = sort @external_list;
$form .= Forms->external_list( $session_id, $name, \%externals, \@external_list, 'host', undef, undef, \%modified );
$hidden{'type'} = 'host';
$hidden{'name'} = $name;
$hidden{'id'} = $properties{'host_id'};
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons();
}
elsif ( $obj_view eq 'host_external_detail' ) {
$form .=
Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'}, $hidden{'selected'}, $hidden{'form_service'} );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
my $detail = $query->param('detail');
my $host_external = $query->param('host_external');
unless ($host_external) { $host_external = $properties{'external'} }
my %where = (
'external_id' => $properties{'external_id'},
'host_id' => $properties{'host_id'}
);
my %external = StorProc->fetch_one_where( 'external_host', \%where );
unless ($detail) { $detail = $external{'data'} }
$form .= Forms->display_hidden( 'Host external name:', 'host_external', $host_external );
$form .= Forms->display_hidden( 'Host external state:', '', $external{'modified'} ? 'locally modified' : 'unmodified from original' );
$form .= Forms->text_area( 'Detail:', 'detail', $detail, '25', '100%', '', '', '', $tab++ );
$hidden{'external_id'} = $external{'external_id'};
$form .= Forms->hidden( \%hidden );
my %docs = Doc->externals();
if ($external{'modified'}) {
$form .= Forms->wizard_doc( 'Reset vs. Save', $docs{'reset_host'} );
my %reset = ( 'name' => 'reset', 'value' => 'Reset to Generic Detail' );
$form .= Forms->form_bottom_buttons( \%reset, \%save, $tab++ );
}
else {
$form .= Forms->wizard_doc( 'Mark vs. Save', $docs{'mark_host'} );
my %mark = ( 'name' => 'mark', 'value' => 'Mark as Modified' );
$form .= Forms->form_bottom_buttons( \%mark, \%save, $tab++ );
}
}
elsif ( $obj_view eq 'service_detail' ) {
my %docs = Doc->manage_hosts_service_detail();
$hidden{'service_id'} = $query->param('service_id');
my $service_name = $query->param('service_name');
my $notes = $query->param('notes');
my $ext_info = $query->param('ext_info');
my $escalation = $query->param('escalation');
if (defined $notes) {
$notes = StorProc->sanitize_string_but_keep_newlines($notes);
$notes =~ s/\n/
/g;
}
unless ( $hidden{'service_name'} ) {
$hidden{'service_name'} = $query->param('service_name');
}
unless ( $hidden{'service_id'} ) {
my %snid = StorProc->fetch_one( 'service_names', 'name', $hidden{'service_name'} );
my %where = (
'host_id' => $properties{'host_id'},
'servicename_id' => $snid{'servicename_id'}
);
my %sid = StorProc->fetch_one_where( 'services', \%where );
$hidden{'service_id'} = $sid{'service_id'};
}
my %p = StorProc->fetch_one( 'services', 'service_id', $hidden{'service_id'} );
unless (defined $notes) {
$notes = $p{'notes'};
}
my %w = ( 'serviceextinfo_id' => $p{'serviceextinfo_id'} );
my %e = StorProc->fetch_one_where( 'extended_service_info_templates', \%w );
$ext_info = $e{'name'};
%w = ( 'tree_id' => $p{'escalation_id'} );
unless ($escalation) {
my %esc = StorProc->fetch_one_where( 'escalation_trees', \%w );
$escalation = $esc{'name'};
}
my %objs = (
'service_id' => $hidden{'service_id'},
'service_name' => $service_name
);
$form .=
Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'}, $hidden{'selected'}, $hidden{'form_service'} );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->display_hidden( 'Service name:', 'service_name', $service_name );
$notes =~ s/
/\n/ig if defined $notes;
my $lines = (( () = split( /\n/, (defined($notes) ? $notes : ''), 20 ) ) || 1) + 1;
$form .= Forms->text_area( 'Notes:', 'notes', $notes, $lines, '74%', '', $docs{'notes'}, '', $tab++ );
$form .= build_service_detail( $hidden{'service_id'} );
my @members = StorProc->fetch_list( 'extended_service_info_templates', 'name' );
$form .= Forms->list_box( 'Extended info template:', 'ext_info', \@members, $ext_info, '', $docs{'extinfo'}, '', $tab++ );
my %where = ( 'type' => 'service' );
@members = ();
@members = ('-- remove escalation tree --') if ($escalation && $escalation ne '-- no service escalation trees --');
push( @members, StorProc->fetch_list_where( 'escalation_trees', 'name', \%where ) );
$form .= Forms->list_box_submit( 'Service escalation tree:',
'escalation', \@members, $escalation, '', $docs{'service_escalation_tree'}, $tab++ );
if ($escalation && $escalation ne '-- no service escalation trees --' && $escalation ne '-- remove escalation tree --') {
my ( $ranks, $templates ) = StorProc->get_tree_detail($escalation);
my %ranks = %{$ranks};
my %templates = %{$templates};
$form .= Forms->escalation_tree( \%ranks, \%templates, 'service_detail' );
}
$hidden{'name'} = $name;
$form .= Forms->hidden( \%hidden );
my %save = ( 'name' => 'save', 'value' => 'Save' );
$form .= Forms->form_bottom_buttons( \%save, $tab++ );
}
elsif ( $obj_view eq 'service_check' ) {
my %docs = Doc->manage_hosts_service_check();
$hidden{'service_id'} = $query->param('service_id');
my %service = StorProc->fetch_one( 'services', 'service_id', $hidden{'service_id'} );
my $service_name = $query->param('service_name');
my %template = StorProc->fetch_one( 'service_templates', 'servicetemplate_id', $service{'servicetemplate_id'} );
my $message = undef;
my $inherit = 0;
$inherit = $query->param('inherit');
my %cmd = StorProc->fetch_one( 'commands', 'command_id', $service{'check_command'} );
my $command = $cmd{'name'};
my $command_save = $cmd{'name'};
my $command_line = $service{'command_line'};
if ( $query->param('command') ) { $command = $query->param('command') }
if ( $query->param('command_save') ) { $command_save = $query->param('command_save'); }
if ( $query->param('command_line') ) { $command_line = $query->param('command_line'); }
unless ( defined($command) && defined($command_save) && $command eq $command_save ) {
%cmd = StorProc->fetch_one( 'commands', 'name', $command );
$command_line = undef;
}
if ( $inherit or !$command ) {
%cmd = StorProc->fetch_one( 'commands', 'command_id', $template{'check_command'} );
if ( $cmd{'name'} ) {
$command = $cmd{'name'};
$command_line = $template{'command_line'};
$inherit = 1;
}
else {
my $got_command = 0;
my $stid = $template{'parent_id'};
my %already_seen = ();
until ($got_command) {
my %t = StorProc->fetch_one( 'service_templates', 'servicetemplate_id', $stid );
if ( $t{'check_command'} ) {
$got_command = 1;
%cmd = StorProc->fetch_one( 'commands', 'command_id', $t{'check_command'} );
$command = $cmd{'name'};
$command_line = $t{'command_line'};
}
else {
$already_seen{$stid} = 1;
if ( $t{'parent_id'} ) {
if ( $already_seen{ $t{'parent_id'} } ) {
$got_command = 1;
$message = (
"Note: no parent template (recursively) has a check command defined.
ERROR: You have a cyclical chain of parents in your service templates, starting with \"$t{'name'}\"."
);
$required{'check_command'} = 1;
$command = undef;
$command_line = undef;
}
else {
$stid = $t{'parent_id'};
}
}
else {
$got_command = 1;
$message = ('Note: no parent template (recursively) has a check command defined.');
$required{'check_command'} = 1;
$command = undef;
$command_line = undef;
}
}
}
}
}
%cmd = StorProc->fetch_one( 'commands', 'name', $command );
my $arg_string = $command_line;
$arg_string =~ s/$command!//;
my $usage = $command;
my @args = split( /ARG/i, $cmd{'command_line'} );
my $args = undef;
if ( $args[1] ) {
$usage .= "!";
my $cnt = 1;
pop @args;
foreach (@args) {
if ( $cmd{'command_line'} =~ /ARG$cnt/i ) {
$args .= "ARG$cnt!";
}
$cnt++;
}
chop $args;
$usage .= $args;
unless ( $command_line =~ /$command/ ) {
$command_line = "$command!$args";
}
}
my %objs = (
'service_id' => $hidden{'service_id'},
'service_name' => $service_name
);
$form .= Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'}, $hidden{'selected'},
$hidden{'form_service'} );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->wizard_doc( 'Service Check', $docs{'service_check'} );
$form .= Forms->display_hidden( 'Service name:', 'service_name', $service_name );
$form .= Forms->checkbox_override( 'Inherit check from template', 'inherit', $inherit, $docs{'use_template_command'} );
my %where = ( 'type' => 'check' );
my @commands = StorProc->fetch_list_where( 'commands', 'name', \%where );
$form .= Forms->list_box_submit( 'Check command:', 'command', \@commands, $command, $required{'check_command'},
$docs{'check_command'}, $tab++ );
$form .= Forms->display_hidden( 'Command definition:', '', HTML::Entities::encode( $cmd{'command_line'} ) );
$form .= Forms->display_hidden( 'Usage:', '', $usage );
$form .= Forms->text_area( 'Command line:', 'command_line', $command_line, '3', '80', '', $docs{'command_line'}, '', $tab++ );
unless ($host) { $host = $name }
$form .= Forms->test_service_check( $test_results, $host, '', $tab++ );
$hidden{'command_save'} = $command;
$hidden{'name'} = $name;
my %instances = StorProc->get_service_instances( $hidden{'service_id'} );
my %inst = ();
foreach my $qname ( $query->param ) {
if ( $qname =~ /args_(\d+)/ ) {
$inst{$1}{'args'} = $query->param($qname);
}
elsif ( $qname =~ /status_(\d+)/ ) {
$inst{$1}{'status'} = 1;
}
elsif ( $qname =~ /instance_(\d+)/ ) {
$inst{$1}{'instance'} = $query->param($qname);
my $iname = $query->param($qname);
$instances{$iname}{'id'} = $1;
}
}
foreach my $i ( keys %instances ) {
if ( $inst{ $instances{$i}{'id'} } ) {
$instances{$i}{'status'} = $inst{ $instances{$i}{'id'} }{'status'};
$instances{$i}{'args'} = $inst{ $instances{$i}{'id'} }{'args'};
}
}
my @rem_instances = $query->param('rem_inst');
foreach my $id (@rem_instances) {
foreach my $i ( keys %instances ) {
if ( $instances{$i}{'id'} eq $id ) { delete $instances{$i} }
}
}
$form .= Forms->service_instances( \%instances, $docs{'service_instance'}, $tab++ );
$form .= Forms->hidden( \%hidden );
my %save = ( 'name' => 'save', 'value' => 'Save' );
$form .= Forms->form_bottom_buttons( \%save, $tab++ );
}
elsif ( $obj_view eq 'service_dependencies' ) {
my %docs = Doc->manage_hosts_service_dependencies();
$hidden{'service_id'} = $query->param('service_id');
my $service_name = $query->param('service_name');
if (! $service_name) {
my @servicename_ids = StorProc->fetch_unique( 'services', 'servicename_id', 'service_id', $hidden{'service_id'} );
my $servicename_id = $servicename_ids[0];
if ($servicename_id) {
my @service_names = StorProc->fetch_unique( 'service_names', 'name', 'servicename_id', $servicename_id );
$service_name = $service_names[0];
}
}
my %objs = (
'service_id' => $hidden{'service_id'},
'service_name' => $service_name
);
$form .=
Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'}, $hidden{'selected'}, $hidden{'form_service'} );
$form .= Forms->display_hidden( 'Service name:', 'service_name', $service_name );
$form .= Forms->wizard_doc( 'Service Dependencies', $docs{'dependencies'} );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
my $dep_template = $query->param('dep_template');
my @dep_hosts = ();
my $dep_service = undef;
if ($dep_template) {
my %dep = StorProc->fetch_one( 'service_dependency_templates', 'name', $dep_template );
my %s = StorProc->fetch_one( 'service_names', 'servicename_id', $dep{servicename_id} );
$dep_service = $s{'name'};
my ( $host, $hosts ) = StorProc->get_dep_on_hosts( $dep{'servicename_id'}, $properties{'host_id'} );
my @hosts = @{$hosts};
@dep_hosts = ($name) if $host;
push( @dep_hosts, @hosts );
}
my %dependencies = StorProc->get_dependencies( $hidden{'service_id'} );
$form .= Forms->dependency_list( $name, 'hosts', $hidden{'service_id'}, $session_id, \%dependencies );
my @dep_templates = StorProc->fetch_list( 'service_dependency_templates', 'name' );
$form .= Forms->dependency_add( $dep_template, \@dep_templates, \@dep_hosts, $dep_service, \%docs, $tab++ );
$hidden{'name'} = $name;
$form .= Forms->hidden( \%hidden );
my %add_dependency = ( 'name' => 'add_dependency', 'value' => 'Add Dependency' );
$form .= Forms->form_bottom_buttons( \%add_dependency, $tab++ );
}
elsif ( $obj_view eq 'service_externals' ) {
$hidden{'service_id'} = $query->param('service_id');
$hidden{'service_name'} = $query->param('service_name');
my %objs = (
'service_id' => $hidden{'service_id'},
'service_name' => $hidden{'service_name'}
);
$form .=
Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'}, $hidden{'selected'}, $hidden{'form_service'} );
$form .= Forms->display_hidden( 'Service name:', 'service_name', $hidden{'service_name'} );
my %externals = ();
my %modified = ();
my %where = ( 'service_id' => $hidden{'service_id'} );
my @externals = StorProc->fetch_list_where( 'external_service', 'external_id', \%where );
foreach my $eid (@externals) {
my %e = StorProc->fetch_one( 'externals', 'external_id', $eid );
$externals{ $e{'name'} } = $eid;
my %where = (
'external_id' => $eid,
'host_id' => $properties{'host_id'},
'service_id' => $hidden{'service_id'}
);
my %external = StorProc->fetch_one_where( 'external_service', \%where );
$modified { $e{'name'} } = $external{'modified'};
}
if (@errors) { $form .= Forms->form_errors( \@errors ) }
if (@messages) {
$form .= Forms->form_message( 'Status:', \@messages, 'msg' );
}
my %w = ( 'type' => 'service' );
my @external_names = StorProc->fetch_list_where( 'externals', 'name', \%w );
my @external_list = ();
foreach my $s (@external_names) {
unless ( $externals{$s} ) { push @external_list, $s }
}
@external_list = sort @external_list;
$form .= Forms->external_list( $session_id, $name, \%externals, \@external_list,
'service', $hidden{'service_id'}, $hidden{'service_name'}, \%modified );
$hidden{'type'} = 'service';
$hidden{'id'} = $properties{'host_id'};
$hidden{'name'} = $name;
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons();
}
elsif ( $obj_view eq 'service_external_detail' ) {
my $service_name = $query->param('service_name');
$hidden{'service_id'} = $query->param('service_id');
$form .=
Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'}, $hidden{'selected'}, $hidden{'form_service'} );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
my $detail = $query->param('detail');
my $service_external = $query->param('service_external');
unless ($service_external) {
$service_external = $properties{'external'};
}
my %where = (
'external_id' => $properties{'external_id'},
'host_id' => $properties{'host_id'},
'service_id' => $hidden{'service_id'}
);
my %external = StorProc->fetch_one_where( 'external_service', \%where );
unless ($detail) { $detail = $external{'data'} }
$form .= Forms->display_hidden( 'Service name:', 'service_name', $service_name );
$form .= Forms->display_hidden( 'Service external name:', 'service_external', $service_external );
$form .= Forms->display_hidden( 'Service external state:', '', $external{'modified'} ? 'locally modified' : 'unmodified from original' );
$form .= Forms->text_area( 'Detail:', 'detail', $detail, '25', '100%', '', '', '', $tab++ );
$hidden{'external_id'} = $external{'external_id'};
$form .= Forms->hidden( \%hidden );
my %docs = Doc->externals();
if ($external{'modified'}) {
$form .= Forms->wizard_doc( 'Reset vs. Save', $docs{'reset_service'} );
my %reset = ( 'name' => 'reset', 'value' => 'Reset to Generic Detail' );
$form .= Forms->form_bottom_buttons( \%reset, \%save, $tab++ );
}
else {
$form .= Forms->wizard_doc( 'Mark vs. Save', $docs{'mark_service'} );
my %mark = ( 'name' => 'mark', 'value' => 'Mark as Modified' );
$form .= Forms->form_bottom_buttons( \%mark, \%save, $tab++ );
}
}
elsif ( $obj_view eq 'saved' ) {
# FIX MINOR: correct $obj_view back to where it came from in all cases
if ( $hidden{'service_name'} ) { $obj_view = 'service_detail' }
my $host_external = $query->param('host_external');
my $service_external = $query->param('service_external');
$form .= Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'},
$hidden{'selected'}, $hidden{'form_service'} );
$form .= Forms->display_hidden( 'Host external name:', 'host_external', $host_external ) if $host_external;
$form .= Forms->display_hidden( 'Service name:', 'service_name', $hidden{'service_name'} ) if ( $hidden{'service_name'} );
$form .= Forms->display_hidden( 'Service external name:', 'service_external', $service_external ) if $service_external;
$form .= Forms->display_hidden( 'Saved:', '', $message );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%close );
}
elsif ( $obj_view =~ /_saved_apply$/ ) {
$obj_view =~ s/_saved_apply//;
$form .= Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'},
$hidden{'selected'}, $hidden{'form_service'} );
$form .= Forms->display_hidden( 'Saved:', '', $message );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons();
}
elsif ( $obj_view eq 'rename' ) {
$form .= Forms->host_top( $properties{'name'}, $session_id, $obj_view, $auth_add{'externals'},
$hidden{'selected'}, $hidden{'form_service'} );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->text_box( 'Rename to:', 'new_name', '', $textsize{'name'}, $required, '', '', $tab++ );
$hidden{'name'} = $name;
$hidden{'rename'} = $name;
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%rename, $tab++ );
}
elsif ( $obj_view eq 'delete_host' ) {
$hidden{'name'} = $name;
my $message = qq(Are you sure you want to remove host \"$name\"?);
$form .= Forms->are_you_sure( 'Confirm Delete', $message, 'confirm_delete_host', \%hidden );
}
elsif ( $obj_view eq 'deleted' ) {
$form .= Forms->form_top( 'Status', '' );
my @message = ("Host \"$name\".");
$form .= Forms->form_message( 'Removed:', \@message, 'row1' );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
return $form;
}
#
############################################################################
# Sub Delete Object
#
sub delete_object($$) {
my $id = shift;
my $name = shift;
my $form = undef;
my $title = undef;
(my $obj_type = $obj) =~ s/escalation_template/escalation/;
my @t_parse = split( /_/, $obj_type );
foreach (@t_parse) { $_ =~ s/ies/y/g; $title .= "\u$_ "; }
$title =~ s/s\s$//;
my %dep_templates = ();
$dep_templates{'time_periods'}{'host_templates'} = [ ('notification_period') ];
$dep_templates{'time_periods'}{'service_templates'} = [ ( 'notification_period', 'check_period' ) ];
$dep_templates{'time_periods'}{'contact_templates'} = [ ( 'host_notification_period', 'service_notification_period' ) ];
$dep_templates{'commands'}{'host_templates'} = [ ( 'check_command', 'event_handler' ) ];
$dep_templates{'commands'}{'service_templates'} = [ ( 'check_command', 'event_handler' ) ];
$dep_templates{'commands'}{'services'} = [ ('check_command') ];
$dep_templates{'host_templates'}{'hosts'} = [ ('hosttemplate_id') ];
$dep_templates{'host_templates'}{'profiles_host'} = [ ('host_template_id') ];
$dep_templates{'service_templates'}{'service_templates'} = [ ('parent_id') ];
$dep_templates{'service_templates'}{'service_names'} = [ ('template') ];
$dep_templates{'service_templates'}{'services'} = [ ('servicetemplate_id') ];
$dep_templates{'contact_templates'}{'contacts'} = [ ('contacttemplate_id') ];
$dep_templates{'service_dependency_templates'}{'service_dependency'} = [ ('template') ];
# $dep_templates{'contactgroups'}{'contactgroup_assign'} = [ ('contactgroup_id') ];
$dep_templates{'contactgroups'}{'tree_template_contactgroup'} = [ ('contactgroup_id') ];
$dep_templates{'escalation_templates'}{'escalation_tree_template'} = [ ('template_id') ];
$dep_templates{'extended_service_info_templates'}{'services'} = [ ('serviceextinfo_id') ];
$dep_templates{'extended_service_info_templates'}{'service_names'} = [ ('extinfo') ];
$dep_templates{'extended_host_info_templates'}{'hosts'} = [ ('hostextinfo_id') ];
$dep_templates{'extended_host_info_templates'}{'profiles_host'} = [ ('host_extinfo_id') ];
unless ($id) {
my $otable = $obj;
if ( $otable =~ /escalation_template/ ) {
$otable = 'escalation_templates';
}
if ( $otable eq 'escalations' ) { $otable = 'escalation_trees' }
my %id = StorProc->fetch_one( $otable, 'name', $name );
$id = $id{ $obj_id{$otable} };
}
$hidden{'id'} = $id;
my $all_clear = 1;
my %dependencies = ();
foreach my $table ( keys %{ $dep_templates{$obj} } ) {
foreach my $column ( @{ $dep_templates{$obj}{$table} } ) {
my @dep = ();
if ( $table =~ /services|service_dependency$/ ) {
my @names = StorProc->get_hostname_servicename( $table, $column, $id );
for my $i ( 0 .. $#names ) {
for my $name ( keys %{ $names[$i] } ) {
push @dep, "$name - $names[$i]{$name}";
}
}
$dependencies{'Host - Service'} = [@dep];
# another special case
# } elsif ($table eq 'contactgroup_assign') {
# my @names = StorProc->get_contactgroup_object($id,\%obj_id);
# for my $i ( 0 .. $#names ) {
# for my $name ( keys %{ $names[$i] } ) {
# push @dep, "$name - $names[$i]{$name}";
# }
# }
# $dependencies{'Templates/Hostgroups'} = [ @dep ];
}
elsif ( $table eq 'tree_template_contactgroup' ) {
@dep = StorProc->get_tree_contactgroup($id);
$dependencies{'Escalation trees'} = [@dep];
}
elsif ( $table eq 'contactgroup_contact' ) {
@dep = StorProc->get_contact_contactgroup($id);
$dependencies{'Contacts'} = [@dep];
}
else {
my %where = ( $column => $id );
@dep = StorProc->fetch_list_where( $table, 'name', \%where );
$dependencies{$table} = [@dep];
}
if ( $dep[0] ) { $all_clear = 0 }
}
}
if ($all_clear) {
if ( $query->param('confirm_delete') ) {
my $otable = $obj;
if ( $otable =~ /escalation_template/ ) {
$otable = 'escalation_templates';
$obj = 'escalation_templates';
}
if ( $otable eq 'escalations' ) {
$otable = 'escalation_trees';
$obj = 'escalation_trees';
}
my $result = StorProc->delete_all( $otable, $obj_id{$obj}, $id );
if ( $result =~ /^Error/ ) {
push @errors, "Unable to process request: $result";
$form .= Forms->header( $page_title, $session_id, $top_menu );
$form .= Forms->form_top( "Delete $title", '' );
$form .= Forms->form_errors( \@errors );
}
else {
my @message = ("$name");
$form .= Forms->header( $page_title, $session_id, $top_menu, '', '1' );
$form .= Forms->form_top( "Delete $title", '' );
$form .= Forms->form_message( 'Removed:', \@message, 'row1' );
}
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
else {
foreach my $name ( $query->param ) {
unless ( $name eq 'nocache' ) {
$hidden{$name} = $query->param($name);
}
}
delete $hidden{'task'};
delete $hidden{'submit'};
if ( $obj =~ /escalation_template/ ) {
$hidden{'task'} = 'escalation_template';
}
elsif ( $obj =~ /escalation_trees/ ) {
$hidden{'task'} = 'escalation_trees';
}
else {
$hidden{'task'} = 'modify';
}
my $message = qq(Are you sure you want to remove \"$name\"?);
$form .= Forms->header( $page_title, $session_id, $top_menu );
$form .= Forms->are_you_sure( "Confirm Delete of $title", $message, 'confirm_delete', \%hidden, 'bail' );
$task = 'delete';
}
}
else {
$form .= Forms->header( $page_title, $session_id, $top_menu );
$form .= Forms->form_top( "Delete $title", '' );
$form .= Forms->display_hidden( "\u\L$title\E name:", 'name', $name );
my @message = ("Cannot delete until all dependencies are removed/reassigned.");
$form .= Forms->form_errors( \@message );
foreach my $dep ( keys %dependencies ) {
@message = ($dep);
$form .= Forms->form_message( 'Object type:', \@message, 'row1' );
$form .= Forms->form_message( ' ', \@{ $dependencies{$dep} }, 'row1' );
}
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%close, $tab++ );
}
return $form;
}
sub rename_object($$) {
my $id = shift;
my $name = shift;
my $form = undef;
my $title = undef;
my $ltitle = undef;
(my $obj_type = $obj) =~ s/escalation_template/escalation/;
my @t_parse = split( /_/, $obj_type );
foreach (@t_parse) { $_ =~ s/ies/y/g; $title .= "\u$_ "; $ltitle = "$_ " }
$title =~ s/s\s$//;
my $new_name = StorProc->sanitize_string( $query->param('new_name') );
if ( defined($new_name) && $name eq $new_name ) { $new_name = undef }
my $saved = 0;
$table = $obj;
if ( $table =~ /service_groups/ ) { $table = 'servicegroups' }
if ( $table =~ /escalation_template/ ) { $table = 'escalation_templates' }
if ( $table =~ /escalation_tree/ ) { $table = 'escalation_trees' }
if ( $table =~ /_externals/ ) { $table = 'externals' }
if ($new_name) {
my %n = StorProc->fetch_one( $table, 'name', $new_name );
if ( $name =~ /^$new_name$/i ) { delete $n{'name'} }
if ( $n{'name'} ) {
$obj_view = 'rename';
$ltitle =~ s/s\s$//;
push @errors, "Cannot rename. Another $ltitle has name \"$new_name\".";
}
else {
if ( $table eq 'commands' ) {
my %command = StorProc->fetch_one( 'commands', 'name', $name );
my $results = StorProc->rename_command( \%command, $new_name );
$name = $new_name;
$saved = 1;
$refresh_left = 1;
}
else {
my %values = ( 'name' => $new_name );
my $result = StorProc->update_obj( $table, 'name', $name, \%values );
if ( $result =~ /^Error/ ) {
push @errors, $result;
}
else {
$name = $new_name;
$saved = 1;
$refresh_left = 1;
}
}
}
}
$form .= Forms->header( $page_title, $session_id, $top_menu, '', $refresh_left );
if ($saved) {
$form .= Forms->form_top( "Rename $title", Validation->dfv_onsubmit_javascript() );
my @message = ("$name");
$form .= Forms->form_message( 'Renamed:', \@message, 'row1' );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
else {
# FIX MINOR: See GWMON-6087 for how this should evolve to constrain names for other objects as well.
if ( $obj eq 'servicegroups' ) {
$form .= Validation->dfv_profile_javascript('rename');
$form .= &$Instrument::show_trace_as_html_comment();
}
$form .= Forms->form_top( "Rename $title", Validation->dfv_onsubmit_javascript(
"if (this.clicked == 'cancel') { return true; }"
) );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->display_hidden( "\u\L$title\E name:", 'name', $name );
$form .= Forms->text_box( 'Rename to:', 'new_name', '', $textsize{'name'}, '', '', '', $tab++ );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%rename, \%cancel, $tab++ );
}
return $form;
}
#
############################################################################
# Manage
#
# GWMON-8039
# FIX MAJOR: Generalize the custom_variables() calling sequence so we accept an array of template hashrefs, each with its own name,
# to allow for a chain of parent templates, instead of a single name and a single template hashref
sub custom_variables($$$$$) {
my $var_menu = shift;
my $var_view = shift;
my $var_type = shift;
my $var_name = shift;
my $var_vars = shift;
my $data = '';
my @custom_variable = (); # will always be present, for both template and object variables
my %inherit_variable = (); # may or may not be present for a particular variable
my %suppress_variable = (); # may or may not be present for a particular variable
my %value_variable = (); # may or may not be present for a particular variable
foreach my $param ( $query->param() ) {
if ( $param =~ /^(_\p{IsWord}+)$/ ) {
# FIX MAJOR: ensure that non-ISO-8859-1 characters are stripped or cause errors to be displayed
push @custom_variable, $param;
}
elsif ( $param =~ /^inherit_(_\p{IsWord}+)$/ ) {
$inherit_variable{$1} = 1;
}
elsif ( $param =~ /^suppress_(_\p{IsWord}+)$/ ) {
$suppress_variable{$1} = 1;
}
elsif ( $param =~ /^value_(_\p{IsWord}+)$/ ) {
# FIX MAJOR: ensure that non-ISO-8859-1 characters are stripped or cause errors to be displayed
$value_variable{$1} = StorProc->sanitize_string( $query->param($param) );
}
}
# FIX MAJOR: handle multiple template hashrefs in $var_vars, to support a chain of parent templates
# (useful mainly for {service and service template} custom variables)
my @parent_vars = ();
if (defined $var_name) {
my %template_variables = map { $_ => $var_vars->{$_} } grep( /^_/, keys %$var_vars );
my %parent_vars = (
menu => $var_menu,
view => $var_view,
type => $var_type,
name => $var_name,
vars => \%template_variables,
);
push @parent_vars, \%parent_vars;
}
my ($template_names, $template_urls, $template_vars) = Forms->resolve_template_variables( $session_id, \@parent_vars );
foreach my $var (@custom_variable) {
if ( exists $template_vars->{$var} ) {
if ( $suppress_variable{$var} ) {
$value_variable{$var} = 'null';
}
elsif ( $inherit_variable{$var} ) {
delete $value_variable{$var};
}
}
else {
if ( $inherit_variable{$var} ) {
push @errors,
"Error: Custom variable \"$var\" used to be in the template, but the template has since been edited. You must start over to ensure that the displayed setup correctly reflects the underlying data.";
}
elsif ( $suppress_variable{$var} ) {
$value_variable{$var} = 'null';
}
}
if ( exists $value_variable{$var} ) {
(my $escaped = $value_variable{$var}) =~ s{]]>}{]]]]>}g;
$data .= "\n \n ";
}
}
return $data;
}
sub manage() {
my $page = undef;
my $name = $query->param('name');
my $title = undef;
my $validation_mini_profile = '';
my @t_parse = split( /_/, $obj );
foreach (@t_parse) { $title .= "\u$_ " }
if ( $query->param('cancel') || $query->param('close') || $query->param('continue') ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
}
else {
my $task = $query->param('submit');
#
# Contacts
#
if ( $obj eq 'contacts' ) {
my $name = $query->param('name');
$hidden{'name'} = $name;
my $got_form = undef;
if ( $query->param('delete') || $query->param('confirm_delete') ) {
unless ( $query->param('bail') ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= delete_object( '', $name );
$got_form = 1;
}
}
elsif ( $query->param('rename') ) {
$page .= rename_object( '', $name );
$got_form = 1;
}
elsif ( $query->param('save') ) {
my %contact = StorProc->fetch_one( 'contacts', 'name', $name );
my %data = parse_query( 'contacts', 'contacts' );
$properties{'template'} = $query->param('template');
my $field_ck = check_fields();
if ( $field_ck == 0 ) {
my %t = StorProc->fetch_one( 'contact_templates', 'name', $properties{'template'} );
my %vals = (
'contacttemplate_id' => $t{'contacttemplate_id'},
'alias' => $data{'alias'},
'email' => $data{'email'},
'pager' => $data{'pager'}
);
my $result = StorProc->update_obj( 'contacts', 'name', $name, \%vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
my %where = ( 'contact_id' => $contact{'contact_id'} );
$result = StorProc->delete_one_where( 'contactgroup_contact', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
my @mems = $query->param('contactgroup');
foreach (@mems) {
my %cg = StorProc->fetch_one( 'contactgroups', 'name', $_ );
my @vals = ( $cg{'contactgroup_id'}, $contact{'contact_id'} );
$result = StorProc->insert_obj( 'contactgroup_contact', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
my $data = '';
unless (@errors) {
$data .= custom_variables('contacts', 'manage', 'contact_templates', $t{'name'}, \%t);
}
unless (@errors) {
my %where = ( 'contact_id' => $contact{'contact_id'} );
my $result = StorProc->delete_one_where( 'contact_overrides', \%where );
my %values = ();
unless ( $query->param('host_notification_period_override') ) {
my $np = $query->param('host_notification_period');
my %np = StorProc->fetch_one( 'time_periods', 'name', $np );
$values{'host_notification_period'} = $np{'timeperiod_id'};
}
unless ( $query->param('service_notification_period_override') ) {
my $np = $query->param('service_notification_period');
my %np = StorProc->fetch_one( 'time_periods', 'name', $np );
$values{'service_notification_period'} = $np{'timeperiod_id'};
}
unless ( $query->param('host_notification_options_override') ) {
my @no = $query->param('host_notification_options');
my $str = undef;
foreach (@no) { $str .= "$_," }
chop $str;
$data .= "\n \n ";
}
unless ( $query->param('service_notification_options_override') ) {
my @no = $query->param('service_notification_options');
my $str = undef;
foreach (@no) { $str .= "$_," }
chop $str;
$data .= "\n \n ";
}
if ($data) {
$values{'data'} = "\n" . $data . "\n";
}
if (%values) {
my @vals = (
$contact{'contact_id'},
$values{'host_notification_period'},
$values{'service_notification_period'},
$values{'data'}
);
$result = StorProc->insert_obj( 'contact_overrides', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
%where = ( 'contact_id' => $contact{'contact_id'} );
$result = StorProc->delete_one_where( 'contact_command_overrides', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
unless ( $query->param('host_notification_commands_override') ) {
my @mems = $query->param('host_notification_commands');
foreach my $cmd (@mems) {
if ($cmd) {
my %c = StorProc->fetch_one( 'commands', 'name', $cmd );
my @vals = ( $contact{'contact_id'}, 'host', $c{'command_id'} );
$result = StorProc->insert_obj( 'contact_command_overrides', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
unless ( $query->param('service_notification_commands_override') ) {
my @mems = $query->param('service_notification_commands');
foreach my $cmd (@mems) {
if ($cmd) {
my %c = StorProc->fetch_one( 'commands', 'name', $cmd );
my @vals = ( $contact{'contact_id'}, 'service', $c{'command_id'} );
$result = StorProc->insert_obj( 'contact_command_overrides', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
unless (@errors) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
my $message = "Change to contact \"$name\" accepted.";
$page .= Forms->success( 'Saved', $message, 'continue', \%hidden );
$got_form = 1;
}
}
}
}
unless ($got_form) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'Contact Properties', 'onsubmit="selIt();"' );
$page .= build_contact();
$page .= Forms->hidden( \%hidden );
%save = ( 'name' => 'save', 'value' => 'Save' );
$page .= Forms->form_bottom_buttons( \%save, \%delete, \%rename, \%cancel, $tab++ );
}
}
elsif ( $query->param('bail') ) {
my $title = undef;
my @t_parse = split( /_/, $obj );
foreach (@t_parse) { $title .= "\u$_ " }
$title =~ s/s$//;
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= build_form('');
}
elsif ( $query->param('delete') or $query->param('confirm_delete') ) {
if ( $obj =~ /escalation/ ) {
$hidden{'type'} = $query->param('type');
}
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= delete_object( '', $name );
}
elsif ( $query->param('save') ) {
my %values = ();
my %data = parse_query( $table, $obj );
my $field_ck = check_fields();
if ( $field_ck == 0 ) {
foreach my $key ( keys %data ) {
unless ( $key =~ /HASH|^name$|members|^contact$|^contactgroup$|^parents$|notification_commands/ ) {
if ($key eq 'notes') {
if (defined $data{$key}) {
# FIX MAJOR NOW: this editing is probably no longer needed
$data{$key} = StorProc->sanitize_string_but_keep_newlines($data{$key});
$data{$key} =~ s/\n/
/g;
}
}
$values{$key} = $data{$key};
}
}
my $result = StorProc->update_obj( $table, 'name', $data{'name'}, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
if ( $obj eq 'contact_templates' ) {
my %o = StorProc->fetch_one( 'contact_templates', 'name', $name );
my %w = (
'contacttemplate_id' => $o{'contacttemplate_id'},
'type' => 'host'
);
my $result = StorProc->delete_one_where( 'contact_command', \%w );
if ( $result =~ /^Error/ ) { push @errors, $result }
if ( $data{'host_notification_commands'} ) {
my @c =
split( /,/, $data{'host_notification_commands'} );
foreach (@c) {
my @vals = ( $o{'contacttemplate_id'}, 'host', $_ );
my $result = StorProc->insert_obj( 'contact_command', \@vals );
if ( $result =~ /Error/ ) { push @errors, $result }
}
}
%w = (
'contacttemplate_id' => $o{'contacttemplate_id'},
'type' => 'service'
);
$result = StorProc->delete_one_where( 'contact_command', \%w );
if ( $result =~ /^Error/ ) { push @errors, $result }
if ( $data{'service_notification_commands'} ) {
my @c =
split( /,/, $data{'service_notification_commands'} );
foreach (@c) {
my @vals = ( $o{'contacttemplate_id'}, 'service', $_ );
my $result = StorProc->insert_obj( 'contact_command', \@vals );
if ( $result =~ /Error/ ) { push @errors, $result }
}
}
}
elsif ( $obj eq 'contactgroups' ) {
my %cg = StorProc->fetch_one( 'contactgroups', 'name', $data{'name'} );
my $result = StorProc->delete_all( 'contactgroup_contact', 'contactgroup_id', $cg{'contactgroup_id'} );
if ( $result =~ /^Error/ ) { push @errors, $result }
if ( $data{'contact'} ) {
my @mems = split( /,/, $data{'contact'} );
foreach (@mems) {
my %c = StorProc->fetch_one( 'contacts', 'name', $_ );
my @vals = ( $cg{'contactgroup_id'}, $c{'contact_id'} );
$result = StorProc->insert_obj( 'contactgroup_contact', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
elsif ( $obj eq 'hostgroups' ) {
my %n = StorProc->fetch_one( 'hostgroups', 'name', $name );
my $result = StorProc->delete_all( 'hostgroup_host', 'hostgroup_id', $n{'hostgroup_id'} );
if ( $result =~ /^Error/ ) { push @errors, $result }
if ( $data{'members'} ) {
my @mems = split( /,/, $data{'members'} );
foreach (@mems) {
my %m = StorProc->fetch_one( 'hosts', 'name', $_ );
my @vals = ( $n{'hostgroup_id'}, $m{'host_id'} );
$result = StorProc->insert_obj( 'hostgroup_host', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
my %hostgroup = StorProc->fetch_one( $table, 'name', $name );
my %w = ( 'hostgroup_id' => $hostgroup{'hostgroup_id'} );
$result = StorProc->delete_one_where( 'contactgroup_hostgroup', \%w );
if ( $result =~ /^Error/ ) { push @errors, $result }
if ( $data{'contactgroup'} ) {
my @mems = split( /,/, $data{'contactgroup'} );
foreach (@mems) {
my %cg = StorProc->fetch_one( 'contactgroups', 'name', $_ );
my $table_name = $contactgroup_table_by_object{$obj};
my @vals = ( $cg{'contactgroup_id'}, $hostgroup{'hostgroup_id'} );
$result = StorProc->insert_obj( 'contactgroup_hostgroup', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
elsif ( $obj eq 'host_templates' ) { # GWMON-4694, GWMON-5062
my %o = StorProc->fetch_one( 'host_templates', 'name', $name );
my %w = ( 'hosttemplate_id' => $o{'hosttemplate_id'} );
my $result = StorProc->delete_one_where( 'contactgroup_host_template', \%w );
if ( $result =~ /^Error/ ) { push @errors, $result }
if ( $data{'contactgroup'} ) {
my @cg = split( /,/, $data{'contactgroup'} );
foreach (@cg) {
my %cg_obj = StorProc->fetch_one( 'contactgroups', 'name', $_ );
my @vals = ( $cg_obj{'contactgroup_id'}, $o{'hosttemplate_id'} );
my $result = StorProc->insert_obj( 'contactgroup_host_template', \@vals );
if ( $result =~ /Error/ ) { push @errors, $result }
}
}
}
unless (@errors) {
my $title = undef;
my @t_parse = split( /_/, $obj );
foreach (@t_parse) { $_ =~ s/ies/y/g; $title .= "$_ "; }
$title =~ s/s\s$//;
$title =~ s/Wizard/Extended/;
if ( $title =~ /Escalation/ ) { $title =~ s/Template//; }
my $message = "Changes to $title \"$name\" have been saved.";
$hidden{'name'} = undef;
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->success( 'Updated', $message, 'continue', \%hidden );
}
else {
foreach (@errors) { error_out("errors $_") }
}
}
elsif ( $field_ck == 1 ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= build_form('');
}
}
elsif ( $query->param('rename') ) {
$page .= rename_object( '', $name );
}
elsif ($name) {
my $title = undef;
my @t_parse = split( /_/, $obj );
foreach (@t_parse) { $title .= "\u$_ " }
$title =~ s/s$//;
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= build_form($validation_mini_profile);
}
}
return $page;
}
#
############################################################################
# Tools
#
sub tools() {
my $page = undef;
if ( $query->param('close') || $query->param('continue') ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$obj = 'close';
}
if ( $obj eq 'import_from_files' ) {
my %backup = ( 'name' => 'backup', 'value' => 'Backup' );
my %import = ( 'name' => 'import_options', 'value' => 'Import' );
use Cwd 'realpath';
my $precached_file = undef;
if ( $query->param('confirm_import') ) {
$precached_file = StorProc->sanitize_string( $query->param('precached_file') );
# We only want to intercept and confirm the import_3x processing.
my $import_option = $query->param('import_option');
if ( $import_option ne 'purge_all_and_import_3x' ) {
$query->param( 'run_import', 'Import' );
}
else {
# For import_3x processing, we need to validate the input file.
if ($precached_file) {
my $abs_path = realpath($precached_file) || '';
if ( $abs_path !~ m@^/usr/local/groundwork/nagios/var/[^/]+@
&& $abs_path !~ m@^/usr/local/groundwork/nagios/tmp/[^/]+@
&& $abs_path !~ m@^/tmp/[^/]+@ )
{
push @errors,
'Error: The precached objects file must reside in one of these directories:
'
. ' /usr/local/groundwork/nagios/var
'
. ' /usr/local/groundwork/nagios/tmp
'
. ' /tmp
';
}
elsif ( !-f $abs_path || !-r $abs_path ) {
$precached_file = $abs_path;
push @errors, "Error: \"$precached_file\" is not a readable file.";
}
if (@errors) {
$query->param( 'import_options', 'Import' );
}
else {
$precached_file = $abs_path;
}
}
}
}
if ( $query->param('continue') ) {
print "Content-type: text/html \n\n";
$page .= Forms->header( $page_title, $session_id, $top_menu );
if ( $query->param('continue') =~ /$abort{'value'}/ ) {
$page .= Forms->form_top( 'Import Nagios Configuration', '' );
$hidden{'obj'} = undef;
$page .= Forms->hidden( \%hidden );
my @message = ("Import of Nagios files aborted.");
$page .= Forms->form_message( 'Action Canceled:', \@message, '' );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
$hidden{'obj'} = undef;
}
}
elsif ( $query->param('backup') ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'Import Nagios Configuration', '' );
my %nagios = StorProc->fetch_one( 'setup', 'name', 'nagios_etc' );
my %backup_dir = StorProc->fetch_one( 'setup', 'name', 'backup_dir' );
my ( $backup, $errs ) = StorProc->backup( $nagios{'value'}, $backup_dir{'value'} );
push( @errors, @{$errs} );
if (@errors) {
my @message = ( "Problem(s) Backing up files and/or database to $backup ." );
push( @message, @errors );
$page .= Forms->form_message( 'Backup error(s):', \@message, 'error' );
}
else {
my @message = ("Files backed up to $backup .");
$page .= Forms->form_message( 'Backup complete:', \@message, '' );
}
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%import, \%abort, $tab++ );
}
elsif ( $query->param('abort') ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'Import Nagios Configuration', '' );
$hidden{'obj'} = undef;
$page .= Forms->hidden( \%hidden );
my @message = ("Import of Nagios files aborted.");
$page .= Forms->form_message( 'Action Canceled:', \@message, '' );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
$hidden{'obj'} = undef;
}
elsif ( $query->param('run_import') ) {
$page .= Forms->header( $page_title, $session_id, $top_menu, '', '', '', '2' );
$page .= Forms->form_top( 'Import Nagios Object Files', '' );
$page .= Forms->wizard_doc( 'Import Process', 'Please keep this page open until the Status reads "Finished".' );
my $import_option = $query->param('import_option');
my $purge_escalations = $query->param('purge_escalations');
$precached_file = StorProc->sanitize_string( $query->param('precached_file') );
$hidden{'CGISESSID'} = $session_id;
$page .= Forms->hidden( \%hidden );
$page .=
Forms->process_import( $import_option, $purge_escalations, $nagios_etc, $abort{'value'}, $continue{'value'}, $precached_file );
use CGI::Ajax;
my $url = Forms->get_ajax_url(); # "$cgi_dir/monarch_ajax.cgi?nocache=$nocache"
my $pjx = new CGI::Ajax( 'process_import' => $url, 'skip_header' => 1 );
return $pjx->build_html( $query, $page );
}
elsif ( $query->param('import_options') ) {
my $import_option = $query->param('import_option');
$page .= Forms->header( $page_title, $session_id, $top_menu, '' );
$page .= Forms->form_top( 'Import Nagios Object Files', '' );
if (@errors) { $page .= Forms->form_errors( \@errors ) }
if ( !$precached_file ) {
my %precached_file = StorProc->fetch_one( 'setup', 'name', 'precached_object_file' );
$precached_file = $precached_file{'value'};
}
$page .= Forms->import_options( $import_option, $precached_file, $tab++ );
$import{'name'} = 'confirm_import';
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%import, \%abort, $tab++ );
}
elsif ( $query->param('confirm_import') ) {
my %docs = Doc->import_nagios_config();
$hidden{'import_option'} = $query->param('import_option');
$hidden{'purge_escalations'} = $query->param('purge_escalations');
$hidden{'precached_file'} = $precached_file;
$page .= Forms->header( $page_title, $session_id, $top_menu, '' );
$page .= Forms->form_top( 'Confirm Import', '' );
$page .= Forms->wizard_doc( 'Caution', $docs{'purge_all_and_import_3x'} );
$import{'name'} = 'run_import';
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%import, \%abort, $tab++ );
}
# FIX MAJOR: This is the wrong file to test for, and the wrong time to test for it.
# We should have a separate import directory to draw from, and it should only be
# tested for once the user decides to move forward.
elsif ( -f "$nagios_etc/nagios.cfg" ) {
my $message =
qq(This tool is for importing Nagios configuration files from standalone Nagios installations,
to bring them under the GroundWork umbrella.
This is an infrequent action, not something you would perform regularly.
Nagios configuration files do not contain all the relationships stored within a GroundWork configuration,
so this is NOT a tool for restoring a GroundWork configuration from a backup.
The Bookshelf contains instructions for that (see
SYSTEM MAINTENANCE).
You are about to update or drop all configuration records in the GroundWork "monarch" database.
Should you choose to continue, it is strongly recommended that you first select the backup option.
Are you sure you want to continue?
);
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'Import Nagios Configuration', '' );
$page .= Forms->hidden( \%hidden );
$page .= Forms->wizard_doc( 'Import from nagios.cfg, cgi.cfg, and related files', $message );
$page .= Forms->form_bottom_buttons( \%backup, \%import, \%abort, $tab++ );
}
else {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'Error', '' );
$hidden{'obj'} = undef;
$page .= Forms->hidden( \%hidden );
my @message = ("Unable to import $nagios_etc/nagios.cfg (update setup options).");
$page .= Forms->form_message( 'Does not exist:', \@message, 'error' );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
}
elsif ( $obj eq 'export_to_files' ) {
require MonarchFile;
my @results = ();
my ( $files, $errors ) = Files->build_files( $user_acct, '', '', '1', $nagios_ver, $nagios_etc, "$doc_root/monarch/download", '1' );
my @errors = @{$errors};
my @files = @{$files};
if (@errors) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'Export Errors', '', '' );
$page .= Forms->form_errors( \@errors );
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
else {
my $tarball = pop @files;
my @list = ($tarball);
@files = sort @files;
push( @list, @files );
my $server = $ENV{'SERVER_NAME'};
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->table_download_links( "$doc_root/monarch/download", \@list, $server );
}
}
return $page;
}
#
############################################################################
# Groups
#
sub groups() {
my $obj_view = $query->param('obj_view');
my @views = ( 'detail', 'macros', 'hosts', 'sub_groups', 'rename' );
foreach my $v (@views) {
if ( $query->param($v) ) { $obj_view = $v }
}
my %save_macros = ();
my @remove_macros = ();
my $form = undef;
@errors = ();
my $name = StorProc->sanitize_string( $query->param('name') );
my %group = StorProc->fetch_one( 'monarch_groups', 'name', $name );
push @errors, delete $group{'error'} if defined $group{'error'};
my $message = undef;
if ( $query->param('add') ) {
## We follow standard fully-qualified-host-name/IP-address restrictions for group names (alphanumerics plus hyphen
## and dot, and not beginning or ending with a hyphen or dot, as the group name will be used in the same context.
unless ( $group{'name'} || $name eq '' || $name =~ /[^a-zA-Z0-9-.]/ || $name =~ /^-|-$/ || $name =~ /^[.]|[.]$/ ) {
my $data .= qq(
);
my @values = ( \undef, $name, '', '', '', $data );
my $id = StorProc->insert_obj_id( 'monarch_groups', \@values, 'group_id' );
unless ( $id =~ /^Error/ ) {
%group = StorProc->fetch_one( 'monarch_groups', 'name', $name );
push @errors, delete $group{'error'} if defined $group{'error'};
unless ($is_portal) {
my %super_user = StorProc->fetch_one( 'user_groups', 'name', 'super_users' );
my @values = ( $id, 'group_macro', $super_user{'usergroup_id'}, $name );
my $result = StorProc->insert_obj( 'access_list', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
unless ( $user_acct eq 'super_user' ) {
my %where = ( 'user_id' => $userid );
my @user_groups = StorProc->fetch_list_where( 'user_group', 'usergroup_id', \%where );
foreach my $ugid (@user_groups) {
if ( $super_user{'usergroup_id'} eq $ugid ) { next }
my @values = ( $id, 'group_macro', $ugid, $name );
my $result = StorProc->insert_obj( 'access_list', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
$obj_view = 'detail';
}
else {
push @errors, $id;
$obj_view = 'new';
}
}
else {
push @errors,
"Check the Monarch group name field. It's either blank, contains illegal characters (anything other than a-z, A-Z, 0-9, hyphen, and dot), begins or ends with a hyphen or dot, or this group already exists.";
$obj_view = 'new';
}
}
elsif ( $query->param('cancel') &&
(!defined($obj_view) || ($obj_view ne 'nagios_cgi' && $obj_view ne 'nagios_cfg' && $obj_view ne 'resource_cfg')) ) {
$obj_view = 'detail';
}
elsif ( $query->param('close') || $query->param('continue') ) {
$form .= Forms->header( $page_title, $session_id, $top_menu );
$obj_view = 'close';
}
elsif ( $query->param('export') ) {
my $results = undef;
if ( $results =~ /^Error/ ) {
push @errors, $results;
}
else {
$obj_view = 'exported';
}
}
elsif ( $query->param('rename') && $query->param('new_name') ) {
my $new_name = StorProc->sanitize_string( $query->param('new_name') );
my %group_exists = StorProc->fetch_one( 'monarch_groups', 'name', $new_name );
push @errors, delete $group_exists{'error'} if defined $group_exists{'error'};
if ( $new_name =~ /[^a-zA-Z0-9-.]/ || $name =~ /^-|-$/ || $name =~ /^[.]|[.]$/ ) {
push @errors,
"Check the new Monarch group name (name = \"$new_name\"). Group names cannot contain illegal characters (anything other than a-z, A-Z, 0-9, hyphen, and dot), or begin or end with a hyphen or dot.";
}
elsif ( $new_name && !$group_exists{'name'} ) {
my %values = ( 'name' => $new_name );
my $result = StorProc->update_obj( 'monarch_groups', 'name', $name, \%values );
if ( $result =~ /^Error/ ) {
push @errors, $result;
}
else {
$name = $new_name;
$refresh_left = 1;
}
}
else {
push @errors, "Check the new Monarch group name (name = \"$new_name\"). It is either blank or this group already exists.";
}
unless (@errors) { $obj_view = 'detail' }
}
elsif ( $query->param('save') ) {
my $description = $query->param('description');
my $inactive = $query->param('inactive') || 0; # param is "1" if set, undef if not
my $sync_hosts = $query->param('sync_hosts') || 0; # param is "2" if set, undef if not; but always undef if inactive is undef
my $status = $inactive + $sync_hosts; # Elsewhere, $status of either undef or 0 is treated like $status of 2.
my $location = StorProc->sanitize_string( $query->param('location') );
my $nagios_etc = $query->param('nagios_etc');
my $use_hosts = $query->param('use_hosts');
my $inherit_host_active_checks_enabled = $query->param('inherit_host_active_checks_enabled');
my $inherit_host_passive_checks_enabled = $query->param('inherit_host_passive_checks_enabled');
my $inherit_service_active_checks_enabled = $query->param('inherit_service_active_checks_enabled');
my $inherit_service_passive_checks_enabled = $query->param('inherit_service_passive_checks_enabled');
my $host_active_checks_enabled = $query->param('host_active_checks_enabled');
my $host_passive_checks_enabled = $query->param('host_passive_checks_enabled');
my $service_active_checks_enabled = $query->param('service_active_checks_enabled');
my $service_passive_checks_enabled = $query->param('service_passive_checks_enabled');
$use_hosts = '' if not defined $use_hosts;
$inherit_host_active_checks_enabled = '' if not defined $inherit_host_active_checks_enabled;
$inherit_host_passive_checks_enabled = '' if not defined $inherit_host_passive_checks_enabled;
$inherit_service_active_checks_enabled = '' if not defined $inherit_service_active_checks_enabled;
$inherit_service_passive_checks_enabled = '' if not defined $inherit_service_passive_checks_enabled;
$host_active_checks_enabled = '-zero-' unless $host_active_checks_enabled;
$host_passive_checks_enabled = '-zero-' unless $host_passive_checks_enabled;
$service_active_checks_enabled = '-zero-' unless $service_active_checks_enabled;
$service_passive_checks_enabled = '-zero-' unless $service_passive_checks_enabled;
my $data .= qq(
);
# FIX LATER: If this error is triggered, we ought to ensure that any changed values the user specified
# get re-established on the screen for further editing, preferably with this field presented using our
# standard light-yellow error background, rather than just getting lost without notice.
push @errors, 'Error: a non-empty build folder must be specified as an absolute pathname.'
if defined $location && $location ne '' && $location !~ m{^/};
unless (@errors) {
my %values = (
'location' => $location,
'description' => $description,
'status' => $status,
'data' => $data
);
my $result = StorProc->update_obj( 'monarch_groups', 'name', $name, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
my @contactgroups = $query->param('contactgroups');
my %contactgroup_name = StorProc->get_table_objects('contactgroups');
$result = StorProc->delete_all( 'contactgroup_group', 'group_id', $group{'group_id'} );
if ( $result =~ /^Error/ ) { push @errors, $result }
foreach my $cg (@contactgroups) {
## my @values = ($contactgroup_name{$cg},'monarch_group',$group{'group_id'});
## my $result = StorProc->insert_obj('contactgroup_assign',\@values);
my @values = ( $contactgroup_name{$cg}, $group{'group_id'} );
my $result = StorProc->insert_obj( 'contactgroup_group', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
unless (@errors) { $obj_view = 'saved' }
}
elsif ( $query->param('set_values') ) {
my %monarch_macros = StorProc->get_table_objects('monarch_macros');
my $label_enabled = 0;
foreach my $qname ( $query->param ) {
if ( $qname =~ /label_enabled/ ) { $label_enabled = 1 }
if ( $qname =~ /value_(\S+)/ ) {
my %where = (
'macro_id' => $monarch_macros{$1},
'group_id' => $group{'group_id'}
);
my $val = $query->param($qname);
my %values = ( 'value' => $val );
my $result = StorProc->update_obj_where( 'monarch_group_macro', \%values, \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
my $label = $query->param('label');
my $data .= qq(
);
my %values = ( 'data' => $data );
my $result = StorProc->update_obj( 'monarch_groups', 'name', $name, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
unless (@errors) {
$obj_view = 'saved';
$message = "Macro values and settings updated.";
}
}
elsif ( $query->param('add_macro') ) {
my %macros = StorProc->get_macros();
my %monarch_macros = StorProc->get_table_objects('monarch_macros');
my @macros = $query->param('add_macro_checked');
foreach my $macro (@macros) {
my @values = ( $group{'group_id'}, $macros{$macro}{'id'}, $macros{$macro}{'value'} );
my $result = StorProc->insert_obj( 'monarch_group_macro', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $query->param('remove_macro') ) {
my %monarch_macros = StorProc->get_table_objects('monarch_macros');
my @macros = $query->param('rem_macro_checked');
foreach my $macro (@macros) {
my %where = (
'group_id' => $group{'group_id'},
'macro_id' => $monarch_macros{$macro}
);
my $result = StorProc->delete_one_where( 'monarch_group_macro', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $query->param('add_group') ) {
my %monarch_groups = StorProc->get_table_objects('monarch_groups');
my @groups = $query->param('add_group_checked');
my %group_hosts = ();
my %host_group = ();
my @order = ();
my %group_child = ();
my %parents_all = StorProc->get_group_parents_all();
my %group_names = StorProc->get_table_objects('monarch_groups');
foreach my $group (@groups) {
my ( $group_hosts, $order ) =
StorProc->get_group_hosts( $group, \%parents_all, \%group_names, \%group_hosts, \@order, \%group_child );
@order = @{$order};
foreach my $group (@order) {
my %where = (
'group_id' => $group{'group_id'},
'child_id' => $monarch_groups{$group}
);
my $result = StorProc->delete_one_where( 'monarch_group_child', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
my @values = ( $group{'group_id'}, $monarch_groups{$group} );
my $result = StorProc->insert_obj( 'monarch_group_child', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $query->param('remove_group') ) {
my %monarch_groups = StorProc->get_table_objects('monarch_groups');
my @children = $query->param('rem_group_checked');
foreach my $child (@children) {
my %where = (
'group_id' => $group{'group_id'},
'child_id' => $monarch_groups{$child}
);
my $result = StorProc->delete_one_where( 'monarch_group_child', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $query->param('add_host') ) {
my %hosts = StorProc->get_table_objects('hosts');
my @hosts = $query->param('add_host_checked');
foreach my $host (@hosts) {
my @values = ( $group{'group_id'}, $hosts{$host} );
my $result = StorProc->insert_obj( 'monarch_group_host', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $query->param('add_hostgroup') ) {
my %hostgroups = StorProc->get_table_objects('hostgroups');
my @hostgroups = $query->param('add_hostgroup_checked');
foreach my $hostgroup (@hostgroups) {
my @values = ( $group{'group_id'}, $hostgroups{$hostgroup} );
my $result = StorProc->insert_obj( 'monarch_group_hostgroup', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $query->param('remove_host') ) {
my %hosts = StorProc->get_table_objects('hosts');
my @hosts = $query->param('rem_host_checked');
foreach my $host (@hosts) {
my %where = ( 'group_id' => $group{'group_id'}, 'host_id' => $hosts{$host} );
my $result = StorProc->delete_one_where( 'monarch_group_host', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
my %hostgroups = StorProc->get_table_objects('hostgroups');
my @hostgroups = $query->param('rem_hostgroup_checked');
foreach my $hostgroup (@hostgroups) {
my %where = (
'group_id' => $group{'group_id'},
'hostgroup_id' => $hostgroups{$hostgroup}
);
my $result = StorProc->delete_one_where( 'monarch_group_hostgroup', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $query->param('delete') || $query->param('confirm_delete') ) {
if ( $query->param('yes') ) {
my $result = StorProc->delete_all( 'monarch_groups', 'group_id', $group{'group_id'} );
if ( $result =~ /^Error/ ) { push @errors, $result }
unless (@errors) {
unless ($is_portal) {
my %where = (
'object' => $group{'group_id'},
'type' => 'group_macro'
);
my $result = StorProc->delete_one_where( 'access_list', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
$obj_view = 'deleted';
$refresh_left = 1;
}
}
elsif ( $query->param('no') ) {
$obj_view = 'detail';
}
else {
foreach my $name ( $query->param ) {
unless ( $name eq 'nocache' ) {
$hidden{$name} = $query->param($name);
}
}
$obj_view = 'delete';
}
}
my %docs = Doc->monarch_groups();
my %save = ( 'name' => 'save', 'value' => 'Save' );
my %apply = ( 'name' => 'apply', 'value' => 'Apply' );
my %export = ( 'name' => 'export', 'value' => 'Export' );
my %obj = ();
$form .= Forms->header( $page_title, $session_id, $top_menu, '', $refresh_left );
if ( $obj_view eq 'detail' ) {
$hidden{'obj_view'} = 'detail';
$form .= Forms->group_top( $name, 'detail' );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->text_box( 'Description:', 'description', $group{'description'}, $textsize{'description'},
'', $docs{'description'}, '', $tab++ );
my @members = StorProc->get_contactgroups( 'monarch_group', $group{'group_id'} );
my @nonmembers = StorProc->fetch_list( 'contactgroups', 'name' );
$form .= Forms->group_main( \%group, \%docs, \@members, \@nonmembers, $tab++ );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%save, \%delete, \%rename, \%close, $tab++ );
}
elsif ( $obj_view eq 'macros' ) {
$hidden{'obj_view'} = 'macros';
$form .= Forms->group_top( $name, 'macros' );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->wizard_doc( 'Group macros', $docs{'macros'} );
my %macros = StorProc->get_macros();
my %group_macros = StorProc->get_group_macros( $group{'group_id'} );
foreach my $macro ( keys %macros ) {
if ( $group_macros{$macro} ) { delete $macros{$macro} }
}
$form .= Forms->group_macros( \%macros, \%group_macros, $group{'label_enabled'}, $group{'label'} );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons();
}
elsif ( $obj_view eq 'hosts' ) {
$hidden{'obj_view'} = 'hosts';
$form .= Forms->group_top( $name, 'hosts' );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->wizard_doc( 'Host Assignment', $docs{'assign_hosts'} );
my ( $nonmembers, $members ) = StorProc->get_group_hosts_old( $group{'group_id'} );
my %nonmembers = %{$nonmembers};
my %members = %{$members};
my ( $hostgroup_nonmembers, $hostgroup_members ) = StorProc->get_hostgroups_hosts( $group{'group_id'} );
my %hostgroup_nonmembers = %{$hostgroup_nonmembers};
my %hostgroup_members = %{$hostgroup_members};
$form .= Forms->group_hosts( \%members, \%nonmembers, \%hostgroup_members, \%hostgroup_nonmembers );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons();
}
elsif ( $obj_view eq 'sub_groups' ) {
$hidden{'obj_view'} = 'sub_groups';
$form .= Forms->group_top( $name, 'sub_groups' );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->wizard_doc( 'Sub Groups', $docs{'sub_groups'} );
my %parents_all = StorProc->get_group_parents_all();
my %group_names = StorProc->get_table_objects('monarch_groups');
my %group_hosts = ();
my @order = ();
my %group_child = ();
my %nonmembers = StorProc->get_possible_groups( $group{'name'} );
my ( $group_hosts, $order, $group_child ) =
StorProc->get_group_hosts( $group{'name'}, \%parents_all, \%group_names, \%group_hosts, \@order, \%group_child );
%group_hosts = %{$group_hosts};
@order = @{$order};
%group_child = %{$group_child};
$form .= Forms->group_children( \%group_hosts, \@order, \%group_child, \%nonmembers );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons();
}
elsif ( $obj_view eq 'new' ) {
$form .= Forms->form_top( 'New Monarch Group', Validation->dfv_onsubmit_javascript(), '' );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->text_box( 'Monarch group name:', 'name', $name, $textsize{'name'}, '', $docs{'name'}, '', $tab++ );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%add, \%cancel, $tab++ );
}
elsif ( $obj_view eq 'nagios_cgi' ) {
$hidden{'obj_view'} = 'nagios_cgi';
$hidden{'name'} = $name;
my $step = $query->param('step');
if ( $query->param('next') ) { $step++ }
if ( $query->param('back') ) { $step-- }
$form .= nagios_cgi( $group{'group_id'}, $name );
}
elsif ( $obj_view eq 'nagios_cfg' ) {
$hidden{'obj_view'} = 'nagios_cfg';
$hidden{'name'} = $name;
my $step = $query->param('step');
if ( $query->param('next') ) { $step++ }
if ( $query->param('back') ) { $step-- }
$form .= nagios_cfg( $group{'group_id'}, $name );
}
elsif ( $obj_view eq 'resource_cfg' ) {
$hidden{'obj_view'} = 'resource_cfg';
$hidden{'name'} = $name;
$form .= resource_cfg( $group{'group_id'}, $name );
}
elsif ( $obj_view eq 'pre_flight_test' ) {
$hidden{'obj_view'} = 'pre_flight_test';
$form .= pre_flight($name);
}
elsif ( $obj_view eq 'build_instance' ) {
require MonarchFile;
my ( $files, $errors ) = Files->build_files( $user_acct, $name, 'commit', '', $nagios_ver, $nagios_etc, '', '1', '1' );
my @errors = @{$errors};
my @files = @{$files};
if (@errors) {
$form .= Forms->form_top( 'Build Instance', '', '' );
$form .= Forms->display_hidden( 'Monarch group name:', 'name', $name );
$form .= Forms->form_errors( \@errors );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
else {
my @results = ("Files for the \"$name\" build were generated in $group{'location'} .");
use MonarchDeploy;
push( @results, Deploy->deploy( $name, $group{'location'}, $group{'nagios_etc'}, $monarch_home ) );
$form .= Forms->form_top( 'Build Instance', '', '' );
$form .= Forms->display_hidden( 'Monarch group name:', 'name', $name );
$form .= Forms->form_message( 'Status', \@results, 'row1', 1 );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
}
elsif ( $obj_view eq 'export' ) {
require MonarchFile;
my ( $files, $errors ) =
Files->build_files( $user_acct, $name, 'commit', '1', $nagios_ver, $nagios_etc, "$doc_root/monarch/download", '1' );
my @errors = @{$errors};
my @files = @{$files};
if (@errors) {
$form .= Forms->form_top( 'Export Instance', '', '' );
$form .= Forms->display_hidden( 'Monarch group name:', 'name', $name );
$form .= Forms->form_errors( \@errors );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
else {
my $tarball = pop @files;
my @list = ($tarball);
@files = sort @files;
push( @list, @files );
my $server = $ENV{'SERVER_NAME'};
$form .= Forms->header( $page_title, $session_id, $top_menu );
$form .= Forms->table_download_links( "$doc_root/monarch/download", \@list, $server );
}
}
elsif ( $obj_view eq 'delete' ) {
$form .= Forms->header( $page_title, $session_id, $top_menu );
$form .= Forms->form_top( 'Groups', '', '' );
$form .= Forms->wizard_doc( 'Remove group?', $name );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%yes, \%no, $tab++ );
}
elsif ( $obj_view eq 'rename' ) {
$form .= Forms->form_top( 'Rename Group', Validation->dfv_onsubmit_javascript(), '' );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->display_hidden( 'Monarch group name:', 'name', $name );
$form .= Forms->text_box( 'Rename to:', 'new_name', '', $textsize{'name'}, '', '', '', $tab++ );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%rename, \%cancel, $tab++ );
}
elsif ( $obj_view eq 'saved' ) {
$form .= Forms->group_top( $name, '' );
$form .= Forms->display_hidden( 'Saved:', '', $message );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%close, $tab++ );
}
return $form;
}
#
############################################################################
# Build instances
#
# FIX THIS: This code construction works, but perhaps would be better constructed
# as an Ajax-enabled application, so progress is reported to the user as it occurs.
sub build_instances() {
my $obj_view = $query->param('obj_view');
my $form = undef;
my $build_form = undef;
@errors = ();
my %groups = ();
my %full_monarch_groups = StorProc->fetch_all('monarch_groups');
if ( defined( $full_monarch_groups{'error'} ) && $full_monarch_groups{'error'} =~ /^Error/ ) {
push @errors, $full_monarch_groups{'error'};
delete $full_monarch_groups{'error'};
}
else {
foreach my $group_id ( keys %full_monarch_groups ) {
$groups{ $full_monarch_groups{$group_id}[1] } = $full_monarch_groups{$group_id}[2];
}
}
if ( $query->param('build') || $query->param('preflight') || $query->param('deploy') ) {
my @groups = $query->param('group');
if ( scalar @groups == 0 ) {
push @errors, 'You have not selected any groups for which to build instances.';
}
else {
## attempt to build instances for all the selected groups, and to collect errors for them
my %have_group = ();
foreach my $group_name (@groups) {
$have_group{$group_name} = 1;
}
my %group_props = ();
foreach my $group_id ( keys %full_monarch_groups ) {
my $group_name = $full_monarch_groups{$group_id}[1];
if ( $have_group{$group_name} ) {
$group_props{$group_name}{'location'} = $full_monarch_groups{$group_id}[3];
my %group_data = StorProc->parse_xml( $full_monarch_groups{$group_id}[5] );
$group_props{$group_name}{'nagios_etc'} = $group_data{'nagios_etc'};
}
}
my $file_errors = 0;
foreach my $group_name ( sort keys %group_props ) {
require MonarchFile;
my $files;
my $errors;
## FIX THIS: account for all cases when building files: build, preflight, deploy
## if ( $query->param('deploy') ) {
( $files, $errors ) =
Files->build_files( $user_acct, $group_name, 'commit', '', $nagios_ver, $nagios_etc, '', '1', '1' );
## }
## else {
## FIX THIS: validate that all the arguments here are correct, and validate that
## this generation of files will be used during a subsequent pre-flight operation
## ( $files, $errors ) =
## Files->build_files( $user_acct, $group_name, 'preflight', '', $nagios_ver, $nagios_etc, "$monarch_home/workspace", '' );
## }
my @file_errors = @{$errors};
if (@file_errors) {
$build_form .= Forms->wizard_doc("Monarch group: $group_name");
$build_form .= Forms->form_errors( \@file_errors );
$file_errors = 1;
}
}
if ($file_errors) {
## FIX THIS: test this: where will the detailed errors show up?
if ( $query->param('deploy') ) {
push @errors, 'Deploying will not be attempted due to the build errors below.';
}
elsif ( $query->param('preflight') ) {
push @errors, 'Preflight will not be attempted due to the build errors below.';
}
else {
push @errors, 'Build errors occurred; see below.';
}
}
else {
## FIX THIS: perhaps stop the deploying of additional groups if we can detect errors along the way
foreach my $group_name ( sort keys %group_props ) {
my @results = ("Files for the \"$group_name\" build were generated in $group_props{$group_name}{'location'} .");
if ( $query->param('preflight') ) {
## FIX THIS: run a pre-flight operation, but don't re-build the files as part of this action;
## work out how that affects our need to synchronize with other pre-flights, commits, and feeders
## FIX THIS: fit the form-building cleanly into the on-screen output
## $build_form .= pre_flight($name);
}
if ( $query->param('deploy') ) {
use MonarchDeploy;
push(
@results,
Deploy->deploy(
$group_name,
$group_props{$group_name}{'location'},
$group_props{$group_name}{'nagios_etc'},
$monarch_home
)
);
}
$build_form .= Forms->wizard_doc("Monarch group: $group_name");
$build_form .= Forms->form_message( 'Status', \@results, 'row1', 1 );
}
}
$obj_view = 'build';
}
}
elsif ( $query->param('close') || $query->param('continue') ) {
$form .= Forms->header( $page_title, $session_id, $top_menu );
$obj_view = 'close';
}
$form .= Forms->header( $page_title, $session_id, $top_menu, '', $refresh_left );
if ( defined($obj_view) && $obj_view eq 'build' ) {
$form .= Forms->form_top( 'Build Instances', '', '' );
if (@errors) { $form .= Forms->form_message( '', \@errors, 'error' ) }
if ($build_form) { $form .= $build_form }
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%close, $tab++ );
}
elsif ( !defined($obj_view) || $obj_view ne 'close' ) {
$form .= Forms->form_top( 'Build Instances', '', '' );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->form_groups( \%groups, $tab++ );
$form .= Forms->hidden( \%hidden );
my %build = ( 'name' => 'build', 'value' => 'Build' );
my %preflight = ( 'name' => 'preflight', 'value' => 'Build and Pre-Flight' );
my %deploy = ( 'name' => 'deploy', 'value' => 'Build and Deploy' );
if ( scalar keys %groups ) {
## FIX THIS: put back the pre-flight option, when we have it working
## $form .= Forms->form_bottom_buttons( \%build, \%preflight, \%deploy, \%close, $tab++ );
$form .= Forms->form_bottom_buttons( \%build, \%deploy, \%close, $tab++ );
}
else {
$form .= Forms->form_bottom_buttons( \%close, $tab++ );
}
}
return $form;
}
#
############################################################################
# Macros
#
sub macros() {
my $form = undef;
my $name = $query->param('name');
my $rename_macro = undef;
my $saved = undef;
my $are_you_sure = undef;
my %save_macros = ();
my @remove_macros = ();
foreach my $qname ( $query->param ) {
if ( $qname =~ /rename_(\S+)/ ) {
$rename_macro = 1;
$name = $1;
}
elsif ( $qname =~ /remove_(\S+)/ ) {
push @remove_macros, $1;
}
elsif ( $qname =~ /value_(\S+)/ ) {
$save_macros{$1}{'value'} = $query->param($qname);
}
elsif ( $qname =~ /description_(\S+)/ ) {
$save_macros{$1}{'description'} = $query->param($qname);
}
}
if ( $query->param('add') ) {
$name =~ s/^\s+|\s+$//g;
my %macro = StorProc->fetch_one( 'monarch_macros', 'name', $name );
if ( $name =~ /\s|\$|!/ ) {
push @errors, "Check the new macro name (name = \"$name\"). Macro names cannot contain illegal characters.";
}
elsif ( $name && (!defined( $macro{'name'} ) || $macro{'name'} ne $name) ) {
my $description = $query->param('description');
my $value = $query->param('value');
my @values = ( \undef, $name, $value, $description );
my $result = StorProc->insert_obj( 'monarch_macros', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
push @errors, "Check the new macro name (name = \"$name\"). It is either blank or this macro already exists.";
}
}
elsif ( $query->param('save') ) {
foreach my $macro ( keys %save_macros ) {
my %values = (
'description' => $save_macros{$macro}{'description'},
'value' => $save_macros{$macro}{'value'}
);
my $result = StorProc->update_obj( 'monarch_macros', 'name', $macro, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
unless (@errors) { $saved = "All changes accepted." }
}
elsif ( $query->param('rename') ) {
$rename_macro = 1;
my $new_name = $query->param('new_name');
$new_name =~ s/^\s+|\s+$//g;
my %macro = StorProc->fetch_one( 'monarch_macros', 'name', $new_name );
if ( $new_name =~ /\s|\$|!/ ) {
push @errors, "Check the new macro name (name = \"$new_name\"). Macro names cannot contain illegal characters.";
}
elsif ( $new_name && !$macro{'name'} ) {
my %values = ( 'name' => $new_name );
my $result = StorProc->update_obj( 'monarch_macros', 'name', $name, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
push @errors, "Check the new macro name (name = \"$new_name\"). It is either blank or this macro already exixts.";
}
unless (@errors) { $rename_macro = undef }
}
elsif ( $query->param('remove') || $query->param('are_you_sure') ) {
unless ( $query->param('no') ) {
if ( $query->param('yes') ) {
foreach my $macro (@remove_macros) {
my $result = StorProc->delete_all( 'monarch_macros', 'name', $macro );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
else {
$hidden{'remove'} = 1;
my @checked = $query->param('macro_checked');
$are_you_sure = "Are you sure you want to remove the following macros from all groups and service checks?";
foreach my $macro (@checked) {
$hidden{"remove_$macro"} = 1;
$are_you_sure .= "
$macro";
}
}
}
}
if ( $query->param('close') || $query->param('continue') ) {
$form .= Forms->header( $page_title, $session_id, $top_menu );
}
elsif ($rename_macro) {
$form .= Forms->header( $page_title, $session_id, $top_menu );
$form .= Forms->form_top( 'Rename Macro', Validation->dfv_onsubmit_javascript(), '' );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->display_hidden( 'Macro name:', 'name', $name );
$form .= Forms->text_box( 'Rename to:', 'new_name', '', $textsize{'name'}, '', '', '', $tab++ );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%rename, \%cancel, $tab++ );
}
elsif ($are_you_sure) {
$form .= Forms->header( $page_title, $session_id, $top_menu );
$form .= Forms->form_top( 'Macros', '', '' );
$form .= Forms->wizard_doc( 'Remove macros', $are_you_sure );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%yes, \%no, $tab++ );
}
elsif ($saved) {
$form .= Forms->header( $page_title, $session_id, $top_menu );
$form .= Forms->form_top( 'Macros', '', '' );
$form .= Forms->display_hidden( 'Saved:', '', $saved );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
else {
my %docs = Doc->monarch_macros();
$form .= Forms->header( $page_title, $session_id, $top_menu );
$form .= Forms->form_top( 'Macros', '', '' );
if (@errors) { $form .= Forms->form_errors( \@errors ) }
$form .= Forms->wizard_doc( 'Group macros', $docs{'macros'} );
my %macros = StorProc->get_macros();
$form .= Forms->macros( \%macros, $tab++ );
$form .= Forms->hidden( \%hidden );
$form .= Forms->form_bottom_buttons( \%save, \%remove, \%close, $tab++ );
}
return $form;
}
#
############################################################################
# Nagios cgi
#
sub nagios_cgi($$) {
my $gid = shift;
my $gname = shift;
my %checks = ();
my %objects = ();
my $step = $query->param('step');
if (defined $step) {
if ( $step eq '1' ) {
%checks = ( 'show_context_help' => '0' );
}
elsif ( $step eq '2' ) {
%checks = (
'use_authentication' => '0',
'lock_author_names' => '0'
);
}
}
my %layout_val = (
'User-defined coordinates' => '-zero-',
'Depth_layers' => '1',
'Collapsed tree' => '2',
'Balanced tree' => '3',
'Circular' => '4',
'Circular (Mark Up)' => '5',
'Circular (Balloon)' => '6'
);
my %val_layout = (
'-zero-' => 'User-defined coordinates',
'1' => 'Depth_layers',
'2' => 'Collapsed tree',
'3' => 'Balanced tree',
'4' => 'Circular',
'5' => 'Circular (Mark Up)',
'6' => 'Circular (Balloon)'
);
if ( $query->param('next') ) {
my %nagios_set = ();
if ($gid) {
my %where = ( 'group_id' => $gid, 'name' => 'physical_html_path' );
%nagios_set = StorProc->fetch_one_where( 'monarch_group_props', \%where );
}
else {
%nagios_set = StorProc->fetch_one( 'setup', 'name', 'physical_html_path' );
}
if ( $nagios_set{'name'} ) {
my %nag_defined = ();
if ($gid) {
# GWMON-4818: monarch_group_props contains duplicate entries for nagios_cgi and nagios_cfg per group.
# Need to loop through hash of table contents to eliminate duplicate entries.
my %unique_props = ();
my %where = ( 'group_id' => $gid, 'type' => 'nagios_cgi' );
my %group_prop_hash = StorProc->fetch_list_hash_array( 'monarch_group_props', \%where );
# process the id's in decending order to keep the latest values saved
my @keys = keys %group_prop_hash;
foreach my $id ( sort { $b <=> $a } @keys ) {
if ( $unique_props{ $group_prop_hash{$id}[2] } ) {
%where = ( 'prop_id' => $id );
my $res = StorProc->delete_one_where( 'monarch_group_props', \%where );
}
else {
$unique_props{ $group_prop_hash{$id}[2] } = 1;
$nag_defined{ $group_prop_hash{$id}[2] } = 1;
}
}
}
else {
my %where = ( 'type' => 'nagios_cgi' );
%nag_defined = StorProc->fetch_list_hash_array( 'setup', \%where );
}
foreach my $name ( $query->param ) {
unless ( $name =~ /^next$|user_acct|^obj$|^nocache$|^step$|^top_menu$|^update_main$|^view$/ ) {
my $val = undef;
if ( $name =~ /layout/ ) {
$val = $query->param($name);
$val = $layout_val{$val};
}
elsif ( defined $checks{$name} ) {
$checks{$name} = '1';
}
else {
$val = $query->param($name);
}
if ($gid) {
if ( $nag_defined{$name} ) {
my %where = (
'group_id' => $gid,
'type' => 'nagios_cgi',
'name' => $name
);
my %values = ( 'value' => $val );
my $result = StorProc->update_obj_where( 'monarch_group_props', \%values, \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my @values = ( \undef, $gid, $name, 'nagios_cgi', $val );
my $result = StorProc->insert_obj( 'monarch_group_props', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
else {
if ( $nag_defined{$name} ) {
my %values = ( 'value' => $val );
my $result = StorProc->update_obj( 'setup', 'name', $name, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my @values = ( $name, 'nagios_cgi', $val );
my $result = StorProc->insert_obj( 'setup', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
}
foreach my $name ( keys %checks ) {
if ($gid) {
if ( $nag_defined{$name} ) {
my %where = (
'group_id' => $gid,
'type' => 'nagios_cgi',
'name' => $name
);
my %values = ( 'value' => $checks{$name} );
my $result = StorProc->update_obj_where( 'monarch_group_props', \%values, \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my @values = ( \undef, $gid, $name, 'nagios_cgi', $checks{$name} );
my $result = StorProc->insert_obj( 'monarch_group_props', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
else {
if ( $nag_defined{$name} ) {
my %values = ( 'value' => $checks{$name} );
my $result = StorProc->update_obj( 'setup', 'name', $name, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my @values = ( $name, 'nagios_cgi', $checks{$name} );
my $result = StorProc->insert_obj( 'setup', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
}
else {
my %nagios_defaults = StorProc->cgi_defaults();
foreach my $name ( keys %nagios_defaults ) {
if ($gid) {
my @values = ( \undef, $gid, $name, 'nagios_cgi', $nagios_defaults{$name} );
my $result = StorProc->insert_obj( 'monarch_group_props', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my @values = ( $name, 'nagios_cgi', $nagios_defaults{$name} );
my $result = StorProc->insert_obj( 'setup', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
$step = 0;
}
unless (@errors) {
if ( $step eq '0' ) {
$step = 1;
}
elsif ( $step eq '1' ) {
$step = 2;
}
elsif ( $step eq '2' ) {
$step = 'saved';
}
}
}
elsif ( $query->param('back') ) {
$step = $step - 1;
}
elsif ( $query->param('sync') ) {
my %where = ( 'type' => 'nagios_cgi' );
my %main_object = StorProc->fetch_list_hash_array( 'setup', \%where );
%where = ( 'group_id' => $gid, 'type' => 'nagios_cgi' );
my $result = StorProc->delete_one_where( 'monarch_group_props', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
foreach my $object ( keys %main_object ) {
my @vals = ( \undef, $gid, $main_object{$object}[0], 'nagios_cgi', $main_object{$object}[2] );
my $result = StorProc->insert_obj( 'monarch_group_props', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $query->param('set_defaults') ) {
my %nagios_defaults = StorProc->cgi_defaults();
if ($gid) {
my %where = ( 'group_id' => $gid, 'type' => 'nagios_cgi' );
my $result = StorProc->delete_one_where( 'monarch_group_props', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my $result = StorProc->delete_all( 'setup', 'type', 'nagios_cgi' );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
foreach my $name ( keys %nagios_defaults ) {
if ($gid) {
my @vals = ( \undef, $gid, $name, 'nagios_cgi', $nagios_defaults{$name} );
my $result = StorProc->insert_obj( 'monarch_group_props', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my @values = ( $name, 'nagios_cgi', $nagios_defaults{$name} );
my $result = StorProc->insert_obj( 'setup', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
$step = 1;
}
elsif ( $query->param('upload') ) {
$step = 'upload';
my $file = $query->param('upload_file');
if ( $file =~ /cgi\.cfg/ ) {
my ($filedata, $errs) = StorProc->upload( '/tmp', $file );
my @errs = @$errs;
if (@errs) { push @errors, @errs }
unless (@errors) {
my @errs = StorProc->import_nagios_cgi($gid, $file, $filedata, 1);
if (@errs) { push( @errors, @errs ) }
$step = 1;
}
}
elsif ($file) {
push @errors, "Invalid file type \"$file\". Filename must contain \"cgi.cfg\".";
}
}
elsif ( $query->param('load_nagios_cgi') ) {
@errors = StorProc->load_nagios_cgi($nagios_etc);
$step = 1;
}
elsif ( defined($task) && $task eq 'view_edit' ) {
$step = 1;
}
%next = ( 'name' => 'next', 'value' => 'Save and Next >>' );
if ($gid) {
%objects = StorProc->get_group_cgi($gid);
}
else {
my %where = ( 'type' => 'nagios_cgi' );
%objects = StorProc->fetch_list_hash_array( 'setup', \%where );
}
my %docs = Doc->cgi_cfg();
my $page = undef;
my $form_title = 'Nagios CGI Configuration';
if ($gid) { $form_title = "$gname Nagios CGI Configuration" }
unless ($step) { $step = 1 }
if ( $step eq '1' ) {
$hidden{'step'} = 1;
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( "$form_title Page 1", '' );
if (@errors) { $page .= Forms->form_errors( \@errors ) }
$page .= Forms->text_box(
'Physical HTML path:',
'physical_html_path', $objects{'physical_html_path'}[2],
$textsize{'long_name'}, '', $docs{'physical_html_path'},
'', $tab++
);
$page .= Forms->text_box(
'URL HTML path:',
'url_html_path', $objects{'url_html_path'}[2],
$textsize{'long_name'}, '', $docs{'url_html_path'}, '', $tab++
);
$page .= Forms->text_box( 'Refresh rate:', 'refresh_rate', $objects{'refresh_rate'}[2], '7', '', $docs{'refresh_rate'}, '', $tab++ );
$page .= Forms->checkbox(
'Context sensitive help',
'show_context_help',
$objects{'show_context_help'}[2],
$docs{'show_context_help'},
'', $tab++
);
$page .= Forms->text_box(
'Nagios process check command:',
'nagios_check_command', $objects{'nagios_check_command'}[2],
$textsize{'long_name'}, '', $docs{'nagios_check_command'},
'', $tab++
);
$page .= Forms->text_box( 'Ping syntax:', 'ping_syntax', $objects{'ping_syntax'}[2],
$textsize{'long_name'}, '', $docs{'ping_syntax'}, '', $tab++ );
$page .= Forms->text_box(
'Statusmap background image:',
'statusmap_background_image', $objects{'statusmap_background_image'}[2],
$textsize{'long_name'}, '', $docs{'statusmap_background_image'},
'', $tab++
);
my @options = (
'User-defined coordinates',
'Depth_layers',
'Collapsed tree',
'Balanced tree',
'Circular',
'Circular (Mark Up)',
'Circular (Balloon)'
);
$objects{'default_statusmap_layout'}[2] = defined( $objects{'default_statusmap_layout'}[2] ) ?
$val_layout{ $objects{'default_statusmap_layout'}[2] } : undef;
$page .= Forms->list_box(
'Default statusmap layout:',
'default_statusmap_layout', \@options, $objects{'default_statusmap_layout'}[2],
'', $docs{'default_statusmap_layout'},
'', $tab++
);
@options = ( 'Collapsed tree', 'Balanced tree', 'Circular' );
$objects{'default_statuswrl_layout'}[2] = defined( $objects{'default_statuswrl_layout'}[2] ) ?
$val_layout{ $objects{'default_statuswrl_layout'}[2] } : undef;
$page .= Forms->list_box(
'Default statuswrl layout:',
'default_statuswrl_layout', \@options, $objects{'default_statuswrl_layout'}[2],
'', $docs{'default_statuswrl_layout'},
'', $tab++
);
$page .= Forms->text_box(
'Status wrl include:',
'statuswrl_include', $objects{'statuswrl_include'}[2],
$textsize{'long_name'}, '', $docs{'statuswrl_include'},
'', $tab++
);
$page .= Forms->text_box(
'Host unreachable sound:',
'host_unreachable_sound', $objects{'host_unreachable_sound'}[2],
$textsize{'long_name'}, '', $docs{'sound_options'}, '', $tab++
);
$page .=
Forms->text_box( 'Host down sound:', 'host_down_sound', $objects{'host_down_sound'}[2], $textsize{'long_name'}, '', '', '', $tab++ );
$page .= Forms->text_box(
'Service critical sound:',
'service_critical_sound', $objects{'service_critical_sound'}[2],
$textsize{'long_name'}, '', '', '', $tab++
);
$page .= Forms->text_box(
'Service warning sound:',
'service_warning_sound', $objects{'service_warning_sound'}[2],
$textsize{'long_name'}, '', '', '', $tab++
);
$page .= Forms->text_box(
'Service unknown sound:',
'service_unknown_sound', $objects{'service_unknown_sound'}[2],
$textsize{'long_name'}, '', '', '', $tab++
);
$page .= Forms->hidden( \%hidden );
if ($gid) {
$page .= Forms->form_bottom_buttons( \%default, \%sync, \%upload, \%next, $tab++ );
}
else {
%upload = ( 'name' => 'load_nagios_cgi', 'value' => 'Load From File' );
$page .= Forms->form_bottom_buttons( \%default, \%upload, \%next, $tab++ );
}
}
elsif ( $step eq '2' ) {
$hidden{'step'} = 2;
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( "$form_title Page 2", '' );
if (@errors) { $page .= Forms->form_errors( \@errors ) }
$page .= Forms->checkbox(
'Use authentication:',
'use_authentication',
$objects{'use_authentication'}[2],
$docs{'use_authentication'},
'', $tab++
);
$page .= Forms->text_box(
'Default user name:',
'default_user_name', $objects{'default_user_name'}[2],
$textsize{'short_name'}, '', $docs{'default_user_name'},
'', $tab++
);
$page .= Forms->text_area(
'Configuration Information Access:',
'authorized_for_configuration_information',
$objects{'authorized_for_configuration_information'}[2],
'3', '80', '', $docs{'authorized_for_configuration_information'},
'', $tab++
);
$page .= Forms->text_area(
'System/Process Information Access:',
'authorized_for_system_information',
$objects{'authorized_for_system_information'}[2],
'3', '80', '', $docs{'authorized_for_system_information'},
'', $tab++
);
$page .= Forms->text_area(
'System/Process Command Access:',
'authorized_for_system_commands',
$objects{'authorized_for_system_commands'}[2],
'3', '80', '', $docs{'authorized_for_system_commands'},
'', $tab++
);
$page .= Forms->text_area(
'Global Host Information Access:',
'authorized_for_all_hosts', $objects{'authorized_for_all_hosts'}[2],
'3', '80', '', $docs{'authorized_for_all_hosts'},
'', $tab++
);
$page .= Forms->text_area(
'Global Host Command Access:',
'authorized_for_all_host_commands',
$objects{'authorized_for_all_host_commands'}[2],
'3', '80', '', $docs{'authorized_for_all_host_commands'},
'', $tab++
);
$page .= Forms->text_area(
'Global Service Information Access:',
'authorized_for_all_services', $objects{'authorized_for_all_services'}[2],
'3', '80', '', $docs{'authorized_for_all_services'},
'', $tab++
);
$page .= Forms->text_area(
'Global Service Command Access:',
'authorized_for_all_service_commands',
$objects{'authorized_for_all_service_commands'}[2],
'3', '80', '', $docs{'authorized_for_all_service_commands'},
'', $tab++
);
if ( $nagios_ver eq '3.x' ) {
$page .= Forms->checkbox(
'Lock author names:',
'lock_author_names',
$objects{'lock_author_names'}[2],
$docs{'lock_author_names'},
'', $tab++
);
}
$page .= Forms->hidden( \%hidden );
%save = ( 'name' => 'next', 'value' => 'Save and Done' );
$page .= Forms->form_bottom_buttons( \%back, \%save, $tab++ );
}
elsif ( $step eq 'upload' ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top_file( "$form_title Upload", '' );
if (@errors) { $page .= Forms->form_errors( \@errors ) }
$page .= Forms->wizard_doc('Upload Nagios CGI configuration file',
"Select the cgi.cfg file you wish to import. The set of values in your file will replace the complete set of Nagios CGI values for the \"$gname\" group.");
$page .= Forms->form_file( $tab++ );
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%upload, \%cancel, $tab++ );
}
elsif ( $step eq 'saved' ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( "$form_title", '' );
my @message = ("Changes to Nagios CGI configuration completed.");
$page .= Forms->form_message( 'Saved:', \@message, 'row1' );
delete $hidden{'task'};
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
return $page;
}
#
############################################################################
# Nagios main cfg
#
sub nagios_cfg($$) {
my $gid = shift;
my $gname = shift;
my %checks = ();
my %objects = ();
my %misc_vals = ();
my $misc_name = '';
my $misc_value= '';
my $step = $query->param('step');
if (defined $step) {
if ( $step eq '1' ) {
%checks = (
'aggregate_status_updates' => '0',
'enable_notifications' => '0',
'execute_service_checks' => '0',
'accept_passive_service_checks' => '0',
'execute_host_checks' => '0',
'accept_passive_host_checks' => '0',
'enable_event_handlers' => '0',
'check_external_commands' => '0',
'retain_state_information' => '0',
'use_retained_program_state' => '0',
'use_retained_scheduling_info' => '0'
);
}
elsif ( $step eq '2' ) {
%checks = (
'use_syslog' => '0',
'log_notifications' => '0',
'log_host_retries' => '0',
'log_service_retries' => '0',
'log_event_handlers' => '0',
'log_initial_states' => '0',
'log_external_commands' => '0',
'log_passive_service_checks' => '0',
'log_passive_checks' => '0',
'auto_reschedule_checks' => '0',
'translate_passive_host_checks' => '0',
'passive_host_checks_are_soft' => '0',
'use_aggressive_host_checking' => '0',
'use_large_installation_tweaks' => '0',
'enable_environment_macros' => '0',
'child_processes_fork_twice' => '0',
'free_child_process_memory' => '0'
);
}
elsif ( $step eq '3' ) {
%checks = (
'enable_flap_detection' => '0',
'obsess_over_services' => '0',
'obsess_over_hosts' => '0',
'process_performance_data' => '0'
);
}
elsif ( $step eq '4' ) {
%checks = (
'check_for_orphaned_services' => '0',
'check_service_freshness' => '0',
'check_host_freshness' => '0',
'use_regexp_matching' => '0',
'use_true_regexp_matching' => '0'
);
}
}
if ( $query->param('next') ) {
my %nagios_set = ();
if ($gid) {
my %where = ( 'group_id' => $gid, 'name' => 'log_file' );
%nagios_set = StorProc->fetch_one_where( 'monarch_group_props', \%where );
}
else {
%nagios_set = StorProc->fetch_one( 'setup', 'name', 'log_file' );
}
if ( $nagios_set{'name'} ) {
my %nag_defined = ();
if ($gid) {
## GWMON-4818: monarch_group_props contains duplicate entries for nagios_cgi and nagios_cfg per group.
## Need to loop through hash of table contents to eliminate duplicate entries.
my %unique_props = ();
my %where = ( 'group_id' => $gid, 'type' => 'nagios_cfg' );
my %group_prop_hash = StorProc->fetch_list_hash_array( 'monarch_group_props', \%where );
# process the id's in decending order to keep the latest values saved
my @keys = keys %group_prop_hash;
foreach my $id ( sort { $b <=> $a } @keys ) {
if ( $unique_props{ $group_prop_hash{$id}[2] } ) {
%where = ( 'prop_id' => $id );
my $res = StorProc->delete_one_where( 'monarch_group_props', \%where );
}
else {
$unique_props{ $group_prop_hash{$id}[2] } = 1;
$nag_defined{ $group_prop_hash{$id}[2] } = 1;
}
}
}
else {
my %where = ( 'type' => 'nagios' );
%nag_defined = StorProc->fetch_list_hash_array( 'setup', \%where );
}
foreach my $name ( $query->param ) {
unless ( $name =~ /^next$|user_acct|^misc_name$|^misc_value$|^nocache$|^obj$|^step$|^top_menu$|^update_main$|^view$/ ) {
if ( $name =~ /radio_option/ ) {
my $val = $query->param($name);
$name =~ s/radio_option_//;
if ( $val eq 'other' ) {
my $other = "other_$name";
$val = $query->param($other);
}
if ($gid) {
if ( $nag_defined{$name} ) {
my %where = (
'group_id' => $gid,
'type' => 'nagios_cfg',
'name' => $name
);
my %values = ( 'value' => $val );
my $result = StorProc->update_obj_where( 'monarch_group_props', \%values, \%where );
if ( $result =~ /^Error/ ) { push @errors, $result; }
}
else {
my @values = ( \undef, $gid, $name, 'nagios_cfg', $val );
my $result = StorProc->insert_obj( 'monarch_group_props', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result; }
}
}
else {
if ( $nag_defined{$name} ) {
my %values = ( 'value' => $val );
my $result = StorProc->update_obj( 'setup', 'name', $name, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result; }
}
else {
my @values = ( $name, 'nagios', $val );
my $result = StorProc->insert_obj( 'setup', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result; }
}
}
}
else {
if ( defined $checks{$name} ) {
$checks{$name} = '1';
}
else {
my $val = $query->param($name);
if ( $val eq '0' ) { $val = '-zero-' }
## GWMON-9020
$val =~ s/[\n\r]+//g if $name =~ /_perfdata_file_template$/;
if ($gid) {
if ( $name =~ /^\d+$/ ) {
my %values = ( 'value' => $val );
my %where = ( 'prop_id' => $name );
my $result = StorProc->update_obj_where( 'monarch_group_props', \%values, \%where );
if ( $result =~ /^Error/ ) { push @errors, $result; }
}
elsif ( $nag_defined{$name} ) {
my %values = ( 'value' => $val );
my %where = (
'group_id' => $gid,
'type' => 'nagios_cfg',
'name' => $name
);
my $result = StorProc->update_obj_where( 'monarch_group_props', \%values, \%where );
if ( $result =~ /^Error/ ) { push @errors, $result; }
}
else {
my @values = ( \undef, $gid, $name, 'nagios_cfg', $val );
my $result = StorProc->insert_obj( 'monarch_group_props', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result; }
}
}
else {
if ( $name =~ /key\d+.\d+$/ || $nag_defined{$name} ) {
my %values = ( 'value' => $val );
my $result = StorProc->update_obj( 'setup', 'name', $name, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result; }
}
else {
my @values = ( $name, 'nagios', $val );
my $result = StorProc->insert_obj( 'setup', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result; }
}
}
}
}
}
}
foreach my $name ( keys %checks ) {
if ($gid) {
if ( $nag_defined{$name} ) {
my %where = (
'group_id' => $gid,
'type' => 'nagios_cfg',
'name' => $name
);
my %values = ( 'value' => $checks{$name} );
my $result = StorProc->update_obj_where( 'monarch_group_props', \%values, \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my @values = ( \undef, $gid, $name, 'nagios_cfg', $checks{$name} );
my $result = StorProc->insert_obj( 'monarch_group_props', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
else {
if ( $nag_defined{$name} ) {
my %values = ( 'value' => $checks{$name} );
my $result = StorProc->update_obj( 'setup', 'name', $name, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my @values = ( $name, 'nagios', $checks{$name} );
my $result = StorProc->insert_obj( 'setup', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
}
else {
my %nagios_defaults = StorProc->nagios_defaults( $nagios_ver, $is_portal );
foreach my $name ( keys %nagios_defaults ) {
if ($gid) {
my @values = ( \undef, $gid, $name, 'nagios_cfg', $nagios_defaults{$name} );
my $result = StorProc->insert_obj( 'monarch_group_props', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my @values = ( $name, 'nagios', $nagios_defaults{$name} );
my $result = StorProc->insert_obj( 'setup', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
$step = 0;
}
unless (@errors) {
if ( $step eq '0' ) { $step = 1; }
elsif ( $step eq '1' ) { $step = 2; }
elsif ( $step eq '2' ) { $step = 3; }
elsif ( $step eq '3' ) { $step = 4; }
elsif ( $step eq '4' ) { $step = 'saved'; }
}
}
elsif ( $query->param('rem_misc') ) {
my @rem_keys = $query->param('rem_key');
foreach my $key (@rem_keys) {
if ($gid) {
my $result = StorProc->delete_all( 'monarch_group_props', 'prop_id', $key );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my $result = StorProc->delete_all( 'setup', 'name', $key );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
elsif ( $query->param('add_misc') ) {
$misc_name = $query->param('misc_name');
$misc_value = $query->param('misc_value');
$misc_name =~ s/^\s+|\s+$//g;
$misc_value =~ s/^\s+|\s+$//g;
my $alt_misc_value = ( $misc_value eq '0' ) ? '-zero-' : $misc_value;
# FIX THIS: we should probably check for all kinds of illegal object-name characters in the
# directive name and reject the directive if it violates the specified name constraints
# Internal whitespace is probably illegal in downstream usage and it also makes the
# directive impossible to delete, given the current construction of the delete code.
if ($misc_name =~ /\s/) {
push @errors, "A miscellaneous directive name is not allowed to contain whitespace.";
}
elsif ($misc_name ne '') {
if ($gid) {
my %where = ( 'group_id' => $gid, 'name' => $misc_name, 'type' => 'nagios_cfg_misc' );
my @existing = StorProc->fetch_list_where( 'monarch_group_props', 'name', \%where );
if (scalar @existing) {
push @errors, "A miscellaneous directive named '$misc_name' already exists for Group '$gname'.";
}
unless (@errors) {
%where = ( 'group_id' => $gid, 'name' => $misc_name, 'type' => 'nagios_cfg' );
@existing = StorProc->fetch_list_where( 'monarch_group_props', 'name', \%where );
if (scalar @existing) {
push @errors, "The Nagios main configuration for Group '$gname' contains a directive named '$misc_name'; you cannot override that with a miscellaneous directive.";
}
}
unless (@errors) {
%where = ( 'group_id' => $gid, 'name' => $misc_name, 'type' => 'nagios_cgi' );
@existing = StorProc->fetch_list_where( 'monarch_group_props', 'name', \%where );
if (scalar @existing) {
push @errors, "The Nagios CGI configuration for Group '$gname' contains a directive named '$misc_name'; you cannot override that with a miscellaneous directive.";
}
}
unless (@errors) {
my @vals = ( \undef, $gid, $misc_name, 'nagios_cfg_misc', $alt_misc_value );
my $result = StorProc->insert_obj( 'monarch_group_props', \@vals );
if ( $result =~ /^Error/ ) {
push @errors, $result;
}
else {
$misc_name = '';
$misc_value = '';
}
}
}
else {
my @existing = StorProc->fetch_list_start( 'setup', 'name', 'name', $misc_name . 'key' );
if (scalar @existing) {
push @errors, "A miscellaneous directive named '$misc_name' already exists.";
}
unless (@errors) {
my %where = ( 'name' => $misc_name, 'type' => 'nagios' );
@existing = StorProc->fetch_list_where( 'setup', 'name', \%where );
if (scalar @existing) {
push @errors, "The Nagios main configuration contains a directive named '$misc_name'; you cannot override that with a miscellaneous directive.";
}
}
unless (@errors) {
my %where = ( 'name' => $misc_name, 'type' => 'nagios_cgi' );
@existing = StorProc->fetch_list_where( 'setup', 'name', \%where );
if (scalar @existing) {
push @errors, "The Nagios CGI configuration contains a directive named '$misc_name'; you cannot override that with a miscellaneous directive.";
}
}
unless (@errors) {
# We don't need this name suffix above for a miscellaneous directive in a group because
# the monarch_group_props.prop_id field already provides the requisite uniqueness.
my @vals = ( $misc_name . 'key' . rand(), 'nagios_cfg_misc', $alt_misc_value );
my $result = StorProc->insert_obj( 'setup', \@vals );
if ( $result =~ /^Error/ ) {
push @errors, $result;
}
else {
$misc_name = '';
$misc_value = '';
}
}
}
}
}
elsif ( $query->param('back') ) {
$step = $step - 1;
}
elsif ( $query->param('sync') ) {
my %where = ( 'type' => 'nagios' );
my %main_object = StorProc->fetch_list_hash_array( 'setup', \%where );
%where = ( 'group_id' => $gid, 'type' => 'nagios_cfg' );
my $result = StorProc->delete_one_where( 'monarch_group_props', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
foreach my $object ( keys %main_object ) {
my @vals = ( \undef, $gid, $main_object{$object}[0], 'nagios_cfg', $main_object{$object}[2] );
my $result = StorProc->insert_obj( 'monarch_group_props', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $query->param('set_defaults') ) {
my %nagios_defaults = StorProc->nagios_defaults( $nagios_ver, $is_portal );
if ($gid) {
my %where = ( 'group_id' => $gid, 'type' => 'nagios_cfg' );
my $result = StorProc->delete_one_where( 'monarch_group_props', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my $result = StorProc->delete_all( 'setup', 'type', 'nagios' );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
foreach my $name ( keys %nagios_defaults ) {
if ($gid) {
my @vals = ( \undef, $gid, $name, 'nagios_cfg', $nagios_defaults{$name} );
my $result = StorProc->insert_obj( 'monarch_group_props', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my @values = ( $name, 'nagios', $nagios_defaults{$name} );
my $result = StorProc->insert_obj( 'setup', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
$step = 1;
}
elsif ( $query->param('upload') ) {
$step = 'upload';
my $file = $query->param('upload_file');
if ( $file =~ /nagios\.cfg/ ) {
my ($filedata, $errs) = StorProc->upload( '/tmp', $file );
my @errs = @$errs;
if (@errs) { push @errors, @errs }
unless (@errors) {
my @errs = StorProc->import_nagios_cfg($gid, $file, $filedata, 1);
if (@errs) { push( @errors, @errs ) }
$step = 1;
}
}
elsif ($file) {
push @errors, "Invalid file type \"$file\". Filename must contain \"nagios.cfg\".";
}
}
elsif ( $query->param('load_nagios_cfg') ) {
@errors = StorProc->load_nagios_cfg($nagios_etc);
$step = 1;
}
elsif ( defined($task) && $task eq 'view_edit' ) {
$step = 1;
}
%next = ( 'name' => 'next', 'value' => 'Save and Next >>' );
if ($gid) {
%objects = StorProc->get_group_cfg($gid);
}
else {
my %where = ( 'type' => 'nagios' );
%objects = StorProc->fetch_list_hash_array( 'setup', \%where );
}
foreach my $obj ( keys %objects ) { $objects{$obj}[2] =~ s/-zero-/0/ if defined $objects{$obj}[2] }
my %docs = Doc->nagios_cfg();
my %where = ( 'type' => 'other' );
my @commands = StorProc->fetch_list_where( 'commands', 'name', \%where );
my $page = undef;
my $form_title = 'Nagios Main Configuration';
if ($gid) { $form_title = "$gname Nagios Main Configuration" }
unless ($step) { $step = 1 }
if ( $step eq '1' ) {
$hidden{'step'} = 1;
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( "$form_title Page 1", '' );
if (@errors) { $page .= Forms->form_errors( \@errors ) }
$page .= Forms->text_box( 'Log file:', 'log_file', $objects{'log_file'}[2], $textsize{'long_name'}, '', $docs{'log_file'}, '', $tab++ );
if ( $nagios_ver =~ /^[23]\.x$/ ) {
$page .= Forms->text_box(
'Object cache file:',
'object_cache_file', $objects{'object_cache_file'}[2],
$textsize{'long_name'}, '', $docs{'object_cache_file'},
'', $tab++
);
}
if ( $nagios_ver eq '3.x' ) {
$page .= Forms->text_box(
'Precached object file:',
'precached_object_file', $objects{'precached_object_file'}[2],
$textsize{'long_name'}, '', $docs{'precached_object_file'},
'', $tab++
);
}
$page .= Forms->text_box(
'Resource file:',
'resource_file', $objects{'resource_file'}[2],
$textsize{'long_name'}, '', $docs{'resource_file'}, '', $tab++
);
$page .=
Forms->text_box( 'Temp file:', 'temp_file', $objects{'temp_file'}[2], $textsize{'long_name'}, '', $docs{'temp_file'}, '', $tab++ );
$page .= Forms->text_box( 'Status file:', 'status_file', $objects{'status_file'}[2],
$textsize{'long_name'}, '', $docs{'status_file'}, '', $tab++ );
if ( $nagios_ver =~ /^[12]\.x$/ ) {
$page .= Forms->checkbox(
'Aggregated status updates option:',
'aggregate_status_updates',
$objects{'aggregate_status_updates'}[2],
$docs{'aggregate_status_updates'},
'', $tab++
);
}
$page .= Forms->text_box(
'Aggregated status data update interval:',
'status_update_interval', $objects{'status_update_interval'}[2],
'7', '', $docs{'status_update_interval'},
'', $tab++
);
$page .= Forms->text_box( 'Nagios user:', 'nagios_user', $objects{'nagios_user'}[2],
$textsize{'long_name'}, '', $docs{'nagios_user'}, '', $tab++ );
$page .= Forms->text_box(
'Nagios group:',
'nagios_group', $objects{'nagios_group'}[2],
$textsize{'long_name'}, '', $docs{'nagios_group'}, '', $tab++
);
$page .= Forms->checkbox(
'Enable notifications:',
'enable_notifications',
$objects{'enable_notifications'}[2],
$docs{'enable_notifications'},
'', $tab++
);
$page .= Forms->checkbox(
'Execute service checks:',
'execute_service_checks',
$objects{'execute_service_checks'}[2],
$docs{'execute_service_checks'},
'', $tab++
);
$page .= Forms->checkbox(
'Accept passive service checks:',
'accept_passive_service_checks',
$objects{'accept_passive_service_checks'}[2],
$docs{'accept_passive_service_checks'},
'', $tab++
);
if ( $nagios_ver =~ /^[23]\.x$/ ) {
$page .= Forms->checkbox(
'Execute host checks',
'execute_host_checks',
$objects{'execute_host_checks'}[2],
$docs{'execute_host_checks'},
'', $tab++
);
$page .= Forms->checkbox(
'Accept passive host checks',
'accept_passive_host_checks',
$objects{'accept_passive_host_checks'}[2],
$docs{'accept_passive_host_checks'},
'', $tab++
);
}
$page .= Forms->checkbox(
'Enable event handlers:',
'enable_event_handlers',
$objects{'enable_event_handlers'}[2],
$docs{'enable_event_handlers'},
'', $tab++
);
my @list = ( 'n', 'h', 'd', 'w', 'm' );
$page .= Forms->list_box(
'Log rotation method:',
'log_rotation_method', \@list, $objects{'log_rotation_method'}[2],
'', $docs{'log_rotation_method'},
'', $tab++
);
$page .= Forms->text_box(
'Log archive path:',
'log_archive_path', $objects{'log_archive_path'}[2],
$textsize{'long_name'}, '', $docs{'log_archive_path'},
'', $tab++
);
$page .= Forms->checkbox(
'External command check option:',
'check_external_commands',
$objects{'check_external_commands'}[2],
$docs{'check_external_commands'},
'', $tab++
);
$page .= Forms->text_box(
'External command check interval:',
'command_check_interval', $objects{'command_check_interval'}[2],
$textsize{'small'}, '', $docs{'command_check_interval'},
'', $tab++
);
$page .= Forms->text_box(
'External command file:',
'command_file', $objects{'command_file'}[2],
$textsize{'long_name'}, '', $docs{'command_file'}, '', $tab++
);
if ( $nagios_ver =~ /^[12]\.x$/ ) {
$page .= Forms->text_box(
'Downtime file:',
'downtime_file', $objects{'downtime_file'}[2],
$textsize{'long_name'}, '', $docs{'downtime_file'}, '', $tab++
);
$page .= Forms->text_box(
'Comment file:',
'comment_file', $objects{'comment_file'}[2],
$textsize{'long_name'}, '', $docs{'comment_file'}, '', $tab++
);
}
$page .=
Forms->text_box( 'Lock file:', 'lock_file', $objects{'lock_file'}[2], $textsize{'long_name'}, '', $docs{'lock_file'}, '', $tab++ );
$page .= Forms->checkbox(
'State retention option:',
'retain_state_information',
$objects{'retain_state_information'}[2],
$docs{'retain_state_information'},
'', $tab++
);
$page .= Forms->text_box(
'State retention file:',
'state_retention_file', $objects{'state_retention_file'}[2],
$textsize{'long_name'}, '', $docs{'state_retention_file'},
'', $tab++
);
$page .= Forms->text_box(
'Retention update interval:',
'retention_update_interval', $objects{'retention_update_interval'}[2],
$textsize{'small'}, '', $docs{'retention_update_interval'},
'', $tab++
);
$page .= Forms->checkbox(
'Use retained program state:',
'use_retained_program_state',
$objects{'use_retained_program_state'}[2],
$docs{'use_retained_program_state'},
'', $tab++
);
if ( $nagios_ver =~ /^[23]\.x$/ ) {
$page .= Forms->checkbox(
'Use retained scheduling info:',
'use_retained_scheduling_info',
$objects{'use_retained_scheduling_info'}[2],
$docs{'use_retained_scheduling_info'},
'', $tab++
);
}
$page .= Forms->hidden( \%hidden );
if ($gid) {
$page .= Forms->form_bottom_buttons( \%default, \%sync, \%upload, \%next, $tab++ );
}
else {
%upload = ( 'name' => 'load_nagios_cfg', 'value' => 'Load From File' );
$page .= Forms->form_bottom_buttons( \%default, \%upload, \%next, $tab++ );
}
}
elsif ( $step eq '2' ) {
$hidden{'step'} = 2;
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( "$form_title Page 2", '' );
if (@errors) { $page .= Forms->form_errors( \@errors ) }
$page .= Forms->checkbox( 'Syslog logging option:', 'use_syslog', $objects{'use_syslog'}[2], $docs{'use_syslog'}, '', $tab++ );
$page .= Forms->checkbox(
'Notification logging option:',
'log_notifications',
$objects{'log_notifications'}[2],
$docs{'log_notifications'},
'', $tab++
);
$page .= Forms->checkbox(
'Host check retry logging option',
'log_host_retries',
$objects{'log_host_retries'}[2],
$docs{'log_host_retries'},
'', $tab++
);
$page .= Forms->checkbox(
'Service check retry logging option:',
'log_service_retries',
$objects{'log_service_retries'}[2],
$docs{'log_service_retries'},
'', $tab++
);
$page .= Forms->checkbox(
'Event handler logging option',
'log_event_handlers',
$objects{'log_event_handlers'}[2],
$docs{'log_event_handlers'},
'', $tab++
);
$page .= Forms->checkbox(
'Initial states logging option:',
'log_initial_states',
$objects{'log_initial_states'}[2],
$docs{'log_initial_states'},
'', $tab++
);
$page .= Forms->checkbox(
'External command logging option:',
'log_external_commands',
$objects{'log_external_commands'}[2],
$docs{'log_external_commands'},
'', $tab++
);
if ( $nagios_ver eq '1.x' ) {
$page .= Forms->checkbox(
'Log passive service checks:',
'log_passive_service_checks',
$objects{'log_passive_service_checks'}[2],
$docs{'log_passive_service_checks'},
'', $tab++
);
}
else {
$page .= Forms->checkbox(
'Passive check logging option:',
'log_passive_checks',
$objects{'log_passive_checks'}[2],
$docs{'log_passive_checks'},
'', $tab++
);
}
$page .= Forms->list_box(
'Global host event handler:',
'global_host_event_handler', \@commands, $objects{'global_host_event_handler'}[2],
'', $docs{'global_host_event_handler'},
'', $tab++
);
$page .= Forms->list_box(
'Global service event handler:',
'global_service_event_handler',
\@commands, $objects{'global_service_event_handler'}[2],
'', $docs{'global_service_event_handler'},
'', $tab++
);
$page .=
Forms->text_box( 'Sleep time:', 'sleep_time', $objects{'sleep_time'}[2], $textsize{'small'}, '', $docs{'sleep_time'}, '', $tab++ );
if ( $nagios_ver eq '1.x' ) {
$page .= Forms->radio_options(
'Inter check delay method:',
'inter_check_delay_method',
$objects{'inter_check_delay_method'}[2],
$docs{'inter_check_delay_method'}, $tab++
);
}
else {
$page .= Forms->radio_options(
'Service inter check delay method:',
'service_inter_check_delay_method',
$objects{'service_inter_check_delay_method'}[2],
$docs{'service_inter_check_delay_method'}, $tab++
);
$page .= Forms->text_box(
'Max service check spread:',
'max_service_check_spread', $objects{'max_service_check_spread'}[2],
$textsize{'small'}, '', $docs{'max_service_check_spread'},
'', $tab++
);
}
$page .= Forms->radio_options(
'Service interleave factor:',
'service_interleave_factor',
$objects{'service_interleave_factor'}[2],
$docs{'service_interleave_factor'}, $tab++
);
if ( $nagios_ver =~ /^[23]\.x$/ ) {
$page .= Forms->radio_options(
'Host inter check delay method:',
'host_inter_check_delay_method',
$objects{'host_inter_check_delay_method'}[2],
$docs{'host_inter_check_delay_method'}, $tab++
);
$page .= Forms->text_box(
'Max host check spread:',
'max_host_check_spread', $objects{'max_host_check_spread'}[2],
$textsize{'small'}, '', $docs{'max_host_check_spread'},
'', $tab++
);
}
$page .= Forms->text_box(
'Maximum concurrent service checks:',
'max_concurrent_checks', $objects{'max_concurrent_checks'}[2],
$textsize{'small'}, '', $docs{'max_concurrent_checks'},
'', $tab++
);
if ( $nagios_ver =~ /^[12]\.x$/ ) {
$page .= Forms->text_box(
'Service reaper frequency:',
'service_reaper_frequency', $objects{'service_reaper_frequency'}[2],
$textsize{'small'}, '', $docs{'service_reaper_frequency'},
'', $tab++
);
}
if ( $nagios_ver eq '3.x' ) {
$page .= Forms->text_box(
'Check result path:',
'check_result_path', $objects{'check_result_path'}[2],
$textsize{'long_size'}, '', $docs{'check_result_path'},
'', $tab++
);
$page .= Forms->text_box(
'External command buffer slots:',
'external_command_buffer_slots',
$objects{'external_command_buffer_slots'}[2],
$textsize{'small'}, '', $docs{'external_command_buffer_slots'},
'', $tab++
);
$page .= Forms->text_box(
'Check result reaper frequency:',
'check_result_reaper_frequency',
$objects{'check_result_reaper_frequency'}[2],
$textsize{'small'}, '', $docs{'check_result_reaper_frequency'},
'', $tab++
);
$page .= Forms->text_box(
'Max check result reaper time:',
'max_check_result_reaper_time',
$objects{'max_check_result_reaper_time'}[2],
$textsize{'small'}, '', $docs{'max_check_result_reaper_time'},
'', $tab++
);
$page .= Forms->text_box(
'Max check result file age:',
'max_check_result_file_age', $objects{'max_check_result_file_age'}[2],
$textsize{'small'}, '', $docs{'max_check_result_file_age'},
'', $tab++
);
$page .= Forms->checkbox(
'Translate passive host checks:',
'translate_passive_host_checks',
$objects{'translate_passive_host_checks'}[2],
$docs{'translate_passive_host_checks'},
'', $tab++
);
$page .= Forms->checkbox(
'Passive host checks are soft:',
'passive_host_checks_are_soft',
$objects{'passive_host_checks_are_soft'}[2],
$docs{'passive_host_checks_are_soft'},
'', $tab++
);
$page .= Forms->text_box(
'Cached host check horizon:',
'cached_host_check_horizon', $objects{'cached_host_check_horizon'}[2],
$textsize{'small'}, '', $docs{'cached_host_check_horizon'},
'', $tab++
);
$page .= Forms->text_box(
'Cached service check horizon:',
'cached_service_check_horizon',
$objects{'cached_service_check_horizon'}[2],
$textsize{'small'}, '', $docs{'cached_service_check_horizon'},
'', $tab++
);
}
$page .= Forms->checkbox(
'Use aggressive host checking:',
'use_aggressive_host_checking',
$objects{'use_aggressive_host_checking'}[2],
$docs{'use_aggressive_host_checking'},
'', $tab++
);
$page .= Forms->text_box(
'Timing interval length:',
'interval_length', $objects{'interval_length'}[2],
$textsize{'small'}, '', $docs{'interval_length'},
'', $tab++
);
if ( $nagios_ver =~ /^[23]\.x$/ ) {
$page .= Forms->checkbox(
'Auto reschedule checks:',
'auto_reschedule_checks',
$objects{'auto_reschedule_checks'}[2],
$docs{'auto_reschedule_checks'},
'', $tab++
);
$page .= Forms->text_box(
'Auto rescheduling interval:',
'auto_rescheduling_interval', $objects{'auto_rescheduling_interval'}[2],
$textsize{'small'}, '', $docs{'auto_rescheduling_interval'},
'', $tab++
);
$page .= Forms->text_box(
'Auto rescheduling window:',
'auto_rescheduling_window', $objects{'auto_rescheduling_window'}[2],
$textsize{'small'}, '', $docs{'auto_rescheduling_window'},
'', $tab++
);
}
if ( $nagios_ver eq '3.x' ) {
$page .= Forms->wizard_doc( 'Large Installation Tweaks', $docs{'large_installation_tweaks'} );
$page .= Forms->checkbox(
'Use large installation tweaks:',
'use_large_installation_tweaks',
$objects{'use_large_installation_tweaks'}[2],
$docs{'use_large_installation_tweaks'},
'', $tab++
);
$page .= Forms->checkbox(
'Enable environment macros:',
'enable_environment_macros',
$objects{'enable_environment_macros'}[2],
$docs{'enable_environment_macros'},
'', $tab++
);
$page .= Forms->checkbox(
'Child processes fork twice:',
'child_processes_fork_twice',
$objects{'child_processes_fork_twice'}[2],
$docs{'child_processes_fork_twice'},
'', $tab++
);
$page .= Forms->checkbox(
'Free child process memory:',
'free_child_process_memory',
$objects{'free_child_process_memory'}[2],
$docs{'free_child_process_memory'},
'', $tab++
);
}
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%back, \%next, $tab++ );
}
elsif ( $step eq '3' ) {
$hidden{'step'} = 3;
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( "$form_title Page 3", '' );
if (@errors) { $page .= Forms->form_errors( \@errors ) }
$page .= Forms->checkbox(
'Flap detection option:',
'enable_flap_detection',
$objects{'enable_flap_detection'}[2],
$docs{'enable_flap_detection'},
'', $tab++
);
$page .= Forms->text_box(
'Low service flap threshold:',
'low_service_flap_threshold', $objects{'low_service_flap_threshold'}[2],
$textsize{'small'}, '', $docs{'service_flap_detection_thresholds'},
'', $tab++
);
$page .= Forms->text_box(
'High service flap threshold:',
'high_service_flap_threshold', $objects{'high_service_flap_threshold'}[2],
$textsize{'small'}, '', '', '', $tab++
);
$page .= Forms->text_box(
'Low host flap threshold:',
'low_host_flap_threshold', $objects{'low_host_flap_threshold'}[2],
$textsize{'small'}, '', $docs{'host_flap_detection_thresholds'},
'', $tab++
);
$page .= Forms->text_box(
'High host flap threshold:',
'high_host_flap_threshold', $objects{'high_host_flap_threshold'}[2],
$textsize{'small'}, '', '', '', $tab++
);
$page .= Forms->checkbox(
'Soft state dependencies:',
'soft_state_dependencies',
$objects{'soft_state_dependencies'}[2],
$docs{'soft_state_dependencies'},
'', $tab++
);
$page .= Forms->text_box(
'Service check timeout:',
'service_check_timeout', $objects{'service_check_timeout'}[2],
$textsize{'small'}, '', $docs{'timeout_values'}, '', $tab++
);
$page .= Forms->text_box(
'Host check timeout:',
'host_check_timeout', $objects{'host_check_timeout'}[2],
$textsize{'small'}, '', '', '', $tab++
);
$page .= Forms->text_box(
'Event handler timeout:',
'event_handler_timeout', $objects{'event_handler_timeout'}[2],
$textsize{'small'}, '', '', '', $tab++
);
$page .= Forms->text_box(
'Notification timeout:',
'notification_timeout', $objects{'notification_timeout'}[2],
$textsize{'small'}, '', '', '', $tab++
);
$page .= Forms->text_box( 'OCSP timeout:', 'ocsp_timeout', $objects{'ocsp_timeout'}[2], $textsize{'small'}, '', '', '', $tab++ );
if ( $nagios_ver =~ /^[23]\.x$/ ) {
$page .= Forms->text_box( 'OCHP timeout:', 'ochp_timeout', $objects{'ochp_timeout'}[2], $textsize{'small'}, '', '', '', $tab++ );
}
$page .=
Forms->text_box( 'Perfdata timeout:', 'perfdata_timeout', $objects{'perfdata_timeout'}[2], $textsize{'small'}, '', '', '', $tab++ );
$page .= Forms->checkbox(
'Obsess over services:',
'obsess_over_services',
$objects{'obsess_over_services'}[2],
$docs{'obsess_over_services'},
'', $tab++
);
$page .= Forms->text_box(
'OCSP command:',
'ocsp_command', $objects{'ocsp_command'}[2],
$textsize{'long_name'}, '', $docs{'ocsp_command'}, '', $tab++
);
if ( $nagios_ver =~ /^[23]\.x$/ ) {
$page .= Forms->checkbox(
'Obsess over hosts:',
'obsess_over_hosts',
$objects{'obsess_over_hosts'}[2],
$docs{'obsess_over_hosts'},
'', $tab++
);
$page .= Forms->text_box(
'OCHP command:',
'ochp_command', $objects{'ochp_command'}[2],
$textsize{'long_name'}, '', $docs{'ochp_command'}, '', $tab++
);
}
$page .= Forms->checkbox(
'Process performance data:',
'process_performance_data',
$objects{'process_performance_data'}[2],
$docs{'process_performance_data'},
'', $tab++
);
$page .= Forms->list_box(
'Host perfdata command:',
'host_perfdata_command', \@commands, $objects{'host_perfdata_command'}[2],
'', $docs{'host_perfdata_command'},
'', $tab++
);
$page .= Forms->list_box(
'Service perfdata command:',
'service_perfdata_command', \@commands, $objects{'service_perfdata_command'}[2],
'', $docs{'service_perfdata_command'},
'', $tab++
);
if ( $nagios_ver =~ /^[23]\.x$/ ) {
$page .= Forms->text_box(
'Host performance data file:',
'host_perfdata_file', $objects{'host_perfdata_file'}[2],
$textsize{'long_name'}, '', $docs{'host_perfdata_file'},
'', $tab++
);
$page .= Forms->text_box(
'Service performance data file:',
'service_perfdata_file', $objects{'service_perfdata_file'}[2],
$textsize{'long_name'}, '', $docs{'service_perfdata_file'},
'', $tab++
);
## GWMON-9020
my $host_temp = $objects{'host_perfdata_file_template'}[2];
$host_temp = '' if not defined $host_temp;
$page .= Forms->text_area(
'Host performance data file template:',
'host_perfdata_file_template', $host_temp,
int((length($host_temp) + 10) / $textsize{'long_name'}) + 1,
$textsize{'long_name'}, '', $docs{'host_perfdata_file_template'},
'', $tab++
);
my $serv_temp = $objects{'service_perfdata_file_template'}[2];
$serv_temp = '' if not defined $serv_temp;
$page .= Forms->text_area(
'Service performance data file template:',
'service_perfdata_file_template', $serv_temp,
int((length($serv_temp) + 10) / $textsize{'long_name'}) + 1,
$textsize{'long_name'}, '', $docs{'service_perfdata_file_template'},
'', $tab++
);
my @opts = ( 'a', 'w' );
$page .= Forms->list_box(
'Host performance data file mode:',
'host_perfdata_file_mode', \@opts, $objects{'host_perfdata_file_mode'}[2],
'', $docs{'host_perfdata_file_mode'},
'', $tab++
);
$page .= Forms->list_box(
'Service performance data file mode:',
'service_perfdata_file_mode', \@opts, $objects{'service_perfdata_file_mode'}[2],
'', $docs{'service_perfdata_file_mode'},
'', $tab++
);
$page .= Forms->text_box(
'Host performance data file processing interval:',
'host_perfdata_file_processing_interval',
$objects{'host_perfdata_file_processing_interval'}[2],
$textsize{'small'}, '', $docs{'host_perfdata_file_processing_interval'},
'', $tab++
);
$page .= Forms->text_box(
'Service performance data file processing interval:',
'service_perfdata_file_processing_interval',
$objects{'service_perfdata_file_processing_interval'}[2],
$textsize{'small'}, '', $docs{'service_perfdata_file_processing_interval'},
'', $tab++
);
$page .= Forms->list_box(
'Host performance data file processing command:',
'host_perfdata_file_processing_command',
\@commands, $objects{'host_perfdata_file_processing_command'}[2],
'', $docs{'host_perfdata_file_processing_command'},
'', $tab++
);
$page .= Forms->list_box(
'Service performance data file processing command:',
'service_perfdata_file_processing_command',
\@commands, $objects{'service_perfdata_file_processing_command'}[2],
'', $docs{'service_perfdata_file_processing_command'},
'', $tab++
);
}
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%back, \%next, $tab++ );
}
elsif ( $step eq '4' ) {
$hidden{'step'} = 4;
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( "$form_title Page 4", '' );
if (@errors) { $page .= Forms->form_errors( \@errors ) }
$page .= Forms->checkbox(
'Check for orphaned services:',
'check_for_orphaned_services',
$objects{'check_for_orphaned_services'}[2],
$docs{'check_for_orphaned_services'},
'', $tab++
);
$page .= Forms->checkbox(
'Check service freshness:',
'check_service_freshness',
$objects{'check_service_freshness'}[2],
$docs{'check_service_freshness'},
'', $tab++
);
$page .= Forms->text_box(
'Service freshness check interval:',
'freshness_check_interval', $objects{'freshness_check_interval'}[2],
$textsize{'small'}, '', $docs{'freshness_check_interval'},
'', $tab++
);
if ( $nagios_ver =~ /^[23]\.x$/ ) {
$page .= Forms->checkbox(
'Check host freshness:',
'check_host_freshness',
$objects{'check_host_freshness'}[2],
$docs{'check_host_freshness'},
'', $tab++
);
$page .= Forms->text_box(
'Host freshness check interval:',
'host_freshness_check_interval',
$objects{'host_freshness_check_interval'}[2],
$textsize{'small'}, '', $docs{'host_freshness_check_interval'},
'', $tab++
);
}
if ($is_portal) {
$page .= Forms->text_box(
'Event broker options:',
'event_broker_options', $objects{'event_broker_options'}[2],
$textsize{'small'}, '', $docs{'event_broker_options'},
'', $tab++
);
## The Nagios doc says "Use multiple broker_module directives if you want to load more than one module.".
## Currently, we only support one copy of the broker_module directive, with no means to specify more copies.
## If we change that, modify the tooltip content, too.
$page .= Forms->text_box(
'Broker module:',
'broker_module', $objects{'broker_module'}[2],
$textsize{'long_name'}, '', $docs{'broker_module'}, '', $tab++
);
}
$page .= Forms->date_format( $objects{'date_format'}[2], $docs{'date_format'}, $tab++ );
$page .= Forms->text_box(
'Illegal object name chars:',
'illegal_object_name_chars', $objects{'illegal_object_name_chars'}[2],
$textsize{'long_name'}, '', $docs{'illegal_object_name_chars'},
'', $tab++
);
$page .= Forms->text_box(
'Illegal macro output characters:',
'illegal_macro_output_chars', $objects{'illegal_macro_output_chars'}[2],
$textsize{'long_name'}, '', $docs{'illegal_macro_output_chars'},
'', $tab++
);
$page .= Forms->text_box( 'Admin email:', 'admin_email', $objects{'admin_email'}[2],
$textsize{'long_name'}, '', $docs{'admin_email'}, '', $tab++ );
$page .= Forms->text_box( 'Admin pager:', 'admin_pager', $objects{'admin_pager'}[2],
$textsize{'long_name'}, '', $docs{'admin_pager'}, '', $tab++ );
%misc_vals = StorProc->get_main_cfg_misc($gid);
$page .= Forms->main_cfg_misc( \%misc_vals, $misc_name, $misc_value, $docs{'misc_directives'}, $tab++ );
$page .= Forms->hidden( \%hidden );
%save = ( 'name' => 'next', 'value' => 'Save and Done' );
$page .= Forms->form_bottom_buttons( \%back, \%save, $tab++ );
}
elsif ( $step eq 'upload' ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top_file("$form_title Upload");
if (@errors) { $page .= Forms->form_errors( \@errors ) }
$page .= Forms->wizard_doc('Upload Nagios main configuration file',
"Select the nagios.cfg file you wish to import. The set of values in your file will replace the complete set of Nagios main configuration values for the \"$gname\" group.");
$page .= Forms->form_file( $tab++ );
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%upload, \%cancel, $tab++ );
}
elsif ( $step eq 'saved' ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( "$form_title", '' );
my @message = ("Changes to nagios configuration completed.");
$page .= Forms->form_message( 'Saved:', \@message, 'row1' );
delete $hidden{'task'};
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
return $page;
}
#
############################################################################
# Nagios resource macros
#
sub resource_cfg($$) {
my $gid = shift;
my $gname = shift;
my $task = $query->param('submit');
my $saved = 0;
my $resource = undef;
my $resource_sav = undef;
my $file = $query->param('upload_file');
my $upload = $query->param('upload');
if ( $query->param('update_resource') ) {
$resource_sav = $query->param('resource');
my $resource_value = $query->param('resource_value');
my $comment = $query->param('comment');
my %values = ( 'value' => $resource_value );
## FIX THIS: Should we strip leading/trailing space from $resource_value, too?
$comment =~ s/^\s+|\s+$//g;
# We cannot use "insert ... on duplicate key update" because monarch_group_props
# does not (yet) have a unique index on {group_id, name} and perhaps including
# {type} as well, though it should. So we simulate it here.
if ($gid) {
my %where = ( 'group_id' => $gid, 'name' => $resource_sav );
my $result = StorProc->update_obj_where( 'monarch_group_props', \%values, \%where );
if ( $result =~ /error/i ) {
push @errors, $result;
}
elsif ( $result == 0 ) {
my @vals = ( \undef, $gid, $resource_sav, 'resource', $resource_value );
my $result = StorProc->insert_obj( 'monarch_group_props', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
else {
my $result = StorProc->update_obj( 'setup', 'name', $resource_sav, \%values );
if ( $result =~ /error/i ) {
push @errors, $result;
}
elsif ( $result == 0 ) {
my @vals = ( $resource_sav, 'resource', $resource_value );
my $result = StorProc->insert_obj( 'setup', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
my $label = $resource_sav;
$label =~ s/user//;
%values = ( 'value' => $comment );
if ($gid) {
my %where = ( 'group_id' => $gid, 'name' => "resource_label$label" );
my $result = StorProc->update_obj_where( 'monarch_group_props', \%values, \%where );
if ( $result =~ /error/i ) {
push @errors, $result;
}
elsif ( $result == 0 ) {
my @vals = ( \undef, $gid, "resource_label$label", 'resource', $comment );
my $result = StorProc->insert_obj( 'monarch_group_props', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
else {
my $result = StorProc->update_obj( 'setup', 'name', "resource_label$label", \%values );
if ( $result =~ /error/i ) {
push @errors, $result;
}
elsif ( $result == 0 ) {
my @vals = ( "resource_label$label", 'resource', $comment );
my $result = StorProc->insert_obj( 'setup', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
unless (@errors) {
$resource_sav = undef;
$resource = undef;
$query->delete('resource_macro');
}
}
elsif ( $query->param('sync') ) {
my %where = ( 'type' => 'resource' );
my %main_object = StorProc->fetch_list_hash_array( 'setup', \%where );
%where = ( 'group_id' => $gid, 'type' => 'resource' );
my $result = StorProc->delete_one_where( 'monarch_group_props', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
foreach my $object ( keys %main_object ) {
my @vals = ( \undef, $gid, $main_object{$object}[0], 'resource', $main_object{$object}[2] );
my $result = StorProc->insert_obj( 'monarch_group_props', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $upload && $file ) {
my ($filedata, $errs) = StorProc->upload( '/tmp', $file );
my @errs = @$errs;
if (@errs) { push @errors, @errs }
unless (@errors) {
my @errs = StorProc->import_resource_cfg($gid, $file, $filedata, 1);
if (@errs) { push( @errors, @errs ) }
}
unless (@errors) { $upload = undef }
}
my $page = Forms->header( $page_title, $session_id, $top_menu );
if ($upload) {
$page .= Forms->form_top_file("$gname Nagios Resource Macros Upload");
if (@errors) { $page .= Forms->form_errors( \@errors ) }
$page .= Forms->wizard_doc('Upload Nagios resource macro file',
"Select the resource.cfg file you wish to import. The set of values in your file will replace the complete set of \$USERn\$ values for the \"$gname\" group.");
$page .= Forms->form_file( $tab++ );
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%upload, \%cancel, $tab++ );
}
else {
$page .= Forms->form_top("$gname Nagios Resource Macros", '', '', '100%' );
my $resource_value = undef;
if (@errors) { $page .= Forms->form_errors( \@errors ) }
my %resources = StorProc->get_resource_values($gid);
my %resource_doc = ();
my %selected = ();
$resource = $resource_sav || $query->param('resource_macro');
if ($resource) {
$resource_value = $resources{$resource};
%selected = ( 'name' => $resource, 'value' => $resource_value );
}
else {
$page .= Forms->wizard_doc('Select resource macro to edit',
'In this screen, you may modify the values of the Nagios resource macros. These values can be symbolically referenced in commands as $USER1$ through $USER32$. Using these symbols instead of literal values in your commands makes it much easier to modify all related commands at one time, in this central place.');
}
$page .= Forms->resource_select( \%resources, \%resource_doc, \%selected, $top_menu, $tab++ );
$page .= Forms->hidden( \%hidden );
if ($gid) {
my %sync = ( 'name' => 'sync', 'value' => 'Sync With Main' );
$page .= Forms->form_bottom_buttons( \%close, \%upload, \%sync, $tab++ );
}
else {
$page .= Forms->form_bottom_buttons( \%close, $tab++ );
}
}
return $page;
}
#
############################################################################
# Pre-Flight Test
#
sub pre_flight($) {
my $group = shift;
my $page = undef;
if ( $query->param('refreshed') ) {
my $group = $query->param('group');
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'Nagios Pre-Flight Test', '' );
my $errors = StorProc->check_version( $monarch_ver );
push @errors, @$errors if @$errors;
if (@errors) { $page .= Forms->form_errors( \@errors ); @errors = (); }
my $results;
my $files;
( $errors, $results, $files ) =
StorProc->synchronized_preflight( $user_acct, $nagios_ver, $nagios_etc, $nagios_bin, $monarch_home, $group, 'html' );
$page .= Forms->form_message( 'Error(s) building file(s):', $errors, 'error' ) if @$errors;
## FIX THIS: make the fourth argument a pattern, not a binary flag
$page .= Forms->form_message( 'Results:', $results, 'row1', 1, 1 ) if @$results;
$hidden{'obj'} = undef;
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
else {
my $now = time;
$refresh_url = "?update_main=1&nocache=$now&refreshed=1&group=$group";
foreach my $name ( keys %hidden ) {
$refresh_url .= qq(&$name=) . (defined( $hidden{$name} ) ? $hidden{$name} : '');
}
$page .= Forms->header( $page_title, $session_id, $top_menu, $refresh_url );
$page .= Forms->form_top( 'Nagios Pre-Flight Test', '' );
my $errors = StorProc->check_version( $monarch_ver );
push @errors, @$errors if @$errors;
if (@errors) { $page .= Forms->form_errors( \@errors ) }
$page .= Forms->form_doc('Running pre-flight check ...');
$page .= Forms->form_bottom_buttons();
}
return $page;
}
#
############################################################################
# Control Center
#
sub control() {
my @menus = ();
my %ver = StorProc->fetch_one( 'setup', 'name', 'nagios_version' );
my $page = undef;
if ( $query->param('close')
|| $query->param('continue')
|| $query->param('cancel') )
{
$page .= Forms->header( $page_title, $session_id, $top_menu );
}
else {
##
######################################################################
# Users
#
if ( $obj eq 'users' ) {
@errors = ();
$table = 'users';
my $user = $query->param('mod_user');
my $user_name = $query->param('user_name');
my @password = $query->param('passwd');
if ( $query->param('task') eq 'No' ) { $task = 'modify' }
if ( $query->param('add') && $user ) {
my $id = undef;
$user =~ s/^\s+|\s+$//g;
my %p = StorProc->fetch_one( 'users', 'user_acct', $user );
if ( !$password[1] ) { $password[1] = 1 }
unless ( $authentication{'disabled'} ) {
if ( $password[0] eq $password[1] ) { $password[1] = undef }
}
else {
$password[1] = undef;
}
unless ( $p{'user_acct'} || $user eq '' || $password[1] ) {
my $now = time;
$now = $now - 100000;
my @saltchars = ( 'a' .. 'z', 'A' .. 'Z', '0' .. '9', ',', '/' );
srand( time() ^ ( $$ + ( $$ << 15 ) ) );
my $salt = $saltchars[ int( rand(64) ) ];
$salt .= $saltchars[ int( rand(64) ) ];
my $newpw = crypt( $password[0], $salt );
my @values = ( \undef, $user, $user_name, $newpw, $now );
$id = StorProc->insert_obj_id( $table, \@values, 'user_id' );
if ( $id =~ /^Error/ ) { push @errors, $id }
}
else {
if ( $p{'user_acct'} ) {
push @errors, "User id \"$user\" already exists.";
}
if ( $user eq '' ) { push @errors, "Required: User id" }
if ( $password[1] ) {
push @errors, "Check password fields. They are either blank or a mismatch.";
}
}
unless (@errors) {
my @user_groups = $query->param('user_groups');
my @ugs = StorProc->get_ids( 'usergroup_id', 'user_groups', \@user_groups );
foreach (@ugs) {
my @values = ( $_, $id );
my $result = StorProc->insert_obj( 'user_group', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
unless (@errors) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( "User Account", '' );
my @message = ("User \"$user\" added.");
$page .= Forms->form_message( 'Added:', \@message, 'row1' );
( $task, $user ) = undef;
delete $hidden{'task'};
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
}
elsif ( $query->param('save') ) {
my %values = ();
if ( !$password[1] ) { $password[1] = 1 }
if ( $query->param('set_password') ) {
if ( $password[0] eq $password[1] ) { $password[1] = undef }
}
else {
$password[1] = undef;
}
unless ( $password[1] ) {
$values{'user_name'} = $user_name;
my @saltchars = ( 'a' .. 'z', 'A' .. 'Z', '0' .. '9', ',', '/' );
srand( time() ^ ( $$ + ( $$ << 15 ) ) );
my $salt = $saltchars[ int( rand(64) ) ];
$salt .= $saltchars[ int( rand(64) ) ];
$values{'password'} = crypt( $password[0], $salt );
my $result = StorProc->update_obj( 'users', 'user_acct', $user, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
unless ( $user eq 'super_user' ) {
my %u = StorProc->fetch_one( 'users', 'user_acct', $user );
$result = StorProc->delete_all( 'user_group', 'user_id', $u{'user_id'} );
if ( $result =~ /^Error/ ) { push @errors, $result }
my @user_groups = $query->param('user_groups');
my @ugs = StorProc->get_ids( 'usergroup_id', 'user_groups', \@user_groups );
foreach (@ugs) {
my @values = ( $_, $u{'user_id'} );
my $result = StorProc->insert_obj( 'user_group', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
else {
push @errors, "Check password field. It's either blank or a mismatch.";
}
unless (@errors) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
my $message = "Changes accepted.";
$page .= Forms->form_top( "User Account", '' );
my @message = ("Changes to \"$user\" accepted.");
$page .= Forms->form_message( 'Saved:', \@message, 'row1' );
( $task, $user ) = undef;
delete $hidden{'task'};
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
}
elsif ( $query->param('confirm_delete') ) {
my $result = StorProc->delete_all( 'users', 'user_acct', $user );
if ( $result =~ /^Error/ ) { push @errors, $result }
unless (@errors) {
$page .= Forms->header( $page_title, $session_id, $top_menu, '', '1' );
my $message = "User \"$user\" deleted.";
$page .= Forms->form_top( "User Account", '' );
my @message = ("Changes to \"$user\" accepted.");
$page .= Forms->form_message( 'Removed:', \@message, 'row1' );
( $task, $user ) = undef;
delete $hidden{'task'};
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
}
elsif ( $query->param('delete') ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$hidden{'mod_user'} = $user;
my $message = qq(Are you sure you want to remove \"$user\"?);
$page .= Forms->are_you_sure( 'Confirm Delete', $message, 'confirm_delete', \%hidden );
$user = undef;
$task = 'Delete';
}
if ( @errors || $user || $task =~ /Add|new/i ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
my @members = $query->param('user_groups');
$page .= Forms->form_top( 'User Account', 'onsubmit="selIt();"' );
if (@errors) { $page .= Forms->form_errors( \@errors ) }
if ( $task =~ /Add|new/ ) {
$page .= Forms->text_box( 'Userid:', 'mod_user', $user, $textsize{'short_name'}, $required{'user_acct'} );
$page .= Forms->text_box( 'User name:', 'user_name', $user_name, $textsize{'long_name'} );
$hidden{'set_password'} = 1;
}
else {
my %p = StorProc->fetch_one( 'users', 'user_acct', $user );
if ( !$members[0] ) {
@members = StorProc->get_names_in( 'usergroup_id', 'user_groups', 'user_group', 'user_id', $p{'user_id'} );
}
$page .= Forms->display_hidden( 'User id:', 'mod_user', $user );
$page .= Forms->text_box( 'User name:', 'user_name', $p{'user_name'}, $textsize{'long_name'} );
$page .= Forms->checkbox( 'Set password:', 'set_password', $query->param('set_password') );
}
$page .= Forms->password_box( 'Password:', 'passwd', $textsize{'short_name'}, $required{'password'} );
$page .= Forms->password_box( 'Password confirm:', 'passwd', $textsize{'short_name'}, $required{'password'} );
%save = ( 'name' => 'save', 'value' => 'Save' );
unless ( $user eq 'super_user' ) {
my @nonmembers = StorProc->fetch_list( 'user_groups', 'name' );
$page .= Forms->members( 'User groups:', 'user_groups', \@members, \@nonmembers );
$page .= Forms->hidden( \%hidden );
if ( $task =~ /Add|new/ ) {
$page .= Forms->form_bottom_buttons( \%add, \%cancel, $tab++ );
}
else {
$page .= Forms->form_bottom_buttons( \%save, \%delete, \%cancel, $tab++ );
}
}
else {
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%save, \%cancel, $tab++ );
}
}
}
#
#################################################################
# User Groups
#
elsif ( $obj eq 'user_groups' ) {
@errors = ();
$table = 'user_groups';
my $groupid = $query->param('groupid');
my $description = $query->param('description');
if ( $query->param('task') eq 'No' ) { $task = 'access_list' }
my $access_set = $query->param('access_set');
if ($access_set) { $task = 'access_list' }
my $access_type = $query->param('access_type');
my $update_assets = undef;
my $saved = 0;
my @message = ();
if ( $query->param('continue')
|| $query->param('close')
|| $query->param('cancel') )
{
$page .= Forms->header( $page_title, $session_id, $top_menu );
}
elsif ( $query->param('add') && $groupid ) {
$groupid =~ s/^\s+|\s+$//g;
my %p = StorProc->fetch_one( 'user_groups', 'name', $groupid );
unless ( $p{'name'} ) {
my @values = ( \undef, $groupid, $description );
my $result = StorProc->insert_obj( $table, \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
push @errors, "Check the name field. It's either blank or that name is already in use.";
}
unless (@errors) {
$task = 'access_list';
}
}
elsif ( $query->param('save') ) {
my %values = ();
$values{'description'} = $description;
my $result = StorProc->update_obj( $table, 'name', $groupid, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
$task = 'saved';
}
elsif ( $query->param('update_access') ) {
my %g = StorProc->fetch_one( 'user_groups', 'name', $groupid );
my $type = undef;
my @assets = $query->param('access_list');
if ( $access_set eq 'tools' || $access_set eq 'control' ) {
my %where = (
'usergroup_id' => $g{'usergroup_id'},
'type' => $access_set
);
my $result = StorProc->delete_one_where( 'access_list', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
foreach my $asset (@assets) {
my @values = ( $asset, $access_set, $g{'usergroup_id'}, 'full_control' );
my $result = StorProc->insert_obj( 'access_list', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $access_set eq 'EZ' ) {
my %where = ( 'usergroup_id' => $g{'usergroup_id'}, 'type' => 'ez' );
my $result = StorProc->delete_one_where( 'access_list', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
my $enable_ez = $query->param('enable_ez');
if ($enable_ez) {
my @values = ( $enable_ez, 'ez', $g{'usergroup_id'}, $enable_ez );
my $result = StorProc->insert_obj( 'access_list', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
my $ez_view = $query->param('ez_view');
if ($ez_view) {
my @values = ( $ez_view, 'ez', $g{'usergroup_id'}, $ez_view );
my $result = StorProc->insert_obj( 'access_list', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
if ( $result =~ /^Error/ ) { push @errors, $result }
foreach my $asset (@assets) {
my @values = ( "ez_$asset", 'ez', $g{'usergroup_id'}, "ez_$asset" );
my $result = StorProc->insert_obj( 'access_list', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
elsif ( $access_set eq 'groups' ) {
my %group_name = StorProc->get_table_objects('monarch_groups');
my %where = (
'usergroup_id' => $g{'usergroup_id'},
'type' => 'group_macro'
);
my $result = StorProc->delete_one_where( 'access_list', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
foreach my $asset (@assets) {
if ( $asset eq 'manage' ) {
my @values = ( $asset, 'group_macro', $g{'usergroup_id'}, 'manage' );
my $result = StorProc->insert_obj( 'access_list', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my @values = ( $group_name{$asset}, 'group_macro', $g{'usergroup_id'}, $asset );
my $result = StorProc->insert_obj( 'access_list', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
}
else {
my %assets = ();
my %vals = ();
my %where = (
'usergroup_id' => $g{'usergroup_id'},
'type' => $access_set
);
my $result = StorProc->delete_one_where( 'access_list', \%where );
if ( $result =~ /^Error/ ) { push @errors, $result }
foreach my $asset ( $query->param ) {
if ( $asset eq 'nocache' ) { next }
if ( $asset =~ /(^\S+)-(\S+)-(.*)/ ) {
my $obj = $3;
$assets{$obj} = $1;
$vals{$obj} .= "$2,";
}
}
foreach my $asset ( keys %assets ) {
$vals{$asset} =~ s/,$//;
my @values = ( $asset, $assets{$asset}, $g{'usergroup_id'}, $vals{$asset} );
my $result = StorProc->insert_obj( 'access_list', \@values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
unless (@errors) {
@message = ("Changes to access set \"$access_set\" accepted.");
$saved = 1;
}
$task = 'access_list';
}
elsif ($groupid ne 'super_users' && $query->param('confirm_delete') ) {
my $result = StorProc->delete_all( 'user_groups', 'name', $groupid );
if ( $result =~ /^Error/ ) { push @errors, $result }
unless (@errors) {
$page .= Forms->header( $page_title, $session_id, $top_menu, '', '1' );
$page .= Forms->form_top( "User Group", '' );
my @message = ("User group \"$groupid\" deleted.");
$page .= Forms->form_message( 'Removed:', \@message, 'row1' );
( $task, $groupid ) = undef;
delete $hidden{'task'};
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
$task = 'delete';
}
else {
$task = 'access_list';
}
}
elsif ( $groupid ne 'super_users' && $query->param('delete') ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$hidden{'groupid'} = $groupid;
$hidden{'task'} = 'access_list';
my $message = qq(Are you sure you want to remove \"$groupid\"?);
$page .= Forms->are_you_sure( 'Confirm Delete', $message, 'confirm_delete', \%hidden );
$groupid = undef;
$task = 'delete';
}
if ( $task eq 'new' ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'User Group', '' );
if (@errors) { $page .= Forms->form_errors( \@errors ) }
$page .= Forms->text_box( 'Group id:', 'groupid', '', $textsize{'short_name'}, $required{'groupid'} );
$page .= Forms->text_box( 'Description:', 'description', $description, $textsize{'long_name'} );
delete $hidden{'task'};
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%add, \%cancel, $tab++ );
}
elsif ( $task eq 'access_list' || $query->param('access_list') ) {
unless ( $groupid eq 'super_users' ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
my %access_button = ();
if (@errors) { $page .= Forms->form_errors( \@errors ) }
my %p = StorProc->fetch_one( 'user_groups', 'name', $groupid );
$description = $p{'description'};
if ( !$access_set ) { $access_set = 'design_manage' }
$hidden{'groupid'} = $groupid;
$hidden{'access_set'} = $access_set;
my @menus = ( 'design_manage', 'groups', 'tools', 'control' );
if ($enable_ez) { push @menus, 'EZ' }
$page .= Forms->access_top( $groupid, $session_id, $access_set, \@menus );
my %g = StorProc->fetch_one( 'user_groups', 'name', $groupid );
if ($saved) {
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_message( 'Saved:', \@message, 'row1' );
}
elsif ( $access_set eq 'tools' ) {
my @tool_menus = ( 'import_from_files', 'export_to_files' );
$access_type = 'tools';
my %values = (
'usergroup_id' => $g{'usergroup_id'},
'type' => 'tools'
);
my @selected = ();
my %selected_hash = StorProc->fetch_list_hash_array( 'access_list', \%values );
foreach my $key ( keys %selected_hash ) {
push @selected, $key;
}
$page .= Forms->hidden( \%hidden );
$page .= Forms->access_checkbox_list( 'Tools:', 'access_list', \@tool_menus, \@selected );
}
elsif ( $access_set eq 'control' ) {
my @control_menus = (
'users', 'user_groups', 'setup', 'nagios_cgi_configuration', 'nagios_main_configuration', 'nagios_resource_macros',
'pre_flight_test', 'commit'
);
$access_type = 'control';
my %assets_selected = undef;
my %values = (
'usergroup_id' => $g{'usergroup_id'},
'type' => 'control'
);
my @selected = ();
my %selected_hash = StorProc->fetch_list_hash_array( 'access_list', \%values );
foreach my $key ( keys %selected_hash ) {
push @selected, $key;
}
$page .= Forms->hidden( \%hidden );
$page .= Forms->access_checkbox_list( 'Control list:', 'access_list', \@control_menus, \@selected );
}
elsif ( $access_set eq 'groups' ) {
my %docs = Doc->access_list();
my @selected = ();
my %where = (
'usergroup_id' => $g{'usergroup_id'},
'type' => 'group_macro'
);
my %selected_hash = StorProc->fetch_list_hash_array( 'access_list', \%where );
my @monarch_group_macro = ('manage');
if ( $selected_hash{'manage'} ) {
@selected = ('manage');
}
$page .= Forms->wizard_doc( 'Groups', $docs{'groups'} );
$page .= Forms->checkbox_list( 'Groups and macros:', 'access_list', \@monarch_group_macro, \@selected );
my %group_name = StorProc->get_table_objects( 'monarch_groups', '1' );
my @groups = StorProc->fetch_list( 'monarch_groups', 'name' );
foreach my $key ( keys %selected_hash ) {
push @selected, $group_name{$key};
}
$page .= Forms->hidden( \%hidden );
$page .= Forms->access_checkbox_list( 'Administered groups:', 'access_list', \@groups, \@selected );
}
elsif ( $access_set eq 'EZ' ) {
my %docs = Doc->access_list();
my @selected = ();
my %where = (
'usergroup_id' => $g{'usergroup_id'},
'type' => 'ez'
);
my %selected_hash = StorProc->fetch_list_hash_array( 'access_list', \%where );
foreach my $key ( keys %selected_hash ) {
$key =~ s/ez_//;
push @selected, $key;
}
my @ez_set = ( 'enable', 'primary_interface', 'only_interface' );
if ( $selected_hash{'manage'} ) {
@selected = ('manage');
}
$page .= Forms->wizard_doc( 'EZ Interface', $docs{'ez'} );
$page .= Forms->access_settings_ez( \%selected_hash );
my @ez_options = ( 'hosts', 'import', 'discover', 'host_groups', 'profiles', 'notifications', 'commit', 'setup' );
$page .= Forms->hidden( \%hidden );
$page .= Forms->access_checkbox_list( 'EZ options:', 'access_list', \@ez_options, \@selected );
}
else {
my @access_list =
( 'time_periods', 'commands', 'contact_templates', 'contacts', 'contactgroups', 'escalations', 'profiles' );
push( @access_list,
( 'hosts', 'host_templates', 'extended_host_info_templates', 'hostgroups', 'parent_child', 'host_dependencies' ) );
push @access_list,
( 'services', 'service_templates', 'service_dependency_templates', 'extended_service_info_templates' );
if ( $nagios_ver =~ /^[23]\.x$/ ) {
push @access_list, 'service_groups';
}
if ($enable_externals) {
push @access_list, 'externals';
}
$access_type = 'design_manage';
my %assets_selected = undef;
my %values = (
'usergroup_id' => $g{'usergroup_id'},
'type' => $access_type
);
my %access_list_values = StorProc->fetch_list_hash_array( 'access_list', \%values );
foreach my $key ( keys %access_list_values ) {
$assets_selected{$key} = $access_list_values{$key}[3];
}
$page .= Forms->hidden( \%hidden );
$page .= Forms->access_list( 'Design/Manage', \@access_list, \%assets_selected, $access_type );
}
}
}
elsif ( $task eq 'saved' ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'User Group', '' );
$page .= Forms->display_hidden( 'Saved:', '', $groupid );
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%close );
}
elsif ( $task eq 'modify' ) {
my $groupid = $query->param('name');
$page .= Forms->header( $page_title, $session_id, $top_menu );
my %p = StorProc->fetch_one( 'user_groups', 'name', $groupid );
$description = $p{'description'};
$page .= Forms->form_top( 'User Group', '' );
$page .= Forms->display_hidden( 'Group id:', 'groupid', $groupid );
$page .= Forms->text_box( 'Description:', 'description', $description, $textsize{'long_name'} );
$page .= Forms->hidden( \%hidden );
my %set = ( 'name' => 'access_list', 'value' => 'Set Access Values' );
if ( $groupid eq 'super_users' ) {
$page .= Forms->form_bottom_buttons( \%save, \%close );
}
else {
$page .= Forms->form_bottom_buttons( \%save, \%set, \%delete, \%close );
}
}
}
#
##################################################################
# Setup
#
elsif ( $obj eq 'setup' ) {
@errors = ();
my $saved = 0;
if ( $query->param('save') ) {
my %where = ();
my %cfg = StorProc->fetch_list_hash_array( 'setup', \%where );
my @setup_props = (
'cgi_home', 'login_authentication', 'session_timeout', 'nagios_etc',
'nagios_bin', 'nagios_version', 'upload_dir', 'backup_dir',
'enable_externals', 'enable_groups', 'enable_ez'
);
foreach my $name (@setup_props) {
my %values = ();
my $value = $query->param($name);
unless ($value) { $value = 0 }
if ( $cfg{$name}[0] ) {
$values{'value'} = $value;
my $result = StorProc->update_obj( 'setup', 'name', $name, \%values );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
else {
my @vals = ( $name, 'config', $value );
my $result = StorProc->insert_obj( 'setup', \@vals );
if ( $result =~ /^Error/ ) { push @errors, $result }
}
}
unless (@errors) { $saved = 1 }
}
if ($saved) {
$refresh_left = 1; # in case externals support changed
$page .= Forms->header( $page_title, $session_id, $top_menu, '', $refresh_left );
$page .= Forms->form_top( 'Setup', '' );
$page .= Forms->form_doc('Updated: Changes to setup accepted.');
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%close, $tab++ );
}
else {
my %docs = Doc->setup();
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'Setup', '' );
my %p = StorProc->fetch_one( 'setup', 'name', 'monarch_version' );
my $errors = StorProc->check_version( $p{'value'} );
push @errors, @$errors if @$errors;
if (@errors) { $page .= Forms->form_errors( \@errors ) }
$page .= Forms->display_hidden( 'Monarch version:', 'monarch_version', $p{'value'}, $docs{'monarch_version'} );
if ($is_portal) {
%p = StorProc->fetch_one( 'setup', 'name', 'nagios_version' );
$page .= Forms->display_hidden( 'Nagios version:', 'nagios_version', $p{'value'}, $docs{'nagios_version'} );
$page .= Forms->display_hidden( 'Nagios etc:', 'nagios_etc', '/usr/local/groundwork/nagios/etc', $docs{'nagios_etc'} );
$page .= Forms->display_hidden( 'Nagios bin:', 'nagios_bin', '/usr/local/groundwork/nagios/bin', $docs{'nagios_bin'} );
$page .= Forms->display_hidden(
'Configuration home:',
'monarch_home', '/usr/local/groundwork/core/monarch',
$docs{'monarch_home'}
);
$page .= Forms->display_hidden(
'Backup directory:',
'backup_dir', '/usr/local/groundwork/core/monarch/backup',
$docs{'backup_home'}
);
$hidden{'upload_dir'} = $upload_dir;
$hidden{'enable_groups'} = 1;
$hidden{'enable_ez'} = 1;
}
else {
%p = StorProc->fetch_one( 'setup', 'name', 'login_authentication' );
my @members = ( 'active', 'passive', 'none' );
$page .= Forms->list_box( 'Login authentication:',
'login_authentication', \@members, $p{'value'}, '', $docs{'login_authentication'} );
%p = StorProc->fetch_one( 'setup', 'name', 'session_timeout' );
$page .= Forms->text_box( 'Session timeout seconds:', 'session_timeout', $p{'value'}, '5', '', $docs{'session_timeout'} );
@members = ( '1.x', '2.x', '3.x' );
%p = StorProc->fetch_one( 'setup', 'name', 'nagios_version' );
$page .= Forms->list_box( 'Nagios version:', 'nagios_version', \@members, $p{'value'}, '', $docs{'nagios_version'} );
$page .= Forms->text_box( 'Nagios etc:', 'nagios_etc', $nagios_etc, $textsize{'long_name'}, '', $docs{'nagios_etc'} );
$page .= Forms->text_box( 'Nagios bin:', 'nagios_bin', $nagios_bin, $textsize{'long_name'}, '', $docs{'nagios_bin'} );
$page .= Forms->display_hidden( 'Monarch home:', 'monarch_home', $monarch_home, $docs{'monarch_home'} );
$page .= Forms->text_box( 'Backup directory:', 'backup_dir', $backup_dir, $textsize{'long_name'}, '', $docs{'backup_dir'} );
$page .= Forms->text_box( 'Upload dir:', 'upload_dir', $upload_dir, $textsize{'long_name'}, '', $docs{'upload_dir'} );
$page .= Forms->checkbox( 'Enable groups:', 'enable_groups', $enable_groups, $docs{'enable_groups'} );
$page .= Forms->checkbox( 'Enable EZ:', 'enable_ez', $enable_ez, $docs{'ez'} );
}
$page .= Forms->checkbox( 'Enable externals:', 'enable_externals', $enable_externals, $docs{'enable_externals'}, '', $tab++ );
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%save, \%cancel, $tab++ );
}
}
#
##################################################################
# Nagios cgi
#
elsif ( $obj eq 'nagios_cgi_configuration' ) {
my $step = $query->param('step');
$page .= nagios_cgi( '', '' );
}
#
##################################################################
# Nagios main
#
elsif ( $obj eq 'nagios_main_configuration' ) {
my $step = $query->param('step');
$page .= nagios_cfg( '', '' );
}
#
##################################################################
# Resource
#
elsif ( $obj eq 'nagios_resource_macros' ) {
$page .= resource_cfg( '', '' );
}
#
##################################################################
# Pre-Flight Test
#
elsif ( $obj eq 'pre_flight_test' ) {
$page .= pre_flight('');
}
#
##################################################################
# Commit
#
elsif ( $obj eq 'commit' ) {
my %abort = ( 'name' => 'abort', 'value' => 'Abort' );
my %backup = ( 'name' => 'backup', 'value' => 'Backup' );
my %commit = ( 'name' => 'commit', 'value' => 'Commit' );
my %nagios = StorProc->fetch_one( 'setup', 'name', 'nagios_etc' );
my %monarch_home = StorProc->fetch_one( 'setup', 'name', 'monarch_home' );
my $workspace = $monarch_home{'value'} . '/workspace';
my %nagios_cfg = StorProc->fetch_one( 'setup', 'name', 'log_file' );
my %nagios_cgi = StorProc->fetch_one( 'setup', 'name', 'default_user_name' );
if ( $query->param('backup') ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'Commit', '' );
my ( $backup, $errs ) = StorProc->backup( $nagios{'value'}, $backup_dir );
push( @errors, @{$errs} );
if (@errors) {
my @message = ("Problem(s) Backing up files and/or database to $backup .");
push( @message, @errors );
$page .= Forms->form_message( 'Backup error(s):', \@message, 'error' );
}
else {
my @message = ("Files backed up to $backup .");
$page .= Forms->form_message( 'Backup complete:', \@message, '' );
}
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%abort, \%commit, $tab++ );
}
elsif ( $query->param('abort') ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'Nagios Commit', '' );
$hidden{'obj'} = undef;
$page .= Forms->hidden( \%hidden );
my @message = ("Commit aborted.");
$page .= Forms->form_message( 'Action Canceled:', \@message, '' );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
$hidden{'obj'} = undef;
}
elsif ( $query->param('commit') ) {
if ( $query->param('refreshed') ) {
my ($errors, $results, $timings) =
StorProc->synchronized_commit( $user_acct, $nagios_ver, $nagios_etc, $nagios_bin, $monarch_home, 'html' );
$page .= Forms->header( $page_title, $session_id, $top_menu );
if (@$errors) {
$page .= Forms->form_top( 'Commit Errors', '', '' );
$page .= Forms->form_errors( $errors );
if (@$timings) {
if (0) {
grep s/ \[[\d.]+ \.\. [\d.]+\]*//, @$timings;
$page .= Forms->form_message( 'Timings:', $timings, 'row1' ) if @$timings;
}
else {
require MonarchGraphs;
my ($errors, $image_file, $image_x, $image_y, $time_ref) = Graphs->graph_commit( $timings );
$page .= Forms->form_errors( $errors ) if @$errors;
$page .= Forms->form_image( $image_file, $image_x, $image_y, 'row1' ) if $image_file;
$page .= Forms->form_message( 'Timings:', $time_ref, 'row1' ) if @$time_ref;
}
}
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%close, $tab++ );
}
else {
$page .= Forms->form_top( 'Nagios Commit', '' );
if (@$timings) {
require MonarchGraphs;
my ($errors, $image_file, $image_x, $image_y, $time_ref) = Graphs->graph_commit( $timings );
$page .= Forms->form_errors( $errors ) if @$errors;
$page .= Forms->form_image( $image_file, $image_x, $image_y, 'row1' ) if $image_file;
$page .= Forms->form_message( 'Timings:', $time_ref, 'row1' ) if @$time_ref;
}
$page .= Forms->form_message( 'Results:', $results, 'row1' );
$hidden{'obj'} = undef;
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%close, $tab++ );
}
}
else {
my $now = time;
$refresh_url = "?nocache=$now&refreshed=1&commit=1";
foreach my $name ( keys %hidden ) {
$refresh_url .= qq(&$name=) . (defined($hidden{$name}) ? $hidden{$name} : '');
}
$page .= Forms->header( $page_title, $session_id, $top_menu, $refresh_url );
$page .= Forms->form_top( 'Commit to Nagios', '' );
$page .= Forms->form_doc('Running commit ...');
$now = time;
$refresh_url = "?update_main=1&nocache=$now&refreshed=1&commit=1";
$page .= Forms->form_bottom_buttons();
}
}
elsif ( $nagios_cfg{'value'} && $nagios_cgi{'type'} ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'Nagios Commit', '' );
my $errors = StorProc->check_version( $monarch_ver );
push @errors, @$errors if @$errors;
if (@errors) { $page .= Forms->form_errors( \@errors ) }
$page .= Forms->hidden( \%hidden );
my @message = ("Are you sure you want to overwrite your active Nagios configuration and restart Nagios?");
push @message, ("Should you choose to continue, it is strongly recommended that you first select the backup option.");
if ( -x "$monarch_home/bin/commit_check" ) {
my $warning = [ qx($monarch_home/bin/commit_check) ];
if (@$warning && $warning->[0] ne "Configuration looks okay.\n") {
$page .= Forms->form_errors( $warning );
}
}
$page .= Forms->form_message( 'Nagios commit:', \@message, '' );
$page .= Forms->form_bottom_buttons( \%abort, \%backup, \%commit, $tab++ );
}
else {
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'Nagios Commit', '' );
unless ( $nagios_cfg{'value'} ) {
push @errors,
'Nagios main configuration has not been defined.',
'Use Control->Nagios main configuration to load an existing file or set defaults.';
}
unless ( $nagios_cgi{'type'} ) {
push @errors,
'Nagios CGI configuration has not been defined.',
'Use Control->Nagios CGI configuration to load an existing file or set defaults.';
}
$page .= Forms->form_message( 'Error(s):', \@errors, 'error' );
$hidden{'obj'} = undef;
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
}
#
##################################################################
# Run Ext info scripts
#
elsif ( $obj eq 'run_extended_info_scripts' ) {
$page .= Forms->header( $page_title, $session_id, $top_menu );
my $ext_info = $query->param('ext_info');
my $type = $query->param('type');
if ($ext_info) {
my @results = ();
if ( $type eq 'host' ) {
my %x = StorProc->fetch_one( 'extended_host_info_templates', 'name', $ext_info );
my %w = ( 'hostextinfo_id' => $x{'hostextinfo_id'} );
my @hosts = StorProc->fetch_list_where( 'hosts', 'name', \%w );
push @results, "Script $x{'script'} from $x{'name'} launched for:";
push @results, "
";
foreach my $host (@hosts) {
my $script = $x{'script'};
$script =~ s/\$HOSTNAME\$/$host/g;
system("$script &");
push @results, "$host '$script'";
push @results, "
";
}
}
elsif ( $type eq 'service' ) {
my %x = StorProc->fetch_one( 'extended_service_info_templates', 'name', $ext_info );
my %service_hosts = StorProc->fetch_service_extinfo( $x{'serviceextinfo_id'} );
push @results, "Script $x{'script'} from $x{'name'} launched for:";
push @results, "
";
foreach my $sid ( keys %service_hosts ) {
my $script = $x{'script'};
$script =~ s/\$HOSTNAME\$/$service_hosts{$sid}[0]/g;
$script =~ s/\$SERVICENAME\$/$service_hosts{$sid}[1]/g;
system("$script &");
push @results, "$service_hosts{$sid}[0] $service_hosts{$sid}[1] '$script'";
push @results, "
";
}
}
$page .= Forms->form_top( 'External Script', '' );
if (@errors) {
$page .= Forms->form_message( 'Error(s):', \@errors, 'error' );
}
$page .= Forms->form_message( 'Results:', \@results, 'row1' );
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
else {
my %scripts = StorProc->fetch_scripts('host');
$page .= Forms->table_script_links( $session_id, 'host', \%scripts );
%scripts = StorProc->fetch_scripts('service');
$page .= Forms->table_script_links( $session_id, 'service', \%scripts );
}
}
#
##################################################################
# Build externals files
#
elsif ( $obj eq 'build_externals' ) {
use MonarchExternals;
my ($results, $errors) = Externals->build_all_externals($user_acct, $session_id, '1');
my @results = @$results;
my @errors = @$errors;
$page .= Forms->header( $page_title, $session_id, $top_menu );
$page .= Forms->form_top( 'Build Externals', '' );
if (@errors) {
$page .= Forms->form_message( 'Error(s):', \@errors, 'error' );
}
$page .= Forms->form_message( 'Results:', \@results, 'row1' );
$hidden{'obj'} = undef;
$page .= Forms->hidden( \%hidden );
$page .= Forms->form_bottom_buttons( \%continue, $tab++ );
}
}
return $page;
}
#
############################################################################
# Search
#
sub search() {
my $detail = Forms->header( $page_title, $session_id, $top_menu );
$detail .= Forms->form_top( 'Search Hosts', 'onsubmit="find_names(); return false;"', '', '100%' );
$detail .= Forms->search($session_id);
$hidden{'view'} = 'search_hosts';
$hidden{'CGISESSID'} = $session_id;
$detail .= Forms->hidden( \%hidden );
$detail .= Forms->form_bottom_buttons();
use CGI::Ajax;
my $url = Forms->get_ajax_url();
my $pjx = new CGI::Ajax( 'get_hosts' => $url );
return $pjx->build_html( $query, $detail );
}
sub search_services() {
my $detail = Forms->header( $page_title, $session_id, $top_menu );
$detail .= Forms->form_top( 'Search Services', 'onsubmit="find_names(); return false;"', '', '100%' );
$detail .= Forms->search( $session_id, 'services' );
$hidden{'view'} = 'search_services';
$hidden{'CGISESSID'} = $session_id;
$detail .= Forms->hidden( \%hidden );
$detail .= Forms->form_bottom_buttons();
use CGI::Ajax;
my $url = Forms->get_ajax_url();
my $pjx = new CGI::Ajax( 'get_services' => $url );
return $pjx->build_html( $query, $detail );
}
sub search_commands() {
my $detail = Forms->header( $page_title, $session_id, $top_menu );
$detail .= Forms->form_top( 'Search Commands', 'onsubmit="find_names(); return false;"', '', '100%' );
$detail .= Forms->search( $session_id, 'commands' );
$hidden{'view'} = 'search_commands';
$hidden{'CGISESSID'} = $session_id;
$detail .= Forms->hidden( \%hidden );
$detail .= Forms->form_bottom_buttons();
use CGI::Ajax;
my $url = Forms->get_ajax_url();
my $pjx = new CGI::Ajax( 'get_commands' => $url );
return $pjx->build_html( $query, $detail );
}
sub search_externals($) {
my $type = shift;
my $detail = Forms->header( $page_title, $session_id, $top_menu );
$detail .= Forms->form_top( "Search \u$type Externals", 'onsubmit="find_names(); return false;"', '', '100%' );
$detail .= Forms->search( $session_id, "$type\_externals" );
$hidden{'view'} = "search_$type\_external";
$hidden{'CGISESSID'} = $session_id;
$detail .= Forms->hidden( \%hidden );
$detail .= Forms->form_bottom_buttons();
use CGI::Ajax;
my $url = Forms->get_ajax_url();
my $pjx = new CGI::Ajax( 'get_externals' => $url );
return $pjx->build_html( $query, $detail );
}
sub schema_mismatch {
my $errors = shift;
my $page = '';
$page .= Forms->header( $page_title, $session_id, $top_menu, $refresh_url );
$page .= Forms->form_top( 'Database Schema Mismatch', '' );
$page .= Forms->form_errors( $errors );
$page .= Forms->form_bottom_buttons();
return $page;
}
#
# Begin processing request
#
# db connection
my $auth = StorProc->dbconnect();
# get config info
my %where = ();
my %objects = StorProc->fetch_list_hash_array( 'setup', \%where );
if ( -e '/usr/local/groundwork/config/db.properties' ) { $is_portal = 1 }
$nagios_ver = $objects{'nagios_version'}[2];
$nagios_bin = $objects{'nagios_bin'}[2];
$nagios_etc = $objects{'nagios_etc'}[2];
$monarch_home = $objects{'monarch_home'}[2];
$monarch_ver = $objects{'monarch_version'}[2];
$backup_dir = $objects{'backup_dir'}[2];
$upload_dir = $objects{'upload_dir'}[2];
$enable_externals = $objects{'enable_externals'}[2];
$enable_groups = $objects{'enable_groups'}[2];
$enable_ez = $objects{'enable_ez'}[2];
$nagios_share = $objects{'physical_html_path'}[2];
if ($is_portal) {
$doc_root = '/usr/local/groundwork/core/monarch/htdocs';
}
#
# Check user
#
my $deny_access = 0;
my $show_login = 0;
my $session_timeout = 0;
if ( defined($view) && $view eq 'logout' ) {
$show_login = 1;
( $userid, $session_id ) = undef;
}
elsif ( $is_portal || $auth == 1 ) {
## Auth level 1 = full access no login.
$user_acct = $ENV{'REMOTE_USER'};
if ($user_acct) {
my %super_user = ();
if ($session_id) {
( $userid, $user_acct, $session_id ) = StorProc->get_session($session_id);
}
else {
( $userid, $session_id ) = StorProc->set_gwm_session($user_acct);
}
my ( $auth_add, $auth_modify, $auth_delete ) = StorProc->auth_matrix( $userid, $auth );
%auth_add = %{$auth_add};
%auth_modify = %{$auth_modify};
%auth_delete = %{$auth_delete};
}
else {
$deny_access = 1;
}
}
elsif ( $auth == 2 ) {
## Auth level 2 = active login.
if ( $query->param('process_login') ) {
$userid = StorProc->check_user( $user_acct, $password );
my ( $auth_add, $auth_modify, $auth_delete ) = StorProc->auth_matrix($userid);
%auth_add = %{$auth_add};
%auth_modify = %{$auth_modify};
%auth_delete = %{$auth_delete};
if ( $auth_add{'enable_ez'}
&& ( $auth_add{'ez_main'} || $auth_add{'ez'} ) )
{
$ez = 1;
}
if ( $userid =~ /^\d+/ ) {
$session_id = StorProc->set_session( $userid, $user_acct );
}
else {
$show_login = 1;
}
}
elsif ($session_id) {
( $userid, $user_acct, $session_id ) = StorProc->get_session($session_id);
if ($user_acct) {
my ( $auth_add, $auth_modify, $auth_delete ) = StorProc->auth_matrix($userid);
%auth_add = %{$auth_add};
%auth_modify = %{$auth_modify};
%auth_delete = %{$auth_delete};
}
else {
$session_timeout = 1;
}
}
else {
$show_login = 1;
( $userid, $session_id ) = undef;
}
}
elsif ( $auth == 3 ) {
## Auth level 3 = passive login - single sign on.
## first check if we have a new user being passed
my $new_user_acct = $ENV{'REMOTE_USER'};
unless ($new_user_acct) { $new_user_acct = $query->param('user_acct') }
if ($new_user_acct) {
# now check for session info
( $userid, $user_acct, $session_id ) = StorProc->get_session( $session_id, $auth );
# does stored user = new user? -- if there is one stored
unless ( $new_user_acct eq $user_acct ) {
## no? then see if new user is valid and give them a sessionid if so
my %user = StorProc->fetch_one( 'users', 'user_acct', $new_user_acct );
$session_id = StorProc->set_session( $user{'user_id'}, $new_user_acct );
$user_acct = $new_user_acct;
}
}
else {
( $userid, $user_acct, $session_id ) = StorProc->get_session( $session_id, $auth );
}
if ($session_id) {
my ( $auth_add, $auth_modify, $auth_delete ) = StorProc->auth_matrix($userid);
%auth_add = %{$auth_add};
%auth_modify = %{$auth_modify};
%auth_delete = %{$auth_delete};
}
else {
$show_login = 1;
( $userid, $session_id ) = undef;
}
}
$deny_access = 1 if not defined $userid;
#
# Create frames and content
#
unless ( (defined($view) && $view =~ /search/) || $show_login ) {
my $cookie = $query->cookie( CGISESSID => $session_id );
print $query->header( -cookie => $cookie );
}
unless ($enable_externals) {
delete $auth_add{'externals'};
delete $auth_modify{'externals'};
delete $auth_delete{'externals'};
}
unless ($enable_groups) {
delete $auth_add{'groups'};
delete $auth_modify{'groups'};
delete $auth_delete{'groups'};
}
if ($show_login) {
print "Content-type: text/html \n\n";
print Forms->login( $page_title, $userid );
}
elsif ($deny_access) {
## print "Content-type: text/html \n\n";
print Forms->header( 'Error', 'no_session', 'no_menu' );
print Forms->form_top( 'Configuration', '' );
print Forms->wizard_doc( 'Access Denied', 'You must log in to use this feature.' );
print Forms->form_bottom_buttons();
print Forms->footer($debug);
}
elsif ( $query->param('update_top') ) {
my @top_menus = ();
my $login = $query->param('login');
if ($session_timeout) {
print Forms->login_redirect;
}
elsif ($ez) {
for my $object (qw(hosts host_groups profiles notifications commit setup)) {
no strict 'refs';
push( @top_menus, $object )
if ( $auth == 1 || $auth_add{ 'ez_' . $object } );
}
my $login = $query->param('login');
}
else {
for my $object ( qw(profiles services hosts contacts escalations time_periods commands) ) {
push( @top_menus, $object )
if ( $auth == 1 || $auth_add{$object} || $auth_modify{$object} );
}
for my $object (qw(groups control)) {
push( @top_menus, $object ) if ( $auth == 1 || $auth_add{$object} );
}
push @top_menus, 'tools';
}
push @top_menus, 'help';
print Forms->top_frame( $session_id, $top_menu, \@top_menus, $auth, $monarch_ver, $enable_ez, $ez, \%auth_add, $login );
}
elsif ( $query->param('update_main') ) {
$hidden{'update_main'} = 1;
if ($debug) {
$debug .= '';
foreach my $name ( sort $query->param ) {
my @values = $query->param($name);
$debug .= "$name = '" . join( "', '", @values ) . "'" . '
';
# ought to be:
# $debug .= HTML::Entities::encode("$name = '" . join("', '", @values) . "'") . '
';
}
$debug .= '';
}
my $errors = StorProc->check_version( $monarch_ver );
if ($session_timeout) {
if ( $view =~ /search/ ) { print "Content-type: text/html \n\n" }
$body .= Forms->login_redirect;
}
elsif (@$errors) {
if ( $view =~ /search/ ) { print "Content-type: text/html \n\n" }
$body .= schema_mismatch($errors);
}
elsif ( $view eq 'host_wizard' ) {
$body .= host_wizard();
}
elsif ( $view eq 'host_profile' ) {
$body .= host_profile();
}
elsif ( $view eq 'service_profile' ) {
$body .= service_profile();
}
elsif ( $view eq 'service_template' ) {
$body .= service_template();
}
elsif ( $view eq 'service_group' ) {
$body .= service_group();
}
elsif ( $view eq 'service' ) {
$body .= service();
}
elsif ( $view eq 'service_externals' ) {
$body .= externals('service');
}
elsif ( $view eq 'host_externals' ) {
$body .= externals('host');
}
elsif ( $view eq 'profile_importer' ) {
$body .= profile_importer();
}
elsif ( $view eq 'manage_host' ) {
$body .= manage_host();
}
elsif ( $view eq 'search_hosts' ) {
$body .= search();
}
elsif ( $view eq 'search_services' ) {
$body .= search_services();
}
elsif ( $view eq 'search_commands' || ( defined($obj) && $obj eq 'commands' && $view eq 'search' ) ) {
$body .= search_commands();
}
elsif ( $view eq 'search_host_externals' ) {
$body .= search_externals('host');
}
elsif ( $view eq 'search_service_externals' ) {
$body .= search_externals('service');
}
elsif ( $view eq 'clone_host' ) {
$body .= clone_host();
}
elsif ( $view eq 'delete_hosts' ) {
$body .= delete_hosts();
}
elsif ( $view eq 'delete_host_services' ) {
$body .= delete_host_services();
}
elsif ( $view eq 'host_dependencies' ) {
$body .= host_dependencies();
}
elsif ( $view eq 'parent_child' ) {
$body .= parent_child();
}
elsif ( $view eq 'escalations' ) {
$body .= escalations();
}
elsif ( $view eq 'escalation_trees' ) {
$body .= escalation_trees();
}
elsif ( $view eq 'commands' ) {
$body .= command_wizard();
}
elsif ( defined($obj) && $obj eq 'time_periods' ) {
$body = time_period();
}
elsif ( $view eq 'tools' ) {
$body .= tools();
}
elsif ( $view eq 'manage' ) {
$body .= manage();
}
elsif ( $view eq 'design' ) {
$body .= design();
}
elsif ( $view eq 'groups' ) {
$body .= groups();
}
elsif ( $view eq 'macros' ) {
$body .= macros();
}
elsif ( $view eq 'build_instances' ) {
$body .= build_instances();
}
elsif ( $view eq 'control' ) {
$body .= control();
}
else {
$body .= Forms->header( $page_title, $session_id, $top_menu );
}
print $body;
print Forms->footer($debug);
}
else {
print Forms->frame( $session_id, $top_menu, $is_portal, $ez );
}
my $result = StorProc->dbdisconnect();