/** \ingroup signature * \file lib/signature.c */ #include "system.h" #include #include #include /* XXX RPMSIGTAG* & related */ #include /* XXX for rpmGetPath() */ #include #include #include #include #include #include "rpmio/digest.h" #include "lib/misc.h" /* XXX for dosetenv() */ #include "lib/rpmlead.h" #include "lib/signature.h" #include "rpmdb/header_internal.h" #include "debug.h" #if !defined(__GLIBC__) && !defined(__APPLE__) char ** environ = NULL; #endif int rpmLookupSignatureType(int action) { static int disabled = 0; int rc = 0; switch (action) { case RPMLOOKUPSIG_DISABLE: disabled = -2; break; case RPMLOOKUPSIG_ENABLE: disabled = 0; case RPMLOOKUPSIG_QUERY: if (disabled) break; /* Disabled */ { char *name = rpmExpand("%{?_signature}", NULL); if (!(name && *name != '\0')) rc = 0; else if (!rstrcasecmp(name, "none")) rc = 0; else if (!rstrcasecmp(name, "pgp")) rc = RPMSIGTAG_PGP; else if (!rstrcasecmp(name, "pgp5")) /* XXX legacy */ rc = RPMSIGTAG_PGP; else if (!rstrcasecmp(name, "gpg")) rc = RPMSIGTAG_GPG; else rc = -1; /* Invalid %_signature spec in macro file */ name = _free(name); } break; } return rc; } /* rpmDetectPGPVersion() returns the absolute path to the "pgp" */ /* executable of the requested version, or NULL when none found. */ const char * rpmDetectPGPVersion(pgpVersion * pgpVer) { /* Actually this should support having more then one pgp version. */ /* At the moment only one version is possible since we only */ /* have one %_pgpbin and one %_pgp_path. */ static pgpVersion saved_pgp_version = PGP_UNKNOWN; char *pgpbin = rpmGetPath("%{?_pgpbin}", NULL); if (saved_pgp_version == PGP_UNKNOWN) { char *pgpvbin = NULL; struct stat st; if (!(pgpbin && pgpbin[0] != '\0')) { pgpbin = _free(pgpbin); saved_pgp_version = -1; return NULL; } rasprintf(&pgpvbin, "%sv", pgpbin); if (stat(pgpvbin, &st) == 0) saved_pgp_version = PGP_5; else if (stat(pgpbin, &st) == 0) saved_pgp_version = PGP_2; else saved_pgp_version = PGP_NOTDETECTED; free(pgpvbin); } if (pgpVer && pgpbin) *pgpVer = saved_pgp_version; return pgpbin; } /** * Print package size. * @todo rpmio: use fdSize rather than fstat(2) to get file size. * @param fd package file handle * @param siglen signature header size * @param pad signature padding * @param datalen length of header+payload * @return rpmRC return code */ static inline rpmRC printSize(FD_t fd, size_t siglen, size_t pad, rpm_off_t datalen) { struct stat st; int fdno = Fileno(fd); if (fstat(fdno, &st) < 0) return RPMRC_FAIL; rpmlog(RPMLOG_DEBUG, "Expected size: %12zd = lead(%d)+sigs(%zd)+pad(%zd)+data(%d)\n", RPMLEAD_SIZE+siglen+pad+datalen, RPMLEAD_SIZE, siglen, pad, datalen); rpmlog(RPMLOG_DEBUG, " Actual size: %12d\n", (int)st.st_size); return RPMRC_OK; } /* XXX sigh yet another duplicate.. */ static unsigned char const header_magic[8] = { 0x8e, 0xad, 0xe8, 0x01, 0x00, 0x00, 0x00, 0x00 }; rpmRC rpmReadSignature(FD_t fd, Header * sighp, sigType sig_type, char ** msg) { char *buf = NULL; int32_t block[4]; int32_t il; int32_t dl; int32_t * ei = NULL; entryInfo pe; size_t nb; int32_t ril = 0; struct indexEntry_s entry; struct entryInfo_s info; unsigned char * dataStart; unsigned char * dataEnd = NULL; Header sigh = NULL; rpmRC rc = RPMRC_FAIL; /* assume failure */ int xx; int i; if (sighp) *sighp = NULL; if (sig_type != RPMSIGTYPE_HEADERSIG) goto exit; memset(block, 0, sizeof(block)); if ((xx = timedRead(fd, (void *)block, sizeof(block))) != sizeof(block)) { rasprintf(&buf, _("sigh size(%d): BAD, read returned %d\n"), (int)sizeof(block), xx); goto exit; } if (memcmp(block, header_magic, sizeof(header_magic))) { rasprintf(&buf, _("sigh magic: BAD\n")); goto exit; } il = ntohl(block[2]); if (il < 0 || il > 32) { rasprintf(&buf, _("sigh tags: BAD, no. of tags(%d) out of range\n"), il); goto exit; } dl = ntohl(block[3]); if (dl < 0 || dl > 8192) { rasprintf(&buf, _("sigh data: BAD, no. of bytes(%d) out of range\n"), dl); goto exit; } memset(&entry, 0, sizeof(entry)); memset(&info, 0, sizeof(info)); nb = (il * sizeof(struct entryInfo_s)) + dl; ei = xmalloc(sizeof(il) + sizeof(dl) + nb); ei[0] = block[2]; ei[1] = block[3]; pe = (entryInfo) &ei[2]; dataStart = (unsigned char *) (pe + il); if ((xx = timedRead(fd, (void *)pe, nb)) != nb) { rasprintf(&buf, _("sigh blob(%d): BAD, read returned %d\n"), (int)nb, xx); goto exit; } /* Check (and convert) the 1st tag element. */ xx = headerVerifyInfo(1, dl, pe, &entry.info, 0); if (xx != -1) { rasprintf(&buf, _("tag[%d]: BAD, tag %d type %d offset %d count %d\n"), 0, entry.info.tag, entry.info.type, entry.info.offset, entry.info.count); goto exit; } /* Is there an immutable header region tag? */ if (entry.info.tag == RPMTAG_HEADERSIGNATURES && entry.info.type == RPM_BIN_TYPE && entry.info.count == REGION_TAG_COUNT) { if (entry.info.offset >= dl) { rasprintf(&buf, _("region offset: BAD, tag %d type %d offset %d count %d\n"), entry.info.tag, entry.info.type, entry.info.offset, entry.info.count); goto exit; } /* Is there an immutable header region tag trailer? */ dataEnd = dataStart + entry.info.offset; (void) memcpy(&info, dataEnd, REGION_TAG_COUNT); /* XXX Really old packages have HEADER_IMAGE, not HEADER_SIGNATURES. */ if (info.tag == htonl(RPMTAG_HEADERIMAGE)) { rpmSigTag stag = htonl(RPMTAG_HEADERSIGNATURES); info.tag = stag; memcpy(dataEnd, &stag, sizeof(stag)); } dataEnd += REGION_TAG_COUNT; xx = headerVerifyInfo(1, dl, &info, &entry.info, 1); if (xx != -1 || !((entry.info.tag == RPMTAG_HEADERSIGNATURES || entry.info.tag == RPMTAG_HEADERIMAGE) && entry.info.type == RPM_BIN_TYPE && entry.info.count == REGION_TAG_COUNT)) { rasprintf(&buf, _("region trailer: BAD, tag %d type %d offset %d count %d\n"), entry.info.tag, entry.info.type, entry.info.offset, entry.info.count); goto exit; } memset(&info, 0, sizeof(info)); /* Is the no. of tags in the region less than the total no. of tags? */ ril = entry.info.offset/sizeof(*pe); if ((entry.info.offset % sizeof(*pe)) || ril > il) { rasprintf(&buf, _("region size: BAD, ril(%d) > il(%d)\n"), ril, il); goto exit; } } /* Sanity check signature tags */ memset(&info, 0, sizeof(info)); for (i = 1; i < il; i++) { xx = headerVerifyInfo(1, dl, pe+i, &entry.info, 0); if (xx != -1) { rasprintf(&buf, _("sigh tag[%d]: BAD, tag %d type %d offset %d count %d\n"), i, entry.info.tag, entry.info.type, entry.info.offset, entry.info.count); goto exit; } } /* OK, blob looks sane, load the header. */ sigh = headerLoad(ei); if (sigh == NULL) { rasprintf(&buf, _("sigh load: BAD\n")); goto exit; } sigh->flags |= HEADERFLAG_ALLOCATED; { size_t sigSize = headerSizeof(sigh, HEADER_MAGIC_YES); size_t pad = (8 - (sigSize % 8)) % 8; /* 8-byte pad */ ssize_t trc; rpm_off_t * archSize = NULL; /* Position at beginning of header. */ if (pad && (trc = timedRead(fd, (void *)block, pad)) != pad) { rasprintf(&buf, _("sigh pad(%zd): BAD, read %zd bytes\n"), pad, trc); goto exit; } /* Print package component sizes. */ if (headerGetEntry(sigh, RPMSIGTAG_SIZE, NULL,(rpm_data_t *)&archSize, NULL)) { rc = printSize(fd, sigSize, pad, *archSize); if (rc != RPMRC_OK) { rasprintf(&buf, _("sigh sigSize(%zd): BAD, fstat(2) failed\n"), sigSize); goto exit; } } } exit: if (sighp && sigh && rc == RPMRC_OK) *sighp = headerLink(sigh); sigh = headerFree(sigh); if (msg != NULL) { *msg = buf; } else { free(buf); } return rc; } int rpmWriteSignature(FD_t fd, Header sigh) { static uint8_t buf[8] = { 0, 0, 0, 0, 0, 0, 0, 0 }; int sigSize, pad; int rc; rc = headerWrite(fd, sigh, HEADER_MAGIC_YES); if (rc) return rc; sigSize = headerSizeof(sigh, HEADER_MAGIC_YES); pad = (8 - (sigSize % 8)) % 8; if (pad) { if (Fwrite(buf, sizeof(buf[0]), pad, fd) != pad) rc = 1; } rpmlog(RPMLOG_DEBUG, "Signature: size(%d)+pad(%d)\n", sigSize, pad); return rc; } Header rpmNewSignature(void) { Header sigh = headerNew(); return sigh; } Header rpmFreeSignature(Header sigh) { return headerFree(sigh); } /** * Generate PGP signature(s) for a header+payload file. * @param file header+payload file name * @retval *sigTagp signature tag * @retval *pktp signature packet(s) * @retval *pktlenp signature packet(s) length * @param passPhrase private key pass phrase * @return 0 on success, 1 on failure */ static int makePGPSignature(const char * file, rpmSigTag * sigTagp, uint8_t ** pktp, size_t * pktlenp, const char * passPhrase) { char * sigfile = NULL; int pid, status; int inpipe[2]; FILE *fpipe; struct stat st; const char * cmd; char *const *av; #ifdef NOTYET pgpDig dig = NULL; pgpDigParams sigp = NULL; #endif int rc = 1; /* assume failure */ rasprintf(&sigfile, "%s.sig", file); addMacro(NULL, "__plaintext_filename", NULL, file, -1); addMacro(NULL, "__signature_filename", NULL, sigfile, -1); inpipe[0] = inpipe[1] = 0; if (pipe(inpipe) < 0) { rpmlog(RPMLOG_ERR, _("Couldn't create pipe for signing: %m")); goto exit; } if (!(pid = fork())) { const char *pgp_path = rpmExpand("%{?_pgp_path}", NULL); const char *path; pgpVersion pgpVer; (void) dup2(inpipe[0], 3); (void) close(inpipe[1]); (void) dosetenv("PGPPASSFD", "3", 1); if (pgp_path && *pgp_path != '\0') (void) dosetenv("PGPPATH", pgp_path, 1); /* dosetenv("PGPPASS", passPhrase, 1); */ unsetenv("MALLOC_CHECK_"); if ((path = rpmDetectPGPVersion(&pgpVer)) != NULL) { switch(pgpVer) { case PGP_2: cmd = rpmExpand("%{?__pgp_sign_cmd}", NULL); rc = poptParseArgvString(cmd, NULL, (const char ***)&av); if (!rc) rc = execve(av[0], av+1, environ); break; case PGP_5: cmd = rpmExpand("%{?__pgp5_sign_cmd}", NULL); rc = poptParseArgvString(cmd, NULL, (const char ***)&av); if (!rc) rc = execve(av[0], av+1, environ); break; case PGP_UNKNOWN: case PGP_NOTDETECTED: errno = ENOENT; break; } } rpmlog(RPMLOG_ERR, _("Could not exec %s: %s\n"), "pgp", strerror(errno)); _exit(EXIT_FAILURE); } delMacro(NULL, "__plaintext_filename"); delMacro(NULL, "__signature_filename"); fpipe = fdopen(inpipe[1], "w"); (void) close(inpipe[0]); if (fpipe) { fprintf(fpipe, "%s\n", (passPhrase ? passPhrase : "")); (void) fclose(fpipe); } (void)waitpid(pid, &status, 0); if (!WIFEXITED(status) || WEXITSTATUS(status)) { rpmlog(RPMLOG_ERR, _("pgp failed\n")); goto exit; } if (stat(sigfile, &st)) { /* PGP failed to write signature */ if (sigfile) (void) unlink(sigfile); /* Just in case */ rpmlog(RPMLOG_ERR, _("pgp failed to write signature\n")); goto exit; } *pktlenp = st.st_size; rpmlog(RPMLOG_DEBUG, "PGP sig size: %zd\n", *pktlenp); *pktp = xmalloc(*pktlenp); { FD_t fd; rc = 0; fd = Fopen(sigfile, "r.fdio"); if (fd != NULL && !Ferror(fd)) { rc = timedRead(fd, (void *)*pktp, *pktlenp); if (sigfile) (void) unlink(sigfile); (void) Fclose(fd); } if (rc != *pktlenp) { *pktp = _free(*pktp); rpmlog(RPMLOG_ERR, _("unable to read the signature\n")); goto exit; } } rpmlog(RPMLOG_DEBUG, "Got %zd bytes of PGP sig\n", *pktlenp); rc = 0; #ifdef NOTYET /* Parse the signature, change signature tag as appropriate. */ dig = pgpNewDig(); (void) pgpPrtPkts(*pktp, *pktlenp, dig, 0); sigp = &dig->signature; dig = pgpFreeDig(dig); #endif exit: free(sigfile); return rc; } /** * Generate GPG signature(s) for a header+payload file. * @param file header+payload file name * @retval *sigTagp signature tag * @retval *pktp signature packet(s) * @retval *pktlenp signature packet(s) length * @param passPhrase private key pass phrase * @return 0 on success, 1 on failure */ static int makeGPGSignature(const char * file, rpmSigTag * sigTagp, uint8_t ** pktp, size_t * pktlenp, const char * passPhrase) { char * sigfile = NULL; int pid, status; int inpipe[2]; FILE * fpipe; struct stat st; const char * cmd; char *const *av; pgpDig dig = NULL; pgpDigParams sigp = NULL; int rc = 1; /* assume failure */ rasprintf(&sigfile, "%s.sig", file); addMacro(NULL, "__plaintext_filename", NULL, file, -1); addMacro(NULL, "__signature_filename", NULL, sigfile, -1); inpipe[0] = inpipe[1] = 0; if (pipe(inpipe) < 0) { rpmlog(RPMLOG_ERR, _("Couldn't create pipe for signing: %m")); goto exit; } if (!(pid = fork())) { const char *gpg_path = rpmExpand("%{?_gpg_path}", NULL); (void) dup2(inpipe[0], 3); (void) close(inpipe[1]); if (gpg_path && *gpg_path != '\0') (void) dosetenv("GNUPGHOME", gpg_path, 1); (void) dosetenv("LC_ALL", "C", 1); unsetenv("MALLOC_CHECK_"); cmd = rpmExpand("%{?__gpg_sign_cmd}", NULL); rc = poptParseArgvString(cmd, NULL, (const char ***)&av); if (!rc) rc = execve(av[0], av+1, environ); rpmlog(RPMLOG_ERR, _("Could not exec %s: %s\n"), "gpg", strerror(errno)); _exit(EXIT_FAILURE); } delMacro(NULL, "__plaintext_filename"); delMacro(NULL, "__signature_filename"); fpipe = fdopen(inpipe[1], "w"); (void) close(inpipe[0]); if (fpipe) { fprintf(fpipe, "%s\n", (passPhrase ? passPhrase : "")); (void) fclose(fpipe); } (void) waitpid(pid, &status, 0); if (!WIFEXITED(status) || WEXITSTATUS(status)) { rpmlog(RPMLOG_ERR, _("gpg exec failed (%d)\n"), WEXITSTATUS(status)); goto exit; } if (stat(sigfile, &st)) { /* GPG failed to write signature */ rpmlog(RPMLOG_ERR, _("gpg failed to write signature\n")); goto exit; } *pktlenp = st.st_size; rpmlog(RPMLOG_DEBUG, "GPG sig size: %zd\n", *pktlenp); *pktp = xmalloc(*pktlenp); { FD_t fd; rc = 0; fd = Fopen(sigfile, "r.fdio"); if (fd != NULL && !Ferror(fd)) { rc = timedRead(fd, (void *)*pktp, *pktlenp); (void) Fclose(fd); } if (rc != *pktlenp) { *pktp = _free(*pktp); rpmlog(RPMLOG_ERR, _("unable to read the signature\n")); goto exit; } } rpmlog(RPMLOG_DEBUG, "Got %zd bytes of GPG sig\n", *pktlenp); /* Parse the signature, change signature tag as appropriate. */ dig = pgpNewDig(); (void) pgpPrtPkts(*pktp, *pktlenp, dig, 0); sigp = &dig->signature; switch (*sigTagp) { case RPMSIGTAG_SIZE: case RPMSIGTAG_MD5: case RPMSIGTAG_SHA1: break; case RPMSIGTAG_GPG: /* XXX check MD5 hash too? */ if (sigp->pubkey_algo == PGPPUBKEYALGO_RSA) *sigTagp = RPMSIGTAG_PGP; break; case RPMSIGTAG_PGP5: /* XXX legacy */ case RPMSIGTAG_PGP: if (sigp->pubkey_algo == PGPPUBKEYALGO_DSA) *sigTagp = RPMSIGTAG_GPG; break; case RPMSIGTAG_DSA: /* XXX check MD5 hash too? */ if (sigp->pubkey_algo == PGPPUBKEYALGO_RSA) *sigTagp = RPMSIGTAG_RSA; break; case RPMSIGTAG_RSA: if (sigp->pubkey_algo == PGPPUBKEYALGO_DSA) *sigTagp = RPMSIGTAG_DSA; break; /* shut up gcc */ case RPMSIGTAG_LEMD5_1: case RPMSIGTAG_LEMD5_2: case RPMSIGTAG_BADSHA1_1: case RPMSIGTAG_BADSHA1_2: case RPMSIGTAG_PAYLOADSIZE: break; } dig = pgpFreeDig(dig); rc = 0; exit: (void) unlink(sigfile); free(sigfile); return rc; } /** * Generate header only signature(s) from a header+payload file. * @param sigh signature header * @param file header+payload file name * @param sigTag type of signature(s) to add * @param passPhrase private key pass phrase * @return 0 on success, -1 on failure */ static int makeHDRSignature(Header sigh, const char * file, rpmSigTag sigTag, const char * passPhrase) { Header h = NULL; FD_t fd = NULL; uint8_t * pkt = NULL; size_t pktlen; char * fn = NULL; char * SHA1 = NULL; int ret = -1; /* assume failure. */ switch (sigTag) { case RPMSIGTAG_SIZE: case RPMSIGTAG_MD5: case RPMSIGTAG_PGP5: /* XXX legacy */ case RPMSIGTAG_PGP: case RPMSIGTAG_GPG: goto exit; break; case RPMSIGTAG_SHA1: fd = Fopen(file, "r.fdio"); if (fd == NULL || Ferror(fd)) goto exit; h = headerRead(fd, HEADER_MAGIC_YES); if (h == NULL) goto exit; (void) Fclose(fd); fd = NULL; if (headerIsEntry(h, RPMTAG_HEADERIMMUTABLE)) { DIGEST_CTX ctx; void * uh; rpmTagType uht; rpm_count_t uhc; if (!headerGetEntry(h, RPMTAG_HEADERIMMUTABLE, &uht, &uh, &uhc) || uh == NULL) { rpmlog(RPMLOG_ERR, _("Immutable header region could not be read. " "Corrupted package?\n")); h = headerFree(h); goto exit; } ctx = rpmDigestInit(PGPHASHALGO_SHA1, RPMDIGEST_NONE); (void) rpmDigestUpdate(ctx, header_magic, sizeof(header_magic)); (void) rpmDigestUpdate(ctx, uh, uhc); (void) rpmDigestFinal(ctx, (void **)&SHA1, NULL, 1); uh = headerFreeData(uh, uht); } h = headerFree(h); if (SHA1 == NULL) goto exit; if (!headerAddEntry(sigh, RPMSIGTAG_SHA1, RPM_STRING_TYPE, SHA1, 1)) goto exit; ret = 0; break; case RPMSIGTAG_DSA: fd = Fopen(file, "r.fdio"); if (fd == NULL || Ferror(fd)) goto exit; h = headerRead(fd, HEADER_MAGIC_YES); if (h == NULL) goto exit; (void) Fclose(fd); fd = rpmMkTempFile(NULL, &fn); if (fd == NULL || Ferror(fd)) goto exit; if (headerWrite(fd, h, HEADER_MAGIC_YES)) goto exit; (void) Fclose(fd); fd = NULL; if (makeGPGSignature(fn, &sigTag, &pkt, &pktlen, passPhrase) || !headerAddEntry(sigh, sigTag, RPM_BIN_TYPE, pkt, pktlen)) goto exit; ret = 0; break; case RPMSIGTAG_RSA: fd = Fopen(file, "r.fdio"); if (fd == NULL || Ferror(fd)) goto exit; h = headerRead(fd, HEADER_MAGIC_YES); if (h == NULL) goto exit; (void) Fclose(fd); fd = rpmMkTempFile(NULL, &fn); if (fd == NULL || Ferror(fd)) goto exit; if (headerWrite(fd, h, HEADER_MAGIC_YES)) goto exit; (void) Fclose(fd); fd = NULL; if (makePGPSignature(fn, &sigTag, &pkt, &pktlen, passPhrase) || !headerAddEntry(sigh, sigTag, RPM_BIN_TYPE, pkt, pktlen)) goto exit; ret = 0; break; /* shut up gcc */ case RPMSIGTAG_LEMD5_1: case RPMSIGTAG_LEMD5_2: case RPMSIGTAG_BADSHA1_1: case RPMSIGTAG_BADSHA1_2: case RPMSIGTAG_PAYLOADSIZE: break; } exit: if (fn) { (void) unlink(fn); free(fn); } free(pkt); free(SHA1); h = headerFree(h); if (fd != NULL) (void) Fclose(fd); return ret; } int rpmAddSignature(Header sigh, const char * file, rpmSigTag sigTag, const char * passPhrase) { struct stat st; uint8_t * pkt = NULL; size_t pktlen; int ret = -1; /* assume failure. */ switch (sigTag) { case RPMSIGTAG_SIZE: if (stat(file, &st) != 0) break; pktlen = st.st_size; if (!headerAddEntry(sigh, sigTag, RPM_INT32_TYPE, &pktlen, 1)) break; ret = 0; break; case RPMSIGTAG_MD5: pktlen = 16; pkt = xcalloc(pktlen, sizeof(*pkt)); if (rpmDoDigest(PGPHASHALGO_MD5, file, 0, pkt, NULL) || !headerAddEntry(sigh, sigTag, RPM_BIN_TYPE, pkt, pktlen)) break; ret = 0; break; case RPMSIGTAG_PGP5: /* XXX legacy */ case RPMSIGTAG_PGP: if (makePGPSignature(file, &sigTag, &pkt, &pktlen, passPhrase) || !headerAddEntry(sigh, sigTag, RPM_BIN_TYPE, pkt, pktlen)) break; #ifdef NOTYET /* XXX needs hdrmd5ctx, like hdrsha1ctx. */ /* XXX Piggyback a header-only RSA signature as well. */ ret = makeHDRSignature(sigh, file, RPMSIGTAG_RSA, passPhrase); #endif ret = 0; break; case RPMSIGTAG_GPG: if (makeGPGSignature(file, &sigTag, &pkt, &pktlen, passPhrase) || !headerAddEntry(sigh, sigTag, RPM_BIN_TYPE, pkt, pktlen)) break; /* XXX Piggyback a header-only DSA signature as well. */ ret = makeHDRSignature(sigh, file, RPMSIGTAG_DSA, passPhrase); break; case RPMSIGTAG_RSA: case RPMSIGTAG_DSA: case RPMSIGTAG_SHA1: ret = makeHDRSignature(sigh, file, sigTag, passPhrase); break; /* shut up gcc */ case RPMSIGTAG_LEMD5_1: case RPMSIGTAG_LEMD5_2: case RPMSIGTAG_BADSHA1_1: case RPMSIGTAG_BADSHA1_2: case RPMSIGTAG_PAYLOADSIZE: break; } free(pkt); return ret; } static int checkPassPhrase(const char * passPhrase, const rpmSigTag sigTag) { int passPhrasePipe[2]; int pid, status; int rc; int xx; passPhrasePipe[0] = passPhrasePipe[1] = 0; xx = pipe(passPhrasePipe); if (!(pid = fork())) { const char * cmd; char *const *av; int fdno; xx = close(STDIN_FILENO); xx = close(STDOUT_FILENO); xx = close(passPhrasePipe[1]); if (! rpmIsVerbose()) xx = close(STDERR_FILENO); if ((fdno = open("/dev/null", O_RDONLY)) != STDIN_FILENO) { xx = dup2(fdno, STDIN_FILENO); xx = close(fdno); } if ((fdno = open("/dev/null", O_WRONLY)) != STDOUT_FILENO) { xx = dup2(fdno, STDOUT_FILENO); xx = close(fdno); } xx = dup2(passPhrasePipe[0], 3); unsetenv("MALLOC_CHECK_"); switch (sigTag) { case RPMSIGTAG_DSA: case RPMSIGTAG_GPG: { const char *gpg_path = rpmExpand("%{?_gpg_path}", NULL); if (gpg_path && *gpg_path != '\0') (void) dosetenv("GNUPGHOME", gpg_path, 1); cmd = rpmExpand("%{?__gpg_check_password_cmd}", NULL); rc = poptParseArgvString(cmd, NULL, (const char ***)&av); if (!rc) rc = execve(av[0], av+1, environ); rpmlog(RPMLOG_ERR, _("Could not exec %s: %s\n"), "gpg", strerror(errno)); } break; case RPMSIGTAG_RSA: case RPMSIGTAG_PGP5: /* XXX legacy */ case RPMSIGTAG_PGP: { const char *pgp_path = rpmExpand("%{?_pgp_path}", NULL); const char *path; pgpVersion pgpVer; (void) dosetenv("PGPPASSFD", "3", 1); if (pgp_path && *pgp_path != '\0') xx = dosetenv("PGPPATH", pgp_path, 1); if ((path = rpmDetectPGPVersion(&pgpVer)) != NULL) { switch(pgpVer) { case PGP_2: cmd = rpmExpand("%{?__pgp_check_password_cmd}", NULL); rc = poptParseArgvString(cmd, NULL, (const char ***)&av); if (!rc) rc = execve(av[0], av+1, environ); break; case PGP_5: /* XXX legacy */ cmd = rpmExpand("%{?__pgp5_check_password_cmd}", NULL); rc = poptParseArgvString(cmd, NULL, (const char ***)&av); if (!rc) rc = execve(av[0], av+1, environ); break; case PGP_UNKNOWN: case PGP_NOTDETECTED: break; } } rpmlog(RPMLOG_ERR, _("Could not exec %s: %s\n"), "pgp", strerror(errno)); _exit(EXIT_FAILURE); } break; default: /* This case should have been screened out long ago. */ rpmlog(RPMLOG_ERR, _("Invalid %%_signature spec in macro file\n")); _exit(EXIT_FAILURE); break; } } xx = close(passPhrasePipe[0]); xx = write(passPhrasePipe[1], passPhrase, strlen(passPhrase)); xx = write(passPhrasePipe[1], "\n", 1); xx = close(passPhrasePipe[1]); (void) waitpid(pid, &status, 0); return ((!WIFEXITED(status) || WEXITSTATUS(status)) ? 1 : 0); } char * rpmGetPassPhrase(const char * prompt, const rpmSigTag sigTag) { char *pass = NULL; int aok = 0; switch (sigTag) { case RPMSIGTAG_DSA: case RPMSIGTAG_GPG: { char *name = rpmExpand("%{?_gpg_name}", NULL); aok = (name && *name != '\0'); name = _free(name); } if (aok) break; rpmlog(RPMLOG_ERR, _("You must set \"%%_gpg_name\" in your macro file\n")); break; case RPMSIGTAG_RSA: case RPMSIGTAG_PGP5: /* XXX legacy */ case RPMSIGTAG_PGP: { char *name = rpmExpand("%{?_pgp_name}", NULL); aok = (name && *name != '\0'); name = _free(name); } if (aok) break; rpmlog(RPMLOG_ERR, _("You must set \"%%_pgp_name\" in your macro file\n")); break; default: /* Currently the calling function (rpm.c:main) is checking this and * doing a better job. This section should never be accessed. */ rpmlog(RPMLOG_ERR, _("Invalid %%_signature spec in macro file\n")); break; } if (aok) { pass = getpass( (prompt ? prompt : "") ); if (checkPassPhrase(pass, sigTag)) pass = NULL; } return pass; } static const char * rpmSigString(rpmRC res) { const char * str; switch (res) { case RPMRC_OK: str = "OK"; break; case RPMRC_FAIL: str = "BAD"; break; case RPMRC_NOKEY: str = "NOKEY"; break; case RPMRC_NOTTRUSTED: str = "NOTRUSTED"; break; default: case RPMRC_NOTFOUND: str = "UNKNOWN"; break; } return str; } static rpmRC verifySizeSignature(const rpmts ts, char ** msg) { rpm_constdata_t sig = rpmtsSig(ts); pgpDig dig = rpmtsDig(ts); rpmRC res; size_t size = 0x7fffffff; const char * title = _("Header+Payload size:"); assert(msg != NULL); *msg = NULL; if (sig == NULL || dig == NULL || dig->nbytes == 0) { res = RPMRC_NOKEY; rasprintf(msg, "%s %s\n", title, rpmSigString(res)); goto exit; } memcpy(&size, sig, sizeof(size)); if (size != dig->nbytes) { res = RPMRC_FAIL; rasprintf(msg, "%s %s Expected(%zd) != (%zd)\n", title, rpmSigString(res), size, dig->nbytes); } else { res = RPMRC_OK; rasprintf(msg, "%s %s (%zd)\n", title, rpmSigString(res), dig->nbytes); } exit: return res; } static rpmRC verifyMD5Signature(const rpmts ts, char ** msg, DIGEST_CTX md5ctx) { rpm_constdata_t sig = rpmtsSig(ts); size_t siglen = rpmtsSiglen(ts); pgpDig dig = rpmtsDig(ts); rpmRC res; uint8_t * md5sum = NULL; size_t md5len = 0; char *md5; const char *title = _("MD5 digest:"); assert(msg != NULL); *msg = NULL; if (md5ctx == NULL || sig == NULL || dig == NULL) { res = RPMRC_NOKEY; rasprintf(msg, "%s %s\n", title, rpmSigString(res)); goto exit; } (void) rpmswEnter(rpmtsOp(ts, RPMTS_OP_DIGEST), 0); (void) rpmDigestFinal(rpmDigestDup(md5ctx), (void **)&md5sum, &md5len, 0); (void) rpmswExit(rpmtsOp(ts, RPMTS_OP_DIGEST), 0); rpmtsOp(ts, RPMTS_OP_DIGEST)->count--; /* XXX one too many */ md5 = pgpHexStr(md5sum, md5len); if (md5len != siglen || memcmp(md5sum, sig, md5len)) { res = RPMRC_FAIL; char *hex = pgpHexStr(sig, siglen); rasprintf(msg, "%s %s Expected(%s) != (%s)\n", title, rpmSigString(res), hex, md5); free(hex); } else { res = RPMRC_OK; rasprintf(msg, "%s %s (%s)\n", title, rpmSigString(res), md5); } free(md5); exit: md5sum = _free(md5sum); return res; } /** * Verify header immutable region SHA1 digest. * @param ts transaction set * @retval msg verbose success/failure text * @param sha1ctx * @return RPMRC_OK on success */ static rpmRC verifySHA1Signature(const rpmts ts, char ** msg, DIGEST_CTX sha1ctx) { const char *sig = rpmtsSig(ts); #ifdef NOTYET size_t siglen = rpmtsSiglen(ts); #endif pgpDig dig = rpmtsDig(ts); rpmRC res; char * SHA1 = NULL; const char *title = _("Header SHA1 digest:"); assert(msg != NULL); *msg = NULL; if (sha1ctx == NULL || sig == NULL || dig == NULL) { res = RPMRC_NOKEY; rasprintf(msg, "%s %s\n", title, rpmSigString(res)); goto exit; } (void) rpmswEnter(rpmtsOp(ts, RPMTS_OP_DIGEST), 0); (void) rpmDigestFinal(rpmDigestDup(sha1ctx), (void **)&SHA1, NULL, 1); (void) rpmswExit(rpmtsOp(ts, RPMTS_OP_DIGEST), 0); if (SHA1 == NULL || strlen(SHA1) != strlen(sig) || strcmp(SHA1, sig)) { res = RPMRC_FAIL; rasprintf(msg, "%s %s Expected(%s) != (%s)\n", title, rpmSigString(res), sig, SHA1 ? SHA1 : "(nil)"); } else { res = RPMRC_OK; rasprintf(msg, "%s %s (%s)\n", title, rpmSigString(res), SHA1); } exit: SHA1 = _free(SHA1); return res; } /** * Verify RSA signature. * @param ts transaction set * @retval msg rbose success/failure text * @param md5ctx * @return RPMRC_OK on success */ static rpmRC verifyRSASignature(rpmts ts, char ** msg, DIGEST_CTX md5ctx) { rpm_constdata_t sig = rpmtsSig(ts); #ifdef NOTYET size_t siglen = rpmtsSiglen(ts); #endif rpmSigTag sigtag = rpmtsSigtag(ts); pgpDig dig = rpmtsDig(ts); pgpDigParams sigp = rpmtsSignature(ts); SECOidTag sigalg; rpmRC res = RPMRC_OK; int xx; SECItem digest; const char *hdr, *signame = _("Unknown");; int sigver; assert(msg != NULL); *msg = NULL; hdr = (dig != NULL && dig->hdrmd5ctx == md5ctx) ? _("Header ") : ""; sigver = sigp !=NULL ? sigp->version : 0; if (md5ctx == NULL || sig == NULL || dig == NULL || sigp == NULL) { res = RPMRC_NOKEY; } if (sigp == NULL) goto exit; /* Verify the desired signature match. */ switch (sigp->pubkey_algo) { case PGPPUBKEYALGO_RSA: if (sigtag == RPMSIGTAG_PGP || sigtag == RPMSIGTAG_PGP5 || sigtag == RPMSIGTAG_RSA) break; default: res = RPMRC_NOKEY; break; } /* Verify the desired hash match. */ /* XXX Values from PKCS#1 v2.1 (aka RFC-3447) */ switch (sigp->hash_algo) { case PGPHASHALGO_MD5: signame = "RSA/MD5"; sigalg = SEC_OID_PKCS1_MD5_WITH_RSA_ENCRYPTION; break; case PGPHASHALGO_SHA1: signame = "RSA/SHA1"; sigalg = SEC_OID_PKCS1_SHA1_WITH_RSA_ENCRYPTION; break; case PGPHASHALGO_MD2: signame = "RSA/MD2"; sigalg = SEC_OID_PKCS1_MD2_WITH_RSA_ENCRYPTION; break; case PGPHASHALGO_SHA256: signame = "RSA/SHA256"; sigalg = SEC_OID_PKCS1_SHA256_WITH_RSA_ENCRYPTION; break; case PGPHASHALGO_SHA384: signame = "RSA/SHA384"; sigalg = SEC_OID_PKCS1_SHA384_WITH_RSA_ENCRYPTION; break; case PGPHASHALGO_SHA512: signame = "RSA/SHA512"; sigalg = SEC_OID_PKCS1_SHA512_WITH_RSA_ENCRYPTION; break; /* fallthrough for unsupported / unknown types */ case PGPHASHALGO_TIGER192: case PGPHASHALGO_HAVAL_5_160: case PGPHASHALGO_RIPEMD160: default: res = RPMRC_NOKEY; sigalg = SEC_OID_UNKNOWN; break; } if (res != RPMRC_OK) { goto exit; } (void) rpmswEnter(rpmtsOp(ts, RPMTS_OP_DIGEST), 0); { DIGEST_CTX ctx = rpmDigestDup(md5ctx); if (sigp->hash != NULL) xx = rpmDigestUpdate(ctx, sigp->hash, sigp->hashlen); #ifdef NOTYET /* XXX not for binary/text signatures as in packages. */ if (!(sigp->sigtype == PGPSIGTYPE_BINARY || sigp->sigtype == PGP_SIGTYPE_TEXT)) { size_t nb = dig->nbytes + sigp->hashlen; uint8_t trailer[6]; nb = htonl(nb); trailer[0] = 0x4; trailer[1] = 0xff; memcpy(trailer+2, &nb, sizeof(nb)); xx = rpmDigestUpdate(ctx, trailer, sizeof(trailer)); } #endif xx = rpmDigestFinal(ctx, (void **)&dig->md5, &dig->md5len, 0); (void) rpmswExit(rpmtsOp(ts, RPMTS_OP_DIGEST), sigp->hashlen); rpmtsOp(ts, RPMTS_OP_DIGEST)->count--; /* XXX one too many */ /* Compare leading 16 bits of digest for quick check. */ if (memcmp(dig->md5, sigp->signhash16, 2)) { res = RPMRC_FAIL; goto exit; } digest.type = siBuffer; digest.data = dig->md5; digest.len = dig->md5len; } /* Retrieve the matching public key. */ res = rpmtsFindPubkey(ts); if (res != RPMRC_OK) goto exit; (void) rpmswEnter(rpmtsOp(ts, RPMTS_OP_SIGNATURE), 0); if (VFY_VerifyDigest(&digest, dig->rsa, dig->rsasig, sigalg, NULL) == SECSuccess) res = RPMRC_OK; else res = RPMRC_FAIL; (void) rpmswExit(rpmtsOp(ts, RPMTS_OP_SIGNATURE), 0); exit: if (sigp != NULL) { char *signid = pgpHexStr(sigp->signid+4, sizeof(sigp->signid)-4); rasprintf(msg, _("%sV%d %s signature: %s, key ID %s\n"), hdr, sigver, signame, rpmSigString(res), signid); free(signid); } else { rasprintf(msg, _("%sV%d %s signature: %s\n"), hdr, sigver, signame, rpmSigString(res)); } return res; } /** * Verify DSA signature. * @param ts transaction set * @retval t verbose success/failure text * @param sha1ctx * @return RPMRC_OK on success */ static rpmRC verifyDSASignature(rpmts ts, char ** msg, DIGEST_CTX sha1ctx) { rpm_constdata_t sig = rpmtsSig(ts); #ifdef NOTYET size_t siglen = rpmtsSiglen(ts); #endif rpmSigTag sigtag = rpmtsSigtag(ts); pgpDig dig = rpmtsDig(ts); pgpDigParams sigp = rpmtsSignature(ts); rpmRC res; int xx; SECItem digest; const char *hdr; int sigver; assert(msg != NULL); *msg = NULL; hdr = (dig != NULL && dig->hdrsha1ctx == sha1ctx) ? _("Header ") : ""; sigver = sigp !=NULL ? sigp->version : 0; if (sha1ctx == NULL || sig == NULL || dig == NULL || sigp == NULL) { res = RPMRC_NOKEY; goto exit; } /* XXX sanity check on sigtag and signature agreement. */ if (!((sigtag == RPMSIGTAG_GPG || sigtag == RPMSIGTAG_DSA) && sigp->pubkey_algo == PGPPUBKEYALGO_DSA && sigp->hash_algo == PGPHASHALGO_SHA1)) { res = RPMRC_NOKEY; goto exit; } (void) rpmswEnter(rpmtsOp(ts, RPMTS_OP_DIGEST), 0); { DIGEST_CTX ctx = rpmDigestDup(sha1ctx); if (sigp->hash != NULL) xx = rpmDigestUpdate(ctx, sigp->hash, sigp->hashlen); if (sigp->version == 4) { size_t nb = sigp->hashlen; uint8_t *trailer = xmalloc(2+sizeof(nb)); nb = htonl(nb); trailer[0] = sigp->version; trailer[1] = 0xff; memcpy(trailer+2, &nb, sizeof(nb)); xx = rpmDigestUpdate(ctx, trailer, sizeof(trailer)); free(trailer); } xx = rpmDigestFinal(ctx, (void **)&dig->sha1, &dig->sha1len, 0); (void) rpmswExit(rpmtsOp(ts, RPMTS_OP_DIGEST), sigp->hashlen); rpmtsOp(ts, RPMTS_OP_DIGEST)->count--; /* XXX one too many */ /* Compare leading 16 bits of digest for quick check. */ if (memcmp(dig->sha1, sigp->signhash16, 2)) { res = RPMRC_FAIL; goto exit; } digest.type = siBuffer; digest.data = dig->sha1; digest.len = dig->sha1len; } /* Retrieve the matching public key. */ res = rpmtsFindPubkey(ts); if (res != RPMRC_OK) goto exit; (void) rpmswEnter(rpmtsOp(ts, RPMTS_OP_SIGNATURE), 0); if (VFY_VerifyDigest(&digest, dig->dsa, dig->dsasig, SEC_OID_ANSIX9_DSA_SIGNATURE_WITH_SHA1_DIGEST, NULL) == SECSuccess) res = RPMRC_OK; else res = RPMRC_FAIL; (void) rpmswExit(rpmtsOp(ts, RPMTS_OP_SIGNATURE), 0); exit: if (sigp != NULL) { char *signid = pgpHexStr(sigp->signid+4, sizeof(sigp->signid)-4); rasprintf(msg, _("%sV%d DSA signature: %s, key ID %s\n"), hdr, sigver, rpmSigString(res), signid); free(signid); } else { rasprintf(msg, _("%sV%d DSA signature: %s\n"), hdr, sigver, rpmSigString(res)); } return res; } rpmRC rpmVerifySignature(const rpmts ts, char ** result) { rpm_constdata_t sig = rpmtsSig(ts); size_t siglen = rpmtsSiglen(ts); rpmSigTag sigtag = rpmtsSigtag(ts); pgpDig dig = rpmtsDig(ts); rpmRC res; assert(result != NULL); if (sig == NULL || siglen <= 0 || dig == NULL) { rasprintf(result, _("Verify signature: BAD PARAMETERS\n")); return RPMRC_NOTFOUND; } switch (sigtag) { case RPMSIGTAG_SIZE: res = verifySizeSignature(ts, result); break; case RPMSIGTAG_MD5: res = verifyMD5Signature(ts, result, dig->md5ctx); break; case RPMSIGTAG_SHA1: res = verifySHA1Signature(ts, result, dig->hdrsha1ctx); break; case RPMSIGTAG_RSA: res = verifyRSASignature(ts, result, dig->hdrmd5ctx); break; case RPMSIGTAG_PGP5: /* XXX legacy */ case RPMSIGTAG_PGP: res = verifyRSASignature(ts, result, ((dig->signature.hash_algo == PGPHASHALGO_MD5) ? dig->md5ctx : dig->sha1ctx)); break; case RPMSIGTAG_DSA: res = verifyDSASignature(ts, result, dig->hdrsha1ctx); break; case RPMSIGTAG_GPG: res = verifyDSASignature(ts, result, dig->sha1ctx); break; case RPMSIGTAG_LEMD5_1: case RPMSIGTAG_LEMD5_2: rasprintf(result, _("Broken MD5 digest: UNSUPPORTED\n")); res = RPMRC_NOTFOUND; break; default: rasprintf(result, _("Signature: UNKNOWN (%d)\n"), sigtag); res = RPMRC_NOTFOUND; break; } return res; }