folkslinux
/
rpm
mirror of https://github.com/rpm-software-management/rpm.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
rpm/lib/query.c

741 lines
19 KiB
C
Raw Blame History

/** \ingroup rpmcli
* \file lib/query.c
*/
#include "system.h"
#ifndef PATH_MAX
# define PATH_MAX 255
#endif
#include "rpmbuild.h"
#include <rpmurl.h>
/*@access Header@*/ /* XXX compared with NULL */
/*@access rpmdbMatchIterator@*/ /* XXX compared with NULL */
/* ======================================================================== */
static char * permsString(int mode)
{
char *perms = xstrdup("----------");
if (S_ISDIR(mode))
perms[0] = 'd';
else if (S_ISLNK(mode))
perms[0] = 'l';
else if (S_ISFIFO(mode))
perms[0] = 'p';
else if (S_ISSOCK(mode))
perms[0] = 's';
else if (S_ISCHR(mode))
perms[0] = 'c';
else if (S_ISBLK(mode))
perms[0] = 'b';
/*@-unrecog@*/
if (mode & S_IRUSR) perms[1] = 'r';
if (mode & S_IWUSR) perms[2] = 'w';
if (mode & S_IXUSR) perms[3] = 'x';
if (mode & S_IRGRP) perms[4] = 'r';
if (mode & S_IWGRP) perms[5] = 'w';
if (mode & S_IXGRP) perms[6] = 'x';
if (mode & S_IROTH) perms[7] = 'r';
if (mode & S_IWOTH) perms[8] = 'w';
if (mode & S_IXOTH) perms[9] = 'x';
if (mode & S_ISUID)
perms[3] = ((mode & S_IXUSR) ? 's' : 'S');
if (mode & S_ISGID)
perms[6] = ((mode & S_IXGRP) ? 's' : 'S');
if (mode & S_ISVTX)
perms[9] = ((mode & S_IXOTH) ? 't' : 'T');
/*@=unrecog@*/
return perms;
}
static void printFileInfo(FILE *fp, const char * name,
unsigned int size, unsigned short mode,
unsigned int mtime,
unsigned short rdev, unsigned int nlink,
const char * owner, const char * group,
int uid, int gid, const char * linkto)
{
char sizefield[15];
char ownerfield[9], groupfield[9];
char timefield[100] = "";
time_t when = mtime; /* important if sizeof(int_32) ! sizeof(time_t) */
struct tm * tm;
static time_t now;
static struct tm nowtm;
const char * namefield = name;
char * perms;
/* On first call, grab snapshot of now */
if (now == 0) {
now = time(NULL);
tm = localtime(&now);
nowtm = *tm; /* structure assignment */
}
perms = permsString(mode);
if (owner)
strncpy(ownerfield, owner, 8);
else
sprintf(ownerfield, "%-8d", uid);
ownerfield[8] = '\0';
if (group)
strncpy(groupfield, group, 8);
else
sprintf(groupfield, "%-8d", gid);
groupfield[8] = '\0';
/* this is normally right */
sprintf(sizefield, "%12u", size);
/* this knows too much about dev_t */
if (S_ISLNK(mode)) {
char *nf = alloca(strlen(name) + sizeof(" -> ") + strlen(linkto));
sprintf(nf, "%s -> %s", name, linkto);
namefield = nf;
} else if (S_ISCHR(mode)) {
perms[0] = 'c';
sprintf(sizefield, "%3u, %3u", ((unsigned)(rdev >> 8) & 0xff),
((unsigned)rdev & 0xff));
} else if (S_ISBLK(mode)) {
perms[0] = 'b';
sprintf(sizefield, "%3u, %3u", ((unsigned)(rdev >> 8) & 0xff),
((unsigned)rdev & 0xff));
}
/* Convert file mtime to display format */
tm = localtime(&when);
{ const char *fmt;
if (now > when + 6L * 30L * 24L * 60L * 60L || /* Old. */
now < when - 60L * 60L) /* In the future. */
{
/* The file is fairly old or in the future.
* POSIX says the cutoff is 6 months old;
* approximate this by 6*30 days.
* Allow a 1 hour slop factor for what is considered "the future",
* to allow for NFS server/client clock disagreement.
* Show the year instead of the time of day.
*/
fmt = "%b %e %Y";
} else {
fmt = "%b %e %H:%M";
}
(void)strftime(timefield, sizeof(timefield) - 1, fmt, tm);
}
fprintf(fp, "%s %4d %-8s%-8s %10s %s %s\n", perms, (int)nlink,
ownerfield, groupfield, sizefield, timefield, namefield);
if (perms) free(perms);
}
static int queryHeader(FILE *fp, Header h, const char * chptr)
{
char * str;
const char * errstr;
str = headerSprintf(h, chptr, rpmTagTable, rpmHeaderFormats, &errstr);
if (str == NULL) {
fprintf(stderr, _("error in format: %s\n"), errstr);
return 1;
}
fputs(str, fp);
return 0;
}
static int countLinks(int_16 * fileRdevList, int_32 * fileInodeList, int nfiles,
int xfile)
{
int nlink = 0;
/* XXX rpm-3.3.12 has not RPMTAG_FILEINODES */
if (!(fileRdevList && fileInodeList && nfiles > 0))
return 1;
while (nfiles-- > 0) {
if (fileRdevList[nfiles] != fileRdevList[xfile])
continue;
if (fileInodeList[nfiles] != fileInodeList[xfile])
continue;
nlink++;
}
return nlink;
}
int showQueryPackage(QVA_t *qva, /*@unused@*/rpmdb rpmdb, Header h)
{
FILE *fp = stdout; /* XXX FIXME: pass as arg */
int queryFlags = qva->qva_flags;
const char *queryFormat = qva->qva_queryFormat;
const char * name, * version, * release;
int_32 count, type;
char * prefix = NULL;
const char ** dirNames, ** baseNames;
const char ** fileMD5List;
const char * fileStatesList;
const char ** fileOwnerList = NULL;
const char ** fileGroupList = NULL;
const char ** fileLinktoList;
int_32 * fileFlagsList, * fileMTimeList, * fileSizeList;
int_32 * fileUIDList = NULL;
int_32 * fileGIDList = NULL;
int_32 * fileInodeList = NULL;
uint_16 * fileModeList;
uint_16 * fileRdevList;
int_32 * dirIndexes;
int i;
headerNVR(h, &name, &version, &release);
if (!queryFormat && !queryFlags) {
fprintf(fp, "%s-%s-%s\n", name, version, release);
} else {
if (queryFormat)
queryHeader(fp, h, queryFormat);
if (queryFlags & QUERY_FOR_LIST) {
if (!headerGetEntry(h, RPMTAG_BASENAMES, &type,
(void **) &baseNames, &count)) {
fputs(_("(contains no files)"), fp);
fputs("\n", fp);
} else {
if (!headerGetEntry(h, RPMTAG_FILESTATES, &type,
(void **) &fileStatesList, &count)) {
fileStatesList = NULL;
}
headerGetEntry(h, RPMTAG_DIRNAMES, NULL,
(void **) &dirNames, NULL);
headerGetEntry(h, RPMTAG_DIRINDEXES, NULL,
(void **) &dirIndexes, NULL);
headerGetEntry(h, RPMTAG_FILEFLAGS, &type,
(void **) &fileFlagsList, &count);
headerGetEntry(h, RPMTAG_FILESIZES, &type,
(void **) &fileSizeList, &count);
headerGetEntry(h, RPMTAG_FILEMODES, &type,
(void **) &fileModeList, &count);
headerGetEntry(h, RPMTAG_FILEMTIMES, &type,
(void **) &fileMTimeList, &count);
headerGetEntry(h, RPMTAG_FILERDEVS, &type,
(void **) &fileRdevList, &count);
headerGetEntry(h, RPMTAG_FILEINODES, &type,
(void **) &fileInodeList, &count);
headerGetEntry(h, RPMTAG_FILELINKTOS, &type,
(void **) &fileLinktoList, &count);
headerGetEntry(h, RPMTAG_FILEMD5S, &type,
(void **) &fileMD5List, &count);
if (!headerGetEntry(h, RPMTAG_FILEUIDS, &type,
(void **) &fileUIDList, &count)) {
fileUIDList = NULL;
} else if (!headerGetEntry(h, RPMTAG_FILEGIDS, &type,
(void **) &fileGIDList, &count)) {
fileGIDList = NULL;
}
if (!headerGetEntry(h, RPMTAG_FILEUSERNAME, &type,
(void **) &fileOwnerList, &count)) {
fileOwnerList = NULL;
} else if (!headerGetEntry(h, RPMTAG_FILEGROUPNAME, &type,
(void **) &fileGroupList, &count)) {
fileGroupList = NULL;
}
for (i = 0; i < count; i++) {
if (!((queryFlags & QUERY_FOR_DOCS) ||
(queryFlags & QUERY_FOR_CONFIG))
|| ((queryFlags & QUERY_FOR_DOCS) &&
(fileFlagsList[i] & RPMFILE_DOC))
|| ((queryFlags & QUERY_FOR_CONFIG) &&
(fileFlagsList[i] & RPMFILE_CONFIG))) {
if (!rpmIsVerbose())
prefix ? fputs(prefix, fp) : 0;
if (queryFlags & QUERY_FOR_STATE) {
if (fileStatesList) {
switch (fileStatesList[i]) {
case RPMFILE_STATE_NORMAL:
fputs(_("normal "), fp); break;
case RPMFILE_STATE_REPLACED:
fputs(_("replaced "), fp); break;
case RPMFILE_STATE_NOTINSTALLED:
fputs(_("not installed "), fp); break;
case RPMFILE_STATE_NETSHARED:
fputs(_("net shared "), fp); break;
default:
fprintf(fp, _("(unknown %3d) "),
(int)fileStatesList[i]);
}
} else {
fputs( _("(no state) "), fp);
}
}
if (queryFlags & QUERY_FOR_DUMPFILES) {
fprintf(fp, "%s%s %d %d %s 0%o ",
dirNames[dirIndexes[i]], baseNames[i],
fileSizeList[i], fileMTimeList[i],
fileMD5List[i], fileModeList[i]);
if (fileOwnerList && fileGroupList)
fprintf(fp, "%s %s", fileOwnerList[i],
fileGroupList[i]);
else if (fileUIDList && fileGIDList)
fprintf(fp, "%d %d", fileUIDList[i],
fileGIDList[i]);
else {
rpmError(RPMERR_INTERNAL, _("package has "
"neither file owner or id lists"));
}
fprintf(fp, " %s %s %u ",
fileFlagsList[i] & RPMFILE_CONFIG ? "1" : "0",
fileFlagsList[i] & RPMFILE_DOC ? "1" : "0",
(unsigned)fileRdevList[i]);
if (strlen(fileLinktoList[i]))
fprintf(fp, "%s\n", fileLinktoList[i]);
else
fprintf(fp, "X\n");
} else if (!rpmIsVerbose()) {
fputs(dirNames[dirIndexes[i]], fp);
fputs(baseNames[i], fp);
fputs("\n", fp);
} else {
char * filespec;
int nlink;
filespec = xmalloc(strlen(dirNames[dirIndexes[i]])
+ strlen(baseNames[i]) + 1);
strcpy(filespec, dirNames[dirIndexes[i]]);
strcat(filespec, baseNames[i]);
nlink = countLinks(fileRdevList, fileInodeList, count, i);
if (fileOwnerList && fileGroupList) {
printFileInfo(fp, filespec, fileSizeList[i],
fileModeList[i], fileMTimeList[i],
fileRdevList[i], nlink,
fileOwnerList[i],
fileGroupList[i], -1,
-1, fileLinktoList[i]);
} else if (fileUIDList && fileGIDList) {
printFileInfo(fp, filespec, fileSizeList[i],
fileModeList[i], fileMTimeList[i],
fileRdevList[i], nlink,
NULL, NULL, fileUIDList[i],
fileGIDList[i],
fileLinktoList[i]);
} else {
rpmError(RPMERR_INTERNAL, _("package has "
"neither file owner or id lists"));
}
free(filespec);
}
}
}
free(dirNames);
free(baseNames);
free(fileLinktoList);
free(fileMD5List);
if (fileOwnerList) free(fileOwnerList);
if (fileGroupList) free(fileGroupList);
}
}
}
return 0; /* XXX FIXME: need real return code */
}
static void
printNewSpecfile(Spec spec)
{
Header h = spec->packages->header;
struct speclines *sl = spec->sl;
struct spectags *st = spec->st;
const char * msgstr = NULL;
int i, j;
if (sl == NULL || st == NULL)
return;
for (i = 0; i < st->st_ntags; i++) {
struct spectag * t = st->st_t + i;
const char * tn = tagName(t->t_tag);
const char * errstr;
char fmt[128];
fmt[0] = '\0';
(void) stpcpy( stpcpy( stpcpy( fmt, "%{"), tn), "}\n");
if (msgstr) xfree(msgstr);
msgstr = headerSprintf(h, fmt, rpmTagTable, rpmHeaderFormats, &errstr);
if (msgstr == NULL) {
fprintf(stderr, _("can't query %s: %s\n"), tn, errstr);
return;
}
switch(t->t_tag) {
case RPMTAG_SUMMARY:
case RPMTAG_GROUP:
free(sl->sl_lines[t->t_startx]);
sl->sl_lines[t->t_startx] = NULL;
if (t->t_lang && strcmp(t->t_lang, RPMBUILD_DEFAULT_LANG))
continue;
{ char *buf = xmalloc(strlen(tn) + sizeof(": ") + strlen(msgstr));
(void) stpcpy( stpcpy( stpcpy(buf, tn), ": "), msgstr);
sl->sl_lines[t->t_startx] = buf;
}
break;
case RPMTAG_DESCRIPTION:
for (j = 1; j < t->t_nlines; j++) {
free(sl->sl_lines[t->t_startx + j]);
sl->sl_lines[t->t_startx + j] = NULL;
}
if (t->t_lang && strcmp(t->t_lang, RPMBUILD_DEFAULT_LANG)) {
free(sl->sl_lines[t->t_startx]);
sl->sl_lines[t->t_startx] = NULL;
continue;
}
sl->sl_lines[t->t_startx + 1] = xstrdup(msgstr);
if (t->t_nlines > 2)
sl->sl_lines[t->t_startx + 2] = xstrdup("\n\n");
break;
}
}
if (msgstr) xfree(msgstr);
for (i = 0; i < sl->sl_nlines; i++) {
if (sl->sl_lines[i] == NULL)
continue;
printf("%s", sl->sl_lines[i]);
}
}
void rpmDisplayQueryTags(FILE * f)
{
const struct headerTagTableEntry * t;
int i;
const struct headerSprintfExtension * ext = rpmHeaderFormats;
for (i = 0, t = rpmTagTable; i < rpmTagTableSize; i++, t++) {
fprintf(f, "%s\n", t->name + 7);
}
while (ext->name) {
if (ext->type == HEADER_EXT_MORE) {
ext = ext->u.more;
continue;
}
/* XXX don't print query tags twice. */
for (i = 0, t = rpmTagTable; i < rpmTagTableSize; i++, t++) {
if (!strcmp(t->name, ext->name))
break;
}
if (i >= rpmTagTableSize && ext->type == HEADER_EXT_TAG)
fprintf(f, "%s\n", ext->name + 7);
ext++;
}
}
int showMatches(QVA_t *qva, rpmdbMatchIterator mi, QVF_t showPackage)
{
Header h;
int ec = 0;
while ((h = rpmdbNextIterator(mi)) != NULL) {
int rc;
if ((rc = showPackage(qva, rpmdbGetIteratorRpmDB(mi), h)) != 0)
ec = rc;
}
rpmdbFreeIterator(mi);
return ec;
}
/**
* @todo Eliminate linkage loop into librpmbuild.a
*/
int (*parseSpecVec) (Spec *specp, const char *specFile, const char *rootdir,
const char *buildRoot, int inBuildArch, const char *passPhrase,
char *cookie, int anyarch, int force) = NULL;
/**
* @todo Eliminate linkage loop into librpmbuild.a
*/
void (*freeSpecVec) (Spec spec) = NULL;
int rpmQueryVerify(QVA_t *qva, rpmQVSources source, const char * arg,
rpmdb rpmdb, QVF_t showPackage)
{
rpmdbMatchIterator mi = NULL;
Header h;
int rc;
int isSource;
int retcode = 0;
char *end = NULL;
switch (source) {
case RPMQV_RPM:
{ int argc = 0;
const char ** argv = NULL;
int i;
rc = rpmGlob(arg, &argc, &argv);
if (rc)
return 1;
for (i = 0; i < argc; i++) {
FD_t fd;
fd = Fopen(argv[i], "r.ufdio");
if (Ferror(fd)) {
/* XXX Fstrerror */
fprintf(stderr, _("open of %s failed: %s\n"), argv[i],
#ifndef NOTYET
urlStrerror(argv[i]));
#else
Fstrerror(fd));
#endif
if (fd) Fclose(fd);
retcode = 1;
break;
}
retcode = rpmReadPackageHeader(fd, &h, &isSource, NULL, NULL);
Fclose(fd);
switch (retcode) {
case 0:
if (h == NULL) {
fprintf(stderr, _("old format source packages cannot "
"be queried\n"));
retcode = 1;
break;
}
retcode = showPackage(qva, rpmdb, h);
headerFree(h);
break;
case 1:
fprintf(stderr, _("%s does not appear to be a RPM package\n"),
argv[i]);
/*@fallthrough@*/
case 2:
fprintf(stderr, _("query of %s failed\n"), argv[i]);
retcode = 1;
break;
}
}
if (argv) {
for (i = 0; i < argc; i++)
xfree(argv[i]);
xfree(argv);
}
} break;
case RPMQV_SPECFILE:
if (showPackage != showQueryPackage)
return 1;
/* XXX Eliminate linkage dependency loop */
if (parseSpecVec == NULL || freeSpecVec == NULL)
return 1;
{ Spec spec = NULL;
Package pkg;
char * buildRoot = NULL;
int inBuildArch = 0;
char * passPhrase = "";
char *cookie = NULL;
int anyarch = 1;
int force = 1;
rc = parseSpecVec(&spec, arg, "/", buildRoot, inBuildArch, passPhrase,
cookie, anyarch, force);
if (rc || spec == NULL) {
fprintf(stderr, _("query of specfile %s failed, can't parse\n"), arg);
if (spec != NULL) freeSpecVec(spec);
retcode = 1;
break;
}
if (specedit) {
printNewSpecfile(spec);
freeSpecVec(spec);
retcode = 0;
break;
}
for (pkg = spec->packages; pkg != NULL; pkg = pkg->next) {
showPackage(qva, NULL, pkg->header);
}
freeSpecVec(spec);
} break;
case RPMQV_ALL:
/* RPMDBI_PACKAGES */
mi = rpmdbInitIterator(rpmdb, RPMDBI_PACKAGES, NULL, 0);
if (mi == NULL) {
fprintf(stderr, _("no packages\n"));
retcode = 1;
} else {
retcode = showMatches(qva, mi, showPackage);
}
break;
case RPMQV_GROUP:
mi = rpmdbInitIterator(rpmdb, RPMTAG_GROUP, arg, 0);
if (mi == NULL) {
fprintf(stderr, _("group %s does not contain any packages\n"), arg);
retcode = 1;
} else {
retcode = showMatches(qva, mi, showPackage);
}
break;
case RPMQV_TRIGGEREDBY:
mi = rpmdbInitIterator(rpmdb, RPMTAG_TRIGGERNAME, arg, 0);
if (mi == NULL) {
fprintf(stderr, _("no package triggers %s\n"), arg);
retcode = 1;
} else {
retcode = showMatches(qva, mi, showPackage);
}
break;
case RPMQV_WHATREQUIRES:
mi = rpmdbInitIterator(rpmdb, RPMTAG_REQUIRENAME, arg, 0);
if (mi == NULL) {
fprintf(stderr, _("no package requires %s\n"), arg);
retcode = 1;
} else {
retcode = showMatches(qva, mi, showPackage);
}
break;
case RPMQV_WHATPROVIDES:
if (arg[0] != '/') {
mi = rpmdbInitIterator(rpmdb, RPMTAG_PROVIDENAME, arg, 0);
if (mi == NULL) {
fprintf(stderr, _("no package provides %s\n"), arg);
retcode = 1;
} else {
retcode = showMatches(qva, mi, showPackage);
}
break;
}
/*@fallthrough@*/
case RPMQV_PATH:
{ const char * s;
char * fn;
for (s = arg; *s; s++)
if (!(*s == '.' || *s == '/')) break;
if (*s == '\0') {
char fnbuf[PATH_MAX];
fn = /*@-unrecog@*/ realpath(arg, fnbuf) /*@=unrecog@*/;
fn = xstrdup( (fn ? fn : arg) );
} else
fn = xstrdup(arg);
(void) rpmCleanPath(fn);
mi = rpmdbInitIterator(rpmdb, RPMTAG_BASENAMES, fn, 0);
if (mi == NULL) {
int myerrno = 0;
if (access(fn, F_OK) != 0)
myerrno = errno;
switch (myerrno) {
default:
fprintf(stderr, _("file %s: %s\n"), fn, strerror(myerrno));
break;
case 0:
fprintf(stderr, _("file %s is not owned by any package\n"), fn);
break;
}
retcode = 1;
} else {
retcode = showMatches(qva, mi, showPackage);
}
xfree(fn);
} break;
case RPMQV_DBOFFSET:
{ int mybase = 10;
const char * myarg = arg;
int recOffset;
/* XXX should be in strtoul */
if (*myarg == '0') {
myarg++;
mybase = 8;
if (*myarg == 'x') {
myarg++;
mybase = 16;
}
}
recOffset = strtoul(myarg, &end, mybase);
if ((*end) || (end == arg) || (recOffset == ULONG_MAX)) {
fprintf(stderr, _("invalid package number: %s\n"), arg);
return 1;
}
rpmMessage(RPMMESS_DEBUG, _("package record number: %u\n"), recOffset);
/* RPMDBI_PACKAGES */
mi = rpmdbInitIterator(rpmdb, RPMDBI_PACKAGES, &recOffset, sizeof(recOffset));
if (mi == NULL) {
fprintf(stderr, _("record %d could not be read\n"), recOffset);
retcode = 1;
} else {
retcode = showMatches(qva, mi, showPackage);
}
} break;
case RPMQV_PACKAGE:
/* XXX HACK to get rpmdbFindByLabel out of the API */
mi = rpmdbInitIterator(rpmdb, RPMDBI_LABEL, arg, 0);
if (mi == NULL) {
fprintf(stderr, _("package %s is not installed\n"), arg);
retcode = 1;
} else {
retcode = showMatches(qva, mi, showPackage);
}
break;
}
return retcode;
}
int rpmQuery(QVA_t *qva, rpmQVSources source, const char * arg)
{
rpmdb rpmdb = NULL;
int rc;
switch (source) {
case RPMQV_RPM:
case RPMQV_SPECFILE:
break;
default:
if (rpmdbOpen(qva->qva_prefix, &rpmdb, O_RDONLY, 0644))
return 1;
break;
}
rc = rpmQueryVerify(qva, source, arg, rpmdb, showQueryPackage);
if (rpmdb)
rpmdbClose(rpmdb);
return rc;
}
Reference in New Issue View Git Blame Copy Permalink