/usr/share/perl5/Apache/Ocsinventory/Server/Inventory/Update.pm is in ocsinventory-server 2.0.5-1.1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 | ###############################################################################
## OCSINVENTORY-NG
## Copyleft Pascal DANEK 2008
## Web : http://www.ocsinventory-ng.org
##
## This code is open source and may be copied and modified as long as the source
## code is always made freely available.
## Please refer to the General Public Licence http://www.gnu.org/ or Licence.txt
################################################################################
package Apache::Ocsinventory::Server::Inventory::Update;
use Apache::Ocsinventory::Server::Inventory::Cache;
use Apache::Ocsinventory::Server::Inventory::Update::Hardware;
use Apache::Ocsinventory::Server::Inventory::Update::AccountInfos;
use strict;
require Exporter;
our @ISA = qw /Exporter/;
our @EXPORT = qw / _update_inventory /;
use Apache::Ocsinventory::Server::System qw / :server /;
use Apache::Ocsinventory::Server::Inventory::Data;
sub _update_inventory{
my ( $sectionsMeta, $sectionsList ) = @_;
my $result = $Apache::Ocsinventory::CURRENT_CONTEXT{'XML_ENTRY'};
my $section;
&_reset_inventory_cache( $sectionsMeta, $sectionsList ) if $ENV{OCS_OPT_INVENTORY_CACHE_ENABLED};
# Call special sections update
if(&_hardware($sectionsMeta->{'hardware'}) or &_accountinfo()){
return 1;
}
# Call the _update_inventory_section for each section
for $section (@{$sectionsList}){
#Only if section exists in XML or if table is mandatory
if (($result->{CONTENT}->{uc $section} || $sectionsMeta->{$section}->{mandatory}) && $sectionsMeta->{$section}->{auto}) {
if(_update_inventory_section($section, $sectionsMeta->{$section})){
return 1;
}
}
}
}
sub _update_inventory_section{
my ($section, $sectionMeta) = @_;
my @bind_values;
my $deviceId = $Apache::Ocsinventory::CURRENT_CONTEXT{'DATABASE_ID'};
my $result = $Apache::Ocsinventory::CURRENT_CONTEXT{'XML_ENTRY'};
my $dbh = $Apache::Ocsinventory::CURRENT_CONTEXT{'DBI_HANDLE'};
# The computer exists.
# We check if this section has changed since the last inventory (only if activated)
# We delete the previous entries
if($Apache::Ocsinventory::CURRENT_CONTEXT{'EXIST_FL'}){
if($ENV{'OCS_OPT_INVENTORY_DIFF'}){
if( _has_changed($section) ){
&_log( 113, 'inventory', "u:$section") if $ENV{'OCS_OPT_LOGLEVEL'};
$sectionMeta->{hasChanged} = 1;
}
else{
return 0;
}
}
else{
$sectionMeta->{hasChanged} = 1;
}
if( $sectionMeta->{delOnReplace} && !($sectionMeta->{writeDiff} && $ENV{'OCS_OPT_INVENTORY_WRITE_DIFF'}) ){
if(!$dbh->do("DELETE FROM $section WHERE HARDWARE_ID=?", {}, $deviceId)){
return(1);
}
}
}
# DEL AND REPLACE, or detect diff on elements of the section (more load on frontends, less on DB backend)
if($Apache::Ocsinventory::CURRENT_CONTEXT{'EXIST_FL'} && $ENV{'OCS_OPT_INVENTORY_WRITE_DIFF'} && $sectionMeta->{writeDiff}){
my @fromDb;
my @fromXml;
my $refXml = $result->{CONTENT}->{uc $section};
my $sth = $dbh->prepare($sectionMeta->{sql_select_string});
$sth->execute($deviceId) or return 1;
while(my @row = $sth->fetchrow_array){
push @fromDb, [ @row ];
}
for my $line (@$refXml){
&_get_bind_values($line, $sectionMeta, \@bind_values);
push @fromXml, [ @bind_values ];
@bind_values = ();
}
#TODO: Sorting XML entries, to compare more quickly with DB elements
my $new=0;
my $del=0;
for my $l_xml (@fromXml){
my $found = 0;
for my $i_db (0..$#fromDb){
next unless $fromDb[$i_db];
my @line = @{$fromDb[$i_db]};
my $comp_xml = join '', @$l_xml;
my $comp_db = join '', @line[2..$#line];
if( $comp_db eq $comp_xml ){
$found = 1;
# The value has been found, we have to delete it from the db list
# (elements remaining will be deleted)
delete $fromDb[$i_db];
last;
}
}
if(!$found){
$new++;
$dbh->do( $sectionMeta->{sql_insert_string}, {}, $deviceId, @$l_xml ) or return 1;
if( $ENV{OCS_OPT_INVENTORY_CACHE_ENABLED} && $sectionMeta->{cache} ){
&_cache( 'add', $section, $sectionMeta, $l_xml );
}
}
}
# Now we have to delete from DB elements that still remain in fromDb
for (@fromDb){
next if !defined (${$_}[0]);
$del++;
$dbh->do( $sectionMeta->{sql_delete_string}, {}, $deviceId, ${$_}[0]) or return 1;
my @ldb = @$_;
@ldb = @ldb[ 2..$#ldb ];
if( $ENV{OCS_OPT_INVENTORY_CACHE_ENABLED} && $sectionMeta->{cache} && !$ENV{OCS_OPT_INVENTORY_CACHE_KEEP}){
&_cache( 'del', $section, $sectionMeta, \@ldb );
}
}
if( $new||$del ){
&_log( 113, 'write_diff', "ch:$section(+$new-$del)") if $ENV{'OCS_OPT_LOGLEVEL'};
}
}
else{
# Processing values
my $sth = $dbh->prepare( $sectionMeta->{sql_insert_string} );
# Multi lines (forceArray)
my $refXml = $result->{CONTENT}->{uc $section};
if($sectionMeta->{multi}){
for my $line (@$refXml){
&_get_bind_values($line, $sectionMeta, \@bind_values);
if(!$sth->execute($deviceId, @bind_values)){
return(1);
}
if( $ENV{OCS_OPT_INVENTORY_CACHE_ENABLED} && $sectionMeta->{cache} ){
&_cache( 'add', $section, $sectionMeta, \@bind_values );
}
@bind_values = ();
}
}
# One line (hash)
else{
&_get_bind_values($refXml, $sectionMeta, \@bind_values);
if( !$sth->execute($deviceId, @bind_values) ){
return(1);
}
if( $ENV{OCS_OPT_INVENTORY_CACHE_ENABLED} && $sectionMeta->{cache} ){
&_cache( 'add', $section, $sectionMeta, \@bind_values );
}
}
}
$dbh->commit unless $ENV{'OCS_OPT_INVENTORY_TRANSACTION'};
0;
}
1;
|