yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-30 17:44:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

[Add] refine slack url (#2739)

Browse Source
This commit is contained in:
SeungwanJo 2022-02-14 02:45:53 +09:00 committed by GitHub
parent d60a085ff2
commit 7ca7f087ab
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
catalog-rest-service/src/main/java/org/openmetadata/catalog/slack/SlackWebhookEventPublisher.java
View File

@ -1,7 +1,10 @@
package org.openmetadata.catalog.slack;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import javax.ws.rs.client.Client;
@ -35,7 +38,7 @@ public class SlackWebhookEventPublisher extends AbstractEventPublisher {
clientBuilder.readTimeout(12, TimeUnit.SECONDS);
client = clientBuilder.build();
target = client.target(slackWebhookURL).request();
openMetadataUrl = config.getOpenMetadataUrl();
openMetadataUrl = refineUri(config.getOpenMetadataUrl());
}
@Override
@ -247,4 +250,20 @@ public class SlackWebhookEventPublisher extends AbstractEventPublisher {
event.getEntityFullyQualifiedName(),
event.getEntityFullyQualifiedName());
}
private String refineUri(String url) {
URI urlInstance = null;
try {
urlInstance = new URI(url);
} catch (URISyntaxException e) {
LOG.error("Slack URL is not in url format - {}", url);
}
if (Objects.nonNull(urlInstance)) {
String scheme = urlInstance.getScheme();
String host = urlInstance.getHost();
return String.format("%s://%s", scheme, host);
}
return url;
}
}