public class SessionManagerImpl extends Object implements SessionManager, SessionCache.StaleCacheListener, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>
ApplicationListener
, which should be
used to keep the Session
instances up-to-date.SessionManager.CreationRequest
Modifier and Type | Field and Description |
---|---|
protected Principal |
asroot
A private session for use only by this instance for running methods via
Executor . |
protected SessionCache |
cache |
protected OmeroContext |
context |
protected long |
defaultTimeToIdle |
protected long |
defaultTimeToLive |
protected Executor |
executor |
protected CounterFactory |
factory |
static String |
GROUP_SUDO_NS |
protected SessionContext |
internalSession
Internal
SessionContext created during init() which is
used for all method calls internal to the session manager (see execute*
methods) |
protected long |
maxUserTimeToIdle |
protected long |
maxUserTimeToLive |
protected PrincipalHolder |
principalHolder |
protected boolean |
readOnly |
protected Roles |
roles |
Constructor and Description |
---|
SessionManagerImpl() |
Modifier and Type | Method and Description |
---|---|
void |
addCallback(String sessionId,
SessionCallback cb) |
int |
close(String uuid)
If reference count for the session is less than 1, close the session.
|
int |
closeAll()
Close all sessions with checking for the necessary reference counts.
|
Session |
copy(Session source) |
Session |
createFromRequest(SessionManager.CreationRequest request) |
protected SessionContext |
createSessionContext(List<?> list,
SessionContext previous)
Takes a snapshot as from
executeSessionContextLookup(ServiceFactory, Principal, Session)
and turns it into a SessionContext instance. |
Share |
createShare(Principal principal,
boolean enabled,
long timeToLive,
String eventType,
String description,
long groupId) |
Session |
createWithAgent(Principal principal,
String agent,
String ip) |
Session |
createWithAgent(Principal _principal,
String credentials,
String agent,
String ip) |
protected void |
define(Session s,
String uuid,
String message,
long started,
long idle,
long live,
String eventType,
String agent,
String ip) |
protected void |
define(Session s,
String uuid,
String message,
long started,
SessionManager.CreationRequest req) |
int |
detach(String uuid)
Allows decrementing the reference count for a session without calling the
actual
SessionManager.close(String) logic. |
protected Map<String,Object> |
environment(String session,
String env) |
boolean |
executePasswordCheck(String name,
String credentials)
Executes a password check using the
Executor framework. |
Session |
find(String uuid) |
List<Session> |
findByUser(String user) |
List<Session> |
findByUserAndAgent(String user,
String... agents)
Returns a non-null, possibly empty list of session instances
belonging to the given user and with one of the given agents.
|
Object |
getCallbackObject(String sessionId,
String name) |
EventContext |
getEventContext(Principal principal)
Provides a partial
EventContext for the current Session . |
Object |
getInput(String session,
String key)
Returns the input environment
Object stored under the given key
or null if none present. |
Object |
getOutput(String session,
String key)
Returns the output environment
Object stored under the given key
or null if none present. |
int |
getReferenceCount(String uuid)
Return the number of client which are presumed to be attached to this
session or throw an exception if there's no such session.
|
Map<String,Map<String,Object>> |
getSessionData()
Return all sessions that are active with associated possibly varying
session data information.
|
SessionStats |
getSessionStats(String uuid)
Return the
SessionStats which are being counted for the given
session or throw an exception if it has been removed. |
List<String> |
getUserRoles(String uuid) |
void |
init()
Initialization method called by the Spring run-time to acquire an initial
Session . |
net.sf.ehcache.Ehcache |
inMemoryCache(String uuid)
Returns after possibly creating an in-memory
cache which
can be used throughout the session. |
Map<String,Object> |
inputEnvironment(String session)
Returns a copy of the input environment.
|
String[] |
notifications(String sessionId) |
void |
onApplicationEvent(org.springframework.context.ApplicationEvent event) |
net.sf.ehcache.Ehcache |
onDiskCache(String uuid)
Returns after possibly creating an on-disk
cache which
can be used throughout the session. |
Map<String,Object> |
outputEnvironment(String session)
Returns a copy of the output environment.
|
void |
prepareReload() |
SessionContext |
reload(SessionContext ctx)
Will be called in a synchronized block by
SessionCache in order
to allow for an update. |
EventContext |
reload(String uuid)
Similar to
SessionManager.getEventContext(Principal) but uses the internal
reload logic to get a fresh representation of the context. |
void |
setApplicationContext(org.springframework.context.ApplicationContext applicationContext) |
void |
setCounterFactory(CounterFactory factory) |
void |
setDefaultTimeToIdle(long defaultTimeToIdle) |
void |
setDefaultTimeToLive(long defaultTimeToLive) |
void |
setExecutor(Executor executor) |
void |
setInput(String session,
String key,
Object object)
|
void |
setOutput(String session,
String key,
Object object)
|
void |
setPrincipalHolder(PrincipalHolder principal) |
void |
setReadOnly(boolean readOnly) |
void |
setRoles(Roles securityRoles) |
IObject |
setSecurityContext(Principal principal,
IObject obj)
Sets the context for the current session to the given value.
|
void |
setSessionCache(SessionCache sessionCache) |
void |
setUuid(String uuid) |
Session |
update(Session session)
Certain fields from the
Session instance will
be copied and then saved to the db, as well as a new
SessionContext created. |
Session |
update(Session session,
boolean trusted)
Same as
SessionManager.update(Session) but some security checks can be
overridden. |
public static final String GROUP_SUDO_NS
protected OmeroContext context
protected Roles roles
protected SessionCache cache
protected Executor executor
protected long defaultTimeToIdle
protected long maxUserTimeToIdle
protected long defaultTimeToLive
protected long maxUserTimeToLive
protected PrincipalHolder principalHolder
protected CounterFactory factory
protected boolean readOnly
protected Principal asroot
Executor
. The name of this Principal
will not be removed
by calls to closeAll()
.protected SessionContext internalSession
SessionContext
created during init()
which is
used for all method calls internal to the session manager (see execute*
methods)public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext) throws org.springframework.beans.BeansException
setApplicationContext
in interface org.springframework.context.ApplicationContextAware
org.springframework.beans.BeansException
public void setUuid(String uuid)
public void setSessionCache(SessionCache sessionCache)
public void setRoles(Roles securityRoles)
public void setExecutor(Executor executor)
public void setDefaultTimeToIdle(long defaultTimeToIdle)
public void setDefaultTimeToLive(long defaultTimeToLive)
public void setPrincipalHolder(PrincipalHolder principal)
public void setCounterFactory(CounterFactory factory)
public void setReadOnly(boolean readOnly)
public void init()
Session
.protected void define(Session s, String uuid, String message, long started, SessionManager.CreationRequest req)
protected void define(Session s, String uuid, String message, long started, long idle, long live, String eventType, String agent, String ip)
public Session createFromRequest(SessionManager.CreationRequest request)
createFromRequest
in interface SessionManager
public Session createWithAgent(Principal _principal, String credentials, String agent, String ip)
createWithAgent
in interface SessionManager
public Session createWithAgent(Principal principal, String agent, String ip)
createWithAgent
in interface SessionManager
public Share createShare(Principal principal, boolean enabled, long timeToLive, String eventType, String description, long groupId)
createShare
in interface SessionManager
public Session update(Session session)
SessionManager
Session
instance will
be copied and then saved to the db, as well as a new
SessionContext
created. This method assumes that the user is NOT
an admin.update
in interface SessionManager
public Session update(Session session, boolean trusted)
SessionManager
SessionManager.update(Session)
but some security checks can be
overridden. This is usually done by checking with the
SecuritySystem
but here the server is in a critical
state, and instead will trust the method invoker.update
in interface SessionManager
protected SessionContext createSessionContext(List<?> list, SessionContext previous)
executeSessionContextLookup(ServiceFactory, Principal, Session)
and turns it into a SessionContext
instance.
List argument should never be null. Abort if
executeSessionContextLookup(ServiceFactory, Principal, Session)
returns null.public Session find(String uuid)
find
in interface SessionManager
public List<Session> findByUser(String user)
findByUser
in interface SessionManager
public List<Session> findByUserAndAgent(String user, String... agents)
SessionManager
findByUserAndAgent
in interface SessionManager
public int getReferenceCount(String uuid)
SessionManager
getReferenceCount
in interface SessionManager
public int detach(String uuid)
SessionManager
SessionManager.close(String)
logic. This is useful when it is assumed
that another user will re-attach to the same session. A timeout can still
cause the session to be removed.detach
in interface SessionManager
public SessionStats getSessionStats(String uuid)
SessionManager
SessionStats
which are being counted for the given
session or throw an exception if it has been removed.getSessionStats
in interface SessionManager
public int close(String uuid)
SessionManager
close
in interface SessionManager
public Map<String,Map<String,Object>> getSessionData()
SessionManager
getSessionData
in interface SessionManager
public int closeAll()
SessionManager
closeAll
in interface SessionManager
public List<String> getUserRoles(String uuid)
getUserRoles
in interface SessionManager
public net.sf.ehcache.Ehcache inMemoryCache(String uuid)
SessionManager
cache
which
can be used throughout the session. On close, the cache will be disposed.inMemoryCache
in interface SessionManager
public net.sf.ehcache.Ehcache onDiskCache(String uuid)
SessionManager
cache
which
can be used throughout the session. On close, the cache will be disposed.onDiskCache
in interface SessionManager
public Object getInput(String session, String key) throws RemovedSessionException
SessionManager
Object
stored under the given key
or null if none present. Throws an exception if there is no
Session
with the given identifier.getInput
in interface SessionManager
session
- Not null.key
- Not null.RemovedSessionException
public Object getOutput(String session, String key) throws RemovedSessionException
SessionManager
Object
stored under the given key
or null if none present. Throws an exception if there is no
Session
with the given identifier.getOutput
in interface SessionManager
session
- Not null.key
- Not null.RemovedSessionException
public Map<String,Object> inputEnvironment(String session)
SessionManager
inputEnvironment
in interface SessionManager
session
- The session id.public Map<String,Object> outputEnvironment(String session)
SessionManager
outputEnvironment
in interface SessionManager
session
- The session id.public void setInput(String session, String key, Object object) throws RemovedSessionException
SessionManager
argument
in the input environment under the
given key, possibly initializing the Map
Throws an exception if
there is no Session
with the given identifier.setInput
in interface SessionManager
session
- Not null.key
- Not null.object
- If null, key will be removed.RemovedSessionException
public void setOutput(String session, String key, Object object) throws RemovedSessionException
SessionManager
argument
in the output environment under the
given key, possibly initializing the Map
Throws an exception if
there is no Session
with the given identifier.setOutput
in interface SessionManager
session
- Not null.key
- Not null.object
- If null, key will be removed.RemovedSessionException
public EventContext getEventContext(Principal principal)
SessionManager
EventContext
for the current Session
.getEventContext
in interface SessionManager
principal
- Non null.public EventContext reload(String uuid)
SessionManager
SessionManager.getEventContext(Principal)
but uses the internal
reload logic to get a fresh representation of the context. This queries
all of the user management tables (experimenter, experimentergroup, etc)
and so should not be used anywhere in a critical path.reload
in interface SessionManager
uuid
- non null.public void onApplicationEvent(org.springframework.context.ApplicationEvent event)
onApplicationEvent
in interface org.springframework.context.ApplicationListener<org.springframework.context.ApplicationEvent>
public void addCallback(String sessionId, SessionCallback cb)
public void prepareReload()
public SessionContext reload(SessionContext ctx)
SessionCache
in order
to allow for an update.reload
in interface SessionCache.StaleCacheListener
public boolean executePasswordCheck(String name, String credentials)
SessionManager
Executor
framework. Also
checks the credentials against current session uuids.executePasswordCheck
in interface SessionManager
public IObject setSecurityContext(Principal principal, IObject obj)
SessionManager
ExperimenterGroup
then the active group is
changed, and any active shares are deactivated. If it is an
Share
then the share is activate (the group is
left alone). Unless otherwise specified, the user's default group is used
as the initial context. Passing any other object will result in an
ApiUsageException
.setSecurityContext
in interface SessionManager
principal
- Principal
for which the context should be set.obj
- IObject
which represents the new context.
Version: 5.3.5-ice35-b73
Copyright © 2017 The University of Dundee & Open Microscopy Environment. All Rights Reserved.