query($q); if (!$result) { return false; } $uid = $result->fetch(PDO::FETCH_COLUMN, 0); return has_credential(CRED_COMMENT_DELETE, array($uid)); } /** * Determine if the user can delete a specific package comment using an array * * Only the comment submitter, Trusted Users, and Developers can delete * comments. This function is used for the frontend side of comment deletion. * * @param array $comment All database information relating a specific comment * * @return bool True if the user can delete the comment, otherwise false */ function can_delete_comment_array($comment) { return has_credential(CRED_COMMENT_DELETE, array($comment['UsersID'])); } /** * Determine if the user can edit a specific package comment * * Only the comment submitter, Trusted Users, and Developers can edit * comments. This function is used for the backend side of comment editing. * * @param string $comment_id The comment ID in the database * * @return bool True if the user can edit the comment, otherwise false */ function can_edit_comment($comment_id=0) { $dbh = DB::connect(); $q = "SELECT UsersID FROM PackageComments "; $q.= "WHERE ID = " . intval($comment_id); $result = $dbh->query($q); if (!$result) { return false; } $uid = $result->fetch(PDO::FETCH_COLUMN, 0); return has_credential(CRED_COMMENT_EDIT, array($uid)); } /** * Determine if the user can edit a specific package comment using an array * * Only the comment submitter, Trusted Users, and Developers can edit * comments. This function is used for the frontend side of comment editing. * * @param array $comment All database information relating a specific comment * * @return bool True if the user can edit the comment, otherwise false */ function can_edit_comment_array($comment) { return has_credential(CRED_COMMENT_EDIT, array($comment['UsersID'])); } /** * Check to see if the package name already exists in the database * * @param string $name The package name to check * * @return string|void Package name if it already exists */ function pkg_from_name($name="") { if (!$name) {return NULL;} $dbh = DB::connect(); $q = "SELECT ID FROM Packages "; $q.= "WHERE Name = " . $dbh->quote($name); $result = $dbh->query($q); if (!$result) { return; } $row = $result->fetch(PDO::FETCH_NUM); return $row[0]; } /** * Get licenses for a specific package * * @param int $pkgid The package to get licenses for * * @return array All licenses for the package */ function pkg_licenses($pkgid) { $lics = array(); $pkgid = intval($pkgid); if ($pkgid > 0) { $dbh = DB::connect(); $q = "SELECT l.Name FROM Licenses l "; $q.= "INNER JOIN PackageLicenses pl ON pl.LicenseID = l.ID "; $q.= "WHERE pl.PackageID = ". $pkgid; $result = $dbh->query($q); if (!$result) { return array(); } while ($row = $result->fetch(PDO::FETCH_COLUMN, 0)) { $lics[] = $row; } } return $lics; } /** * Get package groups for a specific package * * @param int $pkgid The package to get groups for * * @return array All package groups for the package */ function pkg_groups($pkgid) { $grps = array(); $pkgid = intval($pkgid); if ($pkgid > 0) { $dbh = DB::connect(); $q = "SELECT g.Name FROM Groups g "; $q.= "INNER JOIN PackageGroups pg ON pg.GroupID = g.ID "; $q.= "WHERE pg.PackageID = ". $pkgid; $result = $dbh->query($q); if (!$result) { return array(); } while ($row = $result->fetch(PDO::FETCH_COLUMN, 0)) { $grps[] = $row; } } return $grps; } /** * Get providers for a specific package * * @param string $name The name of the "package" to get providers for * * @return array The IDs and names of all providers of the package */ function pkg_providers($name) { $dbh = DB::connect(); $q = "SELECT p.ID, p.Name FROM Packages p "; $q.= "INNER JOIN PackageRelations pr ON pr.PackageID = p.ID "; $q.= "INNER JOIN RelationTypes rt ON rt.ID = pr.RelTypeID "; $q.= "WHERE rt.Name = 'provides' "; $q.= "AND pr.RelName = " . $dbh->quote($name); $result = $dbh->query($q); if (!$result) { return array(); } $providers = array(); while ($row = $result->fetch(PDO::FETCH_NUM)) { $providers[] = $row; } return $providers; } /** * Get package dependencies for a specific package * * @param int $pkgid The package to get dependencies for * * @return array All package dependencies for the package */ function pkg_dependencies($pkgid) { $deps = array(); $pkgid = intval($pkgid); if ($pkgid > 0) { $dbh = DB::connect(); $q = "SELECT pd.DepName, dt.Name, pd.DepCondition, pd.DepArch, p.ID FROM PackageDepends pd "; $q.= "LEFT JOIN Packages p ON pd.DepName = p.Name "; $q.= "OR SUBSTRING(pd.DepName FROM 1 FOR POSITION(': ' IN pd.DepName) - 1) = p.Name "; $q.= "LEFT JOIN DependencyTypes dt ON dt.ID = pd.DepTypeID "; $q.= "WHERE pd.PackageID = ". $pkgid . " "; $q.= "ORDER BY pd.DepName"; $result = $dbh->query($q); if (!$result) { return array(); } while ($row = $result->fetch(PDO::FETCH_NUM)) { $deps[] = $row; } } return $deps; } /** * Get package relations for a specific package * * @param int $pkgid The package to get relations for * * @return array All package relations for the package */ function pkg_relations($pkgid) { $rels = array(); $pkgid = intval($pkgid); if ($pkgid > 0) { $dbh = DB::connect(); $q = "SELECT pr.RelName, rt.Name, pr.RelCondition, pr.RelArch, p.ID FROM PackageRelations pr "; $q.= "LEFT JOIN Packages p ON pr.RelName = p.Name "; $q.= "LEFT JOIN RelationTypes rt ON rt.ID = pr.RelTypeID "; $q.= "WHERE pr.PackageID = ". $pkgid . " "; $q.= "ORDER BY pr.RelName"; $result = $dbh->query($q); if (!$result) { return array(); } while ($row = $result->fetch(PDO::FETCH_NUM)) { $rels[] = $row; } } return $rels; } /** * Get the HTML code to display a package dependency link annotation * (dependency type, architecture, ...) * * @param string $type The name of the dependency type * @param string $arch The package dependency architecture * @param string $desc An optdepends description * * @return string The HTML code of the label to display */ function pkg_deplink_annotation($type, $arch, $desc=false) { if ($type == 'depends' && !$arch) { return ''; } $link = ' ('; if ($type == 'makedepends') { $link .= 'make'; } elseif ($type == 'checkdepends') { $link .= 'check'; } elseif ($type == 'optdepends') { $link .= 'optional'; } if ($type != 'depends' && $arch) { $link .= ', '; } if ($arch) { $link .= htmlspecialchars($arch); } $link .= ')'; if ($type == 'optdepends' && $desc) { $link .= ' – ' . htmlspecialchars($desc) . ' '; } $link .= ''; return $link; } /** * Get the HTML code to display a package dependency link * * @param string $name The name of the dependency * @param string $type The name of the dependency type * @param string $cond The package dependency condition string * @param string $arch The package dependency architecture * @param int $pkg_id The package of the package to display the dependency for * * @return string The HTML code of the label to display */ function pkg_depend_link($name, $type, $cond, $arch, $pkg_id) { if ($type == 'optdepends' && strpos($name, ':') !== false) { $tokens = explode(':', $name, 2); $name = $tokens[0]; $desc = $tokens[1]; } else { $desc = '(unknown)'; } $providers = array(); if (is_null($pkg_id)) { /* * TODO: We currently perform one SQL query per nonexistent * package dependency. It would be much better if we could * annotate dependency data with providers so that we already * know whether a dependency is a "provision name" or a package * from the official repositories at this point. */ $providers = pkg_providers($name); } if (count($providers) > 0) { $link = htmlspecialchars($name) . ' '; $link .= '('; foreach ($providers as $provider) { $name = $provider[1]; $link .= ''; $link .= htmlspecialchars($name) . ', '; } $link = substr($link, 0, -2); $link .= ')'; } else { $link = ''; $link .= htmlspecialchars($name) . ''; $link .= htmlspecialchars($cond); } return $link . pkg_deplink_annotation($type, $arch, $desc); } /** * Get the HTML code to display a package requirement link * * @param string $name The name of the requirement * @param string $type The name of the dependency type * @param string $arch The package dependency architecture * * @return string The HTML code of the link to display */ function pkg_requiredby_link($name, $type, $arch) { if ($type == 'optdepends' && strpos($name, ':') !== false) { $tokens = explode(':', $name, 2); $name = $tokens[0]; } $link = ''; $link .= htmlspecialchars($name) . ''; return $link . pkg_deplink_annotation($type, $arch); } /** * Get the HTML code to display a package relation * * @param string $name The name of the relation * @param string $cond The package relation condition string * @param string $arch The package relation architecture * * @return string The HTML code of the label to display */ function pkg_rel_html($name, $cond, $arch) { $html = htmlspecialchars($name) . htmlspecialchars($cond); if ($arch) { $html .= ' (' . htmlspecialchars($arch) . ')'; } return $html; } /** * Get the HTML code to display a source link * * @param string $url The URL of the source * @param string $arch The source architecture * * @return string The HTML code of the label to display */ function pkg_source_link($url, $arch) { $url = explode('::', $url); $parsed_url = parse_url($url[0]); if (isset($parsed_url['scheme']) || isset($url[1])) { $link = '' . htmlspecialchars($url[0]) . ''; } else { $link = htmlspecialchars($url[0]); } if ($arch) { $link .= ' (' . htmlspecialchars($arch) . ')'; } return $link; } /** * Determine packages that depend on a package * * @param string $name The package name for the dependency search * * @return array All packages that depend on the specified package name */ function pkg_required($name="") { $deps = array(); if ($name != "") { $dbh = DB::connect(); $q = "SELECT p.Name, dt.Name, pd.DepArch FROM PackageDepends pd "; $q.= "LEFT JOIN Packages p ON p.ID = pd.PackageID "; $q.= "LEFT JOIN DependencyTypes dt ON dt.ID = pd.DepTypeID "; $q.= "WHERE pd.DepName = " . $dbh->quote($name) . " "; $q.= "OR SUBSTRING(pd.DepName FROM 1 FOR POSITION(': ' IN pd.DepName) - 1) = " . $dbh->quote($name) . " "; $q.= "ORDER BY p.Name"; $result = $dbh->query($q); if (!$result) {return array();} while ($row = $result->fetch(PDO::FETCH_NUM)) { $deps[] = $row; } } return $deps; } /** * Get all package sources for a specific package * * @param string $pkgid The package ID to get the sources for * * @return array All sources associated with a specific package */ function pkg_sources($pkgid) { $sources = array(); $pkgid = intval($pkgid); if ($pkgid > 0) { $dbh = DB::connect(); $q = "SELECT Source, SourceArch FROM PackageSources "; $q.= "WHERE PackageID = " . $pkgid; $q.= " ORDER BY Source"; $result = $dbh->query($q); if (!$result) { return array(); } while ($row = $result->fetch(PDO::FETCH_NUM)) { $sources[] = $row; } } return $sources; } /** * Determine package names from package IDs * * @param string|array $pkgids The package IDs to get names for * * @return array|string All names if multiple package IDs, otherwise package name */ function pkg_name_from_id($pkgids) { if (is_array($pkgids)) { $pkgids = sanitize_ids($pkgids); $names = array(); $dbh = DB::connect(); $q = "SELECT Name FROM Packages WHERE ID IN ("; $q.= implode(",", $pkgids) . ")"; $result = $dbh->query($q); if ($result) { while ($row = $result->fetch(PDO::FETCH_ASSOC)) { $names[] = $row['Name']; } } return $names; } elseif ($pkgids > 0) { $dbh = DB::connect(); $q = "SELECT Name FROM Packages WHERE ID = " . $pkgids; $result = $dbh->query($q); if ($result) { $name = $result->fetch(PDO::FETCH_NUM); } return $name[0]; } else { return NULL; } } /** * Determine if a package name is on the database blacklist * * @param string $name The package name to check * * @return bool True if the name is blacklisted, otherwise false */ function pkg_name_is_blacklisted($name) { $dbh = DB::connect(); $q = "SELECT COUNT(*) FROM PackageBlacklist "; $q.= "WHERE Name = " . $dbh->quote($name); $result = $dbh->query($q); if (!$result) return false; return ($result->fetchColumn() > 0); } /** * Get the package details * * @param string $id The package ID to get description for * * @return array The package's details OR error message **/ function pkg_get_details($id=0) { $dbh = DB::connect(); $q = "SELECT Packages.*, PackageBases.ID AS BaseID, "; $q.= "PackageBases.Name AS BaseName, PackageBases.NumVotes, "; $q.= "PackageBases.Popularity, PackageBases.OutOfDateTS, "; $q.= "PackageBases.SubmittedTS, PackageBases.ModifiedTS, "; $q.= "PackageBases.SubmitterUID, PackageBases.MaintainerUID, "; $q.= "PackageBases.PackagerUID, PackageBases.FlaggerUID, "; $q.= "(SELECT COUNT(*) FROM PackageRequests "; $q.= " WHERE PackageRequests.PackageBaseID = Packages.PackageBaseID "; $q.= " AND PackageRequests.Status = 0) AS RequestCount "; $q.= "FROM Packages, PackageBases "; $q.= "WHERE PackageBases.ID = Packages.PackageBaseID "; $q.= "AND Packages.ID = " . intval($id); $result = $dbh->query($q); $row = array(); if (!$result) { $row['error'] = __("Error retrieving package details."); } else { $row = $result->fetch(PDO::FETCH_ASSOC); if (empty($row)) { $row['error'] = __("Package details could not be found."); } } return $row; } /** * Display the package details page * * @param string $id The package ID to get details page for * @param array $row Package details retrieved by pkg_get_details() * @param string $SID The session ID of the visitor * * @return void */ function pkg_display_details($id=0, $row, $SID="") { $dbh = DB::connect(); if (isset($row['error'])) { print "
" . $row['error'] . "
\n"; } else { $base_id = pkgbase_from_pkgid($id); $pkgbase_name = pkgbase_name_from_id($base_id); include('pkg_details.php'); if ($SID) { include('pkg_comment_box.php'); } $limit = isset($_GET['comments']) ? 0 : 10; $include_deleted = has_credential(CRED_COMMENT_VIEW_DELETED); $comments = pkgbase_comments($base_id, $limit, $include_deleted); if (!empty($comments)) { include('pkg_comments.php'); } } } /* pkg_search_page(SID) * outputs the body of search/search results page * * parameters: * SID - current Session ID * preconditions: * package search page has been accessed * request variables have not been sanitized * * request vars: * O - starting result number * PP - number of search hits per page * K - package search string * SO - search hit sort order: * values: a - ascending * d - descending * SB - sort search hits by: * values: n - package name * v - number of votes * m - maintainer username * SeB- property that search string (K) represents * values: n - package name * nd - package name & description * x - package name (exact match) * m - package maintainer's username * s - package submitter's username * do_Orphans - boolean. whether to search packages * without a maintainer * * * These two are actually handled in packages.php. * * IDs- integer array of ticked packages' IDs * action - action to be taken on ticked packages * values: do_Flag - Flag out-of-date * do_UnFlag - Remove out-of-date flag * do_Adopt - Adopt * do_Disown - Disown * do_Delete - Delete * do_Notify - Enable notification * do_UnNotify - Disable notification */ function pkg_search_page($SID="") { $dbh = DB::connect(); /* * Get commonly used variables. * TODO: Reduce the number of database queries! */ if ($SID) $myuid = uid_from_sid($SID); /* Sanitize paging variables. */ if (isset($_GET['O'])) { $_GET['O'] = max(intval($_GET['O']), 0); } else { $_GET['O'] = 0; } if (isset($_GET["PP"])) { $_GET["PP"] = bound(intval($_GET["PP"]), 50, 250); } else { $_GET["PP"] = 50; } /* * FIXME: Pull out DB-related code. All of it! This one's worth a * choco-chip cookie, one of those nice big soft ones. */ /* Build the package search query. */ $q_select = "SELECT "; if ($SID) { $q_select .= "CommentNotify.UserID AS Notify, PackageVotes.UsersID AS Voted, "; } $q_select .= "Users.Username AS Maintainer, Packages.Name, Packages.Version, Packages.Description, PackageBases.NumVotes, PackageBases.Popularity, Packages.ID, Packages.PackageBaseID, PackageBases.OutOfDateTS "; $q_from = "FROM Packages LEFT JOIN PackageBases ON (PackageBases.ID = Packages.PackageBaseID) LEFT JOIN Users ON (PackageBases.MaintainerUID = Users.ID) "; if ($SID) { /* This is not needed for the total row count query. */ $q_from_extra = "LEFT JOIN PackageVotes ON (PackageBases.ID = PackageVotes.PackageBaseID AND PackageVotes.UsersID = $myuid) LEFT JOIN CommentNotify ON (PackageBases.ID = CommentNotify.PackageBaseID AND CommentNotify.UserID = $myuid) "; } else { $q_from_extra = ""; } $q_where = 'WHERE PackageBases.PackagerUID IS NOT NULL '; if (isset($_GET['K'])) { if (isset($_GET["SeB"]) && $_GET["SeB"] == "m") { /* Search by maintainer. */ $q_where .= "AND Users.Username = " . $dbh->quote($_GET['K']) . " "; } elseif (isset($_GET["SeB"]) && $_GET["SeB"] == "s") { /* Search by submitter. */ $q_where .= "AND SubmitterUID = " . intval(uid_from_username($_GET['K'])) . " "; } elseif (isset($_GET["SeB"]) && $_GET["SeB"] == "n") { /* Search by name. */ $K = "%" . addcslashes($_GET['K'], '%_') . "%"; $q_where .= "AND (Packages.Name LIKE " . $dbh->quote($K) . ") "; } elseif (isset($_GET["SeB"]) && $_GET["SeB"] == "b") { /* Search by package base name. */ $K = "%" . addcslashes($_GET['K'], '%_') . "%"; $q_where .= "AND (PackageBases.Name LIKE " . $dbh->quote($K) . ") "; } elseif (isset($_GET["SeB"]) && $_GET["SeB"] == "N") { /* Search by name (exact match). */ $q_where .= "AND (Packages.Name = " . $dbh->quote($_GET['K']) . ") "; } elseif (isset($_GET["SeB"]) && $_GET["SeB"] == "B") { /* Search by package base name (exact match). */ $q_where .= "AND (PackageBases.Name = " . $dbh->quote($_GET['K']) . ") "; } else { /* Keyword search (default). */ $count = 0; $q_keywords = ""; $op = ""; foreach (str_getcsv($_GET['K'], ' ') as $term) { if ($term == "") { continue; } if ($count > 0 && strtolower($term) == "and") { $op = "AND "; continue; } if ($count > 0 && strtolower($term) == "or") { $op = "OR "; continue; } if ($count > 0 && strtolower($term) == "not") { $op .= "NOT "; continue; } $term = "%" . addcslashes($term, '%_') . "%"; $q_keywords .= $op . " (Packages.Name LIKE " . $dbh->quote($term) . " OR "; $q_keywords .= "Description LIKE " . $dbh->quote($term) . " OR "; $q_keywords .= "EXISTS (SELECT * FROM PackageKeywords WHERE "; $q_keywords .= "PackageKeywords.PackageBaseID = Packages.PackageBaseID AND "; $q_keywords .= "PackageKeywords.Keyword LIKE " . $dbh->quote($term) . ")) "; $count++; if ($count >= 20) { break; } $op = "AND "; } if (!empty($q_keywords)) { $q_where .= "AND (" . $q_keywords . ") "; } } } if (isset($_GET["do_Orphans"])) { $q_where .= "AND MaintainerUID IS NULL "; } if (isset($_GET['outdated'])) { if ($_GET['outdated'] == 'on') { $q_where .= "AND OutOfDateTS IS NOT NULL "; } elseif ($_GET['outdated'] == 'off') { $q_where .= "AND OutOfDateTS IS NULL "; } } $order = (isset($_GET["SO"]) && $_GET["SO"] == 'd') ? 'DESC' : 'ASC'; $q_sort = "ORDER BY "; $sort_by = isset($_GET["SB"]) ? $_GET["SB"] : ''; switch ($sort_by) { case 'v': $q_sort .= "NumVotes " . $order . ", "; break; case 'p': $q_sort .= "Popularity " . $order . ", "; break; case 'w': if ($SID) { $q_sort .= "Voted " . $order . ", "; } break; case 'o': if ($SID) { $q_sort .= "Notify " . $order . ", "; } break; case 'm': $q_sort .= "Maintainer " . $order . ", "; break; case 'a': $q_sort .= "-ModifiedTS " . $order . ", "; break; default: break; } $q_sort .= " Packages.Name " . $order . " "; $q_limit = "LIMIT ".$_GET["PP"]." OFFSET ".$_GET["O"]; $q = $q_select . $q_from . $q_from_extra . $q_where . $q_sort . $q_limit; $q_total = "SELECT COUNT(*) " . $q_from . $q_where; $result = $dbh->query($q); $result_t = $dbh->query($q_total); if ($result_t) { $row = $result_t->fetch(PDO::FETCH_NUM); $total = $row[0]; } else { $total = 0; } if ($result && $total > 0) { if (isset($_GET["SO"]) && $_GET["SO"] == "d"){ $SO_next = "a"; } else { $SO_next = "d"; } } /* Calculate the results to use. */ $first = $_GET['O'] + 1; /* Calculation of pagination links. */ $per_page = ($_GET['PP'] > 0) ? $_GET['PP'] : 50; $current = ceil($first / $per_page); $pages = ceil($total / $per_page); $templ_pages = array(); if ($current > 1) { $templ_pages['« ' . __('First')] = 0; $templ_pages['‹ ' . __('Previous')] = ($current - 2) * $per_page; } if ($current - 5 > 1) $templ_pages["..."] = false; for ($i = max($current - 5, 1); $i <= min($pages, $current + 5); $i++) { $templ_pages[$i] = ($i - 1) * $per_page; } if ($current + 5 < $pages) $templ_pages["... "] = false; if ($current < $pages) { $templ_pages[__('Next') . ' ›'] = $current * $per_page; $templ_pages[__('Last') . ' »'] = ($pages - 1) * $per_page; } include('pkg_search_form.php'); if ($result) { while ($row = $result->fetch(PDO::FETCH_ASSOC)) { $searchresults[] = $row; } } include('pkg_search_results.php'); return; } /** * Determine if a POST string has been sent by a visitor * * @param string $action String to check has been sent via POST * * @return bool True if the POST string was used, otherwise false */ function current_action($action) { return (isset($_POST['action']) && $_POST['action'] == $action) || isset($_POST[$action]); } /** * Determine if sent IDs are valid integers * * @param array $ids IDs to validate * * @return array All sent IDs that are valid integers */ function sanitize_ids($ids) { $new_ids = array(); foreach ($ids as $id) { $id = intval($id); if ($id > 0) { $new_ids[] = $id; } } return $new_ids; } /** * Add package information to the database for a specific package * * @param int $base_id ID of the package base * @param string $pkgname Name of the new package * @param string $pkgver Version of the new package * @param string $pkgdesc Description of the new package * @param string $pkgurl Upstream URL for the new package * * @return int ID of the new package */ function pkg_create($base_id, $pkgname, $pkgver, $pkgdesc, $pkgurl) { $dbh = DB::connect(); $q = sprintf("INSERT INTO Packages (PackageBaseID, Name, Version, " . "Description, URL) VALUES (%d, %s, %s, %s, %s)", $base_id, $dbh->quote($pkgname), $dbh->quote($pkgver), $dbh->quote($pkgdesc), $dbh->quote($pkgurl)); $dbh->exec($q); return $dbh->lastInsertId(); } /** * Add a dependency for a specific package to the database * * @param int $pkgid The package ID to add the dependency for * @param string $type The type of dependency to add * @param string $depname The name of the dependency to add * @param string $depcondition The type of dependency for the package * @param string $deparch The architecture of the dependency to add * * @return void */ function pkg_add_dep($pkgid, $type, $depname, $depcondition, $deparch) { $dbh = DB::connect(); $q = sprintf("INSERT INTO PackageDepends (PackageID, DepTypeID, DepName, DepCondition, DepArch) VALUES (%d, %d, %s, %s, %s)", $pkgid, pkg_dependency_type_id_from_name($type), $dbh->quote($depname), $dbh->quote($depcondition), $deparch ? $dbh->quote($deparch) : 'NULL' ); $dbh->exec($q); } /** * Add a relation for a specific package to the database * * @param int $pkgid The package ID to add the relation for * @param string $type The type of relation to add * @param string $relname The name of the relation to add * @param string $relcondition The version requirement of the relation * @param string $relarch The architecture of the relation to add * * @return void */ function pkg_add_rel($pkgid, $type, $relname, $relcondition, $relarch) { $dbh = DB::connect(); $q = sprintf("INSERT INTO PackageRelations (PackageID, RelTypeID, RelName, RelCondition, RelArch) VALUES (%d, %d, %s, %s, %s)", $pkgid, pkg_relation_type_id_from_name($type), $dbh->quote($relname), $dbh->quote($relcondition), $relarch ? $dbh->quote($relarch) : 'NULL' ); $dbh->exec($q); } /** * Add a source for a specific package to the database * * @param int $pkgid The package ID to add the source for * @param string $pkgsrc The package source to add to the database * @param string $srcarch The architecture of the source to add * * @return void */ function pkg_add_src($pkgid, $pkgsrc, $srcarch) { $dbh = DB::connect(); $q = sprintf("INSERT INTO PackageSources (PackageID, Source, SourceArch) VALUES (%d, %s, %s)", $pkgid, $dbh->quote($pkgsrc), $srcarch ? $dbh->quote($srcarch) : 'NULL' ); $dbh->exec($q); } /** * Creates a new group and returns its ID * * If the groups already exists, the ID of the already existing group is * returned. * * @param string $name The name of the group to create * * @return int The ID of the group */ function pkg_create_group($name) { $dbh = DB::connect(); $q = sprintf("SELECT ID FROM Groups WHERE Name = %s", $dbh->quote($name)); $result = $dbh->query($q); if ($result) { $grpid = $result->fetch(PDO::FETCH_COLUMN, 0); if ($grpid > 0) { return $grpid; } } $q = sprintf("INSERT INTO Groups (Name) VALUES (%s)", $dbh->quote($name)); $dbh->exec($q); return $dbh->lastInsertId(); } /** * Add a package to a group * * @param int $pkgid The package ID of the package to add * @param int $grpid The group ID of the group to add the package to * * @return void */ function pkg_add_grp($pkgid, $grpid) { $dbh = DB::connect(); $q = sprintf("INSERT INTO PackageGroups (PackageID, GroupID) VALUES (%d, %d)", $pkgid, $grpid ); $dbh->exec($q); } /** * Creates a new license and returns its ID * * If the license already exists, the ID of the already existing license is * returned. * * @param string $name The name of the license to create * * @return int The ID of the license */ function pkg_create_license($name) { $dbh = DB::connect(); $q = sprintf("SELECT ID FROM Licenses WHERE Name = %s", $dbh->quote($name)); $result = $dbh->query($q); if ($result) { $licid = $result->fetch(PDO::FETCH_COLUMN, 0); if ($licid > 0) { return $licid; } } $q = sprintf("INSERT INTO Licenses (Name) VALUES (%s)", $dbh->quote($name)); $dbh->exec($q); return $dbh->lastInsertId(); } /** * Add a license to a package * * @param int $pkgid The package ID of the package * @param int $grpid The ID of the license to add * * @return void */ function pkg_add_lic($pkgid, $licid) { $dbh = DB::connect(); $q = sprintf("INSERT INTO PackageLicenses (PackageID, LicenseID) VALUES (%d, %d)", $pkgid, $licid ); $dbh->exec($q); } /** * Determine package information for latest package * * @param int $numpkgs Number of packages to get information on * * @return array $packages Package info for the specified number of recent packages */ function latest_pkgs($numpkgs) { $dbh = DB::connect(); $q = "SELECT Packages.*, MaintainerUID, SubmittedTS "; $q.= "FROM Packages LEFT JOIN PackageBases ON "; $q.= "PackageBases.ID = Packages.PackageBaseID "; $q.= "ORDER BY SubmittedTS DESC "; $q.= "LIMIT " . intval($numpkgs); $result = $dbh->query($q); $packages = array(); if ($result) { while ($row = $result->fetch(PDO::FETCH_ASSOC)) { $packages[] = $row; } } return $packages; }