diff options
Diffstat (limited to 'class/Parser.php')
| -rw-r--r-- | class/Parser.php | 166 |
1 files changed, 166 insertions, 0 deletions
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 @@ +<?php + +/* vim: set expandtab tabstop=4 shiftwidth=4 softtabstop=4: */ + +/** + * Class for "repo" Table management + * + * PHP version 5 + * + * Copyright © 2010 Remi Collet + * + * This file is part of rpmphp. + * + * rpmphp is free software: you can redistribute it and/or modify + * it under the terms of the GNU Affero General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + * + * rpmphp is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU Affero General Public License for more details. + * + * You should have received a copy of the GNU Affero General Public License + * along with rpmphp. If not, see <http://www.gnu.org/licenses/>. + * + * @category Main + * @package RPMPHP + * + * @author Remi Collet <unknown@unknwown.com> + * @author Johan Cwiklinski <johan@x-tnd.be> + * @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 |