blob: 41d644805f462928a3669e8f2c04828ef6a48d4c (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
|
package org.bouncycastle.jce.provider;
import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.security.cert.CertificateParsingException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import org.bouncycastle.asn1.ASN1InputStream;
import org.bouncycastle.asn1.ASN1Sequence;
import org.bouncycastle.asn1.x509.CertificatePair;
import org.bouncycastle.x509.X509CertificatePair;
import org.bouncycastle.x509.X509StreamParserSpi;
import org.bouncycastle.x509.util.StreamParsingException;
public class X509CertPairParser
extends X509StreamParserSpi
{
private InputStream currentStream = null;
private X509CertificatePair readDERCrossCertificatePair(
InputStream in)
throws IOException, CertificateParsingException
{
ASN1InputStream dIn = new ASN1InputStream(in);
ASN1Sequence seq = (ASN1Sequence)dIn.readObject();
CertificatePair pair = CertificatePair.getInstance(seq);
return new X509CertificatePair(pair);
}
public void engineInit(InputStream in)
{
currentStream = in;
if (!currentStream.markSupported())
{
currentStream = new BufferedInputStream(currentStream);
}
}
public Object engineRead() throws StreamParsingException
{
try
{
currentStream.mark(10);
int tag = currentStream.read();
if (tag == -1)
{
return null;
}
currentStream.reset();
return readDERCrossCertificatePair(currentStream);
}
catch (Exception e)
{
throw new StreamParsingException(e.toString(), e);
}
}
public Collection engineReadAll() throws StreamParsingException
{
X509CertificatePair pair;
List certs = new ArrayList();
while ((pair = (X509CertificatePair)engineRead()) != null)
{
certs.add(pair);
}
return certs;
}
}
|