import org.argeo.jcr.JcrUtils;
import org.argeo.slc.SlcException;
import org.argeo.slc.aether.AetherTemplate;
-import org.argeo.slc.repo.RepoNames;
-import org.argeo.slc.repo.RepoTypes;
+import org.argeo.slc.jcr.SlcNames;
+import org.argeo.slc.jcr.SlcTypes;
+import org.argeo.slc.repo.ArtifactIndexer;
+import org.argeo.slc.repo.RepoConstants;
import org.osgi.framework.Constants;
import org.osgi.framework.Version;
import org.sonatype.aether.artifact.Artifact;
private Set<String> excludedArtifacts = new HashSet<String>();
private Session jcrSession;
- private String artifactBasePath = "/slc/repo/artifacts";
+ private String artifactBasePath = RepoConstants.ARTIFACTS_BASE_PATH;
+ private String distributionsBasePath = "/slc/repo/distributions";
+ private String distributionName;
+
+ private ArtifactIndexer artifactIndexer = new ArtifactIndexer();
public void run() {
log.debug(jcrSession.getUserID());
Long begin = System.currentTimeMillis();
try {
JcrUtils.mkdirs(jcrSession, artifactBasePath);
+ JcrUtils.mkdirs(jcrSession, distributionsBasePath + '/'
+ + distributionName);
artifacts: for (Artifact artifact : artifacts) {
File file = artifact.getFile();
if (file == null) {
log.warn("File not found for " + artifact);
- file = new File(System.getProperty("user.home")
- + File.separator
- + ".m2"
- + File.separator
- + "repository"
- + File.separator
- + artifact.getGroupId().replace('.',
- File.separatorChar)
- + File.separator
- + artifact.getArtifactId()
- + File.separator
- + artifact.getVersion()
- + File.separator
- + artifact.getArtifactId()
- + '-'
- + artifact.getVersion()
- + (artifact.getClassifier().equals("") ? ""
- : '-' + artifact.getClassifier()) + '.'
- + artifact.getExtension());
+ file = artifactToFile(artifact);
if (!file.exists()) {
log.warn("Generated file " + file + " for " + artifact
Node parentNode;
if (!jcrSession.itemExists(parentPath)) {
parentNode = JcrUtils.mkdirs(jcrSession, parentPath,
- NodeType.NT_FOLDER, false);
+ NodeType.NT_FOLDER);
} else {
parentNode = jcrSession.getNode(parentPath);
}
} else {
fileNode = parentNode.getNode(file.getName());
}
- processArtifact(fileNode, artifact);
- if (fileNode.isNodeType(RepoTypes.SLC_JAR_FILE)) {
+
+ if (artifactIndexer.support(fileNode.getPath()))
+ artifactIndexer.index(fileNode);
+ if (fileNode.isNodeType(SlcTypes.SLC_JAR_FILE)) {
processOsgiBundle(fileNode);
}
jcrSession.save();
+
+ if (!jcrSession
+ .itemExists(bundleDistributionPath(fileNode))
+ && fileNode
+ .isNodeType(SlcTypes.SLC_BUNDLE_ARTIFACT))
+ jcrSession.getWorkspace().clone(
+ jcrSession.getWorkspace().getName(),
+ fileNode.getPath(),
+ bundleDistributionPath(fileNode), false);
+
if (log.isDebugEnabled())
log.debug("Synchronized " + fileNode);
} catch (Exception e) {
+ artifact.getArtifactId() + '/' + artifact.getVersion();
}
- protected void processArtifact(Node fileNode, Artifact artifact) {
+ protected String bundleDistributionPath(Node fileNode) {
try {
- fileNode.addMixin(RepoTypes.SLC_ARTIFACT);
- fileNode.setProperty(RepoNames.SLC_ARTIFACT_ID,
- artifact.getArtifactId());
- fileNode.setProperty(RepoNames.SLC_GROUP_ID, artifact.getGroupId());
- fileNode.setProperty(RepoNames.SLC_ARTIFACT_VERSION,
- artifact.getVersion());
- fileNode.setProperty(RepoNames.SLC_ARTIFACT_EXTENSION,
- artifact.getExtension());
- fileNode.setProperty(RepoNames.SLC_ARTIFACT_CLASSIFIER,
- artifact.getClassifier());
+ return distributionsBasePath
+ + '/'
+ + distributionName
+ + '/'
+ + fileNode.getProperty(SlcNames.SLC_SYMBOLIC_NAME)
+ .getString()
+ + '_'
+ + fileNode.getProperty(SlcNames.SLC_BUNDLE_VERSION)
+ .getString();
} catch (RepositoryException e) {
- throw new SlcException("Cannot process artifact " + artifact
- + " on node " + fileNode, e);
+ throw new SlcException("Cannot create distribution path for "
+ + fileNode, e);
}
+ }
+ protected File artifactToFile(Artifact artifact) {
+ return new File(System.getProperty("user.home")
+ + File.separator
+ + ".m2"
+ + File.separator
+ + "repository"
+ + File.separator
+ + artifact.getGroupId().replace('.', File.separatorChar)
+ + File.separator
+ + artifact.getArtifactId()
+ + File.separator
+ + artifact.getVersion()
+ + File.separator
+ + artifact.getArtifactId()
+ + '-'
+ + artifact.getVersion()
+ + (artifact.getClassifier().equals("") ? ""
+ : '-' + artifact.getClassifier()) + '.'
+ + artifact.getExtension());
}
protected void processOsgiBundle(Node fileNode) {
Binary manifestBinary = null;
InputStream manifestIn = null;
try {
- manifestBinary = fileNode.getProperty(RepoNames.SLC_MANIFEST)
+ manifestBinary = fileNode.getProperty(SlcNames.SLC_MANIFEST)
.getBinary();
manifestIn = manifestBinary.getStream();
Manifest manifest = new Manifest(manifestIn);
return;// not an osgi bundle
}
- fileNode.addMixin(RepoTypes.SLC_BUNDLE_ARTIFACT);
+ fileNode.addMixin(SlcTypes.SLC_BUNDLE_ARTIFACT);
+
+ // symbolic name
+ String symbolicName = attrs.getValue(Constants.BUNDLE_SYMBOLICNAME);
+ // make sure there is no directive
+ symbolicName = symbolicName.split(";")[0];
+ fileNode.setProperty(SlcNames.SLC_SYMBOLIC_NAME, symbolicName);
+
+ // direct mapping
addAttr(Constants.BUNDLE_SYMBOLICNAME, fileNode, attrs);
addAttr(Constants.BUNDLE_NAME, fileNode, attrs);
addAttr(Constants.BUNDLE_DESCRIPTION, fileNode, attrs);
if (attrs.containsKey(new Name(
Constants.BUNDLE_REQUIREDEXECUTIONENVIRONMENT)))
fileNode.setProperty(
- RepoNames.SLC_
+ SlcNames.SLC_
+ Constants.BUNDLE_REQUIREDEXECUTIONENVIRONMENT,
attrs.getValue(
Constants.BUNDLE_REQUIREDEXECUTIONENVIRONMENT)
// bundle classpath
if (attrs.containsKey(new Name(Constants.BUNDLE_CLASSPATH)))
- fileNode.setProperty(RepoNames.SLC_
- + Constants.BUNDLE_CLASSPATH,
- attrs.getValue(Constants.BUNDLE_CLASSPATH).split(","));
+ fileNode.setProperty(
+ SlcNames.SLC_ + Constants.BUNDLE_CLASSPATH, attrs
+ .getValue(Constants.BUNDLE_CLASSPATH)
+ .split(","));
// version
Version version = new Version(
attrs.getValue(Constants.BUNDLE_VERSION));
- cleanSubNodes(fileNode, RepoNames.SLC_ + Constants.BUNDLE_VERSION);
- Node bundleVersionNode = fileNode.addNode(RepoNames.SLC_
- + Constants.BUNDLE_VERSION, RepoTypes.SLC_OSGI_VERSION);
+ fileNode.setProperty(SlcNames.SLC_BUNDLE_VERSION,
+ version.toString());
+ cleanSubNodes(fileNode, SlcNames.SLC_ + Constants.BUNDLE_VERSION);
+ Node bundleVersionNode = fileNode.addNode(SlcNames.SLC_
+ + Constants.BUNDLE_VERSION, SlcTypes.SLC_OSGI_VERSION);
mapOsgiVersion(version, bundleVersionNode);
// fragment
- cleanSubNodes(fileNode, RepoNames.SLC_ + Constants.FRAGMENT_HOST);
+ cleanSubNodes(fileNode, SlcNames.SLC_ + Constants.FRAGMENT_HOST);
if (attrs.containsKey(new Name(Constants.FRAGMENT_HOST))) {
String fragmentHost = attrs.getValue(Constants.FRAGMENT_HOST);
String[] tokens = fragmentHost.split(";");
- Node node = fileNode.addNode(RepoNames.SLC_
- + Constants.FRAGMENT_HOST, RepoTypes.SLC_FRAGMENT_HOST);
- node.setProperty(RepoNames.SLC_SYMBOLIC_NAME, tokens[0]);
+ Node node = fileNode.addNode(SlcNames.SLC_
+ + Constants.FRAGMENT_HOST, SlcTypes.SLC_FRAGMENT_HOST);
+ node.setProperty(SlcNames.SLC_SYMBOLIC_NAME, tokens[0]);
for (int i = 1; i < tokens.length; i++) {
if (tokens[i]
.startsWith(Constants.BUNDLE_VERSION_ATTRIBUTE)) {
- node.setProperty(RepoNames.SLC_BUNDLE_VERSION,
+ node.setProperty(SlcNames.SLC_BUNDLE_VERSION,
attributeValue(tokens[i]));
}
}
}
// imported packages
- cleanSubNodes(fileNode, RepoNames.SLC_ + Constants.IMPORT_PACKAGE);
+ cleanSubNodes(fileNode, SlcNames.SLC_ + Constants.IMPORT_PACKAGE);
if (attrs.containsKey(new Name(Constants.IMPORT_PACKAGE))) {
String importPackages = attrs
.getValue(Constants.IMPORT_PACKAGE);
- String[] packages = importPackages.split(",");
+ List<String> packages = parsePackages(importPackages);
for (String pkg : packages) {
String[] tokens = pkg.split(";");
- Node node = fileNode.addNode(RepoNames.SLC_
+ Node node = fileNode.addNode(SlcNames.SLC_
+ Constants.IMPORT_PACKAGE,
- RepoTypes.SLC_IMPORTED_PACKAGE);
- node.setProperty(RepoNames.SLC_NAME, tokens[0]);
+ SlcTypes.SLC_IMPORTED_PACKAGE);
+ node.setProperty(SlcNames.SLC_NAME, tokens[0]);
for (int i = 1; i < tokens.length; i++) {
if (tokens[i].startsWith(Constants.VERSION_ATTRIBUTE)) {
- node.setProperty(RepoNames.SLC_VERSION,
+ node.setProperty(SlcNames.SLC_VERSION,
attributeValue(tokens[i]));
} else if (tokens[i]
.startsWith(Constants.RESOLUTION_DIRECTIVE)) {
node.setProperty(
- RepoNames.SLC_OPTIONAL,
+ SlcNames.SLC_OPTIONAL,
directiveValue(tokens[i]).equals(
Constants.RESOLUTION_OPTIONAL));
}
}
// dynamic import package
- cleanSubNodes(fileNode, RepoNames.SLC_
+ cleanSubNodes(fileNode, SlcNames.SLC_
+ Constants.DYNAMICIMPORT_PACKAGE);
if (attrs.containsKey(new Name(Constants.DYNAMICIMPORT_PACKAGE))) {
String importPackages = attrs
.getValue(Constants.DYNAMICIMPORT_PACKAGE);
- String[] packages = importPackages.split(",");
+ List<String> packages = parsePackages(importPackages);
for (String pkg : packages) {
String[] tokens = pkg.split(";");
- Node node = fileNode.addNode(RepoNames.SLC_
+ Node node = fileNode.addNode(SlcNames.SLC_
+ Constants.DYNAMICIMPORT_PACKAGE,
- RepoTypes.SLC_DYNAMIC_IMPORTED_PACKAGE);
- node.setProperty(RepoNames.SLC_NAME, tokens[0]);
+ SlcTypes.SLC_DYNAMIC_IMPORTED_PACKAGE);
+ node.setProperty(SlcNames.SLC_NAME, tokens[0]);
for (int i = 1; i < tokens.length; i++) {
if (tokens[i].startsWith(Constants.VERSION_ATTRIBUTE)) {
- node.setProperty(RepoNames.SLC_VERSION,
+ node.setProperty(SlcNames.SLC_VERSION,
attributeValue(tokens[i]));
}
}
}
// exported packages
- cleanSubNodes(fileNode, RepoNames.SLC_ + Constants.EXPORT_PACKAGE);
+ cleanSubNodes(fileNode, SlcNames.SLC_ + Constants.EXPORT_PACKAGE);
if (attrs.containsKey(new Name(Constants.EXPORT_PACKAGE))) {
String exportPackages = attrs
.getValue(Constants.EXPORT_PACKAGE);
- List<String> packages = parseExportPackage(exportPackages);
+ List<String> packages = parsePackages(exportPackages);
for (String pkg : packages) {
String[] tokens = pkg.split(";");
- Node node = fileNode.addNode(RepoNames.SLC_
+ Node node = fileNode.addNode(SlcNames.SLC_
+ Constants.EXPORT_PACKAGE,
- RepoTypes.SLC_EXPORTED_PACKAGE);
- node.setProperty(RepoNames.SLC_NAME, tokens[0]);
+ SlcTypes.SLC_EXPORTED_PACKAGE);
+ node.setProperty(SlcNames.SLC_NAME, tokens[0]);
// TODO: are these cleans really necessary?
- cleanSubNodes(node, RepoNames.SLC_USES);
- cleanSubNodes(node, RepoNames.SLC_VERSION);
+ cleanSubNodes(node, SlcNames.SLC_USES);
+ cleanSubNodes(node, SlcNames.SLC_VERSION);
for (int i = 1; i < tokens.length; i++) {
if (tokens[i].startsWith(Constants.VERSION_ATTRIBUTE)) {
String versionStr = attributeValue(tokens[i]);
Node versionNode = node.addNode(
- RepoNames.SLC_VERSION,
- RepoTypes.SLC_OSGI_VERSION);
+ SlcNames.SLC_VERSION,
+ SlcTypes.SLC_OSGI_VERSION);
mapOsgiVersion(new Version(versionStr), versionNode);
} else if (tokens[i]
.startsWith(Constants.USES_DIRECTIVE)) {
for (String usedPackage : usedPackages.split(",")) {
// log.debug("usedPackage='" + usedPackage +
// "'");
- Node usesNode = node.addNode(
- RepoNames.SLC_USES,
- RepoTypes.SLC_JAVA_PACKAGE);
- usesNode.setProperty(RepoNames.SLC_NAME,
+ Node usesNode = node.addNode(SlcNames.SLC_USES,
+ SlcTypes.SLC_JAVA_PACKAGE);
+ usesNode.setProperty(SlcNames.SLC_NAME,
usedPackage);
}
}
}
// required bundle
- cleanSubNodes(fileNode, RepoNames.SLC_ + Constants.REQUIRE_BUNDLE);
+ cleanSubNodes(fileNode, SlcNames.SLC_ + Constants.REQUIRE_BUNDLE);
if (attrs.containsKey(new Name(Constants.REQUIRE_BUNDLE))) {
String requireBundle = attrs.getValue(Constants.REQUIRE_BUNDLE);
String[] bundles = requireBundle.split(",");
for (String bundle : bundles) {
String[] tokens = bundle.split(";");
- Node node = fileNode.addNode(RepoNames.SLC_
+ Node node = fileNode.addNode(SlcNames.SLC_
+ Constants.REQUIRE_BUNDLE,
- RepoTypes.SLC_REQUIRED_BUNDLE);
- node.setProperty(RepoNames.SLC_SYMBOLIC_NAME, tokens[0]);
+ SlcTypes.SLC_REQUIRED_BUNDLE);
+ node.setProperty(SlcNames.SLC_SYMBOLIC_NAME, tokens[0]);
for (int i = 1; i < tokens.length; i++) {
if (tokens[i]
.startsWith(Constants.BUNDLE_VERSION_ATTRIBUTE)) {
- node.setProperty(RepoNames.SLC_BUNDLE_VERSION,
+ node.setProperty(SlcNames.SLC_BUNDLE_VERSION,
attributeValue(tokens[i]));
} else if (tokens[i]
.startsWith(Constants.RESOLUTION_DIRECTIVE)) {
node.setProperty(
- RepoNames.SLC_OPTIONAL,
+ SlcNames.SLC_OPTIONAL,
directiveValue(tokens[i]).equals(
Constants.RESOLUTION_OPTIONAL));
}
}
}
- private List<String> parseExportPackage(String str) {
+ /** Parse package list with nested directive with ',' */
+ private List<String> parsePackages(String str) {
List<String> res = new ArrayList<String>();
StringBuffer curr = new StringBuffer("");
boolean in = false;
}
}
res.add(curr.toString());
+ log.debug(res);
return res;
}
private void addAttr(Name key, Node node, Attributes attrs)
throws RepositoryException {
- if (attrs.containsKey(key))
- node.setProperty(RepoNames.SLC_ + key, attrs.getValue(key));
+ if (attrs.containsKey(key)) {
+ String value = attrs.getValue(key);
+ node.setProperty(SlcNames.SLC_ + key, value);
+ }
}
private void cleanSubNodes(Node node, String name)
protected void mapOsgiVersion(Version version, Node versionNode)
throws RepositoryException {
- versionNode.setProperty(RepoNames.SLC_MAJOR, version.getMajor());
- versionNode.setProperty(RepoNames.SLC_MINOR, version.getMinor());
- versionNode.setProperty(RepoNames.SLC_MICRO, version.getMicro());
+ versionNode.setProperty(SlcNames.SLC_AS_STRING, version.toString());
+ versionNode.setProperty(SlcNames.SLC_MAJOR, version.getMajor());
+ versionNode.setProperty(SlcNames.SLC_MINOR, version.getMinor());
+ versionNode.setProperty(SlcNames.SLC_MICRO, version.getMicro());
if (!version.getQualifier().equals(""))
- versionNode.setProperty(RepoNames.SLC_QUALIFIER,
+ versionNode.setProperty(SlcNames.SLC_QUALIFIER,
version.getQualifier());
}
bi = new ByteArrayInputStream(bo.toByteArray());
manifestBinary = jcrSession.getValueFactory().createBinary(
bi);
- fileNode.addMixin(RepoTypes.SLC_JAR_FILE);
- fileNode.setProperty(RepoNames.SLC_MANIFEST, manifestBinary);
+ fileNode.addMixin(SlcTypes.SLC_JAR_FILE);
+ fileNode.setProperty(SlcNames.SLC_MANIFEST, manifestBinary);
Attributes attrs = manifest.getMainAttributes();
addAttr(Attributes.Name.MANIFEST_VERSION, fileNode, attrs);
addAttr(Attributes.Name.SIGNATURE_VERSION, fileNode, attrs);
this.jcrSession = jcrSession;
}
+ public void setDistributionName(String distributionName) {
+ this.distributionName = distributionName;
+ }
+
}
projects / gpl / argeo-slc.git / blobdiff