Commit f85b68cd authored by Richard Levitte's avatar Richard Levitte
Browse files

Make it possible to have multiple active certificates with the same 

subject.
parent 5679bcce

CHANGES

+8 −0
Original line number Diff line number Diff line
@@ -4,6 +4,14 @@ 


 Changes between 0.9.7a and 0.9.8  [xx XXX xxxx]



  *) Make it possible to have multiple active certificates with the same

     subject in the CA index file.  This is done only if the keyword

     'unique_subject' is set to 'no' in the main CA section (default

     if 'CA_default') of the configuration file.  The value is saved

     with the database itself in a separate index attribute file,

     named like the index file with '.attr' appended to the name.

     [Richard Levitte]



  *) Generate muti valued AVAs using '+' notation in config files for

     req and dirName.

     [Steve Henson]

apps/apps.c

+442 −0
Original line number Diff line number Diff line
@@ -1422,3 +1422,445 @@ char *make_config_name() 


	return p;

	}



static unsigned long index_serial_hash(const char **a)

	{

	const char *n;



	n=a[DB_serial];

	while (*n == '0') n++;

	return(lh_strhash(n));

	}



static int index_serial_cmp(const char **a, const char **b)

	{

	const char *aa,*bb;



	for (aa=a[DB_serial]; *aa == '0'; aa++);

	for (bb=b[DB_serial]; *bb == '0'; bb++);

	return(strcmp(aa,bb));

	}



static int index_name_qual(char **a)

	{ return(a[0][0] == 'V'); }



static unsigned long index_name_hash(const char **a)

	{ return(lh_strhash(a[DB_name])); }



int index_name_cmp(const char **a, const char **b)

	{ return(strcmp(a[DB_name],

	     b[DB_name])); }



static IMPLEMENT_LHASH_HASH_FN(index_serial_hash,const char **)

static IMPLEMENT_LHASH_COMP_FN(index_serial_cmp,const char **)

static IMPLEMENT_LHASH_HASH_FN(index_name_hash,const char **)

static IMPLEMENT_LHASH_COMP_FN(index_name_cmp,const char **)



#undef BSIZE

#define BSIZE 256



BIGNUM *load_serial(char *serialfile, int create, ASN1_INTEGER **retai)

	{

	BIO *in=NULL;

	BIGNUM *ret=NULL;

	MS_STATIC char buf[1024];

	ASN1_INTEGER *ai=NULL;



	ai=ASN1_INTEGER_new();

	if (ai == NULL) goto err;



	if ((in=BIO_new(BIO_s_file())) == NULL)

		{

		ERR_print_errors(bio_err);

		goto err;

		}



	if (BIO_read_filename(in,serialfile) <= 0)

		{

		if (!create)

			{

			perror(serialfile);

			goto err;

			}

		else

			{

			ASN1_INTEGER_set(ai,1);

			ret=BN_new();

			if (ret == NULL)

				BIO_printf(bio_err, "Out of memory\n");

			else

				BN_one(ret);

			}

		}

	else

		{

		if (!a2i_ASN1_INTEGER(in,ai,buf,1024))

			{

			BIO_printf(bio_err,"unable to load number from %s\n",

				serialfile);

			goto err;

			}

		ret=ASN1_INTEGER_to_BN(ai,NULL);

		if (ret == NULL)

			{

			BIO_printf(bio_err,"error converting number from bin to BIGNUM\n");

			goto err;

			}

		}



	if (ret && retai)

		{

		*retai = ai;

		ai = NULL;

		}

 err:

	if (in != NULL) BIO_free(in);

	if (ai != NULL) ASN1_INTEGER_free(ai);

	return(ret);

	}



int save_serial(char *serialfile, BIGNUM *serial, ASN1_INTEGER **retai)

	{

	BIO *out;

	int ret=0;

	ASN1_INTEGER *ai=NULL;



	out=BIO_new(BIO_s_file());

	if (out == NULL)

		{

		ERR_print_errors(bio_err);

		goto err;

		}

	if (BIO_write_filename(out,serialfile) <= 0)

		{

		perror(serialfile);

		goto err;

		}



	if ((ai=BN_to_ASN1_INTEGER(serial,NULL)) == NULL)

		{

		BIO_printf(bio_err,"error converting serial to ASN.1 format\n");

		goto err;

		}

	i2a_ASN1_INTEGER(out,ai);

	BIO_puts(out,"\n");

	ret=1;

	if (retai)

		{

		*retai = ai;

		ai = NULL;

		}

err:

	if (out != NULL) BIO_free_all(out);

	if (ai != NULL) ASN1_INTEGER_free(ai);

	return(ret);

	}



