public class ConnectionHandler extends java.lang.Object implements IGeppettoManagerCallbackListener
Modifier and Type | Class and Description |
---|---|
private class |
ConnectionHandler.Error |
(package private) class |
ConnectionHandler.PersistedProject |
private class |
ConnectionHandler.UserPrivilegesDT |
Modifier and Type | Field and Description |
---|---|
private IGeppettoManager |
geppettoManager |
private IGeppettoProject |
geppettoProject |
private static Log |
logger |
private SimulationServerConfig |
simulationServerConfig |
private WebsocketConnection |
websocketConnection |
Modifier | Constructor and Description |
---|---|
protected |
ConnectionHandler(WebsocketConnection websocketConnection,
IGeppettoManager geppettoManager) |
Modifier and Type | Method and Description |
---|---|
void |
checkExperimentStatus(java.lang.String requestID,
java.lang.String projectId) |
void |
checkUserPrivileges(java.lang.String requestID)
Sends to the client login user privileges
|
void |
cloneExperiment(java.lang.String requestID,
long projectId,
long experimentID) |
void |
closeProject() |
void |
deleteExperiment(java.lang.String requestID,
long experimentId,
long projectId) |
void |
downloadModel(java.lang.String requestID,
java.lang.String aspectInstancePath,
java.lang.String format,
long experimentID,
long projectId) |
void |
downloadProject(java.lang.String requestID,
long projectId) |
void |
downloadResults(java.lang.String requestID,
java.lang.String aspectPath,
long projectId,
long experimentId,
java.lang.String format) |
private void |
error(java.lang.Exception exception,
java.lang.String errorMessage) |
void |
experimentError(java.lang.String titleMessage,
java.lang.String logMessage,
java.lang.Exception exception,
IExperiment experiment) |
void |
fetchVariable(java.lang.String requestID,
java.lang.Long projectId,
java.lang.String dataSourceId,
java.lang.String variableId) |
<T> T |
fromJSON(<any> type,
java.lang.String jsonPacket) |
void |
getDropboxToken(java.lang.String requestID) |
void |
getExperimentState(java.lang.String requestID,
long experimentId,
long projectId,
java.util.List<java.lang.String> variables) |
private Gson |
getGson() |
SimulationServerConfig |
getSimulationServerConfig() |
void |
getSupportedOuputs(java.lang.String requestID,
java.lang.String aspectInstancePath,
long experimentID,
long projectId) |
void |
getVersionNumber(java.lang.String requestID) |
private void |
info(java.lang.String requestID,
java.lang.String message) |
void |
linkDropBox(java.lang.String requestID,
java.lang.String key) |
void |
loadExperiment(java.lang.String requestID,
long experimentID,
long projectId) |
void |
loadGeppettoProject(java.lang.String requestID,
IGeppettoProject geppettoProject,
long experimentId) |
void |
loadProjectFromContent(java.lang.String requestID,
java.lang.String projectContent) |
void |
loadProjectFromId(java.lang.String requestID,
long projectId,
long experimentId) |
void |
loadProjectFromURL(java.lang.String requestID,
java.lang.String urlString) |
void |
makeProjectPublic(java.lang.String requestID,
long projectId,
boolean isPublic) |
void |
newExperiment(java.lang.String requestID,
long projectId) |
void |
newExperimentBatch(java.lang.String requestID,
long projectId,
WebsocketConnection.BatchExperiment batchExperiment)
Creates new experiments in a batch
|
void |
persistProject(java.lang.String requestID,
long projectId) |
void |
resolveImportType(java.lang.String requestID,
java.lang.Long projectId,
java.util.List<java.lang.String> typePaths) |
void |
resolveImportValue(java.lang.String requestID,
java.lang.Long projectId,
java.lang.Long experimentId,
java.lang.String path) |
private IExperiment |
retrieveExperiment(long experimentID,
IGeppettoProject geppettoProject) |
private IGeppettoProject |
retrieveGeppettoProject(long projectId) |
void |
runExperiment(java.lang.String requestID,
long experimentID,
long projectId)
Run the Experiment
|
void |
runQuery(java.lang.String requestID,
java.lang.Long projectId,
java.util.List<RunnableQuery> runnableQueries) |
void |
runQueryCount(java.lang.String requestID,
java.lang.Long projectId,
java.util.List<RunnableQuery> runnableQueries) |
void |
saveExperimentProperties(java.lang.String requestID,
long projectId,
long experimentId,
java.util.Map<java.lang.String,java.lang.String> properties) |
void |
saveProjectProperties(java.lang.String requestID,
long projectId,
java.util.Map<java.lang.String,java.lang.String> properties) |
void |
sendDataSourceResults(java.lang.String requestID,
java.lang.String dataSourceName,
java.net.URL url,
WebsocketConnection visitor) |
void |
sendScriptData(java.lang.String requestID,
java.lang.Long projectId,
java.lang.String urlString,
WebsocketConnection visitor) |
void |
setConnectionProject(IGeppettoProject geppettoProject) |
void |
setExperimentView(java.lang.String requestID,
java.lang.String view,
long projectId,
long experimentID) |
void |
setParameters(java.lang.String requestID,
java.util.Map<java.lang.String,java.lang.String> modelParameters,
long projectId,
long experimentID) |
void |
setWatchedVariables(java.lang.String requestID,
java.util.List<java.lang.String> variables,
long experimentID,
long projectId,
boolean watch)
Adds watch lists with variables to be watched
|
void |
unLinkDropBox(java.lang.String requestID,
java.lang.String key) |
void |
uploadModel(java.lang.String aspectPath,
long projectId,
long experimentId,
java.lang.String format) |
void |
uploadResults(java.lang.String aspectPath,
long projectId,
long experimentId,
java.lang.String format) |
private static Log logger
private SimulationServerConfig simulationServerConfig
private WebsocketConnection websocketConnection
private IGeppettoManager geppettoManager
private IGeppettoProject geppettoProject
protected ConnectionHandler(WebsocketConnection websocketConnection, IGeppettoManager geppettoManager)
websocketConnection
- geppettoManager
- public void loadProjectFromId(java.lang.String requestID, long projectId, long experimentId)
requestID
- projectId
- public void loadProjectFromContent(java.lang.String requestID, java.lang.String projectContent)
requestID
- projectContent
- public void loadProjectFromURL(java.lang.String requestID, java.lang.String urlString)
requestID
- urlString
- public void loadGeppettoProject(java.lang.String requestID, IGeppettoProject geppettoProject, long experimentId)
requestID
- geppettoProject
- public void newExperiment(java.lang.String requestID, long projectId)
projectId
- public void newExperimentBatch(java.lang.String requestID, long projectId, WebsocketConnection.BatchExperiment batchExperiment)
requestID
- projectId
- batchSize
- - how many experiments we need to createnames
- - experiment namespublic void cloneExperiment(java.lang.String requestID, long projectId, long experimentID)
projectId
- public void loadExperiment(java.lang.String requestID, long experimentID, long projectId)
requestID
- experimentID
- projectId
- public void runExperiment(java.lang.String requestID, long experimentID, long projectId)
public void fetchVariable(java.lang.String requestID, java.lang.Long projectId, java.lang.String dataSourceId, java.lang.String variableId)
requestID
- projectId
- experimentId
- dataSourceId
- variableId
- public void resolveImportType(java.lang.String requestID, java.lang.Long projectId, java.util.List<java.lang.String> typePaths)
requestID
- projectId
- experimentId
- dataSourceServiceId
- variableId
- GeppettoExecutionException
public void runQuery(java.lang.String requestID, java.lang.Long projectId, java.util.List<RunnableQuery> runnableQueries)
requestID
- projectId
- runnableQueryParameters
- public void runQueryCount(java.lang.String requestID, java.lang.Long projectId, java.util.List<RunnableQuery> runnableQueries)
requestID
- projectId
- runnableQueries
- public void resolveImportValue(java.lang.String requestID, java.lang.Long projectId, java.lang.Long experimentId, java.lang.String path)
requestID
- projectId
- experimentId
- path
- public void setWatchedVariables(java.lang.String requestID, java.util.List<java.lang.String> variables, long experimentID, long projectId, boolean watch) throws GeppettoExecutionException, GeppettoInitializationException
requestID
- jsonLists
- GeppettoExecutionException
GeppettoInitializationException
public void getVersionNumber(java.lang.String requestID)
requestID
- public void getExperimentState(java.lang.String requestID, long experimentId, long projectId, java.util.List<java.lang.String> variables)
requestID
- experimentId
- projectId
- variables
- public void downloadModel(java.lang.String requestID, java.lang.String aspectInstancePath, java.lang.String format, long experimentID, long projectId)
requestID
- aspectInstancePath
- format
- public void getSupportedOuputs(java.lang.String requestID, java.lang.String aspectInstancePath, long experimentID, long projectId)
requestID
- aspectInstancePath
- public void sendScriptData(java.lang.String requestID, java.lang.Long projectId, java.lang.String urlString, WebsocketConnection visitor)
requestID
- projectId
- urlString
- visitor
- public void sendDataSourceResults(java.lang.String requestID, java.lang.String dataSourceName, java.net.URL url, WebsocketConnection visitor)
requestID
- url
- visitor
- public void setParameters(java.lang.String requestID, java.util.Map<java.lang.String,java.lang.String> modelParameters, long projectId, long experimentID)
requestID
- modelPath
- modelParameters
- projectId
- experimentID
- public void setExperimentView(java.lang.String requestID, java.lang.String view, long projectId, long experimentID)
requestID
- view
- projectId
- experimentID
- private IExperiment retrieveExperiment(long experimentID, IGeppettoProject geppettoProject)
experimentID
- geppettoProject
- private IGeppettoProject retrieveGeppettoProject(long projectId)
projectId
- public <T> T fromJSON(<any> type, java.lang.String jsonPacket) throws GeppettoExecutionException
type
- jsonPacket
- GeppettoExecutionException
private Gson getGson()
public SimulationServerConfig getSimulationServerConfig()
private void error(java.lang.Exception exception, java.lang.String errorMessage)
exception
- errorMessage
- private void info(java.lang.String requestID, java.lang.String message)
requestID
- exception
- errorMessage
- public void checkExperimentStatus(java.lang.String requestID, java.lang.String projectId)
requestID
- projectId
- public void deleteExperiment(java.lang.String requestID, long experimentId, long projectId)
requestID
- experimentId
- projectId
- public void makeProjectPublic(java.lang.String requestID, long projectId, boolean isPublic)
requestID
- projectId
- public void persistProject(java.lang.String requestID, long projectId)
requestID
- projectId
- public void getDropboxToken(java.lang.String requestID)
public void linkDropBox(java.lang.String requestID, java.lang.String key)
requestID
- key
- public void unLinkDropBox(java.lang.String requestID, java.lang.String key)
requestID
- key
- public void uploadModel(java.lang.String aspectPath, long projectId, long experimentId, java.lang.String format)
aspectPath
- projectId
- experimentId
- format
- public void uploadResults(java.lang.String aspectPath, long projectId, long experimentId, java.lang.String format)
aspectPath
- projectId
- experimentId
- format
- public void downloadResults(java.lang.String requestID, java.lang.String aspectPath, long projectId, long experimentId, java.lang.String format)
requestID
- aspectPath
- projectId
- experimentId
- format
- public void saveProjectProperties(java.lang.String requestID, long projectId, java.util.Map<java.lang.String,java.lang.String> properties)
requestID
- projectId
- properties
- public void saveExperimentProperties(java.lang.String requestID, long projectId, long experimentId, java.util.Map<java.lang.String,java.lang.String> properties)
requestID
- projectId
- experimentId
- properties
- public void closeProject()
public void setConnectionProject(IGeppettoProject geppettoProject) throws GeppettoExecutionException
geppettoProject
- GeppettoExecutionException
public void checkUserPrivileges(java.lang.String requestID)
requestID
- public void experimentError(java.lang.String titleMessage, java.lang.String logMessage, java.lang.Exception exception, IExperiment experiment)
experimentError
in interface IGeppettoManagerCallbackListener
public void downloadProject(java.lang.String requestID, long projectId)