132 |
$log->logdie("need id") unless defined $id; |
$log->logdie("need id") unless defined $id; |
133 |
$log->logdie("need ds") unless $ds; |
$log->logdie("need ds") unless $ds; |
134 |
|
|
135 |
$log->debug("id: $id ds = ",dump($ds)); |
$log->debug("id: $id ds = ", sub { dump($ds) }); |
136 |
|
|
137 |
my $hash = $self->ds_to_hash( $ds, 'search' ) || return; |
my $hash = $self->ds_to_hash( $ds, 'search' ) || return; |
138 |
|
|
139 |
$hash->{database} ||= $self->database; |
$hash->{database} ||= $self->database; |
140 |
$hash->{id} ||= $id; |
$hash->{id} ||= $id; |
141 |
|
|
142 |
|
foreach my $f ( keys %$hash ) { |
143 |
|
if ( ref($hash->{$f}) eq 'ARRAY' ) { |
144 |
|
$hash->{$f} = join(' <*> ', @{ $hash->{$f} }); |
145 |
|
} |
146 |
|
} |
147 |
|
|
148 |
$log->debug("add( $id, ", sub { dump($ds) }," ) => ", sub { dump( $hash ) }); |
$log->debug("add( $id, ", sub { dump($ds) }," ) => ", sub { dump( $hash ) }); |
149 |
|
|
150 |
$self->index->add_doc( $hash ); |
$self->index->add_doc( $hash ); |
151 |
|
|
152 |
|
$self->{count}++; |
153 |
|
|
154 |
return 1; |
return 1; |
155 |
} |
} |
156 |
|
|
167 |
|
|
168 |
my $log = $self->_get_logger(); |
my $log = $self->_get_logger(); |
169 |
|
|
170 |
$log->info("dummy finish"); |
$log->info("indexed ", $self->{count}, " records"); |
171 |
|
|
172 |
} |
} |
173 |
|
|