diff options
Diffstat (limited to 'pki/base/common/src/com/netscape/cmscore/request/RequestRepository.java')
-rw-r--r-- | pki/base/common/src/com/netscape/cmscore/request/RequestRepository.java | 148 |
1 files changed, 148 insertions, 0 deletions
diff --git a/pki/base/common/src/com/netscape/cmscore/request/RequestRepository.java b/pki/base/common/src/com/netscape/cmscore/request/RequestRepository.java new file mode 100644 index 000000000..bb1f27bab --- /dev/null +++ b/pki/base/common/src/com/netscape/cmscore/request/RequestRepository.java @@ -0,0 +1,148 @@ +// --- BEGIN COPYRIGHT BLOCK --- +// This program is free software; you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation; version 2 of the License. +// +// This program 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 General Public License for more details. +// +// You should have received a copy of the GNU General Public License along +// with this program; if not, write to the Free Software Foundation, Inc., +// 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. +// +// (C) 2007 Red Hat, Inc. +// All rights reserved. +// --- END COPYRIGHT BLOCK --- +package com.netscape.cmscore.request; + +import java.util.*; +import java.io.*; +import java.math.*; +import com.netscape.certsrv.dbs.EDBException; +import com.netscape.certsrv.dbs.IDBSubsystem; +import com.netscape.certsrv.dbs.*; +import com.netscape.certsrv.request.*; +import com.netscape.certsrv.base.*; +import com.netscape.certsrv.apps.*; +import com.netscape.cmscore.dbs.*; + + +/** + * TODO: what does this class provide beyond the Repository + * base class?? + * <p> + * @author thayes + * @version $Revision: 14561 $ $Date: 2007-05-01 10:28:56 -0700 (Tue, 01 May 2007) $ + */ +class RequestRepository + extends Repository { + + IDBSubsystem mDB = null; + IRequestQueue mRequestQueue = null; + /** + * Create a request repository that uses the LDAP database + * <p> + * @param name + * the name of the repository. This String is used to + * construct the DN for the repository's LDAP entry. + * @param db + * the LDAP database system. + */ + public RequestRepository(String name, int increment, IDBSubsystem db) + throws EDBException { + super(db, increment, "ou=" + name + ",ou=requests," + db.getBaseDN()); + + CMS.debug("RequestRepository: constructor 1"); + mBaseDN = "ou=" + name + ",ou=requests," + db.getBaseDN(); + + // Let RequestRecord class register its + // database mapping and object mapping values + RequestRecord.register(db); + mDB = db; + } + + public RequestRepository(String name, int increment, IDBSubsystem db,IRequestQueue requestQueue) + throws EDBException { + super(db, increment, "ou=" + name + ",ou=requests," + db.getBaseDN()); + + CMS.debug("RequestRepository: constructor2."); + mRequestQueue = requestQueue; + mBaseDN = "ou=" + name + ",ou=requests," + db.getBaseDN(); + + // Let RequestRecord class register its + // database mapping and object mapping values + RequestRecord.register(db); + mDB = db; + } + + /** + * get the LDAP base DN for this repository. This + * value can be used by the request queue to create the + * name for the request records themselves. + * <p> + * @return + * the LDAP base DN. + */ + public String getBaseDN() { + return mBaseDN; + } + + /** + * Resets serial number. + */ + public void resetSerialNumber(BigInteger serial) throws EBaseException + { + setTheSerialNumber(serial); + } + + /** + * Removes all objects with this repository. + */ + public void removeAllObjects() throws EBaseException + { + IDBSSession s = mDB.createSession(); + try { + Enumeration e = s.search(getBaseDN(), + "(" + RequestRecord.ATTR_REQUEST_ID + "=*)"); + while (e.hasMoreElements()) { + RequestRecord r = (RequestRecord)e.nextElement(); + String name = "cn" + "=" + + r.getRequestId().toString() + "," + getBaseDN(); + s.delete(name); + } + } finally { + if (s != null) + s.close(); + } + } + + public BigInteger getLastSerialNumberInRange(BigInteger min, BigInteger max) + { + + CMS.debug("RequestRepository: in getLastSerialNumberInRange: min " + min + " max " + max); + + CMS.debug("RequestRepository: mRequestQueue " + mRequestQueue); + + BigInteger ret = null; + + if(mRequestQueue == null) { + + CMS.debug("RequestRepository: mRequestQueue is null."); + + } else { + + CMS.debug("RequestRepository: about to call mRequestQueue.getLastRequestIdInRange"); + ret = mRequestQueue.getLastRequestIdInRange(min,max); + + } + + return ret; + + } + /** + * the LDAP base DN for this repository + */ + protected String mBaseDN; +} |