diff options
Diffstat (limited to 'rhautoimport.pm')
| -rw-r--r-- | rhautoimport.pm | 187 |
1 files changed, 36 insertions, 151 deletions
diff --git a/rhautoimport.pm b/rhautoimport.pm index 76e3893..4bf9568 100644 --- a/rhautoimport.pm +++ b/rhautoimport.pm @@ -25,19 +25,31 @@ use strict; package rhautoimport; -use IO::Handle; -use IPC::Open3; -use File::Spec; use File::Basename; -use URI::Escape; +use IPC::Open3; +use IO::Handle; use LWP::Simple; use XML::Feed; +use RHRD::rddb; -my $ssh_host = "airplay"; -my $ssh_user = "rhautoimport"; -my $ssh_key_file = "$ENV{'HOME'}/.rhautoimport/import.key"; -my $ssh_dir = "/programm/.rhautoimport"; -my $rdimport_wrapper = "/usr/local/bin/dropbox_newfile.pl"; +use constant { + RD_USER => 'autoimport', +}; + + +sub get_dropboxes +{ + my ($groupname) = @_; + + my ($dbh, $status, $errorstring) = RHRD::rddb::opendb(); + if(!defined $dbh) { + return ($dbh, $errorstring); + } + my @allowed_dbs = RHRD::rddb::get_dropboxes($dbh, RD_USER, $groupname); + RHRD::rddb::closedb($dbh); + + return @allowed_dbs; +} sub fetch_parse_rss { @@ -59,162 +71,35 @@ sub fetch_parse_rss return XML::Feed->parse(\$xml); } -sub clear_carts +# TODO: use rhimportd for this? +sub check_file_extension { - my ($dbh, $group, $to_cart, $progress_cb) = @_; + my ($file) = @_; - my ($low_cart, $high_cart) = ($to_cart, $to_cart); - if($to_cart == 0) { - ($low_cart, $high_cart) = get_cart_range($dbh, $group); - } - - my $log = "clearing Carts $low_cart - $high_cart\n"; - print $log; - my $cart = $low_cart; - while($cart <= $high_cart) { - $progress_cb->($cart - $low_cart, $high_cart + 1 - $low_cart, "deleting $cart") if($progress_cb); - - my $sql = qq{select CUT_NAME from CUTS where CART_NUMBER='$cart';}; - my $sth = $dbh->prepare($sql); - $sth->execute(); - while(my $cut_name = $sth->fetchrow_array()) { - delete_file("/var/snd/$cut_name.wav"); - $log .= " - deleting file /var/snd/$cut_name.wav"; + my $ext = uc((fileparse($file, qr/\.[^.]*/))[2]); + foreach (".MP3", ".OGG", ".FLAC", ".WAV") { + if($ext eq $_) { + return 1; } - $sth->finish(); - - $sql = qq{delete from CUTS where CART_NUMBER='$cart';}; - $sth = $dbh->prepare($sql); - $sth->execute(); - $sth->finish(); - - $sql = qq{delete from CART where NUMBER='$cart';}; - $sth = $dbh->prepare($sql); - $sth->execute(); - $sth->finish(); - - $cart++; - } - - return $log; -} - -sub import_single -{ - my ($file, $dropbox, $user, $progress_cb, $error_cb) = @_; - print "Starting import from file $file to $dropbox\n"; - $progress_cb->(0, 1, $file) if($progress_cb); - prepare_import($user); - my ($ret, $out) = import_file($file, $dropbox, $user, $error_cb); - if($ret) { - $progress_cb->(1, 1, "Import abgeschlossen!") if($progress_cb); - } else { - $progress_cb->(0, 1, "Import abgebrochen!") if($progress_cb); } - return ($ret, $out); + return 0; } -sub scp_put_file -{ - my ($file, $user, $host, $path) = @_; - my @cmd = ( 'scp', '-prqB', '-i', $ssh_key_file, $file, "$user\@$host:$path/" ); - my ($reader, $writer, $error ) = ( new IO::Handle, new IO::Handle, new IO::Handle ); - $writer->autoflush(1); - local $SIG{CHLD} = 'DEFAULT'; - my $pid = open3($writer, $reader, $error, @cmd); - binmode($reader, ":utf8"); - binmode($writer, ":utf8"); - binmode($error, ":utf8"); - waitpid $pid, 0; - my $errstr = ""; - if ( $? >> 8 ) { - $errstr = join('', <$error>); - } - return $errstr; -} - -sub ssh_exec_command -{ - my ($command) = @_; - my @cmd = ( 'ssh' , '-q', '-o', 'BatchMode=yes', '-i', $ssh_key_file, "$ssh_user\@$ssh_host" , $command ); - my ($reader, $writer, $error ) = ( new IO::Handle, new IO::Handle, new IO::Handle ); - $writer->autoflush(1); - local $SIG{CHLD} = 'DEFAULT'; - my $pid = open3($writer, $reader, $error, @cmd); - binmode($reader, ":utf8"); - binmode($writer, ":utf8"); - binmode($error, ":utf8"); - waitpid $pid, 0; - my $out = join('', <$reader>); - my $errstr = ""; - if ( $? >> 8 ) { - $errstr = join('', <$error>); - $errstr = "unkown error" if($errstr eq ""); - } - return ($out, $errstr); -} - -sub prepare_import -{ - my ($user) = @_; - - ### create user directory - ssh_exec_command("umask 002; mkdir -p \"$ssh_dir/$user\""); -} - -sub import_file +sub clear_carts { - my ($file, $dropbox, $user, $error_cb) = @_; + my ($show_id) = @_; - print " - importing $file to $dropbox .. "; - $| = 1; - - ### copy file to master server - my $err = scp_put_file($file, $ssh_user, $ssh_host, "$ssh_dir/$user"); - if($err ne "") { - print "Transfer Error\n"; - if($error_cb) { - return $error_cb->($err); - } - return 0; - } - print "transferred .. "; - - ### remotely call rdimport - my ($volume, $directories, $remote_file) = File::Spec->splitpath($file); - $remote_file = "$ssh_dir/$user/$remote_file"; - my ($out ,$error) = ssh_exec_command("$rdimport_wrapper --path \"$dropbox\" --file \"$remote_file\""); - my $lastline = $1 if $out =~ /\n(.*)$/; - if($error ne "" || $lastline !~ /^[0-9:\- ]+:\s+Deleted file/) { - print "Import Error\n"; - delete_file($remote_file); - if($error_cb) { - if($error) { - return $error_cb->("Import Fehler: $error"); - } - else { - return $error_cb->("Import Fehler: \n$out"); - } - } - return 0; - } - - print "imported OK\n"; - return (1, $out); + return (1, "clear_carts not implemented...\n"); } -sub delete_file +sub import_uri { - my ($filename) = @_; + my ($show_id, $uri) = @_; - print " - deleting $filename\n"; - my ($out ,$err) = ssh_exec_command("rm \"$filename\""); - if($err ne "") { - return 0; - } - return 1; + return (1, "import_uri not implemented...\n"); } +# TODO: use rhimportd for this? sub pv_add_note { my ( $title, $text, $id, $date, $type, $index ) = @_; |