/*
- * Copyright (C) 2007-2012 Mathieu Baudier
+ * Copyright (C) 2007-2012 Argeo GmbH
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
*/
public class ArtifactIndexer implements NodeIndexer {
private Log log = LogFactory.getLog(ArtifactIndexer.class);
+ private Boolean force = false;
public Boolean support(String path) {
String relativePath = getRelativePath(path);
public void index(Node fileNode) {
Artifact artifact = null;
try {
+ if (!support(fileNode.getPath()))
+ return;
+
+ // Already indexed
+ if (!force && fileNode.isNodeType(SlcTypes.SLC_ARTIFACT))
+ return;
+
if (!fileNode.isNodeType(NodeType.NT_FILE))
return;
artifact.getClassifier());
JcrUtils.updateLastModified(fileNode);
+ // make sure there are checksums
+ String shaNodeName = fileNode.getName() + ".sha1";
+ if (!fileNode.getParent().hasNode(shaNodeName)) {
+ String sha = JcrUtils.checksumFile(fileNode, "SHA-1");
+ JcrUtils.copyBytesAsFile(fileNode.getParent(), shaNodeName,
+ sha.getBytes());
+ }
+ String md5NodeName = fileNode.getName() + ".md5";
+ if (!fileNode.getParent().hasNode(md5NodeName)) {
+ String md5 = JcrUtils.checksumFile(fileNode, "MD5");
+ JcrUtils.copyBytesAsFile(fileNode.getParent(), md5NodeName,
+ md5.getBytes());
+ }
+
// set higher levels
Node artifactVersionBase = fileNode.getParent();
if (!artifactVersionBase
artifact.getGroupId());
}
JcrUtils.updateLastModifiedAndParents(groupBase,
- RepoConstants.ARTIFACTS_BASE_PATH);
+ RepoConstants.DEFAULT_ARTIFACTS_BASE_PATH);
if (log.isTraceEnabled())
log.trace("Indexed artifact " + artifact + " on " + fileNode);
}
private String getRelativePath(String nodePath) {
- String basePath = RepoConstants.ARTIFACTS_BASE_PATH;
+ String basePath = RepoConstants.DEFAULT_ARTIFACTS_BASE_PATH;
if (!nodePath.startsWith(basePath))
return null;
String relativePath = nodePath.substring(basePath.length());
return relativePath;
}
+
+ public void setForce(Boolean force) {
+ this.force = force;
+ }
+
}