Skip to content

Commit cf7243c

Browse files
authored
Merge pull request #379 from arunans23/inbound
Improve connector loader to avoid inbound endpoints
2 parents c6806a8 + ba062a4 commit cf7243c

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

org.eclipse.lemminx/src/main/java/org/eclipse/lemminx/customservice/synapse/connectors/AbstractConnectorLoader.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,8 @@
3535
import java.util.logging.Logger;
3636
import java.util.stream.Collectors;
3737

38+
import static org.eclipse.lemminx.customservice.synapse.utils.Constant.INBOUND_CONNECTOR_PREFIX;
39+
3840
/**
3941
* Abstract class to load connectors.
4042
*/
@@ -122,7 +124,7 @@ private void extractZips(List<File> connectorZips, File extractFolder, InboundCo
122124
File extractToFolder = new File(extractTo);
123125
try {
124126
Utils.extractZip(zip, extractToFolder);
125-
if (zipName.contains(Constant.INBOUND_CONNECTOR_PREFIX)) {
127+
if (zipName.contains(INBOUND_CONNECTOR_PREFIX)) {
126128
String schema = Utils.readFile(extractToFolder.toPath().resolve(Constant.RESOURCES)
127129
.resolve(Constant.UI_SCHEMA_JSON).toFile());
128130
inboundConnectorHolder.saveInboundConnector(Utils.getJsonObject(schema)
@@ -140,8 +142,9 @@ private void readConnectors(File connectorFolder) {
140142
File[] files = connectorFolder.listFiles(File::isDirectory);
141143
for (File f : files) {
142144
String connectorName = getConnectorName(f);
143-
if (!connectorHolder.exists(connectorName)) {
144-
Connector connector = connectorReader.readConnector(f.getAbsolutePath(), projectUri);
145+
String connectorPath = f.getAbsolutePath();
146+
if (!(connectorHolder.exists(connectorName) || connectorPath.contains(INBOUND_CONNECTOR_PREFIX))) {
147+
Connector connector = connectorReader.readConnector(connectorPath, projectUri);
145148
if (connector != null) {
146149
connector.setConnectorZipPath(
147150
getConnectorZip(connectorHolder.getConnectorZips(), connector.getExtractedConnectorPath()));

0 commit comments

Comments
 (0)