public class org.apache.nifi.processors.standard.PutEmail extends org.apache.nifi.processor.AbstractProcessor { private static final java.util.regex.Pattern MAIL_PROPERTY_PATTERN; public static final org.apache.nifi.components.PropertyDescriptor SMTP_HOSTNAME; public static final org.apache.nifi.components.PropertyDescriptor SMTP_PORT; public static final org.apache.nifi.components.AllowableValue PASSWORD_BASED_AUTHORIZATION_MODE; public static final org.apache.nifi.components.AllowableValue OAUTH_AUTHORIZATION_MODE; public static final org.apache.nifi.components.PropertyDescriptor AUTHORIZATION_MODE; public static final org.apache.nifi.components.PropertyDescriptor OAUTH2_ACCESS_TOKEN_PROVIDER; public static final org.apache.nifi.components.PropertyDescriptor SMTP_USERNAME; public static final org.apache.nifi.components.PropertyDescriptor SMTP_PASSWORD; public static final org.apache.nifi.components.PropertyDescriptor SMTP_AUTH; public static final org.apache.nifi.components.PropertyDescriptor SMTP_TLS; public static final org.apache.nifi.components.PropertyDescriptor SMTP_SOCKET_FACTORY; public static final org.apache.nifi.components.PropertyDescriptor HEADER_XMAILER; public static final org.apache.nifi.components.PropertyDescriptor ATTRIBUTE_NAME_REGEX; public static final org.apache.nifi.components.PropertyDescriptor CONTENT_TYPE; public static final org.apache.nifi.components.PropertyDescriptor FROM; public static final org.apache.nifi.components.PropertyDescriptor TO; public static final org.apache.nifi.components.PropertyDescriptor CC; public static final org.apache.nifi.components.PropertyDescriptor BCC; public static final org.apache.nifi.components.PropertyDescriptor SUBJECT; public static final org.apache.nifi.components.PropertyDescriptor MESSAGE; public static final org.apache.nifi.components.PropertyDescriptor ATTACH_FILE; public static final org.apache.nifi.components.PropertyDescriptor CONTENT_AS_MESSAGE; public static final org.apache.nifi.components.PropertyDescriptor INCLUDE_ALL_ATTRIBUTES; public static final org.apache.nifi.components.PropertyDescriptor INPUT_CHARACTER_SET; public static final org.apache.nifi.processor.Relationship REL_SUCCESS; public static final org.apache.nifi.processor.Relationship REL_FAILURE; private java.util.List properties; private java.util.Set relationships; private static final java.util.Map propertyToContext; private volatile java.util.regex.Pattern attributeNamePattern; private volatile java.util.Optional oauth2AccessTokenProviderOptional; public static final java.lang.String BODY_SEPARATOR; public void () { org.apache.nifi.processors.standard.PutEmail v; v := @this: org.apache.nifi.processors.standard.PutEmail; specialinvoke v.()>(); v. = null; return; } protected void init(org.apache.nifi.processor.ProcessorInitializationContext) { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.ArrayList v; java.util.HashSet v; org.apache.nifi.processor.Relationship v, v; java.util.Set v; java.util.List v; org.apache.nifi.processors.standard.PutEmail v; org.apache.nifi.processor.ProcessorInitializationContext v; v := @this: org.apache.nifi.processors.standard.PutEmail; v := @parameter: org.apache.nifi.processor.ProcessorInitializationContext; v = new java.util.ArrayList; specialinvoke v.()>(); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = staticinvoke (v); v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = staticinvoke (v); v. = v; return; } public java.util.Set getRelationships() { org.apache.nifi.processors.standard.PutEmail v; java.util.Set v; v := @this: org.apache.nifi.processors.standard.PutEmail; v = v.; return v; } protected java.util.List getSupportedPropertyDescriptors() { org.apache.nifi.processors.standard.PutEmail v; java.util.List v; v := @this: org.apache.nifi.processors.standard.PutEmail; v = v.; return v; } protected org.apache.nifi.components.PropertyDescriptor getSupportedDynamicPropertyDescriptor(java.lang.String) { org.apache.nifi.expression.ExpressionLanguageScope v; org.apache.nifi.processors.standard.PutEmail$DynamicMailPropertyValidator v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v; org.apache.nifi.processors.standard.PutEmail v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.PutEmail; v := @parameter: java.lang.String; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.("SMTP property passed to the Mail Session"); v = virtualinvoke v.(0); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = new org.apache.nifi.processors.standard.PutEmail$DynamicMailPropertyValidator; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext) { org.apache.nifi.components.ValidationContext v; org.apache.nifi.components.PropertyDescriptor v, v, v; java.util.ArrayList v; org.apache.nifi.components.PropertyValue v, v, v; java.lang.String v, v, v; org.apache.nifi.components.ValidationResult v; org.apache.nifi.components.ValidationResult$Builder v, v, v, v; java.util.Collection v; org.apache.nifi.processors.standard.PutEmail v; v := @this: org.apache.nifi.processors.standard.PutEmail; v := @parameter: org.apache.nifi.components.ValidationContext; v = new java.util.ArrayList; v = specialinvoke v.(v); specialinvoke v.(java.util.Collection)>(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != null goto label; if v != null goto label; if v != null goto label; v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = virtualinvoke v.("To, CC, BCC"); v = virtualinvoke v.(0); v = virtualinvoke v.("Must specify at least one To/CC/BCC address"); v = virtualinvoke v.(); interfaceinvoke v.(v); label: return v; } public void onScheduled(org.apache.nifi.processor.ProcessContext) { org.apache.nifi.processor.ProcessContext v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.components.PropertyValue v, v, v; org.apache.nifi.controller.ControllerService v; org.apache.nifi.processors.standard.PutEmail v; java.util.Optional v, v; java.lang.String v; java.util.regex.Pattern v; boolean v; v := @this: org.apache.nifi.processors.standard.PutEmail; v := @parameter: org.apache.nifi.processor.ProcessContext; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != null goto label; v = null; goto label; label: v = staticinvoke (v); label: v. = v; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(class "Lorg/apache/nifi/oauth2/OAuth2AccessTokenProvider;"); interfaceinvoke v.(); v = staticinvoke (v); v. = v; goto label; label: v = staticinvoke (); v. = v; label: return; } private void setMessageHeader(java.lang.String, java.lang.String, jakarta.mail.Message) throws jakarta.mail.MessagingException { java.lang.Object[] v; jakarta.mail.Message v; org.apache.nifi.logging.ComponentLog v; org.apache.nifi.processors.standard.PutEmail v; java.lang.String v, v, v; java.io.UnsupportedEncodingException v; v := @this: org.apache.nifi.processors.standard.PutEmail; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: jakarta.mail.Message; v = virtualinvoke v.(); label: v = staticinvoke (v); virtualinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Unable to add header {} with value {} due to encoding exception", v); label: return; catch java.io.UnsupportedEncodingException from label to label with label; } public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) { byte[] v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v; java.util.regex.Matcher v; java.util.Map v; jakarta.mail.Session v; jakarta.mail.internet.PreencodedMimeBodyPart v; java.util.Set v; jakarta.mail.internet.MimeMultipart v; java.lang.Throwable v; jakarta.mail.Address[] v; java.lang.Object[] v, v, v, v; jakarta.mail.util.ByteArrayDataSource v; org.apache.nifi.provenance.ProvenanceReporter v; org.apache.nifi.processor.Relationship v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Properties v; org.apache.nifi.processor.ProcessSession v; jakarta.mail.internet.InternetAddress[] v, v, v, v; org.apache.nifi.processors.standard.PutEmail v; org.apache.nifi.flowfile.attributes.CoreAttributes v; java.util.Date v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v; jakarta.mail.Message$RecipientType v, v, v; org.apache.nifi.processor.io.InputStreamCallback v; boolean v, v, v, v; org.apache.nifi.flowfile.FlowFile v; java.util.regex.Pattern v, v; jakarta.activation.DataHandler v, v, v, v; org.apache.nifi.logging.ComponentLog v, v; jakarta.mail.internet.MimeMessage v; java.nio.charset.Charset v; java.lang.Boolean v; jakarta.mail.internet.MimeBodyPart v; java.util.Iterator v; org.apache.nifi.processor.ProcessContext v; jakarta.mail.Address v; java.lang.Object v, v, v, v; v := @this: org.apache.nifi.processors.standard.PutEmail; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v = interfaceinvoke v.(); if v != null goto label; return; label: v = specialinvoke v.(v, v); v = specialinvoke v.(v); v = new jakarta.mail.internet.MimeMessage; specialinvoke v.(jakarta.mail.Session)>(v); label: v = ; v = specialinvoke v.(v, v, v); virtualinvoke v.(v); v = ; v = ; v = specialinvoke v.(v, v, v); virtualinvoke v.(v, v); v = ; v = ; v = specialinvoke v.(v, v, v); virtualinvoke v.(v, v); v = ; v = ; v = specialinvoke v.(v, v, v); virtualinvoke v.(v, v); v = v.; if v == null goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); specialinvoke v.(v, v, v); goto label; label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); specialinvoke v.("X-Mailer", v, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); virtualinvoke v.(v); v = specialinvoke v.(v, v, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = specialinvoke v.(v); v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = staticinvoke ("; charset=\"%s\"", v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001\u0001"); virtualinvoke v.(v, v); v = new java.util.Date; specialinvoke v.()>(); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = specialinvoke v.(v); v = new jakarta.mail.internet.PreencodedMimeBodyPart; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); v = "base64"; v = virtualinvoke v.(v); if v == 0 goto label; v = staticinvoke (v); goto label; label: v = v; label: v = new jakarta.activation.DataHandler; v = new jakarta.mail.util.ByteArrayDataSource; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = staticinvoke ("; charset=\"%s\"", v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001\u0001"); specialinvoke v.(byte[],java.lang.String)>(v, v); specialinvoke v.(jakarta.activation.DataSource)>(v); virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("Content-Transfer-Encoding", v); v = new jakarta.mail.internet.MimeBodyPart; specialinvoke v.()>(); v = staticinvoke (v); interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v, v, null); virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("Content-Transfer-Encoding", v); v = new jakarta.mail.internet.MimeMultipart; specialinvoke v.()>(); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.("Content-Transfer-Encoding", v); label: virtualinvoke v.(); virtualinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v[0]; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("mailto:\u0001"); interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Sent email as a result of receiving {}", v); label: goto label; label: v := @caughtexception; interfaceinvoke v.(); v = virtualinvoke v.(); v = newarray (java.lang.Object)[3]; v[0] = v; v = virtualinvoke v.(); v[1] = v; v[2] = v; interfaceinvoke v.("Failed to send email for {}: {}; routing to failure", v); v = ; interfaceinvoke v.(v, v); label: return; catch org.apache.nifi.processor.exception.ProcessException from label to label with label; catch jakarta.mail.MessagingException from label to label with label; catch java.io.IOException from label to label with label; } private java.lang.String getMessage(org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) { byte[] v; long v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v; java.nio.charset.Charset v; int v; java.lang.Boolean v, v; java.lang.String v, v, v; org.apache.nifi.processor.io.InputStreamCallback v; boolean v, v, v; org.apache.nifi.flowfile.FlowFile v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.processors.standard.PutEmail v; v := @this: org.apache.nifi.processors.standard.PutEmail; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v = ""; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = newarray (byte)[v]; v = staticinvoke (v); interfaceinvoke v.(v, v); v = specialinvoke v.(v); v = new java.lang.String; v = lengthof v; specialinvoke v.(byte[],int,int,java.nio.charset.Charset)>(v, 0, v, v); v = v; goto label; label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (v, v); return v; label: return v; } private jakarta.mail.Session createMailSession(java.util.Properties) { java.util.Properties v; org.apache.nifi.processors.standard.PutEmail v; java.lang.String v; org.apache.nifi.processors.standard.PutEmail$1 v; jakarta.mail.Session v; boolean v; v := @this: org.apache.nifi.processors.standard.PutEmail; v := @parameter: java.util.Properties; v = virtualinvoke v.("mail.smtp.auth"); v = staticinvoke (v); if v == 0 goto label; v = new org.apache.nifi.processors.standard.PutEmail$1; specialinvoke v.(org.apache.nifi.processors.standard.PutEmail,java.util.Properties)>(v, v); v = staticinvoke (v, v); goto label; label: v = staticinvoke (v); label: return v; } private java.util.Properties getMailPropertiesFromFlowFile(org.apache.nifi.processor.ProcessContext, org.apache.nifi.flowfile.FlowFile) { org.apache.nifi.components.PropertyValue v, v, v, v; java.util.Map v, v; java.lang.String v, v, v; boolean v, v, v; java.util.Properties v; java.util.Iterator v, v; org.apache.nifi.flowfile.FlowFile v; org.apache.nifi.processor.ProcessContext v; java.util.Set v, v; java.util.function.Consumer v; org.apache.nifi.processors.standard.PutEmail v; java.util.Optional v; java.lang.Object v, v, v, v; v := @this: org.apache.nifi.processors.standard.PutEmail; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.flowfile.FlowFile; v = new java.util.Properties; specialinvoke v.()>(); v = ; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if null == v goto label; virtualinvoke v.(v, v); goto label; label: v = v.; v = staticinvoke (v); virtualinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if null == v goto label; v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: return v; } private static java.lang.String formatAttributes(org.apache.nifi.flowfile.FlowFile, java.lang.String) { java.lang.Object[] v, v, v, v; java.util.Date v; long v, v; java.lang.Long v; java.util.Map v; java.lang.String v, v, v, v, v, v, v, v; boolean v; java.util.Iterator v; org.apache.nifi.flowfile.FlowFile v; java.util.Set v; java.lang.Object v, v, v; java.lang.StringBuilder v; org.apache.nifi.flowfile.attributes.CoreAttributes v; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.lang.String; v = new java.lang.StringBuilder; specialinvoke v.(java.lang.String)>(v); virtualinvoke v.("\n\n--------------------------------------------------\n"); virtualinvoke v.("\nStandard FlowFile Metadata:"); v = newarray (java.lang.Object)[2]; v[0] = "id"; v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v[1] = v; v = staticinvoke ("\n\t%1$s = \'%2$s\'", v); virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "entryDate"; v = new java.util.Date; v = interfaceinvoke v.(); specialinvoke v.(long)>(v); v[1] = v; v = staticinvoke ("\n\t%1$s = \'%2$s\'", v); virtualinvoke v.(v); v = newarray (java.lang.Object)[2]; v[0] = "fileSize"; v = interfaceinvoke v.(); v = staticinvoke (v); v[1] = v; v = staticinvoke ("\n\t%1$s = \'%2$s\'", v); virtualinvoke v.(v); virtualinvoke v.("\nFlowFile Attributes:"); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = newarray (java.lang.Object)[2]; v = interfaceinvoke v.(); v[0] = v; v = interfaceinvoke v.(); v[1] = v; v = staticinvoke ("\n\t%1$s = \'%2$s\'", v); virtualinvoke v.(v); goto label; label: virtualinvoke v.("\n"); v = virtualinvoke v.(); return v; } private jakarta.mail.internet.InternetAddress[] toInetAddresses(org.apache.nifi.processor.ProcessContext, org.apache.nifi.flowfile.FlowFile, org.apache.nifi.components.PropertyDescriptor) throws jakarta.mail.internet.AddressException { java.lang.Throwable v; jakarta.mail.internet.AddressException v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.PropertyValue v, v; java.lang.String v, v, v, v, v; boolean v, v; org.apache.nifi.flowfile.FlowFile v; org.apache.nifi.processor.ProcessContext v; jakarta.mail.internet.InternetAddress[] v; org.apache.nifi.processors.standard.PutEmail v; v := @this: org.apache.nifi.processors.standard.PutEmail; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: org.apache.nifi.components.PropertyDescriptor; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Required property \'\u0001\' evaluates to an empty string."); v = new jakarta.mail.internet.AddressException; specialinvoke v.(java.lang.String)>(v); throw v; label: v = newarray (jakarta.mail.internet.InternetAddress)[0]; goto label; label: v = staticinvoke (v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Unable to parse a valid address for property \'\u0001\' with value \'\u0001\'"); v = new jakarta.mail.internet.AddressException; specialinvoke v.(java.lang.String)>(v); throw v; label: return v; catch jakarta.mail.internet.AddressException from label to label with label; } protected void send(jakarta.mail.Message) throws jakarta.mail.MessagingException { org.apache.nifi.processors.standard.PutEmail v; jakarta.mail.Message v; v := @this: org.apache.nifi.processors.standard.PutEmail; v := @parameter: jakarta.mail.Message; staticinvoke (v); return; } private java.nio.charset.Charset getCharset(org.apache.nifi.processor.ProcessContext) { java.nio.charset.Charset v; org.apache.nifi.processor.ProcessContext v; org.apache.nifi.processors.standard.PutEmail v; java.lang.String v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.PropertyValue v; v := @this: org.apache.nifi.processors.standard.PutEmail; v := @parameter: org.apache.nifi.processor.ProcessContext; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); return v; } private java.lang.String getEncoding(org.apache.nifi.processor.ProcessContext) { org.apache.nifi.processor.ProcessContext v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.PropertyValue v; java.nio.charset.Charset v, v; org.apache.nifi.processors.standard.PutEmail v; java.lang.String v; boolean v; v := @this: org.apache.nifi.processors.standard.PutEmail; v := @parameter: org.apache.nifi.processor.ProcessContext; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = staticinvoke ("US-ASCII"); v = virtualinvoke v.(v); if v == 0 goto label; return "7bit"; label: return "base64"; } static void () { java.util.Map v, v, v, v, v, v, v, v; org.apache.nifi.components.AllowableValue v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.expression.ExpressionLanguageScope v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.nio.charset.Charset v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.regex.Pattern v; org.apache.nifi.components.AllowableValue[] v, v, v; java.lang.String[] v, v; java.util.HashMap v; org.apache.nifi.components.Validator v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v; v = staticinvoke ("^mail\\.smtps?\\.([a-z0-9\\.]+)$"); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("SMTP Hostname"); v = virtualinvoke v.("The hostname of the SMTP host"); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("SMTP Port"); v = virtualinvoke v.("The Port used for SMTP communications"); v = virtualinvoke v.(1); v = virtualinvoke v.("25"); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("password-based-authorization-mode", "Use Password", "Use password"); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("oauth-based-authorization-mode", "Use OAuth2", "Use OAuth to acquire access token"); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("authorization-mode"); v = virtualinvoke v.("Authorization Mode"); v = virtualinvoke v.("How to authorize sending email on the user\'s behalf."); v = virtualinvoke v.(1); v = newarray (org.apache.nifi.components.AllowableValue)[2]; v = ; v[0] = v; v = ; v[1] = v; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("oauth2-access-token-provider"); v = virtualinvoke v.("OAuth Access Token Provider"); v = virtualinvoke v.("OAuth service that can provide access tokens."); v = virtualinvoke v.(class "Lorg/apache/nifi/oauth2/OAuth2AccessTokenProvider;"); v = ; v = newarray (org.apache.nifi.components.AllowableValue)[1]; v = ; v[0] = v; v = virtualinvoke v.(v, v); v = virtualinvoke v.(1); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("SMTP Username"); v = virtualinvoke v.("Username for the SMTP account"); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("SMTP Password"); v = virtualinvoke v.("Password for the SMTP account"); v = ; v = newarray (org.apache.nifi.components.AllowableValue)[1]; v = ; v[0] = v; v = virtualinvoke v.(v, v); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = virtualinvoke v.(1); v = virtualinvoke v.();