bakaid commented on a change in pull request #558: MINIFICPP-542 - Add PutSFTP processor URL: https://github.com/apache/nifi-minifi-cpp/pull/558#discussion_r285495763
########## File path: extensions/sftp/processors/PutSFTP.h ########## @@ -0,0 +1,183 @@ +/** + * PutSFTP class declaration + * + * 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. + */ +#ifndef __PUT_SFTP_H__ +#define __PUT_SFTP_H__ + +#include <memory> +#include <string> +#include <list> +#include <map> +#include <mutex> +#include <thread> + +#include "utils/ByteArrayCallback.h" +#include "FlowFileRecord.h" +#include "core/Processor.h" +#include "core/ProcessSession.h" +#include "core/Core.h" +#include "core/Property.h" +#include "core/Resource.h" +#include "controllers/SSLContextService.h" +#include "core/logging/LoggerConfiguration.h" +#include "utils/Id.h" +#include "../client/SFTPClient.h" + +namespace org { +namespace apache { +namespace nifi { +namespace minifi { +namespace processors { + +class PutSFTP : public core::Processor { + public: + + static constexpr char const *CONFLICT_RESOLUTION_REPLACE = "REPLACE"; + static constexpr char const *CONFLICT_RESOLUTION_IGNORE = "IGNORE"; + static constexpr char const *CONFLICT_RESOLUTION_RENAME = "RENAME"; + static constexpr char const *CONFLICT_RESOLUTION_REJECT = "REJECT"; + static constexpr char const *CONFLICT_RESOLUTION_FAIL = "FAIL"; + static constexpr char const *CONFLICT_RESOLUTION_NONE = "NONE"; + + static constexpr char const *PROXY_TYPE_DIRECT = "DIRECT"; + static constexpr char const *PROXY_TYPE_HTTP = "HTTP"; + static constexpr char const *PROXY_TYPE_SOCKS = "SOCKS"; + + static constexpr char const* ProcessorName = "PutSFTP"; + + + /*! + * Create a new processor + */ + PutSFTP(std::string name, utils::Identifier uuid = utils::Identifier()); + virtual ~PutSFTP(); + + // Supported Properties + static core::Property Hostname; + static core::Property Port; + static core::Property Username; + static core::Property Password; + static core::Property PrivateKeyPath; + static core::Property PrivateKeyPassphrase; + static core::Property RemotePath; + static core::Property CreateDirectory; + static core::Property DisableDirectoryListing; + static core::Property BatchSize; + static core::Property ConnectionTimeout; + static core::Property DataTimeout; + static core::Property ConflictResolution; + static core::Property RejectZeroByte; + static core::Property DotRename; + static core::Property TempFilename; + static core::Property HostKeyFile; + static core::Property LastModifiedTime; + static core::Property Permissions; + static core::Property RemoteOwner; + static core::Property RemoteGroup; + static core::Property StrictHostKeyChecking; + static core::Property UseKeepaliveOnTimeout; + static core::Property UseCompression; + static core::Property ProxyType; + static core::Property ProxyHost; + static core::Property ProxyPort; + static core::Property HttpProxyUsername; + static core::Property HttpProxyPassword; + + // Supported Relationships + static core::Relationship Success; + static core::Relationship Reject; + static core::Relationship Failure; + + virtual bool supportsDynamicProperties() override { Review comment: Thanks for the heads-up, I will keep this as-is then, and remember not do it in the core. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