CA_DB *load_index(char *dbfile, DB_ATTR *db_attr)

	{

	CA_DB *retdb = NULL;

	TXT_DB *tmpdb = NULL;

	BIO *in = BIO_new(BIO_s_file());

	CONF *dbattr_conf = NULL;

	char buf[1][BSIZE];

	long errorline= -1;



	if (in == NULL)

		{

		ERR_print_errors(bio_err);

		goto err;

		}

	if (BIO_read_filename(in,dbfile) <= 0)

		{

		perror(dbfile);

		BIO_printf(bio_err,"unable to open '%s'\n",dbfile);

		goto err;

		}

	if ((tmpdb = TXT_DB_read(in,DB_NUMBER)) == NULL)

		{

		if (tmpdb != NULL) TXT_DB_free(tmpdb);

		goto err;

		}



#ifndef OPENSSL_SYS_VMS

	BIO_snprintf(buf[0], sizeof buf[0], "%s.attr", dbfile);

#else

	BIO_snprintf(buf[0], sizeof buf[0], "%s-attr", dbfile);

#endif

	dbattr_conf = NCONF_new(NULL);

	if (NCONF_load(dbattr_conf,buf[0],&errorline) <= 0)

		{

		if (errorline > 0)

			{

			BIO_printf(bio_err,

				"error on line %ld of db attribute file '%s'\n"

				,errorline,buf[0]);

			goto err;

			}

		else

			{

			NCONF_free(dbattr_conf);

			dbattr_conf = NULL;

			}

		}



	if ((retdb = OPENSSL_malloc(sizeof(CA_DB))) == NULL)

		{

		fprintf(stderr, "Out of memory\n");

		goto err;

		}



	retdb->db = tmpdb;

	tmpdb = NULL;

	if (db_attr)

		retdb->attributes = *db_attr;

	else

		{

		retdb->attributes.unique_subject = 1;

		}



	if (dbattr_conf)

		{

		char *p = NCONF_get_string(dbattr_conf,NULL,"unique_subject");

		if (p)

			{

			BIO_printf(bio_err, "DEBUG[load_index]: unique_subject = \"%s\"\n", p);

			switch(*p)

				{

			case 'f': /* false */

			case 'F': /* FALSE */

			case 'n': /* no */

			case 'N': /* NO */

				retdb->attributes.unique_subject = 0;

				break;

			case 't': /* true */

			case 'T': /* TRUE */

			case 'y': /* yes */

			case 'Y': /* YES */

			default:

				retdb->attributes.unique_subject = 1;

				break;

				}

			}

		}



 err:

	if (dbattr_conf) NCONF_free(dbattr_conf);

	if (tmpdb) TXT_DB_free(tmpdb);

	if (in) BIO_free_all(in);

	return retdb;

	}



int index_index(CA_DB *db)

	{

	if (!TXT_DB_create_index(db->db, DB_serial, NULL,

				LHASH_HASH_FN(index_serial_hash),

				LHASH_COMP_FN(index_serial_cmp)))

		{

		BIO_printf(bio_err,

		  "error creating serial number index:(%ld,%ld,%ld)\n",

		  			db->db->error,db->db->arg1,db->db->arg2);

			return 0;

		}



	if (db->attributes.unique_subject

		&& !TXT_DB_create_index(db->db, DB_name, index_name_qual,

			LHASH_HASH_FN(index_name_hash),

			LHASH_COMP_FN(index_name_cmp)))

		{

		BIO_printf(bio_err,"error creating name index:(%ld,%ld,%ld)\n",

			db->db->error,db->db->arg1,db->db->arg2);

		return 0;

		}

	return 1;

	}



