sub _indexer {
$indexer ||= KinoSearch::Index::Indexer->new(
schema => $schema,
- index => '/tmp/index',
+ index => "/tmp/kinosearch.$database",
create => 1,
);
};
sub filter {
my $change = shift;
my $doc = $change->{doc} || next;
+
+ _indexer->delete_by_term( field => '_id', term => $doc->{_id} );
+ return 0 if $doc->{_deleted};
+
my $flat;
flatten( \$flat, $doc, '' );
foreach my $field ( keys %$flat ) {