package SL::BackgroundJob::RemoveInvalidFileEntries;

use strict;
use warnings;

use parent qw(SL::BackgroundJob::Base);

use SL::File;

use constant WAITING_FOR_EXECUTION => 0;
use constant SCAN_START            => 1;
use constant DONE                  => 2;

# Data format:
# my $data = {
#   file_errors = [
#     "Ich bin ein Fehler",
#   ],
# }

sub scan_file_entry {
  my ($self)  = @_;
  my $job_obj = $self->{job_obj};
  $job_obj->set_data(status => SCAN_START())->save;

  my @file_entries = @{ SL::DB::Manager::File->get_all() };

  my @files = map { SL::File::Object->new(db_file => $_, id => $_->id, loaded => 1) } @file_entries;

  my $data  = $job_obj->data_as_hash;
  foreach my $file (@files) {
    unless (eval {$file->get_file()}) {
      #warn $@;
      push(@{$data->{file_errors}}, $@);
      $job_obj->update_attributes(data_as_hash => $data);
      $file->loaded_db_file->delete();
    }
  }
}

sub run {
  my ($self, $job_obj) = @_;
  $self->{job_obj} = $job_obj;

  $self->scan_file_entry();

  $job_obj->set_data(status => DONE())->save;
  return 1;
}

1;