/[dehs]/trunk/dehs_pg.php
ViewVC logotype

Diff of /trunk/dehs_pg.php

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 43 by evaso-guest, Wed Mar 28 23:54:07 2007 UTC revision 44 by evaso-guest, Fri Aug 3 15:50:04 2007 UTC
# Line 416  function is_updated ($up_vers,$debian_ve Line 416  function is_updated ($up_vers,$debian_ve
416  if ($up_vers=='') return 0;  if ($up_vers=='') return 0;
417  passthru("dpkg --compare-versions '$up_vers' eq '" . vers_conv($debian_vers) . "'",$great);  passthru("dpkg --compare-versions '$up_vers' eq '" . vers_conv($debian_vers) . "'",$great);
418  if ($great!=0) return 1;  if ($great!=0) return 1;
419  else return 0;  else return 0;
420  }  }
421  function db_upstream($initial='%') {  function db_upstream($initial='%') {
422         global $dirs,$dbconn;         global $dirs,$dbconn;
# Line 434  function db_upstream($initial='%') { Line 434  function db_upstream($initial='%') {
434                      $updated=is_updated($uscan_res[0],$res_array[version]);                      $updated=is_updated($uscan_res[0],$res_array[version]);
435                                  if ($uscan_res[0]!=$res_array[up_version]) ($keep_changes=1);                                  if ($uscan_res[0]!=$res_array[up_version]) ($keep_changes=1);
436                                  else $keep_changes=0;                                  else $keep_changes=0;
437                                  pg_exec($db, "UPDATE pkgs SET version='". $version . "', up_version='" . $uscan_res[0] . "',up_url='" . $uscan_res[2] . "', watch_warn='" . $uscan_res[1] . "',keep_changes='$keep_changes', wwiz_version=NULL, wwiz_type=NULL, wwiz=NULL, updated='$updated' WHERE id=$res_array[id]") or Die("Error in update pkgs upstream");                  $up_url=iconv("ISO-8859-1","UTF-8",$uscan_res[2]);
438                                    $up_version=iconv("ISO-8859-1","UTF-8",$uscan_res[0]);
439                                    $watch_warn=iconv("ISO-8859-1","UTF-8",$uscan_res[1]);
440                                    pg_exec($db, "UPDATE pkgs SET version='". $version . "', up_version='" . $up_version . "',up_url='" . $up_url . "', watch_warn='" . $watch_warn . "',keep_changes='$keep_changes', wwiz_version=NULL, wwiz_type=NULL, wwiz=NULL, updated='$updated' WHERE id=$res_array[id]") or Die("Error in update pkgs upstream");
441                                  #print "\rUpdated " . $res_array['name'] .  " => $updated Up Version => ". $uscan_res[0];                                  #print "\rUpdated " . $res_array['name'] .  " => $updated Up Version => ". $uscan_res[0];
442                                  print "\rUpstream left => " . $tot --;                                  print "\rUpstream left => " . $tot --;
443  #                               }  #                               }
# Line 455  function check_url ($url) { Line 458  function check_url ($url) {
458     if (isset ($url_p["host"])) $host = $url_p["host"];     if (isset ($url_p["host"])) $host = $url_p["host"];
459     else return false;     else return false;
460     preg_match("/(http|ftp)/",$host,$matches);     preg_match("/(http|ftp)/",$host,$matches);
461     if ($matches[1]=='http') $fp = fsockopen ($host, 80, $errno, $errstr, 10);     if ($matches[1]=='http') $fp = fsockopen ($host, 80, $errno, $errstr, 5);
462     elseif ($matches[1]=='ftp') $fp2 = fsockopen ($host, 21, $errno, $errstr, 10);     elseif ($matches[1]=='ftp') $fp2 = fsockopen ($host, 21, $errno, $errstr, 5);
463     if (!$fp AND !$fp2) return false;     if (!$fp AND !$fp2) return false;
464     else return true;     else return true;
465  }  }
466  function keep_remote ($localfile,$remotefile) {  function keep_remote ($localfile,$remotefile) {
467          #if (!check_url($remotefile)) return false;          if (!check_url($remotefile)) return false;
468          $rfp = @fopen ($remotefile, "rb");  #       $rfp = @fopen ($remotefile, "r");
469          if (!$rfp) {  #       if (!$rfp) {
470                  return false;  #               return false;
471                  }  #               }
472          $lfp = fopen ($localfile, "w");  #     fclose($rfp);
473    #       $lfp = fopen ($localfile, "w");
474    #       stream_set_blocking($rfp,0);
475  #       ini_set ( "memory_limit", "100M");  #       ini_set ( "memory_limit", "100M");
476          while (!feof($rfp)) {  #       while (!feof($rfp)) {
477                  $data = fread($rfp, 1024);  #               $data = fread($rfp, 8192);
478                  $bytes+=1024;  #               $bytes+=8192;
479                  #print "Downlaoding $remotefile: $bytes\r";  #               print "Downlaoding $remotefile: $bytes\r";
480                  fwrite($lfp, $data);  #               fwrite($lfp, $data);
481          }  #       } while (true);
482  #       ini_set ( "memory_limit", "15M");  #       ini_set ( "memory_limit", "15M");
483          fclose($lfp);  
484          fclose($rfp);          if (!copy($remotefile, $localfile)) {
485        echo "Copia di $file non riuscita ...\n";
486        return false;
487    }
488    #       fclose($lfp);
489    #       fclose($rfp);
490    
491          return true;          return true;
492  }  }
493  function up_changes($src_name='%') {  function up_changes($src_name='%') {
494      global $dbconn;      global $dbconn;
495          $changes_files=array("CHANGES","NEWS","Changelog","ChangeLog","changelog");          $changes_files=array("CHANGES","NEWS","Changelog","ChangeLog","changelog");
496      $db = pg_connect($dbconn) ;      $db = pg_pconnect($dbconn) ;
497      $rsql=pg_exec($db, "SELECT id,up_url FROM pkgs WHERE up_url!=''  AND keep_changes='t' AND name LIKE '$src_name%'");      $rsql=pg_exec($db, "SELECT id,up_url FROM pkgs WHERE up_url!=''  AND keep_changes='t' AND name LIKE '$src_name%'");
498          $tot=pg_numrows($rsql);          $tot=pg_numrows($rsql);
499          while ($res_array=pg_fetch_array($rsql)) {          while ($res_array=pg_fetch_array($rsql)) {
500                      $localfile=tempnam("/tmp/", "dehs-" . $res_array[id] . ".tar.gz");                      $localfile=tempnam("/tmp/", "dehs-" . $res_array[id] . ".tar.gz");
501                          #print "I'm downloading $res_array[up_url]\r";                          print "I'm downloading $res_array[up_url]\r";
502                          $res=keep_remote($localfile,$res_array['up_url']);                          $res=keep_remote($localfile,$res_array['up_url']);
503                          #print "UPDATE pkgs SET up_changes='', keep_changes='f' WHERE id=$res_array[id]";                          print "UPDATE pkgs SET up_changes='', keep_changes='f' WHERE id=$res_array[id]";
504                          if (!$res) {                          if (!$res) {
505                                  pg_exec($db, "UPDATE pkgs SET up_changes='', keep_changes='f' WHERE id=$res_array[id]");                                  pg_exec($db, "UPDATE pkgs SET up_changes='', keep_changes='f' WHERE id=$res_array[id]");
506                                  $notdown++;                                  $notdown++;
# Line 562  function db_up_error() { Line 572  function db_up_error() {
572          print "Total line => $totline\n";          print "Total line => $totline\n";
573          foreach ($ferrors as $line) {          foreach ($ferrors as $line) {
574             # print $line . "\n";             # print $line . "\n";
575                  $founded=preg_match("/Package:.+<strong>([^<]+)<\/strong><\/a>.+<strong>((\d+)\syear\sand\s|)(\d+)\sdays/sS",$line,$matches);                  $founded=preg_match("/Package:.+?>([^<]+)<\/a>.+<strong>((\d+)\syear\sand\s|)(\d+)\sdays/sS",$line,$matches);
576                  if ($founded) {                  if ($founded) {
577                          $errors[$matches[1]][err_tot]++;                          $errors[$matches[1]][err_tot]++;
578                          $errors[$matches[1]][days]+=$matches[3]*365+$matches[4];                          $errors[$matches[1]][days]+=$matches[3]*365+$matches[4];
# Line 755  function dehsqa_db () { Line 765  function dehsqa_db () {
765                          else $wwiz=$res_array[wwiz_type];                          else $wwiz=$res_array[wwiz_type];
766                          $xml="<data><id>$res_array[id]</id>" .                          $xml="<data><id>$res_array[id]</id>" .
767                                  "<up_version>$version</up_version>" .                                  "<up_version>$version</up_version>" .
                                 "<wwiz>$wwiz</wwiz>" .  
768                                  "</data>";                                  "</data>";
769                          $value=addslashes($xml);                          $value=addslashes($xml);
770                          dba_replace($res_array[name],$xml,$id);                          dba_replace($res_array[name],$xml,$id);
# Line 779  db_add(); Line 788  db_add();
788  keep_popcon();  keep_popcon();
789  db_popcon();  db_popcon();
790  keep_diff();  keep_diff();
791  #db_up_error();  db_up_error();
792  db_upstream();  db_upstream();
793  watch_fill();  watch_fill();
794  up_changes();  up_changes();
Legend:
Removed from v.43  
changed lines
  Added in v.44
  ViewVC Help
Powered by ViewVC 1.1.5