gosa-si/server/events/gosaTriggered.pm

   1 package gosaTriggered;
   2 use Exporter;
   3 @ISA = qw(Exporter);
   4 my @events = (
   5     "get_events",
   6     "get_login_usr_for_client",
   7     "get_client_for_login_usr",
   8     "gen_smb_hash",
   9     "trigger_reload_ldap_config",
  10     "ping",
  11     "network_completition",
  12     "set_activated_for_installation",
  13     "new_key_for_client",
  14     "detect_hardware",
  15     "get_login_usr",
  16     "get_login_client",
  17     "trigger_action_localboot",
  18     "trigger_action_faireboot",
  19     "trigger_action_reboot",
  20     "trigger_action_activate",
  21     "trigger_action_lock",
  22     "trigger_action_halt",
  23     "trigger_action_update",
  24     "trigger_action_reinstall",
  25     "trigger_action_memcheck",
  26     "trigger_action_sysinfo",
  27     "trigger_action_instant_update",
  28     "trigger_action_rescan",
  29     "trigger_action_wake",
  30     "recreate_fai_server_db",
  31     "send_user_msg",
  32     );
  33 @EXPORT = @events;
  34
  35 use strict;
  36 use warnings;
  37 use GOSA::GosaSupportDaemon;
  38 use Data::Dumper;
  39 use Crypt::SmbHash;
  40 use Net::ARP;
  41 use Net::Ping;
  42 use Socket;
  43 use utf8;
  44
  45 BEGIN {}
  46
  47 END {}
  48
  49 ### Start ######################################################################
  50
  51 #&main::read_configfile($main::cfg_file, %cfg_defaults);
  52
  53 sub get_events {
  54     return \@events;
  55 }
  56
  57 sub send_user_msg {
  58     my ($msg, $msg_hash, $session_id) = @_ ;
  59     my @out_msg_l;
  60     my @user_list;
  61     my @group_list;
  62
  63     my $header = @{$msg_hash->{'header'}}[0];
  64     my $source = @{$msg_hash->{'source'}}[0];
  65     my $target = @{$msg_hash->{'target'}}[0];
  66     my $message = @{$msg_hash->{'message'}}[0];
  67     if( exists $msg_hash->{'user'} ) { @user_list = @{$msg_hash->{'user'}}; }
  68     if( exists $msg_hash->{'group'} ) { @group_list = @{$msg_hash->{'group'}}; }
  69
  70     # error handling
  71     if( not @user_list && not @group_list ) {
  72         &main::daemon_log("WARNING: no user-tag or a group-tag specified in 'send_user_msg'", 3);
  73         return ("<xml><header>$header</header><source>GOSA</source><target>GOSA</target>".
  74                 "<error_string>no user-tag or a group-tag specified in 'send_user_msg'</error_string></xml>");
  75     }
  76     if( not defined $message ) {
  77         &main::daemon_log("WARNING: no message-tag specified in 'send_user_msg'", 3);
  78         return ("<xml><header>$header</header><source>GOSA</source><target>GOSA</target>".
  79                 "<error_string>no message-tag specified in 'send_user_msg'</error_string></xml>");
  80
  81     }
  82
  83     # resolve groups to users
  84     if( @group_list ) {
  85         # build ldap connection
  86         &main::refresh_ldap_handle();
  87         if( not defined $main::ldap_handle ) {
  88             &main::daemon_log("ERROR: cannot connect to ldap", 1);
  89             return ();
  90         }
  91         foreach my $group (@group_list) {
  92             # Perform search
  93             my $mesg = $main::ldap_handle->search(
  94                     base => $main::ldap_base,
  95                     scope => 'sub',
  96                     attrs => ['memberUid'],
  97                     filter => "(&(objectClass=posixGroup)(cn=$group)(memberUid=*))");
  98             if($mesg->code) {
  99                 &main::daemon_log($mesg->error, 1);
 100                 return ();
 101             }
 102             my $entry= $mesg->entry(0);
 103             my @users= $entry->get_value("memberUid");
 104             foreach my $user (@users) { push(@user_list, $user); }
 105         }
 106     }
 107
 108     # drop multiple users in @user_list
 109     my %seen = ();
 110     foreach my $user (@user_list) {
 111         $seen{$user}++;
 112     }
 113     @user_list = keys %seen;
 114
 115     # build xml messages sended to client where user is logged in
 116     foreach my $user (@user_list) {
 117         my $sql_statement = "SELECT * FROM $main::login_users_tn WHERE user='$user'";
 118         my $db_res = $main::login_users_db->select_dbentry($sql_statement);
 119
 120         if(0 == keys(%{$db_res})) {
 121
 122         } else {
 123             while( my($hit, $content) = each %{$db_res} ) {
 124                 my $out_hash = &create_xml_hash('send_user_msg', $main::server_address, $content->{'client'});
 125                 &add_content2xml_hash($out_hash, 'message', $message);
 126                 &add_content2xml_hash($out_hash, 'user', $user);
 127                 if( exists $msg_hash->{'jobdb_id'} ) {
 128                     &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
 129                 }
 130                 my $out_msg = &create_xml_string($out_hash);
 131                 push(@out_msg_l, $out_msg);
 132             }
 133         }
 134     }
 135
 136     return @out_msg_l;
 137 }
 138
 139
 140 sub recreate_fai_server_db {
 141     my ($msg, $msg_hash, $session_id) = @_ ;
 142     my $out_msg;
 143
 144     $main::fai_server_db->create_table("new_fai_server", \@main::fai_server_col_names);
 145     &main::create_fai_server_db("new_fai_server");
 146     $main::fai_server_db->move_table("new_fai_server", $main::fai_server_tn);
 147
 148     my @out_msg_l = ( $out_msg );
 149     return @out_msg_l;
 150 }
 151
 152
 153 sub get_login_usr_for_client {
 154     my ($msg, $msg_hash, $session_id) = @_ ;
 155     my $header = @{$msg_hash->{'header'}}[0];
 156     my $source = @{$msg_hash->{'source'}}[0];
 157     my $target = @{$msg_hash->{'target'}}[0];
 158     my $client = @{$msg_hash->{'client'}}[0];
 159
 160     $header =~ s/^gosa_//;
 161
 162     my $sql_statement = "SELECT * FROM known_clients WHERE hostname='$client' OR macaddress='$client'";
 163     my $res = $main::known_clients_db->select_dbentry($sql_statement);
 164
 165     my $out_msg = "<xml><header>$header</header><source>$target</source><target>$source</target>";
 166     $out_msg .= &db_res2xml($res);
 167     $out_msg .= "</xml>";
 168
 169     my @out_msg_l = ( $out_msg );
 170     return @out_msg_l;
 171 }
 172
 173
 174 sub get_client_for_login_usr {
 175     my ($msg, $msg_hash, $session_id) = @_ ;
 176     my $header = @{$msg_hash->{'header'}}[0];
 177     my $source = @{$msg_hash->{'source'}}[0];
 178     my $target = @{$msg_hash->{'target'}}[0];
 179     my $usr = @{$msg_hash->{'usr'}}[0];
 180     $header =~ s/^gosa_//;
 181
 182     my $sql_statement = "SELECT * FROM known_clients WHERE login LIKE '%$usr%'";
 183     my $res = $main::known_clients_db->select_dbentry($sql_statement);
 184
 185     my $out_msg = "<xml><header>$header</header><source>$target</source><target>$source</target>";
 186     $out_msg .= &db_res2xml($res);
 187     $out_msg .= "</xml>";
 188     my @out_msg_l = ( $out_msg );
 189     return @out_msg_l;
 190
 191 }
 192
 193
 194 sub ping {
 195     my ($msg, $msg_hash, $session_id) = @_ ;
 196     my $out_msg = $msg;
 197     $out_msg =~ s/<header>gosa_/<header>/;
 198     $out_msg =~ s/<\/xml>/<session_id>$session_id<\/session_id><\/xml>/;
 199
 200     my @out_msg_l = ( $out_msg );
 201     return @out_msg_l;
 202 }
 203
 204 sub gen_smb_hash {
 205      my ($msg, $msg_hash, $session_id) = @_ ;
 206      my $source = @{$msg_hash->{source}}[0];
 207      my $target = @{$msg_hash->{target}}[0];
 208      my $password = @{$msg_hash->{password}}[0];
 209
 210      my %data= ('hash' => join(q[:], ntlmgen $password));
 211      my $out_msg = &build_msg("gen_smb_hash", $target, 'GOSA', \%data );
 212      return ( $out_msg );
 213 }
 214
 215
 216 sub network_completition {
 217      my ($msg, $msg_hash, $session_id) = @_ ;
 218      my $source = @{$msg_hash->{source}}[0];
 219      my $target = @{$msg_hash->{target}}[0];
 220      my $name = @{$msg_hash->{hostname}}[0];
 221
 222      # Can we resolv the name?
 223      my %data;
 224      if (inet_aton($name)){
 225              my $address = inet_ntoa(inet_aton($name));
 226              my $p = Net::Ping->new('tcp');
 227              my $mac= "";
 228              if ($p->ping($address, 1)){
 229                $mac = Net::ARP::arp_lookup("", $address);
 230              }
 231
 232              %data= ('ip' => $address, 'mac' => $mac);
 233      } else {
 234              %data= ('ip' => '', 'mac' => '');
 235      }
 236
 237      my $out_msg = &build_msg("network_completition", $target, 'GOSA', \%data );
 238
 239      return ( $out_msg );
 240 }
 241
 242
 243 sub detect_hardware {
 244     my ($msg, $msg_hash) = @_ ;
 245     # just forward msg to client, but dont forget to split off 'gosa_' in header
 246     my $source = @{$msg_hash->{source}}[0];
 247     my $target = @{$msg_hash->{target}}[0];
 248
 249     my $out_hash = &create_xml_hash("detect_hardware", $source, $target);
 250     if( exists $msg_hash->{'jobdb_id'} ) {
 251         &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
 252     }
 253     my $out_msg = &create_xml_string($out_hash);
 254
 255     my @out_msg_l = ( $out_msg );
 256     return @out_msg_l;
 257
 258 }
 259
 260
 261 sub trigger_reload_ldap_config {
 262     my ($msg, $msg_hash) = @_ ;
 263     my $target = @{$msg_hash->{target}}[0];
 264
 265     my $out_hash = &create_xml_hash("reload_ldap_config", $main::server_address, $main::server_address, $target);
 266     if( exists $msg_hash->{'jobdb_id'} ) {
 267         &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
 268     }
 269     my $out_msg = &create_xml_string($out_hash);
 270     my @out_msg_l;
 271     push(@out_msg_l, $out_msg);
 272     return @out_msg_l;
 273 }
 274
 275
 276 sub set_activated_for_installation {
 277     my ($msg, $msg_hash) = @_;
 278
 279     my $header = @{$msg_hash->{header}}[0];
 280     my $source = @{$msg_hash->{source}}[0];
 281     my $target = @{$msg_hash->{target}}[0];
 282
 283     my $out_hash = &create_xml_hash("set_activated_for_installation", $source, $target);
 284     if( exists $msg_hash->{'jobdb_id'} ) {
 285         &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
 286     }
 287     my $out_msg = &create_xml_string($out_hash);
 288     my @out_msg_l = ( $out_msg );
 289     return @out_msg_l;
 290 }
 291
 292
 293 sub trigger_action_faireboot {
 294     my ($msg, $msg_hash) = @_;
 295     my $macaddress = @{$msg_hash->{target}}[0];
 296     my $source = @{$msg_hash->{source}}[0];
 297
 298     my @out_msg_l;
 299     $msg =~ s/<header>gosa_trigger_action_faireboot<\/header>/<header>trigger_action_faireboot<\/header>/;
 300     push(@out_msg_l, $msg);
 301
 302     &main::change_goto_state('locked', \@{$msg_hash->{target}});
 303     &main::change_fai_state('localboot', \@{$msg_hash->{target}});
 304
 305     # delete all jobs from jobqueue which correspond to fai
 306     my $sql_statement = "DELETE FROM $main::job_queue_tn WHERE (macaddress='$macaddress' AND ".
 307         "status='processing')";
 308     $main::job_db->del_dbentry($sql_statement );
 309
 310     return @out_msg_l;
 311 }
 312
 313
 314 sub trigger_action_lock {
 315     my ($msg, $msg_hash) = @_;
 316     my $macaddress = @{$msg_hash->{target}}[0];
 317     my $source = @{$msg_hash->{source}}[0];
 318
 319     &main::change_goto_state('locked', \@{$msg_hash->{target}});
 320
 321     my @out_msg_l;
 322     return @out_msg_l;
 323 }
 324
 325
 326 sub trigger_action_activate {
 327     my ($msg, $msg_hash) = @_;
 328     my $macaddress = @{$msg_hash->{target}}[0];
 329     my $source = @{$msg_hash->{source}}[0];
 330
 331     &main::change_goto_state('active', \@{$msg_hash->{target}});
 332
 333     my $out_hash = &create_xml_hash("set_activated_for_installation", $source, $macaddress);
 334     if( exists $msg_hash->{'jobdb_id'} ) {
 335         &add_content2xml_hash($out_hash, 'jobdb_id', @{$msg_hash->{'jobdb_id'}}[0]);
 336     }
 337     my $out_msg = &create_xml_string($out_hash);
 338
 339     return ( $out_msg );
 340 }
 341
 342
 343 sub trigger_action_localboot {
 344     my ($msg, $msg_hash) = @_;
 345     $msg =~ s/<header>gosa_trigger_action_localboot<\/header>/<header>trigger_action_localboot<\/header>/;
 346
 347     &main::change_fai_state('localboot', \@{$msg_hash->{target}});
 348
 349     my @out_msg_l = ($msg);
 350     return @out_msg_l;
 351 }
 352
 353
 354 sub trigger_action_halt {
 355     my ($msg, $msg_hash) = @_;
 356     $msg =~ s/<header>gosa_trigger_action_halt<\/header>/<header>trigger_action_halt<\/header>/;
 357
 358     &main::change_fai_state('halt', \@{$msg_hash->{target}});
 359
 360     my @out_msg_l = ($msg);
 361     return @out_msg_l;
 362 }
 363
 364
 365 sub trigger_action_reboot {
 366     my ($msg, $msg_hash) = @_;
 367     $msg =~ s/<header>gosa_trigger_action_reboot<\/header>/<header>trigger_action_reboot<\/header>/;
 368
 369     &main::change_fai_state('reboot', \@{$msg_hash->{target}});
 370
 371     my @out_msg_l = ($msg);
 372     return @out_msg_l;
 373 }
 374
 375
 376 sub trigger_action_memcheck {
 377     my ($msg, $msg_hash) = @_ ;
 378     $msg =~ s/<header>gosa_trigger_action_memcheck<\/header>/<header>trigger_action_memcheck<\/header>/;
 379
 380     &main::change_fai_state('memcheck', \@{$msg_hash->{target}});
 381
 382     my @out_msg_l = ($msg);
 383     return @out_msg_l;
 384 }
 385
 386
 387 sub trigger_action_reinstall {
 388     my ($msg, $msg_hash) = @_;
 389     $msg =~ s/<header>gosa_trigger_action_reinstall<\/header>/<header>trigger_action_reinstall<\/header>/;
 390
 391     &main::change_fai_state('reinstall', \@{$msg_hash->{target}});
 392
 393     my %data = ( 'macAddress'  => \@{$msg_hash->{target}} );
 394     my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
 395     my @out_msg_l = ($wake_msg, $msg);
 396     return @out_msg_l;
 397 }
 398
 399
 400 sub trigger_action_update {
 401     my ($msg, $msg_hash) = @_;
 402     $msg =~ s/<header>gosa_trigger_action_update<\/header>/<header>trigger_action_update<\/header>/;
 403
 404     &main::change_fai_state('update', \@{$msg_hash->{target}});
 405
 406     my %data = ( 'macAddress'  => \@{$msg_hash->{target}} );
 407     my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
 408     my @out_msg_l = ($wake_msg, $msg);
 409     return @out_msg_l;
 410 }
 411
 412
 413 sub trigger_action_instant_update {
 414     my ($msg, $msg_hash) = @_;
 415     $msg =~ s/<header>gosa_trigger_action_instant_update<\/header>/<header>trigger_action_instant_update<\/header>/;
 416
 417     &main::change_fai_state('update', \@{$msg_hash->{target}});
 418
 419     my %data = ( 'macAddress'  => \@{$msg_hash->{target}} );
 420     my $wake_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
 421     my @out_msg_l = ($wake_msg, $msg);
 422     return @out_msg_l;
 423 }
 424
 425
 426 sub trigger_action_sysinfo {
 427     my ($msg, $msg_hash) = @_;
 428     $msg =~ s/<header>gosa_trigger_action_sysinfo<\/header>/<header>trigger_action_sysinfo<\/header>/;
 429
 430     &main::change_fai_state('sysinfo', \@{$msg_hash->{target}});
 431
 432     my @out_msg_l = ($msg);
 433     return @out_msg_l;
 434 }
 435
 436
 437 sub new_key_for_client {
 438     my ($msg, $msg_hash) = @_;
 439     $msg =~ s/<header>gosa_new_key_for_client<\/header>/<header>new_key<\/header>/;
 440     my @out_msg_l = ($msg);
 441     return @out_msg_l;
 442 }
 443
 444
 445 sub trigger_action_rescan {
 446     my ($msg, $msg_hash) = @_;
 447     $msg =~ s/<header>gosa_trigger_action_rescan<\/header>/<header>trigger_action_rescan<\/header>/;
 448     my @out_msg_l = ($msg);
 449     return @out_msg_l;
 450 }
 451
 452
 453 sub trigger_action_wake {
 454     my ($msg, $msg_hash) = @_;
 455     my %data = ( 'macAddress'  => \@{$msg_hash->{target}} );
 456     my $out_msg = &build_msg("trigger_wake", "GOSA", "KNOWN_SERVER", \%data);
 457     my @out_msg_l = ($out_msg);
 458     return @out_msg_l;
 459 }
 460
 461
 462 1;