int save_index(char *dbfile, char *suffix, CA_DB *db)

	{

	char buf[3][BSIZE];

	BIO *out = BIO_new(BIO_s_file());

	int j;



	if (out == NULL)

		{

		ERR_print_errors(bio_err);

		goto err;

		}



	j = strlen(dbfile) + strlen(suffix);

	if (j + 6 >= BSIZE)

		{

		BIO_printf(bio_err,"file name too long\n");

		goto err;

		}



#ifndef OPENSSL_SYS_VMS

	j = BIO_snprintf(buf[2], sizeof buf[2], "%s.attr", dbfile);

#else

	j = BIO_snprintf(buf[2], sizeof buf[2], "%s-attr", dbfile);

#endif

#ifndef OPENSSL_SYS_VMS

	j = BIO_snprintf(buf[1], sizeof buf[1], "%s.attr.%s", dbfile, suffix);

#else

	j = BIO_snprintf(buf[1], sizeof buf[1], "%s-attr-%s", dbfile, suffix);

#endif

#ifndef OPENSSL_SYS_VMS

	j = BIO_snprintf(buf[0], sizeof buf[0], "%s.%s", dbfile, suffix);

#else

	j = BIO_snprintf(buf[0], sizeof buf[0], "%s-%s", dbfile, suffix);

#endif

	BIO_printf(bio_err, "DEBUG: writing \"%s\"\n", buf[0]);

	if (BIO_write_filename(out,buf[0]) <= 0)

		{

		perror(dbfile);

		BIO_printf(bio_err,"unable to open '%s'\n", dbfile);

		goto err;

		}

	j=TXT_DB_write(out,db->db);

	if (j <= 0) goto err;

			

	BIO_free(out);



	out = BIO_new(BIO_s_file());

	BIO_printf(bio_err, "DEBUG: writing \"%s\"\n", buf[1]);

	if (BIO_write_filename(out,buf[1]) <= 0)

		{

		perror(buf[2]);

		BIO_printf(bio_err,"unable to open '%s'\n", buf[2]);

		goto err;

		}

	BIO_printf(out,"unique_subject = %s\n",

		db->attributes.unique_subject ? "yes" : "no");

	BIO_free(out);



	return 1;

 err:

	return 0;

	}



int rotate_index(char *dbfile, char *new_suffix, char *old_suffix)

	{

	char buf[5][BSIZE];

	int i,j;

	struct stat sb;



	i = strlen(dbfile) + strlen(old_suffix);

	j = strlen(dbfile) + strlen(new_suffix);

	if (i > j) j = i;

	if (j + 6 >= BSIZE)

		{

		BIO_printf(bio_err,"file name too long\n");

		goto err;

		}



#ifndef OPENSSL_SYS_VMS

	j = BIO_snprintf(buf[4], sizeof buf[4], "%s.attr", dbfile);

#else

	j = BIO_snprintf(buf[4], sizeof buf[4], "%s-attr", dbfile);

#endif

#ifndef OPENSSL_SYS_VMS

	j = BIO_snprintf(buf[2], sizeof buf[2], "%s.attr.%s",

		dbfile, new_suffix);

#else

	j = BIO_snprintf(buf[2], sizeof buf[2], "%s-attr-%s",

		dbfile, new_suffix);

#endif

#ifndef OPENSSL_SYS_VMS

	j = BIO_snprintf(buf[0], sizeof buf[0], "%s.%s",

		dbfile, new_suffix);

#else

	j = BIO_snprintf(buf[0], sizeof buf[0], "%s-%s",

		dbfile, new_suffix);

#endif

#ifndef OPENSSL_SYS_VMS

	j = BIO_snprintf(buf[1], sizeof buf[1], "%s.%s",

		dbfile, old_suffix);

#else

	j = BIO_snprintf(buf[1], sizeof buf[1], "%s-%s",

		dbfile, old_suffix);

#endif

#ifndef OPENSSL_SYS_VMS

	j = BIO_snprintf(buf[3], sizeof buf[3], "%s.attr.%s",

		dbfile, old_suffix);

#else

	j = BIO_snprintf(buf[3], sizeof buf[3], "%s-attr-%s",

		dbfile, old_suffix);

#endif

	if (stat(dbfile,&sb) < 0)

		{

		if (errno != ENOENT 

#ifdef ENOTDIR

			&& errno != ENOTDIR)

#endif

			goto err;

		}

	else

		{

		BIO_printf(bio_err, "DEBUG: renaming \"%s\" to \"%s\"\n",

			dbfile, buf[1]);

		if (rename(dbfile,buf[1]) < 0)

			{

			BIO_printf(bio_err,

				"unable to rename %s to %s\n",

				dbfile, buf[1]);

			perror("reason");

			goto err;

			}

		}

	BIO_printf(bio_err, "DEBUG: renaming \"%s\" to \"%s\"\n",

		buf[0],dbfile);

	if (rename(buf[0],dbfile) < 0)

		{

		BIO_printf(bio_err,

			"unable to rename %s to %s\n",

			buf[0],dbfile);

		perror("reason");

		rename(buf[1],dbfile);

		goto err;

		}

	if (stat(buf[4],&sb) < 0)

		{

		if (errno != ENOENT 

#ifdef ENOTDIR

			&& errno != ENOTDIR)

#endif

			goto err;

		}

	else

		{

		BIO_printf(bio_err, "DEBUG: renaming \"%s\" to \"%s\"\n",

			buf[4],buf[3]);

		if (rename(buf[4],buf[3]) < 0)

			{

			BIO_printf(bio_err,

				"unable to rename %s to %s\n",

				buf[4], buf[3]);

			perror("reason");

			rename(dbfile,buf[0]);

			rename(buf[1],dbfile);

			goto err;

			}

		}

	BIO_printf(bio_err, "DEBUG: renaming \"%s\" to \"%s\"\n",

		buf[2],buf[4]);

	if (rename(buf[2],buf[4]) < 0)

		{

		BIO_printf(bio_err,

			"unable to rename %s to %s\n",

			buf[2],buf[4]);

		perror("reason");

		rename(buf[3],buf[4]);

		rename(dbfile,buf[0]);

		rename(buf[1],dbfile);

		goto err;

		}

	return 1;

 err:

	return 0;

	}



