59 lines
2.2 KiB
Java
59 lines
2.2 KiB
Java
|
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 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;
|
||
|
|
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public class X509CertPairParser extends X509StreamParserSpi {
|
||
|
|
private InputStream currentStream = null;
|
||
|
|
|
||
|
|
@Override // org.bouncycastle.x509.X509StreamParserSpi
|
||
|
|
public Collection engineReadAll() throws StreamParsingException {
|
||
|
|
ArrayList arrayList = new ArrayList();
|
||
|
|
while (true) {
|
||
|
|
X509CertificatePair x509CertificatePair = (X509CertificatePair) engineRead();
|
||
|
|
if (x509CertificatePair == null) {
|
||
|
|
return arrayList;
|
||
|
|
}
|
||
|
|
arrayList.add(x509CertificatePair);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // org.bouncycastle.x509.X509StreamParserSpi
|
||
|
|
public Object engineRead() throws StreamParsingException {
|
||
|
|
try {
|
||
|
|
this.currentStream.mark(10);
|
||
|
|
if (this.currentStream.read() == -1) {
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
this.currentStream.reset();
|
||
|
|
return readDERCrossCertificatePair(this.currentStream);
|
||
|
|
} catch (Exception e) {
|
||
|
|
throw new StreamParsingException(e.toString(), e);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // org.bouncycastle.x509.X509StreamParserSpi
|
||
|
|
public void engineInit(InputStream inputStream) {
|
||
|
|
this.currentStream = inputStream;
|
||
|
|
if (inputStream.markSupported()) {
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
this.currentStream = new BufferedInputStream(this.currentStream);
|
||
|
|
}
|
||
|
|
|
||
|
|
private X509CertificatePair readDERCrossCertificatePair(InputStream inputStream) throws IOException, CertificateParsingException {
|
||
|
|
return new X509CertificatePair(CertificatePair.getInstance((ASN1Sequence) new ASN1InputStream(inputStream).readObject()));
|
||
|
|
}
|
||
|
|
}
|