/*
- * Copyright 2011-2012 GRNET S.A. All rights reserved.
+ * Copyright 2011-2013 GRNET S.A. All rights reserved.
*
* Redistribution and use in source and binary forms, with or
* without modification, are permitted provided that the following
* Entry point classes define <code>onModuleLoad()</code>.
*/
public class Pithos implements EntryPoint, ResizeHandler {
+ private static final boolean IsLOGEnabled = false;
+ public static final boolean IsDetailedHTTPLOGEnabled = true;
+ public static final boolean IsFullResponseBodyLOGEnabled = true;
+ private static final boolean EnableScheduledRefresh = true; // Make false only for debugging purposes.
+
+ public static final Set<String> HTTPHeadersToIgnoreInLOG = new HashSet<String>();
+ static {
+ HTTPHeadersToIgnoreInLOG.add(Const.HTTP_HEADER_CONNECTION);
+ HTTPHeadersToIgnoreInLOG.add(Const.HTTP_HEADER_DATE);
+ HTTPHeadersToIgnoreInLOG.add(Const.HTTP_HEADER_KEEP_ALIVE);
+ HTTPHeadersToIgnoreInLOG.add(Const.HTTP_HEADER_SERVER);
+ HTTPHeadersToIgnoreInLOG.add(Const.HTTP_HEADER_VARY);
+ HTTPHeadersToIgnoreInLOG.add(Const.IF_MODIFIED_SINCE);
+ }
public static final Configuration config = GWT.create(Configuration.class);
+ public static final String CONFIG_API_PATH = config.apiPath();
+ static {
+ LOG("CONFIG_API_PATH = ", CONFIG_API_PATH);
+ }
+
+ public static final Dictionary otherProperties = Dictionary.getDictionary(Const.OTHER_PROPERTIES);
+ public static String getFromOtherPropertiesOrDefault(String key, String def) {
+ try {
+ final String value = otherProperties.get(key);
+ return value == null ? def : value;
+ }
+ catch(Exception e) {
+ return def;
+ }
+ }
+
+ public static String getFromOtherPropertiesOrNull(String key) {
+ return getFromOtherPropertiesOrDefault(key, null);
+ }
+
+ public static final String OTHERPROPS_STORAGE_API_URL = getFromOtherPropertiesOrNull("STORAGE_API_URL");
+ public static final String OTHERPROPS_USER_CATALOGS_API_URL = getFromOtherPropertiesOrNull("USER_CATALOGS_API_URL");
+ static {
+ LOG("STORAGE_API_URL = ", OTHERPROPS_STORAGE_API_URL);
+ LOG("USER_CATALOGS_API_URL = ", OTHERPROPS_USER_CATALOGS_API_URL);
+ }
+
+ public static final String STORAGE_API_URL;
+ static {
+ if(OTHERPROPS_STORAGE_API_URL != null) {
+ STORAGE_API_URL = OTHERPROPS_STORAGE_API_URL;
+ }
+ else if(CONFIG_API_PATH != null) {
+ STORAGE_API_URL = CONFIG_API_PATH;
+ }
+ else {
+ throw new RuntimeException("Unknown STORAGE_API_URL");
+ }
+
+ LOG("Computed STORAGE_API_URL = ", STORAGE_API_URL);
+ }
+
+ public static final String STORAGE_VIEW_URL;
+ static {
+ final String viewURL = getFromOtherPropertiesOrNull("STORAGE_VIEW_URL");
+ if(viewURL != null) {
+ STORAGE_VIEW_URL = viewURL;
+ }
+ else {
+ STORAGE_VIEW_URL = STORAGE_API_URL;
+ }
+
+ LOG("Computed STORAGE_VIEW_URL = ", STORAGE_VIEW_URL);
+ }
+
+ public static final String PUBLIC_LINK_VIEW_PREFIX = getFromOtherPropertiesOrDefault("PUBLIC_LINK_VIEW_PREFIX", "");
+
+ public static final String USER_CATALOGS_API_URL;
+ static {
+ if(OTHERPROPS_USER_CATALOGS_API_URL != null) {
+ USER_CATALOGS_API_URL = OTHERPROPS_USER_CATALOGS_API_URL;
+ }
+ else if(OTHERPROPS_STORAGE_API_URL != null) {
+ throw new RuntimeException("STORAGE_API_URL is defined but USER_CATALOGS_API_URL is not");
+ }
+ else {
+ // https://server.com/v1/ --> https://server.com
+ String url = CONFIG_API_PATH;
+ url = Helpers.stripTrailing(url, "/");
+ url = Helpers.upToIncludingLastPart(url, "/");
+ url = Helpers.stripTrailing(url, "/");
+ url = url + "/user_catalogs";
+
+ USER_CATALOGS_API_URL = url;
+
+ LOG("Computed USER_CATALOGS_API_URL = ", USER_CATALOGS_API_URL);
+ }
+ }
public interface Style extends CssResource {
String commandAnchor();
return displayName == null ? getUserID() : displayName;
}
- public boolean hasUserDisplayNameForID(String userID) {
+ public boolean hasDisplayNameForUserID(String userID) {
return userCatalogs.getDisplayName(userID) != null;
}
- public String getUserDisplayNameForID(String userID) {
+ public boolean hasIDForUserDisplayName(String userDisplayName) {
+ return userCatalogs.getID(userDisplayName) != null;
+ }
+
+ public String getDisplayNameForUserID(String userID) {
return userCatalogs.getDisplayName(userID);
}
- public String getUserIDForDisplayName(String displayName) {
- return userCatalogs.getUserID(displayName);
+ public String getIDForUserDisplayName(String userDisplayName) {
+ return userCatalogs.getID(userDisplayName);
}
- public List<String> getUserDisplayNamesForIDs(List<String> userIDs) {
+ public List<String> getDisplayNamesForUserIDs(List<String> userIDs) {
if(userIDs == null) {
userIDs = new ArrayList<String>();
}
final List<String> userDisplayNames = new ArrayList<String>();
for(String userID : userIDs) {
- final String displayName = getUserDisplayNameForID(userID);
+ final String displayName = getDisplayNameForUserID(userID);
userDisplayNames.add(displayName);
}
private String userID = null;
/**
- * Hold mappings from user UUIDs to emails and vice-versa.
+ * Holds mappings from user UUIDs to emails and vice-versa.
*/
private UserCatalogs userCatalogs = new UserCatalogs();
}
static native void __ConsoleLog(String message) /*-{
- try {
- console.log(message);
- } catch (e) {
- }
+ try { console.log(message); } catch (e) {}
}-*/;
- public static void LOG(String ...args) {
+ public static void LOGError(Throwable error, StringBuilder sb) {
+ if(!isLOGEnabled()) { return; }
+
+ sb.append("\nException: [" + error.toString().replace("\n", "\n ") + "]");
+ Throwable cause = error.getCause();
+ if(cause != null) {
+ sb.append("\nCauses:\n");
+ while(cause != null) {
+ sb.append(" ");
+ sb.append("[" + cause.toString().replace("\n", "\n ") + "]");
+ sb.append("\n");
+ cause = cause.getCause();
+ }
+ }
+ else {
+ sb.append("\n");
+ }
+
+ StackTraceElement[] stackTrace = error.getStackTrace();
+ sb.append("Stack trace (" + stackTrace.length + " elements):\n");
+ for(int i = 0; i < stackTrace.length; i++) {
+ StackTraceElement errorElem = stackTrace[i];
+ sb.append(" [" + i + "] ");
+ sb.append(errorElem.toString());
+ sb.append("\n");
+ }
+ }
+
+ public static void LOGError(Throwable error) {
+ if(!isLOGEnabled()) { return; }
+
+ final StringBuilder sb = new StringBuilder();
+ LOGError(error, sb);
+ if(sb.length() > 0) {
+ __ConsoleLog(sb.toString());
+ }
+ }
+
+ public static boolean isLOGEnabled() {
+ return IsLOGEnabled;
+ }
+
+ public static void LOG(Object ...args) {
+ if(!isLOGEnabled()) { return; }
+
final StringBuilder sb = new StringBuilder();
- for(String arg : args) {
- sb.append(arg);
+ for(Object arg : args) {
+ if(arg instanceof Throwable) {
+ LOGError((Throwable) arg, sb);
+ }
+ else {
+ sb.append(arg);
+ }
}
+
if(sb.length() > 0) {
__ConsoleLog(sb.toString());
}
}
private void initialize() {
+ userCatalogs.updateWithIDAndName("*", "All Pithos users");
+
lastModified = new Date(); //Initialize if-modified-since value with now.
resources.pithosCss().ensureInjected();
boolean bareContent = Window.Location.getParameter("noframe") != null;
- String contentWidth = bareContent ? Const.PERCENT_100 : "75%";
+ String contentWidth = bareContent ? Const.PERCENT_100 : Const.PERCENT_75;
VerticalPanel outer = new VerticalPanel();
outer.setWidth(Const.PERCENT_100);
Scheduler.get().scheduleDeferred(new ScheduledCommand() {
@Override
public void execute() {
+ LOG("Pithos::initialize() Calling Pithos::fetchAccount()");
fetchAccount(new Command() {
@Override
});
}
- public void scheduleResfresh() {
+ public void scheduleRefresh() {
+ if(!Pithos.EnableScheduledRefresh) { return; }
+
Scheduler.get().scheduleFixedDelay(new RepeatingCommand() {
@Override
return true;
}
- HeadRequest<Folder> head = new HeadRequest<Folder>(Folder.class, getApiPath(), f.getOwnerID(), "/" + f.getContainer()) {
+ HeadRequest<Folder> head = new HeadRequest<Folder>(Folder.class, getStorageAPIURL(), f.getOwnerID(), "/" + f.getContainer()) {
@Override
public void onSuccess(Folder _result) {
@Override
public void execute() {
- scheduleResfresh();
+ scheduleRefresh();
}
}, false);
@Override
public void execute() {
- scheduleResfresh();
+ scheduleRefresh();
}
});
}
else {
- scheduleResfresh();
+ scheduleRefresh();
}
}
@Override
public void onError(Throwable t) {
if(t instanceof RestException && ((RestException) t).getHttpStatusCode() == HttpStatus.SC_NOT_MODIFIED) {
- scheduleResfresh();
+ scheduleRefresh();
}
else if(retries >= MAX_RETRIES) {
- GWT.log("Error heading folder", t);
+ LOG("Error heading folder. ", t);
setError(t);
if(t instanceof RestException) {
displayError("Error heading folder: " + ((RestException) t).getHttpStatusText());
}
}
else {//retry
- GWT.log("Retry " + retries);
+ LOG("Retry ", retries);
Scheduler.get().scheduleDeferred(this);
}
}
* Parse and store the user credentials to the appropriate fields.
*/
private boolean parseUserCredentials() {
- Configuration conf = (Configuration) GWT.create(Configuration.class);
- Dictionary otherProperties = Dictionary.getDictionary(Const.OTHER_PROPERTIES);
- String cookie = otherProperties.get(Const.AUTH_COOKIE);
+ final String cookie = otherProperties.get(Const.AUTH_COOKIE);
String auth = Cookies.getCookie(cookie);
if(auth == null) {
authenticateUser();
if(auth.endsWith("\"")) {
auth = auth.substring(0, auth.length() - 1);
}
- String[] authSplit = auth.split("\\" + conf.cookieSeparator(), 2);
+ String[] authSplit = auth.split("\\" + config.cookieSeparator(), 2);
if(authSplit.length != 2) {
authenticateUser();
return false;
}
- userID = authSplit[0];
- userToken = authSplit[1];
+ this.userID = authSplit[0];
+ this.userToken = authSplit[1];
String gotoUrl = Window.Location.getParameter("goto");
if(gotoUrl != null && gotoUrl.length() > 0) {
public void fetchAccount(final Command callback) {
String path = "?format=json";
- GetRequest<AccountResource> getAccount = new GetRequest<AccountResource>(AccountResource.class, getApiPath(), userID, path) {
+ GetRequest<AccountResource> getAccount = new GetRequest<AccountResource>(AccountResource.class, getStorageAPIURL(), userID, path) {
@Override
- public void onSuccess(AccountResource _result) {
- account = _result;
+ public void onSuccess(AccountResource accountResource) {
+ account = accountResource;
if(callback != null) {
callback.execute();
}
+
+ final List<String> memberIDs = new ArrayList<String>();
+ final List<Group> groups = account.getGroups();
+ for(Group group : groups) {
+ memberIDs.addAll(group.getMemberIDs());
+ }
+ memberIDs.add(Pithos.this.getUserID());
+
+ final List<String> theUnknown = Pithos.this.filterUserIDsWithUnknownDisplayName(memberIDs);
// Initialize the user catalog
- new UpdateUserCatalogs(Pithos.this, Pithos.this.getUserID()).scheduleDeferred();
+ new UpdateUserCatalogs(Pithos.this, theUnknown).scheduleDeferred();
+ LOG("Called new UpdateUserCatalogs(Pithos.this, theUnknown).scheduleDeferred();");
}
@Override
public void onError(Throwable t) {
- GWT.log("Error getting account", t);
+ LOG("Error getting account", t);
setError(t);
if(t instanceof RestException) {
displayError("Error getting account: " + ((RestException) t).getHttpStatusText());
}
public void updateStatistics() {
- HeadRequest<AccountResource> headAccount = new HeadRequest<AccountResource>(AccountResource.class, getApiPath(), userID, "", account) {
+ HeadRequest<AccountResource> headAccount = new HeadRequest<AccountResource>(AccountResource.class, getStorageAPIURL(), userID, "", account) {
@Override
public void onSuccess(AccountResource _result) {
@Override
public void onError(Throwable t) {
- GWT.log("Error getting account", t);
+ LOG("Error getting account", t);
setError(t);
if(t instanceof RestException) {
displayError("Error getting account: " + ((RestException) t).getHttpStatusText());
protected void createHomeContainer(final AccountResource _account, final Command callback) {
String path = "/" + Const.HOME_CONTAINER;
- PutRequest createPithos = new PutRequest(getApiPath(), getUserID(), path) {
+ PutRequest createPithos = new PutRequest(getStorageAPIURL(), getUserID(), path) {
@Override
public void onSuccess(Resource result) {
if(!_account.hasTrashContainer()) {
@Override
public void onError(Throwable t) {
- GWT.log("Error creating pithos", t);
+ LOG("Error creating pithos", t);
setError(t);
if(t instanceof RestException) {
displayError("Error creating pithos: " + ((RestException) t).getHttpStatusText());
protected void createTrashContainer(final Command callback) {
String path = "/" + Const.TRASH_CONTAINER;
- PutRequest createPithos = new PutRequest(getApiPath(), getUserID(), path) {
+ PutRequest createPithos = new PutRequest(getStorageAPIURL(), getUserID(), path) {
@Override
public void onSuccess(Resource result) {
fetchAccount(callback);
@Override
public void onError(Throwable t) {
- GWT.log("Error creating pithos", t);
+ LOG("Error creating pithos", t);
setError(t);
if(t instanceof RestException) {
displayError("Error creating pithos: " + ((RestException) t).getHttpStatusText());
$doc.body.onselectstart = null;
}-*/;
- /**
- * @return the absolute path of the API root URL
- */
- public String getApiPath() {
- Configuration conf = (Configuration) GWT.create(Configuration.class);
- return conf.apiPath();
+ public static String getStorageAPIURL() {
+ return STORAGE_API_URL;
+ }
+
+ public static String getStorageViewURL() {
+ return STORAGE_VIEW_URL;
+ }
+
+ public static String getUserCatalogsURL() {
+ return USER_CATALOGS_API_URL;
+ }
+
+ public static String getFileViewURL(File file) {
+ return Pithos.getStorageViewURL() + file.getOwnerID() + file.getUri();
}
/**
final PleaseWaitPopup pwp = new PleaseWaitPopup();
pwp.center();
String path = "/" + folder.getContainer() + "/" + folder.getPrefix() + "?delimiter=/" + "&t=" + System.currentTimeMillis();
- DeleteRequest deleteFolder = new DeleteRequest(getApiPath(), folder.getOwnerID(), path) {
+ DeleteRequest deleteFolder = new DeleteRequest(getStorageAPIURL(), folder.getOwnerID(), path) {
@Override
protected void onUnauthorized(Response response) {
@Override
public void onError(Throwable t) {
- GWT.log("", t);
+ LOG(t);
setError(t);
if(t instanceof RestException) {
if(((RestException) t).getHttpStatusCode() != Response.SC_NOT_FOUND) {
if(iter.hasNext()) {
File file = iter.next();
String path = targetUri + "/" + file.getName();
- PutRequest copyFile = new PutRequest(getApiPath(), targetUsername, path) {
+ PutRequest copyFile = new PutRequest(getStorageAPIURL(), targetUsername, path) {
@Override
public void onSuccess(Resource result) {
copyFiles(iter, targetUsername, targetUri, callback);
@Override
public void onError(Throwable t) {
- GWT.log("", t);
+ LOG(t);
setError(t);
if(t instanceof RestException) {
displayError("Unable to copy file: " + ((RestException) t).getHttpStatusText());
public void copyFolder(final Folder f, final String targetUsername, final String targetUri, boolean move, final Command callback) {
String path = targetUri + "?delimiter=/";
- PutRequest copyFolder = new PutRequest(getApiPath(), targetUsername, path) {
+ PutRequest copyFolder = new PutRequest(getStorageAPIURL(), targetUsername, path) {
@Override
public void onSuccess(Resource result) {
if(callback != null) {
@Override
public void onError(Throwable t) {
- GWT.log("", t);
+ LOG(t);
setError(t);
if(t instanceof RestException) {
displayError("Unable to copy folder: " + ((RestException) t).getHttpStatusText());
}
void createMySharedTree() {
+ LOG("Pithos::createMySharedTree()");
mysharedTreeSelectionModel = new SingleSelectionModel<Folder>();
mysharedTreeSelectionModel.addSelectionChangeHandler(new Handler() {
@Override
}
void createOtherSharedTree() {
+ LOG("Pithos::createOtherSharedTree()");
otherSharedTreeSelectionModel = new SingleSelectionModel<Folder>();
otherSharedTreeSelectionModel.addSelectionChangeHandler(new Handler() {
@Override
});
selectionModels.add(otherSharedTreeSelectionModel);
otherSharedTreeViewModel = new OtherSharedTreeViewModel(Pithos.this, otherSharedTreeSelectionModel);
- otherSharedTreeViewModel.initialize(new Command() {
+ // #3784 We show it empty...
+ otherSharedTreeView = new OtherSharedTreeView(otherSharedTreeViewModel, true);
+ trees.insert(otherSharedTreeView, 1);
+ LOG("Pithos::createOtherSharedTree(), initializing otherSharedTreeViewModel with a callback");
+ otherSharedTreeViewModel.initialize(new Command() {
@Override
public void execute() {
- otherSharedTreeView = new OtherSharedTreeView(otherSharedTreeViewModel);
+ // #3784 ... then remove the empty stuff and add a new view with the populated model
+ trees.remove(otherSharedTreeView);
+
+ otherSharedTreeView = new OtherSharedTreeView(otherSharedTreeViewModel, false);
trees.insert(otherSharedTreeView, 1);
treeViews.add(otherSharedTreeView);
- scheduleResfresh();
+ scheduleRefresh();
}
});
}
- public native void log1(String message)/*-{
- $wnd.console.log(message);
- }-*/;
-
public String getErrorData() {
- if(error != null) {
- return error.toString();
+ final StringBuilder sb = new StringBuilder();
+ final String NL = Const.NL;
+ Throwable t = this.error;
+ while(t != null) {
+ sb.append(t.toString());
+ sb.append(NL);
+ StackTraceElement[] traces = t.getStackTrace();
+ for(StackTraceElement trace : traces) {
+ sb.append(" [");
+ sb.append(trace.getClassName());
+ sb.append("::");
+ sb.append(trace.getMethodName());
+ sb.append("() at ");
+ sb.append(trace.getFileName());
+ sb.append(":");
+ sb.append(trace.getLineNumber());
+ sb.append("]");
+ sb.append(NL);
+ }
+ t = t.getCause();
}
- return "";
+
+ return sb.toString();
}
public void setError(Throwable t) {
error = t;
+ LOG(t);
}
public void showRelevantToolbarButtons() {
}
}
else {
- HeadRequest<Folder> headFolder = new HeadRequest<Folder>(Folder.class, getApiPath(), folder.getOwnerID(), folder.getUri(), folder) {
+ HeadRequest<Folder> headFolder = new HeadRequest<Folder>(Folder.class, getStorageAPIURL(), folder.getOwnerID(), folder.getUri(), folder) {
@Override
public void onSuccess(Folder _result) {
if(t instanceof RestException) {
if(((RestException) t).getHttpStatusCode() == Response.SC_NOT_FOUND) {
final String path = folder.getUri();
- PutRequest newFolder = new PutRequest(getApiPath(), folder.getOwnerID(), path) {
+ PutRequest newFolder = new PutRequest(getStorageAPIURL(), folder.getOwnerID(), path) {
@Override
public void onSuccess(Resource _result) {
scheduleFolderHeadCommand(folder, callback);
@Override
public void onError(Throwable _t) {
- GWT.log("", _t);
setError(_t);
if(_t instanceof RestException) {
displayError("Unable to create folder: " + ((RestException) _t).getHttpStatusText());
displayError("System error heading folder: " + t.getMessage());
}
- GWT.log("Error heading folder", t);
+ LOG("Error heading folder", t);
setError(t);
}
}
public void scheduleFileHeadCommand(File f, final Command callback) {
- HeadRequest<File> headFile = new HeadRequest<File>(File.class, getApiPath(), f.getOwnerID(), f.getUri(), f) {
+ HeadRequest<File> headFile = new HeadRequest<File>(File.class, getStorageAPIURL(), f.getOwnerID(), f.getUri(), f) {
@Override
public void onSuccess(File _result) {
@Override
public void onError(Throwable t) {
- GWT.log("Error heading file", t);
+ LOG("Error heading file", t);
setError(t);
if(t instanceof RestException) {
displayError("Error heading file: " + ((RestException) t).getHttpStatusText());
fileList.selectByUrl(selectedUrls);
}
- public void emptyContainer(final Folder container) {
+ public void purgeContainer(final Folder container) {
String path = "/" + container.getName() + "?delimiter=/";
- DeleteRequest delete = new DeleteRequest(getApiPath(), getUserID(), path) {
+ DeleteRequest delete = new DeleteRequest(getStorageAPIURL(), getUserID(), path) {
@Override
protected void onUnauthorized(Response response) {
@Override
public void onError(Throwable t) {
- GWT.log("Error deleting trash", t);
+ LOG("Error deleting trash", t);
setError(t);
if(t instanceof RestException) {
displayError("Error deleting trash: " + ((RestException) t).getHttpStatusText());
projects / pithos-web-client / blobdiff