void free_index(CA_DB *db)

	{

	TXT_DB_free(db->db);

	OPENSSL_free(db);

	}

apps/apps.h

+31 −1
Original line number Diff line number Diff line
@@ -287,7 +287,37 @@ char *make_config_name(void); 
/* Functions defined in ca.c and also used in ocsp.c */

int unpack_revinfo(ASN1_TIME **prevtm, int *preason, ASN1_OBJECT **phold,

			ASN1_GENERALIZEDTIME **pinvtm, char *str);

int make_serial_index(TXT_DB *db);



#define DB_type         0

#define DB_exp_date     1

#define DB_rev_date     2

#define DB_serial       3       /* index - unique */

#define DB_file         4       

#define DB_name         5       /* index - unique when active and not disabled */

#define DB_NUMBER       6



#define DB_TYPE_REV	'R'

#define DB_TYPE_EXP	'E'

#define DB_TYPE_VAL	'V'



typedef struct db_attr_st

	{

	int unique_subject;

	} DB_ATTR;

typedef struct ca_db_st

	{

	DB_ATTR attributes;

	TXT_DB *db;

	} CA_DB;



BIGNUM *load_serial(char *serialfile, int create, ASN1_INTEGER **retai);

int save_serial(char *serialfile, BIGNUM *serial, ASN1_INTEGER **retai);

CA_DB *load_index(char *dbfile, DB_ATTR *dbattr);

int index_index(CA_DB *db);

int save_index(char *dbfile, char *suffix, CA_DB *db);

int rotate_index(char *dbfile, char *new_suffix, char *old_suffix);

void free_index(CA_DB *db);

int index_name_cmp(const char **a, const char **b);



X509_NAME *do_subject(char *str, long chtype);

apps/ca.c

+84 −341

File changed.

Preview size limit exceeded, changes collapsed.

apps/ocsp.c

+10 −36
Original line number Diff line number Diff line
@@ -68,19 +68,6 @@ 
/* Maximum leeway in validity period: default 5 minutes */

#define MAX_VALIDITY_PERIOD	(5 * 60)



/* CA index.txt definitions */

#define DB_type         0

#define DB_exp_date     1

#define DB_rev_date     2

#define DB_serial       3       /* index - unique */

#define DB_file         4       

#define DB_name         5       /* index - unique for active */

#define DB_NUMBER       6



#define DB_TYPE_REV	'R'

#define DB_TYPE_EXP	'E'

#define DB_TYPE_VAL	'V'



