Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-08 02:58:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-14089 Add MethodsEndpointUrlPrefix Property to PublishSlack Processor

Browse Source 
This closes #9586.

Signed-off-by: Lehel Boer <lehelb@apache.org>
This commit is contained in:
Ryosuke Takahashi 2024-12-17 21:37:44 +09:00 committed by lehelb
parent 32bc68a40c
commit 547f1016db
No known key found for this signature in database
GPG Key ID: DF88194D25018859
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
nifi-extension-bundles/nifi-slack-bundle/nifi-slack-processors/src/main/java/org/apache/nifi/processors/slack/PublishSlack.java
View File

@ -17,6 +17,8 @@
package org.apache.nifi.processors.slack;
import com.slack.api.Slack;
import com.slack.api.SlackConfig;
import com.slack.api.bolt.App;
import com.slack.api.bolt.AppConfig;
import com.slack.api.methods.MethodsClient;
@ -211,6 +213,15 @@ public class PublishSlack extends AbstractProcessor {
.required(false)
.build();
static PropertyDescriptor METHODS_ENDPOINT_URL_PREFIX = new PropertyDescriptor.Builder()
.name("Methods Endpoint Url Prefix")
.description("Customization of the Slack Client. Set the methodsEndpointUrlPrefix. If you need to set a different URL prefix for Slack API Methods calls, " +
"you can set the one. Default value: https://slack.com/api/")
.addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
.expressionLanguageSupported(ExpressionLanguageScope.FLOWFILE_ATTRIBUTES)
.required(false)
.build();
private static final List<PropertyDescriptor> properties = List.of(ACCESS_TOKEN,
CHANNEL,
PUBLISH_STRATEGY,
@ -218,7 +229,8 @@ public class PublishSlack extends AbstractProcessor {
CHARACTER_SET,
SEND_CONTENT_AS_ATTACHMENT,
MAX_FILE_SIZE,
THREAD_TS);
THREAD_TS,
METHODS_ENDPOINT_URL_PREFIX);
public static final Relationship REL_SUCCESS = new Relationship.Builder()
@ -279,7 +291,14 @@ public class PublishSlack extends AbstractProcessor {
private App createSlackApp(final ProcessContext context) {
final String botToken = context.getProperty(ACCESS_TOKEN).getValue();
final String methodsEndpointUrlPrefix = context.getProperty(METHODS_ENDPOINT_URL_PREFIX).getValue();
final SlackConfig slackConfig = new SlackConfig();
if (context.getProperty(METHODS_ENDPOINT_URL_PREFIX).isSet()) {
slackConfig.setMethodsEndpointUrlPrefix(methodsEndpointUrlPrefix);
}
final AppConfig appConfig = AppConfig.builder()
.slack(Slack.getInstance(slackConfig))
.singleTeamBotToken(botToken)
.build();