Compare commits

..

2 Commits

6 changed files with 24 additions and 61 deletions

View File

@ -2,28 +2,20 @@ This project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.htm
# Changelog for org.gcube.data-access.sh-fuse-integration
## [v2.0.1] 2021-02-09
### Fix
- all logs set to WARN [#22814]
## [v2.0.0] 2021-05-19
### Feature
- porting to uma token [#21441]
## [v1.2.0-SNAPSHOT] 2022-02-10
### Fixes
- removed internal logback.xml #22814
## [v1.1.1] 2021-01-15
### Fixes
- issue on right displayed
- [#20417]
- https://support.d4science.org/issues/20417
## [v1.1.0] 2020-09-07
### Fixes
- Solved issue on data download [#19651]
- Solved issue on data download (https://support.d4science.org/issues/19651)

15
pom.xml
View File

@ -4,7 +4,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>org.gcube.data-access</groupId>
<artifactId>sh-fuse-integration</artifactId>
<version>2.0.1</version>
<version>1.2.0-SNAPSHOT</version>
<name>SHFuseIntegration</name>
<parent>
@ -33,7 +33,7 @@
<dependency>
<groupId>org.gcube.distribution</groupId>
<artifactId>gcube-bom</artifactId>
<version>2.0.1</version>
<version>1.5.0</version>
<type>pom</type>
<scope>import</scope>
</dependency>
@ -51,11 +51,6 @@
<artifactId>gxJRS</artifactId>
</dependency>
<dependency>
<groupId>org.gcube.common</groupId>
<artifactId>common-authorization</artifactId>
</dependency>
<dependency>
<groupId>org.gcube.common</groupId>
<artifactId>storagehub-client-library</artifactId>
@ -66,10 +61,6 @@
<artifactId>storagehub-model</artifactId>
<version>[1.0.0-SNAPSHOT, 2.0.0-SNAPSHOT)</version>
</dependency>
<dependency>
<groupId>org.gcube.core</groupId>
<artifactId>common-gcube-calls</artifactId>
</dependency>
<dependency>
<groupId>org.cache2k</groupId>
<artifactId>cache2k-jcache</artifactId>
@ -126,4 +117,4 @@
</plugin>
</plugins>
</build>
</project>
</project>

View File

@ -10,7 +10,7 @@ import java.util.concurrent.TimeUnit;
import org.cache2k.Cache;
import org.cache2k.Cache2kBuilder;
import org.gcube.common.authorization.library.AuthorizedTasks;
import org.gcube.common.authorization.library.provider.AccessTokenProvider;
import org.gcube.common.authorization.library.provider.SecurityTokenProvider;
import org.gcube.common.scope.api.ScopeProvider;
import org.gcube.common.storagehub.client.dsl.ContainerType;
import org.gcube.common.storagehub.client.dsl.FileContainer;
@ -63,11 +63,8 @@ public class StorageHubFS extends FuseStubFS {
super();
this.token = token;
this.scope = scope;
logger.debug("using token {} in scope {}", token , scope);
ScopeProvider.instance.set(scope);
AccessTokenProvider.instance.set(token);
SecurityTokenProvider.instance.set(token);
client = new StorageHubClient();
rootDirectory = client.getWSRoot();
cache = new Cache2kBuilder<String, ItemContainer<Item>>() {}
@ -84,7 +81,7 @@ public class StorageHubFS extends FuseStubFS {
@Override
public synchronized int write(String path, Pointer buf, long size, long offset, FuseFileInfo fi) {
ScopeProvider.instance.set(scope);
AccessTokenProvider.instance.set(token);
SecurityTokenProvider.instance.set(token);
logger.trace("{}) calling write {} - {} ",Thread.currentThread().getName(), size , offset);
SHFile file = tempFiles.get(path);
@ -113,7 +110,7 @@ public class StorageHubFS extends FuseStubFS {
@Override
public synchronized int create(final String path, @mode_t long mode, FuseFileInfo fi) {
ScopeProvider.instance.set(scope);
AccessTokenProvider.instance.set(token);
SecurityTokenProvider.instance.set(token);
logger.trace(Thread.currentThread().getName()+" ) calling create "+path);
if (pathUtils.getPath(path) != null) {
@ -166,7 +163,7 @@ public class StorageHubFS extends FuseStubFS {
public int getattr(String path, FileStat stat) {
ScopeProvider.instance.set(scope);
AccessTokenProvider.instance.set(token);
SecurityTokenProvider.instance.set(token);
logger.trace(Thread.currentThread().getName()+" ) calling getattr "+path);
if (Objects.equals(path, "/") || path.contains("Trash") || path.equals("/"+VREFOLDERS_NAME)) {
@ -229,7 +226,7 @@ public class StorageHubFS extends FuseStubFS {
@Override
public int mkdir(String path, @mode_t long mode) {
ScopeProvider.instance.set(scope);
AccessTokenProvider.instance.set(token);
SecurityTokenProvider.instance.set(token);
logger.trace(Thread.currentThread().getName()+" ) calling mkdir");
@ -259,7 +256,7 @@ public class StorageHubFS extends FuseStubFS {
@Override
public int read(String path, Pointer buf, @size_t long size, @off_t long offset, FuseFileInfo fi) {
ScopeProvider.instance.set(scope);
AccessTokenProvider.instance.set(token);
SecurityTokenProvider.instance.set(token);
logger.trace("!!! read called in path {} with size {} and offset {} and pointer address {}",path, size, offset, buf.address());
@ -327,7 +324,7 @@ public class StorageHubFS extends FuseStubFS {
public int readdir(String path, Pointer buf, FuseFillDir filter, @off_t long offset, FuseFileInfo fi) {
logger.trace("readdir called");
ScopeProvider.instance.set(scope);
AccessTokenProvider.instance.set(token);
SecurityTokenProvider.instance.set(token);
logger.trace(Thread.currentThread().getName()+" ) calling readdir "+path);
if (path.contains(".Trash")) return 0;
@ -420,7 +417,7 @@ public class StorageHubFS extends FuseStubFS {
@Override
public int rename(String path, String newName) {
ScopeProvider.instance.set(scope);
AccessTokenProvider.instance.set(token);
SecurityTokenProvider.instance.set(token);
ItemContainer<? extends Item> folder = pathUtils.getPath(path);
if (folder == null) {
@ -458,7 +455,7 @@ public class StorageHubFS extends FuseStubFS {
return -ErrorCodes.EACCES();
ScopeProvider.instance.set(scope);
AccessTokenProvider.instance.set(token);
SecurityTokenProvider.instance.set(token);
ItemContainer<? extends Item> folder = pathUtils.getPath(path);
if (folder == null) {
@ -468,7 +465,7 @@ public class StorageHubFS extends FuseStubFS {
return -ErrorCodes.ENOTDIR();
}
ScopeProvider.instance.set(scope);
AccessTokenProvider.instance.set(token);
SecurityTokenProvider.instance.set(token);
try {
checkSpecialFolderRemove(path);
@ -497,7 +494,7 @@ public class StorageHubFS extends FuseStubFS {
@Override
public int unlink(String path) {
ScopeProvider.instance.set(scope);
AccessTokenProvider.instance.set(token);
SecurityTokenProvider.instance.set(token);
ItemContainer<? extends Item> file = pathUtils.getPath(path);
if (file == null) {
@ -507,7 +504,7 @@ public class StorageHubFS extends FuseStubFS {
return -ErrorCodes.EISDIR();
}
ScopeProvider.instance.set(scope);
AccessTokenProvider.instance.set(token);
SecurityTokenProvider.instance.set(token);
try {
file.delete();
cache.remove(path);
@ -543,7 +540,7 @@ public class StorageHubFS extends FuseStubFS {
logger.info("truncate called {} ",path);
ScopeProvider.instance.set(scope);
AccessTokenProvider.instance.set(token);
SecurityTokenProvider.instance.set(token);
cache.remove(path);
uploadFile(path);
return 0;

View File

@ -1,17 +0,0 @@
<configuration>
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{0}: %msg%n</pattern>
</encoder>
</appender>
<logger name="org.gcube.data.access.storagehub.fs" level="WARN" />
<logger name="org.gcube" level="WARN" />
<root level="WARN">
<appender-ref ref="STDOUT" />
</root>
</configuration>

View File

@ -11,7 +11,7 @@ public class FuseTest {
@Test
public void mount() {
StorageHubFS memfs = new StorageHubFS("AccessToken","/gcube");
StorageHubFS memfs = new StorageHubFS("b7c80297-e4ed-42ab-ab42-fdc0b8b0eabf-98187548","/gcube");
try {
String path;
switch (Platform.getNativePlatform().getOS()) {

View File

@ -7,7 +7,7 @@
</appender>
<logger name="org.gcube.data.access.storagehub.fs" level="WARN" />
<logger name="org.gcube.data.access.storagehub.fs" level="TRACE" />
<logger name="org.gcube" level="WARN" />
<root level="WARN">