static int add_ocsp_cert(OCSP_REQUEST **req, X509 *cert, X509 *issuer,

				STACK_OF(OCSP_CERTID) *ids);

static int add_ocsp_serial(OCSP_REQUEST **req, char *serial, X509 *issuer,
@@ -89,12 +76,12 @@ static int print_ocsp_summary(BIO *out, OCSP_BASICRESP *bs, OCSP_REQUEST *req, 
				STACK *names, STACK_OF(OCSP_CERTID) *ids,

				long nsec, long maxage);



static int make_ocsp_response(OCSP_RESPONSE **resp, OCSP_REQUEST *req, TXT_DB *db,

static int make_ocsp_response(OCSP_RESPONSE **resp, OCSP_REQUEST *req, CA_DB *db,

			X509 *ca, X509 *rcert, EVP_PKEY *rkey,

			STACK_OF(X509) *rother, unsigned long flags,

			int nmin, int ndays);



static char **lookup_serial(TXT_DB *db, ASN1_INTEGER *ser);

static char **lookup_serial(CA_DB *db, ASN1_INTEGER *ser);

static BIO *init_responder(char *port);

static int do_responder(OCSP_REQUEST **preq, BIO **pcbio, BIO *acbio, char *port);

static int send_ocsp_response(BIO *cbio, OCSP_RESPONSE *resp);
@@ -142,7 +129,7 @@ int MAIN(int argc, char **argv) 
	X509 *rca_cert = NULL;

	char *ridx_filename = NULL;

	char *rca_filename = NULL;

	TXT_DB *rdb = NULL;

	CA_DB *rdb = NULL;

	int nmin = 0, ndays = -1;



	if (bio_err == NULL) bio_err = BIO_new_fp(stderr, BIO_NOCLOSE);
@@ -697,22 +684,9 @@ int MAIN(int argc, char **argv) 


	if (ridx_filename && !rdb)

		{

		BIO *db_bio = NULL;

		db_bio = BIO_new_file(ridx_filename, "r");

		if (!db_bio)

			{

			BIO_printf(bio_err, "Error opening index file %s\n", ridx_filename);

			goto end;

			}

		rdb = TXT_DB_read(db_bio, DB_NUMBER);

		BIO_free(db_bio);

		if (!rdb)

			{

			BIO_printf(bio_err, "Error reading index file %s\n", ridx_filename);

			goto end;

			}

		if (!make_serial_index(rdb))

			goto end;

		rdb = load_index(ridx_filename, NULL);

		if (!rdb) goto end;

		if (!index_index(rdb)) goto end;

		}



	if (rdb)
@@ -894,7 +868,7 @@ end: 
	X509_free(cert);

	X509_free(rsigner);

	X509_free(rca_cert);

	TXT_DB_free(rdb);

	free_index(rdb);

	BIO_free_all(cbio);

	BIO_free_all(acbio);

	BIO_free(out);
@@ -1036,7 +1010,7 @@ static int print_ocsp_summary(BIO *out, OCSP_BASICRESP *bs, OCSP_REQUEST *req, 
	}





static int make_ocsp_response(OCSP_RESPONSE **resp, OCSP_REQUEST *req, TXT_DB *db,

static int make_ocsp_response(OCSP_RESPONSE **resp, OCSP_REQUEST *req, CA_DB *db,

			X509 *ca, X509 *rcert, EVP_PKEY *rkey,

			STACK_OF(X509) *rother, unsigned long flags,

			int nmin, int ndays)
@@ -1128,7 +1102,7 @@ static int make_ocsp_response(OCSP_RESPONSE **resp, OCSP_REQUEST *req, TXT_DB *d 


	}



static char **lookup_serial(TXT_DB *db, ASN1_INTEGER *ser)

static char **lookup_serial(CA_DB *db, ASN1_INTEGER *ser)

	{

	int i;

	BIGNUM *bn = NULL;
@@ -1141,7 +1115,7 @@ static char **lookup_serial(TXT_DB *db, ASN1_INTEGER *ser) 
		itmp = BN_bn2hex(bn);

	row[DB_serial] = itmp;

	BN_free(bn);

	rrow=TXT_DB_get_by_index(db,DB_serial,row);

	rrow=TXT_DB_get_by_index(db->db,DB_serial,row);

	OPENSSL_free(itmp);

	return rrow;

	}