From 93c01077b80cc8d6044d1ec82e981c9f2b26f362 Mon Sep 17 00:00:00 2001 From: Remi Collet Date: Mon, 1 Nov 2010 10:06:52 +0100 Subject: start to move the parsing from refresh.php to a Parser class --- class/Parser.php | 166 +++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 166 insertions(+) create mode 100644 class/Parser.php (limited to 'class/Parser.php') diff --git a/class/Parser.php b/class/Parser.php new file mode 100644 index 0000000..76e289f --- /dev/null +++ b/class/Parser.php @@ -0,0 +1,166 @@ +. + * + * @category Main + * @package RPMPHP + * + * @author Remi Collet + * @author Johan Cwiklinski + * @copyright 2010 Remi Collet + * @license http://www.gnu.org/licenses/agpl-3.0-standalone.html AGPL License 3.0 or (at your option) any later version + * @link http://github.com/remicollet/rpmphp/ + * @since The begining of times. +*/ +class Parser +{ + /** + * Display a message + */ + static private function log($msg) + { + echo date("r : ") . $msg ."\n"; + } + /** + * Parse the Bugzilla ACL list from pkgdb + * + * @param TableAcl $acls the table to write to + * @param string $url the file to read from + * + * @return integer number of parsed line + */ + static public function readAcls(TableAcls $acls, $url) + { + $tot = 0; + + self::log("Read pkgdb/owner"); + $fic=fopen($url, 'r'); + if (!$fic) { + self::log("ERROR reading '$url'"); + } else { + $nb = $acls->getCount(); + $acls->truncate(); + self::log("Delete $nb owners"); + + for ($tot=0 ; $line=fgetcsv($fic, 1024, '|'); ) { + if (count($line)>5 && substr($line[0], 0, 1)!='#') { + for ($i=0; $i<6; $i++) { + $line[$i]=trim($line[$i]); + } + $input = array( + 'collection' => $line[0], + 'name' => $line[1], + 'summary' => $line[2], + ); + if (!empty($line[3])) { + $input['owner'] = $line[3]; + } + if (!empty($line[4])) { + $input['qa'] = $line[3]; + } + if (!empty($line[5])) { + $input['cc'] = $line[3]; + } + if ($acls->add($input)) { + $tot++; + } + } + } + fclose($fic); + self::log("wrote $tot package's owner"); + } + return $tot; + } + + /** + * Parse the content of a R repository + * + * @param TableUpstream $uptable the table to write to + * @param hastable $repo the repo to read from + * + * @return integer number of parsed line + */ + static private function readOneR(TableUpstream $uptable, $repo) + { + $tot = 0; + + self::log("Reading " . $repo["name"] . " (" . + $repo["state"] . ")"); + $index = @file_get_contents($repo["url"]); + if (!$index) { + self::log("Can't read [" . $repo["url"] . "], skip this channel"); + return 0; + } + if ($repo["state"]=="stable") { + $crit = array('type'=>'R', 'channel'=>$repo['name']); + $nb = $uptable->delete($crit); + self::log("Delete $nb packages"); + } + $results=array(); + $pat = '/Package: *(.*)\nVersion: *(.*)\n/i'; + if (preg_match_all($pat, $index, $results, PREG_SET_ORDER)) { + foreach ($results as $result) { + $rpmname = "R-".$result[1]; + $ver = str_replace('-', '.', $result[2]); + $add = $uptable->record( + "R", + $repo["name"], + $rpmname, + $ver, + $repo["state"]=='stable', + ($repo["state"]=="stable"?"":"devel") + ); + + if ($add) { + $tot++; + } + } + self::log("Write $tot packages in this channel"); + } else { + self::log("No package in this channel"); + } + return $tot; + } + + /** + * Parse the content of a R repository + * + * @param TableUpstream $uptable the table to write to + * @param TableRRepo $rrepo the table to read from + * + * @return integer number of parsed line + */ + static public function readR(TableUpstream $uptable, TableRRepo $rrepo) + { + $tot = 0; + + foreach ($rrepo->request() as $repo) { + $tot += self::readOneR($uptable, $repo); + } + self::log("Write $tot packages in all channels"); + return $tot; + } +} +?> \ No newline at end of file -- cgit