exceptionfactory commented on code in PR #6376: URL: https://github.com/apache/nifi/pull/6376#discussion_r968423628
########## nifi-nar-bundles/nifi-workday-bundle/nifi-workday-processors/src/main/java/org/apache/nifi/processors/workday/GetWorkdayReport.java: ########## @@ -0,0 +1,442 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.nifi.processors.workday; + +import static org.apache.nifi.expression.ExpressionLanguageScope.FLOWFILE_ATTRIBUTES; +import static org.apache.nifi.expression.ExpressionLanguageScope.NONE; +import static org.apache.nifi.processor.util.StandardValidators.NON_BLANK_VALIDATOR; +import static org.apache.nifi.processor.util.StandardValidators.URL_VALIDATOR; + +import java.io.BufferedInputStream; +import java.io.IOException; +import java.io.InputStream; +import java.io.OutputStream; +import java.net.URI; +import java.nio.charset.StandardCharsets; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Base64; +import java.util.Collection; +import java.util.Collections; +import java.util.HashMap; +import java.util.HashSet; +import java.util.List; +import java.util.Map; +import java.util.Optional; +import java.util.Set; +import java.util.UUID; +import java.util.concurrent.TimeUnit; +import java.util.concurrent.atomic.AtomicReference; +import java.util.regex.Pattern; +import java.util.stream.Collectors; +import org.apache.nifi.annotation.behavior.EventDriven; +import org.apache.nifi.annotation.behavior.InputRequirement; +import org.apache.nifi.annotation.behavior.InputRequirement.Requirement; +import org.apache.nifi.annotation.behavior.SideEffectFree; +import org.apache.nifi.annotation.behavior.SupportsBatching; +import org.apache.nifi.annotation.behavior.WritesAttribute; +import org.apache.nifi.annotation.behavior.WritesAttributes; +import org.apache.nifi.annotation.documentation.CapabilityDescription; +import org.apache.nifi.annotation.documentation.Tags; +import org.apache.nifi.annotation.lifecycle.OnScheduled; +import org.apache.nifi.components.PropertyDescriptor; +import org.apache.nifi.components.ValidationContext; +import org.apache.nifi.components.ValidationResult; +import org.apache.nifi.flowfile.FlowFile; +import org.apache.nifi.flowfile.attributes.CoreAttributes; +import org.apache.nifi.logging.ComponentLog; +import org.apache.nifi.processor.AbstractProcessor; +import org.apache.nifi.processor.ProcessContext; +import org.apache.nifi.processor.ProcessSession; +import org.apache.nifi.processor.Relationship; +import org.apache.nifi.processor.exception.ProcessException; +import org.apache.nifi.processor.util.StandardValidators; +import org.apache.nifi.record.path.RecordPath; +import org.apache.nifi.record.path.RecordPathResult; +import org.apache.nifi.schema.access.SchemaNotFoundException; +import org.apache.nifi.security.util.crypto.HashAlgorithm; +import org.apache.nifi.serialization.MalformedRecordException; +import org.apache.nifi.serialization.RecordReader; +import org.apache.nifi.serialization.RecordReaderFactory; +import org.apache.nifi.serialization.RecordSetWriter; +import org.apache.nifi.serialization.RecordSetWriterFactory; +import org.apache.nifi.serialization.record.Record; +import org.apache.nifi.serialization.record.RecordFieldType; +import org.apache.nifi.serialization.record.RecordSchema; +import org.apache.nifi.web.client.api.HttpResponseEntity; +import org.apache.nifi.web.client.api.WebClientService; +import org.apache.nifi.web.client.provider.api.WebClientServiceProvider; + +@Tags({"Workday", "report"}) +@InputRequirement(Requirement.INPUT_ALLOWED) +@CapabilityDescription("A processor which can interact with a configurable Workday Report. The processor can forward the content without modification, or you can transform it by" + + " providing the specific Record Reader and Record Writer services based on your needs. You can also hash, or remove fields using the input parameters and schemes in the Record Writer. " + + "Supported Workday report formats are: csv, simplexml, json") +@EventDriven +@SideEffectFree +@SupportsBatching +@WritesAttributes({ + @WritesAttribute(attribute = GetWorkdayReport.GET_WORKDAY_REPORT_JAVA_EXCEPTION_CLASS, description = "The Java exception class raised when the processor fails"), + @WritesAttribute(attribute = GetWorkdayReport.GET_WORKDAY_REPORT_JAVA_EXCEPTION_MESSAGE, description = "The Java exception message raised when the processor fails"), + @WritesAttribute(attribute = "mime.type", description = "Sets the mime.type attribute to the MIME Type specified by the Source / Record Writer"), + @WritesAttribute(attribute= GetWorkdayReport.RECORD_COUNT, description = "The number of records in an outgoing FlowFile. This is only populated on the 'success' relationship " + + "when Record Reader and Writer is set.")}) +public class GetWorkdayReport extends AbstractProcessor { + + protected static final String STATUS_CODE = "getworkdayreport.status.code"; + protected static final String REQUEST_URL = "getworkdayreport.request.url"; + protected static final String REQUEST_DURATION = "getworkdayreport.request.duration"; + protected static final String TRANSACTION_ID = "getworkdayreport.tx.id"; + protected static final String GET_WORKDAY_REPORT_JAVA_EXCEPTION_CLASS = "getworkdayreport.java.exception.class"; + protected static final String GET_WORKDAY_REPORT_JAVA_EXCEPTION_MESSAGE = "getworkdayreport.java.exception.message"; + protected static final String RECORD_COUNT = "record.count"; + protected static final String BASIC_PREFIX = "Basic "; + protected static final String COLUMNS_TO_HASH_SEPARATOR = ","; + protected static final String HEADER_AUTHORIZATION = "Authorization"; + protected static final String HEADER_CONTENT_TYPE = "Content-Type"; + protected static final String USERNAME_PASSWORD_SEPARATOR = ":"; + + protected static final PropertyDescriptor REPORT_URL = new PropertyDescriptor.Builder() + .name("Workday Report URL") + .displayName("Workday Report URL") + .description("HTTP remote URL of Workday report including a scheme of http or https, as well as a hostname or IP address with optional port and path elements.") + .required(true) + .expressionLanguageSupported(FLOWFILE_ATTRIBUTES) + .addValidator(URL_VALIDATOR) + .build(); + + protected static final PropertyDescriptor WORKDAY_USERNAME = new PropertyDescriptor.Builder() + .name("Workday Username") + .displayName("Workday Username") + .description("The username provided for authentication of Workday requests. Encoded using Base64 for HTTP Basic Authentication as described in RFC 7617.") + .required(true) + .addValidator(StandardValidators.createRegexMatchingValidator(Pattern.compile("^[\\x20-\\x39\\x3b-\\x7e\\x80-\\xff]+$"))) + .expressionLanguageSupported(FLOWFILE_ATTRIBUTES) + .build(); + + protected static final PropertyDescriptor WORKDAY_PASSWORD = new PropertyDescriptor.Builder() + .name("Workday Password") + .displayName("Workday Password") + .description("The password provided for authentication of Workday requests. Encoded using Base64 for HTTP Basic Authentication as described in RFC 7617.") + .required(true) + .sensitive(true) + .addValidator(StandardValidators.createRegexMatchingValidator(Pattern.compile("^[\\x20-\\x7e\\x80-\\xff]+$"))) + .expressionLanguageSupported(FLOWFILE_ATTRIBUTES) + .build(); + + protected static final PropertyDescriptor WEB_CLIENT_SERVICE = new PropertyDescriptor.Builder() + .name("Web Client Service Provider") + .description("Web client which is used to communicate with the Workday API.") + .required(true) + .identifiesControllerService(WebClientServiceProvider.class) + .build(); + + protected static final PropertyDescriptor FIELDS_TO_HASH = new PropertyDescriptor.Builder() + .name("Hashed Fields") + .displayName("Hashed Fields") + .description("Comma separated record paths to be replaced with their corresponding hash.") + .required(false) + .expressionLanguageSupported(FLOWFILE_ATTRIBUTES) + .addValidator(NON_BLANK_VALIDATOR) + .build(); + + protected static final PropertyDescriptor HASHING_ALGORITHM = new PropertyDescriptor.Builder() + .name("Hashing Algorithm") + .displayName("Hashing Algorithm") + .description("Determines what hashing algorithm should be used to perform the hashing function.") + .required(true) + .allowableValues(HashAlgorithm.SHA256.getName(), HashAlgorithm.SHA512.getName()) + .defaultValue(HashAlgorithm.SHA256.getName()) + .addValidator(NON_BLANK_VALIDATOR) + .expressionLanguageSupported(NONE) + .dependsOn(FIELDS_TO_HASH) + .build(); + + protected static final PropertyDescriptor RECORD_READER_FACTORY = new PropertyDescriptor.Builder() + .name("record-reader") + .displayName("Record Reader") + .description("Specifies the Controller Service to use for parsing incoming data and determining the data's schema.") + .identifiesControllerService(RecordReaderFactory.class) + .required(false) + .build(); + + protected static final PropertyDescriptor RECORD_WRITER_FACTORY = new PropertyDescriptor.Builder() + .name("record-writer") + .displayName("Record Writer") + .description("The Record Writer to use for serializing Records to an output FlowFile.") + .identifiesControllerService(RecordSetWriterFactory.class) + .dependsOn(RECORD_READER_FACTORY) + .required(true) + .build(); + + protected static final Relationship ORIGINAL = new Relationship.Builder() + .name("Original") + .description("Request FlowFiles transferred when receiving HTTP responses with a status code between 200 and 299.") + .build(); + + protected static final Relationship FAILURE = new Relationship.Builder() + .name("Failure") + .description("Request FlowFiles transferred when receiving socket communication errors.") + .build(); + + protected static final Relationship RESPONSE = new Relationship.Builder() + .name("Response") + .description("Response FlowFiles transferred when receiving HTTP responses with a status code between 200 and 299.") + .build(); + + protected static final Set<Relationship> RELATIONSHIPS = Collections.unmodifiableSet(new HashSet<>(Arrays.asList(ORIGINAL, RESPONSE, FAILURE))); + protected static final List<PropertyDescriptor> PROPERTIES = Collections.unmodifiableList(Arrays.asList(REPORT_URL, WORKDAY_USERNAME, WORKDAY_PASSWORD, WEB_CLIENT_SERVICE, + FIELDS_TO_HASH, HASHING_ALGORITHM, RECORD_READER_FACTORY, RECORD_WRITER_FACTORY)); Review Comment: Recommend reformatting this declaration to list each property on a separate line. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
