1 files changed, 131 insertions, 0 deletions
diff --git a/core/src/main/j2me/org/spongycastle/crypto/tls/OCSPStatusRequest.java b/core/src/main/j2me/org/spongycastle/crypto/tls/OCSPStatusRequest.java
new file mode 100644
index 00000000..ea68af90
--- /dev/null
+++ b/core/src/main/j2me/org/spongycastle/crypto/tls/OCSPStatusRequest.java
@@ -0,0 +1,131 @@
+package org.spongycastle.crypto.tls;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.util.Vector;
+
+import org.spongycastle.asn1.ASN1Encoding;
+import org.spongycastle.asn1.ocsp.ResponderID;
+import org.spongycastle.asn1.x509.Extensions;
+
+/**
+ * RFC 3546 3.6
+ */
+public class OCSPStatusRequest
+{
+    protected Vector responderIDList;
+    protected Extensions requestExtensions;
+
+    /**
+     * @param responderIDList
+     *            a {@link Vector} of {@link ResponderID}, specifying the list of trusted OCSP
+     *            responders. An empty list has the special meaning that the responders are
+     *            implicitly known to the server - e.g., by prior arrangement.
+     * @param requestExtensions
+     *            OCSP request extensions. A null value means that there are no extensions.
+     */
+    public OCSPStatusRequest(Vector responderIDList, Extensions requestExtensions)
+    {
+        this.responderIDList = responderIDList;
+        this.requestExtensions = requestExtensions;
+    }
+
+    /**
+     * @return a {@link Vector} of {@link ResponderID}
+     */
+    public Vector getResponderIDList()
+    {
+        return responderIDList;
+    }
+
+    /**
+     * @return OCSP request extensions
+     */
+    public Extensions getRequestExtensions()
+    {
+        return requestExtensions;
+    }
+
+    /**
+     * Encode this {@link OCSPStatusRequest} to an {@link OutputStream}.
+     * 
+     * @param output
+     *            the {@link OutputStream} to encode to.
+     * @throws IOException
+     */
+    public void encode(OutputStream output) throws IOException
+    {
+        if (responderIDList == null || responderIDList.isEmpty())
+        {
+            TlsUtils.writeUint16(0, output);
+        }
+        else
+        {
+            ByteArrayOutputStream buf = new ByteArrayOutputStream();
+            for (int i = 0; i < responderIDList.size(); ++i)
+            {
+                ResponderID responderID = (ResponderID) responderIDList.elementAt(i);
+                byte[] derEncoding = responderID.getEncoded(ASN1Encoding.DER);
+                TlsUtils.writeOpaque16(derEncoding, buf);
+            }
+            TlsUtils.checkUint16(buf.size());
+            TlsUtils.writeUint16(buf.size(), output);
+            output.write(buf.toByteArray());
+        }
+
+        if (requestExtensions == null)
+        {
+            TlsUtils.writeUint16(0, output);
+        }
+        else
+        {
+            byte[] derEncoding = requestExtensions.getEncoded(ASN1Encoding.DER);
+            TlsUtils.checkUint16(derEncoding.length);
+            TlsUtils.writeUint16(derEncoding.length, output);
+            output.write(derEncoding);
+        }
+    }
+
+    /**
+     * Parse an {@link OCSPStatusRequest} from an {@link InputStream}.
+     * 
+     * @param input
+     *            the {@link InputStream} to parse from.
+     * @return an {@link OCSPStatusRequest} object.
+     * @throws IOException
+     */
+    public static OCSPStatusRequest parse(InputStream input) throws IOException
+    {
+        Vector responderIDList = new Vector();
+        {
+            int length = TlsUtils.readUint16(input);
+            if (length > 0)
+            {
+                byte[] data = TlsUtils.readFully(length, input);
+                ByteArrayInputStream buf = new ByteArrayInputStream(data);
+                do
+                {
+                    byte[] derEncoding = TlsUtils.readOpaque16(buf);
+                    ResponderID responderID = ResponderID.getInstance(TlsUtils.readDERObject(derEncoding));
+                    responderIDList.addElement(responderID);
+                }
+                while (buf.available() > 0);
+            }
+        }
+
+        Extensions requestExtensions = null;
+        {
+            int length = TlsUtils.readUint16(input);
+            if (length > 0)
+            {
+                byte[] derEncoding = TlsUtils.readFully(length, input);
+                requestExtensions = Extensions.getInstance(TlsUtils.readDERObject(derEncoding));
+            }
+        }
+
+        return new OCSPStatusRequest(responderIDList, requestExtensions);
+    }
+}