entaxy/entaxy-public
14
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

ENTAXY-374 fix file connection #11

Merged
skryuchkov merged 1 commits from ENTAXY-374 into master 2022-09-09 13:33:09 +03:00
Conversation 0 Commits 1 Files Changed 3 +16 -5
3 changed files with 16 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
platform/runtime/core/initializer/connection-initializer/src/main/java/ru/entaxy/esb/platform/runtime/core/initializer/connection/ConnectionInitializer.java
View File

@ -204,7 +204,8 @@ public class ConnectionInitializer extends AbstractInitializer {
.command("build") .command("build")
.set(EntaxyProducerService.INSTRUCTIONS.ARTIFACT.TIMESTAMP, newTimestamp) .set(EntaxyProducerService.INSTRUCTIONS.ARTIFACT.TIMESTAMP, newTimestamp)
.command("install") .command("install")
.set("update", ""); .set("update", "")
.set("installLocal", true);
String instructions = builder String instructions = builder
.getInstructionsString(); .getInstructionsString();

8
platform/runtime/core/object-producing/object-producer-core/src/main/java/ru/entaxy/platform/core/producer/executor/commands/Build.java
View File

@ -21,6 +21,7 @@ package ru.entaxy.platform.core.producer.executor.commands;
import java.util.Map; import java.util.Map;
import org.osgi.framework.Constants;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -137,6 +138,13 @@ public class Build extends AbstractCommandExecutor {
} }
} }
artifact.getProperties().putAll(g.getProperties()); artifact.getProperties().putAll(g.getProperties());
// TODO get value from manifest
// ArtifactManifest must be improved to provide read access to all attributes
if (!artifact.getProperties().containsKey(Constants.BUNDLE_SYMBOLICNAME)) {
artifact.getProperties().put(Constants.BUNDLE_SYMBOLICNAME
, artifact.getCoordinates().getGroupId()
+ "." + artifact.getCoordinates().getArtifactId());
}
artifactList.add(artifact); artifactList.add(artifact);
printOutput("\n\t == " + artifact.getCoordinates().toString() + " ==\n"); printOutput("\n\t == " + artifact.getCoordinates().toString() + " ==\n");
printOutput(new String(artifact.asByteArray())); printOutput(new String(artifact.asByteArray()));

10
platform/runtime/core/object-producing/object-producer-core/src/main/java/ru/entaxy/platform/core/producer/executor/commands/Install.java
View File

@ -90,6 +90,8 @@ public class Install extends AbstractCommandExecutor {
Installer<?> installer = null; Installer<?> installer = null;
String artifactUpdate = update;
printOutput("-> Installing artifact: [" + da.getArtifact().getCoordinates().toString() + "]"); printOutput("-> Installing artifact: [" + da.getArtifact().getCoordinates().toString() + "]");
if (installLocal) { if (installLocal) {
LocalInstaller localInstaller = artifactService.installers().local() LocalInstaller localInstaller = artifactService.installers().local()
@ -110,14 +112,14 @@ public class Install extends AbstractCommandExecutor {
BlueprintInstaller blueprintInstaller = installer.typed(BlueprintInstaller.class); BlueprintInstaller blueprintInstaller = installer.typed(BlueprintInstaller.class);
if (installOnlyIfMissing) if (installOnlyIfMissing)
blueprintInstaller.installOnlyIfMissing(); blueprintInstaller.installOnlyIfMissing();
if (update != null) { if (artifactUpdate != null) {
if (!CommonUtils.isValid(update)) { if (!CommonUtils.isValid(artifactUpdate)) {
update = da artifactUpdate = da
.getArtifact().getProperties() .getArtifact().getProperties()
.getOrDefault(Constants.BUNDLE_SYMBOLICNAME, "") .getOrDefault(Constants.BUNDLE_SYMBOLICNAME, "")
.toString(); .toString();
} }
blueprintInstaller.update(update); blueprintInstaller.update(artifactUpdate);
} }
result = blueprintInstaller.start().install(); result = blueprintInstaller.start().install();
} else { } else {