GUACAMOLE-5: Expose session as a REST resource. Refactor /api/data to /api/session/data.

This commit is contained in:
Michael Jumper
2016-07-12 16:57:29 -07:00
parent 1aa256b26c
commit c586d1840d
11 changed files with 177 additions and 45 deletions

View File

@@ -20,7 +20,7 @@
package org.apache.guacamole.rest; package org.apache.guacamole.rest;
import org.apache.guacamole.rest.session.UserContextResourceFactory; import org.apache.guacamole.rest.session.UserContextResourceFactory;
import org.apache.guacamole.rest.session.SessionDataRESTService; import org.apache.guacamole.rest.session.SessionRESTService;
import com.google.inject.Scopes; import com.google.inject.Scopes;
import com.google.inject.assistedinject.FactoryModuleBuilder; import com.google.inject.assistedinject.FactoryModuleBuilder;
import com.google.inject.matcher.Matchers; import com.google.inject.matcher.Matchers;
@@ -38,6 +38,7 @@ import org.apache.guacamole.rest.connection.ConnectionModule;
import org.apache.guacamole.rest.connectiongroup.ConnectionGroupModule; import org.apache.guacamole.rest.connectiongroup.ConnectionGroupModule;
import org.apache.guacamole.rest.language.LanguageRESTService; import org.apache.guacamole.rest.language.LanguageRESTService;
import org.apache.guacamole.rest.patch.PatchRESTService; import org.apache.guacamole.rest.patch.PatchRESTService;
import org.apache.guacamole.rest.session.SessionResourceFactory;
import org.apache.guacamole.rest.tunnel.TunnelRESTService; import org.apache.guacamole.rest.tunnel.TunnelRESTService;
import org.apache.guacamole.rest.user.UserModule; import org.apache.guacamole.rest.user.UserModule;
@@ -92,7 +93,8 @@ public class RESTServiceModule extends ServletModule {
bind(TunnelRESTService.class); bind(TunnelRESTService.class);
// Root-level resources // Root-level resources
bind(SessionDataRESTService.class); bind(SessionRESTService.class);
install(new FactoryModuleBuilder().build(SessionResourceFactory.class));
install(new FactoryModuleBuilder().build(UserContextResourceFactory.class)); install(new FactoryModuleBuilder().build(UserContextResourceFactory.class));
// Resources below root // Resources below root

View File

@@ -0,0 +1,81 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.guacamole.rest.session;
import com.google.inject.Inject;
import javax.ws.rs.Consumes;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.QueryParam;
import javax.ws.rs.core.MediaType;
import org.apache.guacamole.GuacamoleException;
import org.apache.guacamole.GuacamoleSession;
import org.apache.guacamole.rest.auth.AuthenticationService;
/**
* A REST service which exposes all data associated with Guacamole users'
* sessions.
*
* @author Michael Jumper
*/
@Path("/session")
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
public class SessionRESTService {
/**
* A service for authenticating users from auth tokens.
*/
@Inject
private AuthenticationService authenticationService;
/**
* Factory for creating SessionResources which expose a given
* GuacamoleSession.
*/
@Inject
private SessionResourceFactory sessionResourceFactory;
/**
* Retrieves a resource representing the GuacamoleSession associated with
* the given authentication token.
*
* @param authToken
* The authentication token that is used to authenticate the user
* having the session being exposed.
*
* @return
* A resource representing the GuacamoleSession associated with the
* given authentication token.
*
* @throws GuacamoleException
* If the authentication token is invalid.
*/
@Path("/")
public SessionResource getSessionResource(@QueryParam("token") String authToken)
throws GuacamoleException {
// Return a resource exposing the retrieved session
GuacamoleSession session = authenticationService.getGuacamoleSession(authToken);
return sessionResourceFactory.create(session);
}
}

View File

@@ -20,34 +20,32 @@
package org.apache.guacamole.rest.session; package org.apache.guacamole.rest.session;
import com.google.inject.Inject; import com.google.inject.Inject;
import com.google.inject.assistedinject.Assisted;
import com.google.inject.assistedinject.AssistedInject;
import javax.ws.rs.Consumes; import javax.ws.rs.Consumes;
import javax.ws.rs.Path; import javax.ws.rs.Path;
import javax.ws.rs.PathParam; import javax.ws.rs.PathParam;
import javax.ws.rs.Produces; import javax.ws.rs.Produces;
import javax.ws.rs.QueryParam;
import javax.ws.rs.core.MediaType; import javax.ws.rs.core.MediaType;
import org.apache.guacamole.GuacamoleException; import org.apache.guacamole.GuacamoleException;
import org.apache.guacamole.GuacamoleSession; import org.apache.guacamole.GuacamoleSession;
import org.apache.guacamole.net.auth.UserContext; import org.apache.guacamole.net.auth.UserContext;
import org.apache.guacamole.rest.ObjectRetrievalService; import org.apache.guacamole.rest.ObjectRetrievalService;
import org.apache.guacamole.rest.auth.AuthenticationService;
/** /**
* A REST service which exposes all data associated with a Guacamole user's * A REST resource which exposes all data associated with a Guacamole user's
* session via the underlying UserContexts. * session via the underlying UserContexts.
* *
* @author Michael Jumper * @author Michael Jumper
*/ */
@Path("/data")
@Produces(MediaType.APPLICATION_JSON) @Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON) @Consumes(MediaType.APPLICATION_JSON)
public class SessionDataRESTService { public class SessionResource {
/** /**
* A service for authenticating users from auth tokens. * The GuacamoleSession being exposed by this SessionResource.
*/ */
@Inject private final GuacamoleSession session;
private AuthenticationService authenticationService;
/** /**
* Service for convenient retrieval of objects. * Service for convenient retrieval of objects.
@@ -62,14 +60,23 @@ public class SessionDataRESTService {
@Inject @Inject
private UserContextResourceFactory userContextResourceFactory; private UserContextResourceFactory userContextResourceFactory;
/**
* Creates a new SessionResource which exposes the data within the given
* GuacamoleSession.
*
* @param session
* The GuacamoleSession which should be exposed through this
* SessionResource.
*/
@AssistedInject
public SessionResource(@Assisted GuacamoleSession session) {
this.session = session;
}
/** /**
* Retrieves a resource representing the UserContext associated with the * Retrieves a resource representing the UserContext associated with the
* AuthenticationProvider having the given identifier. * AuthenticationProvider having the given identifier.
* *
* @param authToken
* The authentication token that is used to authenticate the user
* performing the operation.
*
* @param authProviderIdentifier * @param authProviderIdentifier
* The unique identifier of the AuthenticationProvider associated with * The unique identifier of the AuthenticationProvider associated with
* the UserContext being retrieved. * the UserContext being retrieved.
@@ -79,17 +86,14 @@ public class SessionDataRESTService {
* AuthenticationProvider having the given identifier. * AuthenticationProvider having the given identifier.
* *
* @throws GuacamoleException * @throws GuacamoleException
* If the authentication token or AuthenticationProvider identifier are * If the AuthenticationProvider identifier is invalid.
* invalid.
*/ */
@Path("{dataSource}") @Path("data/{dataSource}")
public UserContextResource getUserContextResource( public UserContextResource getUserContextResource(
@QueryParam("token") String authToken,
@PathParam("dataSource") String authProviderIdentifier) @PathParam("dataSource") String authProviderIdentifier)
throws GuacamoleException { throws GuacamoleException {
// Pull UserContext defined by the given auth provider identifier // Pull UserContext defined by the given auth provider identifier
GuacamoleSession session = authenticationService.getGuacamoleSession(authToken);
UserContext userContext = retrievalService.retrieveUserContext(session, authProviderIdentifier); UserContext userContext = retrievalService.retrieveUserContext(session, authProviderIdentifier);
// Return a resource exposing the retrieved UserContext // Return a resource exposing the retrieved UserContext

View File

@@ -0,0 +1,45 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.guacamole.rest.session;
import org.apache.guacamole.GuacamoleSession;
/**
* Factory which creates resources that expose the contents of a given
* GuacamoleSession.
*
* @author Michael Jumper
*/
public interface SessionResourceFactory {
/**
* Creates a new SessionResource which exposes the contents of the
* given GuacamoleSession.
*
* @param session
* The GuacamoleSession whose contents should be exposed.
*
* @return
* A new SessionResource which exposes the contents of the given
* GuacamoleSession.
*/
SessionResource create(GuacamoleSession session);
}

View File

@@ -60,7 +60,7 @@ angular.module('rest').factory('activeConnectionService', ['$injector',
// Retrieve tunnels // Retrieve tunnels
return $http({ return $http({
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/activeConnections', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/activeConnections',
params : httpParameters params : httpParameters
}); });
@@ -159,7 +159,7 @@ angular.module('rest').factory('activeConnectionService', ['$injector',
// Perform active connection deletion via PATCH // Perform active connection deletion via PATCH
return $http({ return $http({
method : 'PATCH', method : 'PATCH',
url : 'api/data/' + encodeURIComponent(dataSource) + '/activeConnections', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/activeConnections',
params : httpParameters, params : httpParameters,
data : activeConnectionPatch data : activeConnectionPatch
}); });

View File

@@ -73,7 +73,7 @@ angular.module('rest').factory('connectionGroupService', ['$injector',
return $http({ return $http({
cache : cacheService.connections, cache : cacheService.connections,
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/connectionGroups/' + encodeURIComponent(connectionGroupID) + '/tree', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/connectionGroups/' + encodeURIComponent(connectionGroupID) + '/tree',
params : httpParameters params : httpParameters
}); });
@@ -106,7 +106,7 @@ angular.module('rest').factory('connectionGroupService', ['$injector',
return $http({ return $http({
cache : cacheService.connections, cache : cacheService.connections,
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/connectionGroups/' + encodeURIComponent(connectionGroupID), url : 'api/session/data/' + encodeURIComponent(dataSource) + '/connectionGroups/' + encodeURIComponent(connectionGroupID),
params : httpParameters params : httpParameters
}); });
@@ -136,7 +136,7 @@ angular.module('rest').factory('connectionGroupService', ['$injector',
if (!connectionGroup.identifier) { if (!connectionGroup.identifier) {
return $http({ return $http({
method : 'POST', method : 'POST',
url : 'api/data/' + encodeURIComponent(dataSource) + '/connectionGroups', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/connectionGroups',
params : httpParameters, params : httpParameters,
data : connectionGroup data : connectionGroup
}) })
@@ -152,7 +152,7 @@ angular.module('rest').factory('connectionGroupService', ['$injector',
else { else {
return $http({ return $http({
method : 'PUT', method : 'PUT',
url : 'api/data/' + encodeURIComponent(dataSource) + '/connectionGroups/' + encodeURIComponent(connectionGroup.identifier), url : 'api/session/data/' + encodeURIComponent(dataSource) + '/connectionGroups/' + encodeURIComponent(connectionGroup.identifier),
params : httpParameters, params : httpParameters,
data : connectionGroup data : connectionGroup
}) })
@@ -185,7 +185,7 @@ angular.module('rest').factory('connectionGroupService', ['$injector',
// Delete connection group // Delete connection group
return $http({ return $http({
method : 'DELETE', method : 'DELETE',
url : 'api/data/' + encodeURIComponent(dataSource) + '/connectionGroups/' + encodeURIComponent(connectionGroup.identifier), url : 'api/session/data/' + encodeURIComponent(dataSource) + '/connectionGroups/' + encodeURIComponent(connectionGroup.identifier),
params : httpParameters params : httpParameters
}) })

View File

@@ -56,7 +56,7 @@ angular.module('rest').factory('connectionService', ['$injector',
return $http({ return $http({
cache : cacheService.connections, cache : cacheService.connections,
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/connections/' + encodeURIComponent(id), url : 'api/session/data/' + encodeURIComponent(dataSource) + '/connections/' + encodeURIComponent(id),
params : httpParameters params : httpParameters
}); });
@@ -84,7 +84,7 @@ angular.module('rest').factory('connectionService', ['$injector',
// Retrieve connection history // Retrieve connection history
return $http({ return $http({
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/connections/' + encodeURIComponent(id) + '/history', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/connections/' + encodeURIComponent(id) + '/history',
params : httpParameters params : httpParameters
}); });
@@ -113,7 +113,7 @@ angular.module('rest').factory('connectionService', ['$injector',
return $http({ return $http({
cache : cacheService.connections, cache : cacheService.connections,
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/connections/' + encodeURIComponent(id) + '/parameters', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/connections/' + encodeURIComponent(id) + '/parameters',
params : httpParameters params : httpParameters
}); });
@@ -143,7 +143,7 @@ angular.module('rest').factory('connectionService', ['$injector',
if (!connection.identifier) { if (!connection.identifier) {
return $http({ return $http({
method : 'POST', method : 'POST',
url : 'api/data/' + encodeURIComponent(dataSource) + '/connections', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/connections',
params : httpParameters, params : httpParameters,
data : connection data : connection
}) })
@@ -159,7 +159,7 @@ angular.module('rest').factory('connectionService', ['$injector',
else { else {
return $http({ return $http({
method : 'PUT', method : 'PUT',
url : 'api/data/' + encodeURIComponent(dataSource) + '/connections/' + encodeURIComponent(connection.identifier), url : 'api/session/data/' + encodeURIComponent(dataSource) + '/connections/' + encodeURIComponent(connection.identifier),
params : httpParameters, params : httpParameters,
data : connection data : connection
}) })
@@ -192,7 +192,7 @@ angular.module('rest').factory('connectionService', ['$injector',
// Delete connection // Delete connection
return $http({ return $http({
method : 'DELETE', method : 'DELETE',
url : 'api/data/' + encodeURIComponent(dataSource) + '/connections/' + encodeURIComponent(connection.identifier), url : 'api/session/data/' + encodeURIComponent(dataSource) + '/connections/' + encodeURIComponent(connection.identifier),
params : httpParameters params : httpParameters
}) })

View File

@@ -76,7 +76,7 @@ angular.module('rest').factory('historyService', ['$injector',
// Retrieve connection history // Retrieve connection history
return $http({ return $http({
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/history/connections', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/history/connections',
params : httpParameters params : httpParameters
}); });

View File

@@ -62,7 +62,7 @@ angular.module('rest').factory('permissionService', ['$injector',
return $http({ return $http({
cache : cacheService.users, cache : cacheService.users,
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/users/' + encodeURIComponent(userID) + '/permissions', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/users/' + encodeURIComponent(userID) + '/permissions',
params : httpParameters params : httpParameters
}); });
@@ -235,7 +235,7 @@ angular.module('rest').factory('permissionService', ['$injector',
// Patch user permissions // Patch user permissions
return $http({ return $http({
method : 'PATCH', method : 'PATCH',
url : 'api/data/' + encodeURIComponent(dataSource) + '/users/' + encodeURIComponent(userID) + '/permissions', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/users/' + encodeURIComponent(userID) + '/permissions',
params : httpParameters, params : httpParameters,
data : permissionPatch data : permissionPatch
}) })

View File

@@ -58,7 +58,7 @@ angular.module('rest').factory('schemaService', ['$injector',
return $http({ return $http({
cache : cacheService.schema, cache : cacheService.schema,
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/schema/userAttributes', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/schema/userAttributes',
params : httpParameters params : httpParameters
}); });
@@ -92,7 +92,7 @@ angular.module('rest').factory('schemaService', ['$injector',
return $http({ return $http({
cache : cacheService.schema, cache : cacheService.schema,
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/schema/connectionAttributes', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/schema/connectionAttributes',
params : httpParameters params : httpParameters
}); });
@@ -126,7 +126,7 @@ angular.module('rest').factory('schemaService', ['$injector',
return $http({ return $http({
cache : cacheService.schema, cache : cacheService.schema,
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/schema/connectionGroupAttributes', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/schema/connectionGroupAttributes',
params : httpParameters params : httpParameters
}); });
@@ -157,7 +157,7 @@ angular.module('rest').factory('schemaService', ['$injector',
return $http({ return $http({
cache : cacheService.schema, cache : cacheService.schema,
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/schema/protocols', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/schema/protocols',
params : httpParameters params : httpParameters
}); });

View File

@@ -70,7 +70,7 @@ angular.module('rest').factory('userService', ['$injector',
return $http({ return $http({
cache : cacheService.users, cache : cacheService.users,
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/users', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/users',
params : httpParameters params : httpParameters
}); });
@@ -103,7 +103,7 @@ angular.module('rest').factory('userService', ['$injector',
return $http({ return $http({
cache : cacheService.users, cache : cacheService.users,
method : 'GET', method : 'GET',
url : 'api/data/' + encodeURIComponent(dataSource) + '/users/' + encodeURIComponent(username), url : 'api/session/data/' + encodeURIComponent(dataSource) + '/users/' + encodeURIComponent(username),
params : httpParameters params : httpParameters
}); });
@@ -135,7 +135,7 @@ angular.module('rest').factory('userService', ['$injector',
// Delete user // Delete user
return $http({ return $http({
method : 'DELETE', method : 'DELETE',
url : 'api/data/' + encodeURIComponent(dataSource) + '/users/' + encodeURIComponent(user.username), url : 'api/session/data/' + encodeURIComponent(dataSource) + '/users/' + encodeURIComponent(user.username),
params : httpParameters params : httpParameters
}) })
@@ -173,7 +173,7 @@ angular.module('rest').factory('userService', ['$injector',
// Create user // Create user
return $http({ return $http({
method : 'POST', method : 'POST',
url : 'api/data/' + encodeURIComponent(dataSource) + '/users', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/users',
params : httpParameters, params : httpParameters,
data : user data : user
}) })
@@ -211,7 +211,7 @@ angular.module('rest').factory('userService', ['$injector',
// Update user // Update user
return $http({ return $http({
method : 'PUT', method : 'PUT',
url : 'api/data/' + encodeURIComponent(dataSource) + '/users/' + encodeURIComponent(user.username), url : 'api/session/data/' + encodeURIComponent(dataSource) + '/users/' + encodeURIComponent(user.username),
params : httpParameters, params : httpParameters,
data : user data : user
}) })
@@ -256,7 +256,7 @@ angular.module('rest').factory('userService', ['$injector',
// Update user password // Update user password
return $http({ return $http({
method : 'PUT', method : 'PUT',
url : 'api/data/' + encodeURIComponent(dataSource) + '/users/' + encodeURIComponent(username) + '/password', url : 'api/session/data/' + encodeURIComponent(dataSource) + '/users/' + encodeURIComponent(username) + '/password',
params : httpParameters, params : httpParameters,
data : new UserPasswordUpdate({ data : new UserPasswordUpdate({
oldPassword : oldPassword, oldPassword : oldPassword,