import java.util.StringJoiner;
import java.util.concurrent.CompletableFuture;
+import javax.xml.XMLConstants;
import javax.xml.namespace.QName;
import javax.xml.transform.Source;
import javax.xml.transform.TransformerException;
import org.argeo.api.acr.ContentResourceException;
import org.argeo.api.acr.CrAttributeType;
import org.argeo.api.acr.CrName;
+import org.argeo.api.acr.DName;
import org.argeo.api.acr.NamespaceUtils;
import org.argeo.api.acr.spi.ContentProvider;
import org.argeo.api.acr.spi.ProvidedContent;
import org.argeo.api.cms.CmsLog;
import org.argeo.cms.acr.AbstractContent;
import org.argeo.cms.acr.ContentUtils;
-import org.argeo.util.FsUtils;
+import org.argeo.cms.util.FsUtils;
/** Content persisted as a filesystem {@link Path}. */
public class FsContent extends AbstractContent implements ProvidedContent {
private static final Map<QName, String> POSIX_KEYS;
static {
BASIC_KEYS = new HashMap<>();
- BASIC_KEYS.put(CrName.creationTime.qName(), "basic:creationTime");
- BASIC_KEYS.put(CrName.lastModifiedTime.qName(), "basic:lastModifiedTime");
- BASIC_KEYS.put(CrName.size.qName(), "basic:size");
+ BASIC_KEYS.put(DName.creationdate.qName(), "basic:creationTime");
+ BASIC_KEYS.put(DName.getlastmodified.qName(), "basic:lastModifiedTime");
+ BASIC_KEYS.put(DName.getcontentlength.qName(), "basic:size");
+
BASIC_KEYS.put(CrName.fileKey.qName(), "basic:fileKey");
POSIX_KEYS = new HashMap<>(BASIC_KEYS);
- POSIX_KEYS.put(CrName.owner.qName(), "owner:owner");
- POSIX_KEYS.put(CrName.group.qName(), "posix:group");
+ POSIX_KEYS.put(DName.owner.qName(), "owner:owner");
+ POSIX_KEYS.put(DName.group.qName(), "posix:group");
POSIX_KEYS.put(CrName.permissions.qName(), "posix:permissions");
}
} else {
// TODO should we support prefixed name for known types?
- QName providerName = NamespaceUtils.parsePrefixedName(provider, path.getFileName().toString());
+ QName providerName = provider.fromFsPrefixedName(path.getFileName().toString());
// QName providerName = new QName(path.getFileName().toString());
// TODO remove extension if mounted?
this.name = new ContentName(providerName, session);
} else {
UserDefinedFileAttributeView udfav = Files.getFileAttributeView(path,
UserDefinedFileAttributeView.class);
- String prefixedName = NamespaceUtils.toPrefixedName(provider, key);
+ String prefixedName = provider.toFsPrefixedName(key);
if (!udfav.list().contains(prefixedName))
return Optional.empty();
ByteBuffer buf = ByteBuffer.allocate(udfav.size(prefixedName));
if (udfav != null) {
try {
for (String name : udfav.list()) {
- QName providerName = NamespaceUtils.parsePrefixedName(provider, name);
+ QName providerName = provider.fromFsPrefixedName(name);
+ if (providerName.getNamespaceURI().equals(XMLConstants.XMLNS_ATTRIBUTE_NS_URI))
+ continue; // skip prefix mapping
QName sessionName = new ContentName(providerName, getSession());
result.add(sessionName);
}
protected void removeAttr(QName key) {
UserDefinedFileAttributeView udfav = Files.getFileAttributeView(path, UserDefinedFileAttributeView.class);
try {
- udfav.delete(NamespaceUtils.toPrefixedName(provider, key));
+ udfav.delete(provider.toFsPrefixedName(key));
} catch (IOException e) {
throw new ContentResourceException("Cannot delete attribute " + key + " for " + path, e);
}
UserDefinedFileAttributeView udfav = Files.getFileAttributeView(path, UserDefinedFileAttributeView.class);
ByteBuffer bb = ByteBuffer.wrap(toWrite.getBytes(StandardCharsets.UTF_8));
try {
- udfav.write(NamespaceUtils.toPrefixedName(provider, key), bb);
+ udfav.write(provider.toFsPrefixedName(key), bb);
} catch (IOException e) {
throw new ContentResourceException("Cannot delete attribute " + key + " for " + path, e);
}
if (POSIX_KEYS.containsKey(key))
return POSIX_KEYS.get(key);
else
- return USER_ + NamespaceUtils.toPrefixedName(provider, key);
+ return USER_ + provider.toFsPrefixedName(key);
}
/*
public Content add(QName name, QName... classes) {
FsContent fsContent;
try {
- Path newPath = path.resolve(NamespaceUtils.toPrefixedName(provider, name));
- if (ContentName.contains(classes, CrName.collection.qName()))
+ Path newPath = path.resolve(provider.toFsPrefixedName(name));
+ if (ContentName.contains(classes, DName.collection.qName()))
Files.createDirectory(newPath);
else
Files.createFile(newPath);
@Override
public List<QName> getContentClasses() {
List<QName> res = new ArrayList<>();
- List<String> value = getMultiple(CrName.cc.qName(), String.class);
+ List<String> value = getMultiple(DName.resourcetype.qName(), String.class);
for (String s : value) {
QName name = NamespaceUtils.parsePrefixedName(provider, s);
res.add(name);
}
if (Files.isDirectory(path))
- res.add(CrName.collection.qName());
+ res.add(DName.collection.qName());
return res;
}
public void addContentClasses(QName... contentClass) {
List<String> toWrite = new ArrayList<>();
for (QName cc : getContentClasses()) {
- if (cc.equals(CrName.collection.qName()))
+ if (cc.equals(DName.collection.qName()))
continue; // skip
toWrite.add(NamespaceUtils.toPrefixedName(provider, cc));
}
for (QName cc : contentClass) {
toWrite.add(NamespaceUtils.toPrefixedName(provider, cc));
}
- put(CrName.cc.qName(), toWrite);
+ put(DName.resourcetype.qName(), toWrite);
}
/*
*/
@SuppressWarnings("unchecked")
public <A> CompletableFuture<A> write(Class<A> clss) {
- if (isContentClass(CrName.collection.qName())) {
+ if (isContentClass(DName.collection.qName())) {
throw new IllegalStateException("Cannot directly write to a collection");
}
if (InputStream.class.isAssignableFrom(clss)) {