class org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback extends java.lang.Object implements org.apache.nifi.processor.io.StreamCallback
{
private java.lang.String algorithm;
private java.lang.Integer cipher;
private java.lang.String provider;
private java.lang.String publicKeyring;
private java.lang.String userId;
private java.lang.String filename;
void <init>(java.lang.String, java.lang.Integer, java.lang.String, java.lang.String, java.lang.String, java.lang.String)
{
org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback v;
java.lang.String v, v, v, v, v;
java.lang.Integer v;
v := @this: org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Integer;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback: java.lang.String algorithm> = v;
v.<org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback: java.lang.Integer cipher> = v;
v.<org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback: java.lang.String provider> = v;
v.<org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback: java.lang.String publicKeyring> = v;
v.<org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback: java.lang.String userId> = v;
v.<org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback: java.lang.String filename> = v;
return;
}
public void process(java.io.InputStream, java.io.OutputStream) throws java.io.IOException
{
byte[] v, v, v, v;
java.util.Date v;
org.bouncycastle.openpgp.operator.jcajce.JcePGPDataEncryptorBuilder v, v, v, v;
java.lang.Integer v;
java.security.SecureRandom v;
boolean v;
org.bouncycastle.openpgp.PGPCompressedDataGenerator v;
org.bouncycastle.openpgp.PGPPublicKey v;
java.lang.Exception v, v;
java.lang.Throwable v, v, v, v;
org.apache.nifi.processor.exception.ProcessException v, v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
java.io.OutputStream v, v, v, v;
org.bouncycastle.openpgp.operator.jcajce.JcePublicKeyKeyEncryptionMethodGenerator v, v;
org.bouncycastle.openpgp.PGPLiteralDataGenerator v;
org.bouncycastle.bcpg.ArmoredOutputStream v;
org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback v;
org.bouncycastle.openpgp.PGPEncryptedDataGenerator v;
java.lang.Object v;
java.io.InputStream v;
v := @this: org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback;
v := @parameter: java.io.InputStream;
v := @parameter: java.io.OutputStream;
v = v.<org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback: java.lang.String algorithm>;
v = staticinvoke <org.apache.nifi.processors.standard.EncryptContent: boolean isPGPArmoredAlgorithm(java.lang.String)>(v);
label:
v = v.<org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback: java.lang.String userId>;
v = v.<org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback: java.lang.String publicKeyring>;
v = staticinvoke <org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor: org.bouncycastle.openpgp.PGPPublicKey getPublicKey(java.lang.String,java.lang.String)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.nifi.processor.exception.ProcessException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Invalid public keyring - \u0001");
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v;
if v == 0 goto label;
v = new org.bouncycastle.bcpg.ArmoredOutputStream;
specialinvoke v.<org.bouncycastle.bcpg.ArmoredOutputStream: void <init>(java.io.OutputStream)>(v);
v = v;
label:
v = new org.bouncycastle.openpgp.PGPEncryptedDataGenerator;
v = new org.bouncycastle.openpgp.operator.jcajce.JcePGPDataEncryptorBuilder;
v = v.<org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback: java.lang.Integer cipher>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
specialinvoke v.<org.bouncycastle.openpgp.operator.jcajce.JcePGPDataEncryptorBuilder: void <init>(int)>(v);
v = virtualinvoke v.<org.bouncycastle.openpgp.operator.jcajce.JcePGPDataEncryptorBuilder: org.bouncycastle.openpgp.operator.jcajce.JcePGPDataEncryptorBuilder setWithIntegrityPacket(boolean)>(1);
v = new java.security.SecureRandom;
specialinvoke v.<java.security.SecureRandom: void <init>()>();
v = virtualinvoke v.<org.bouncycastle.openpgp.operator.jcajce.JcePGPDataEncryptorBuilder: org.bouncycastle.openpgp.operator.jcajce.JcePGPDataEncryptorBuilder setSecureRandom(java.security.SecureRandom)>(v);
v = v.<org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback: java.lang.String provider>;
v = virtualinvoke v.<org.bouncycastle.openpgp.operator.jcajce.JcePGPDataEncryptorBuilder: org.bouncycastle.openpgp.operator.jcajce.JcePGPDataEncryptorBuilder setProvider(java.lang.String)>(v);
specialinvoke v.<org.bouncycastle.openpgp.PGPEncryptedDataGenerator: void <init>(org.bouncycastle.openpgp.operator.PGPDataEncryptorBuilder)>(v);
v = new org.bouncycastle.openpgp.operator.jcajce.JcePublicKeyKeyEncryptionMethodGenerator;
specialinvoke v.<org.bouncycastle.openpgp.operator.jcajce.JcePublicKeyKeyEncryptionMethodGenerator: void <init>(org.bouncycastle.openpgp.PGPPublicKey)>(v);
v = v.<org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback: java.lang.String provider>;
v = virtualinvoke v.<org.bouncycastle.openpgp.operator.jcajce.JcePublicKeyKeyEncryptionMethodGenerator: org.bouncycastle.openpgp.operator.jcajce.JcePublicKeyKeyEncryptionMethodGenerator setProvider(java.lang.String)>(v);
virtualinvoke v.<org.bouncycastle.openpgp.PGPEncryptedDataGenerator: void addMethod(org.bouncycastle.openpgp.operator.PGPKeyEncryptionMethodGenerator)>(v);
v = newarray (byte)[65536];
v = virtualinvoke v.<org.bouncycastle.openpgp.PGPEncryptedDataGenerator: java.io.OutputStream open(java.io.OutputStream,byte[])>(v, v);
label:
v = new org.bouncycastle.openpgp.PGPCompressedDataGenerator;
specialinvoke v.<org.bouncycastle.openpgp.PGPCompressedDataGenerator: void <init>(int,int)>(1, 1);
v = newarray (byte)[65536];
v = virtualinvoke v.<org.bouncycastle.openpgp.PGPCompressedDataGenerator: java.io.OutputStream open(java.io.OutputStream,byte[])>(v, v);
label:
v = new org.bouncycastle.openpgp.PGPLiteralDataGenerator;
specialinvoke v.<org.bouncycastle.openpgp.PGPLiteralDataGenerator: void <init>()>();
v = v.<org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor$OpenPGPEncryptCallback: java.lang.String filename>;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v = newarray (byte)[65536];
v = virtualinvoke v.<org.bouncycastle.openpgp.PGPLiteralDataGenerator: java.io.OutputStream open(java.io.OutputStream,char,java.lang.String,java.util.Date,byte[])>(v, 98, v, v, v);
label:
v = newarray (byte)[4096];
label:
v = virtualinvoke v.<java.io.InputStream: int read(byte[])>(v);
if v < 0 goto label;
virtualinvoke v.<java.io.OutputStream: void write(byte[],int,int)>(v, 0, v);
goto label;
label:
if v == null goto label;
virtualinvoke v.<java.io.OutputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
if v == null goto label;
virtualinvoke v.<java.io.OutputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
if v == null goto label;
virtualinvoke v.<java.io.OutputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
if v == 0 goto label;
virtualinvoke v.<java.io.OutputStream: void close()>();
goto label;
label:
v := @caughtexception;
if v == 0 goto label;
virtualinvoke v.<java.io.OutputStream: void close()>();
label:
throw v;
label:
v := @caughtexception;
v = new org.apache.nifi.processor.exception.ProcessException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
}
}