src/main/java/net/webstructor/peer/Sessioner.java - master - akolonin/aigents-java

src/main/java/net/webstructor/peer/Sessioner.java
95 строк3 KB
Anton Kolonin
2.9.3. Refactoring Conversationer for configurable Intenters
05 июл 2020, 18:11
05 июл 2020, 18:1173705d4
/*
 * MIT License
 * 
 * Copyright (c) 2005-2020 by Anton Kolonin, Aigents®
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in all
 * copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 */
package net.webstructor.peer;

import java.util.Collection;
import java.util.Iterator;

import net.webstructor.agent.Body;
import net.webstructor.agent.Schema;
import net.webstructor.al.AL;
import net.webstructor.comm.Communicator;
import net.webstructor.core.Thing;
import net.webstructor.util.MapMap;

/* user session can be identified as TCP/IP socket, 
 * HTTP cookie, IRC nickname, SMS phone number or email address, 
 * so that conversational context will be associated 
 * with a corresponding user 
 */
public class Sessioner {

	MapMap sessions = new MapMap();

	protected Body body;
	
	public Sessioner(Body body) {
		this.body = body;
	}

	public Session getSavedSession(Communicator communicator, String type, String key) {
		//get peer with session key from storage,
		try {
			Collection sessions = body.storager.getByName(Peer.login_token,key);
			//New version - peer'S session:
			if (!AL.empty(sessions)) for (Iterator it = sessions.iterator(); it.hasNext();) {
				Thing sess = (Thing)(it.next());
				Collection is = sess.getThings(AL.is);
				if (!AL.empty(is) && is.size() == 1){
					Thing peer = (Thing)(is.iterator().next());
					if (!Schema.peer.equals(peer.name())){//if not a root peer class but peer instance
//TODO: remove login tokens from peers when ported update functions across messengers!
						//peer.set(Peer.login_token, null);//remove login tokens from peers forever
						return new Session(this,communicator,type,key,peer);
					}
				}
			}
			//Old version - peer IS session (fallback):
			Collection peers = body.storager.getByName(Peer.login_token,key);
			if (!AL.empty(peers) && peers.size() == 1) {
				//if found, create Session pre-initialized with the peer
				return new Session(this,communicator,type,key,(Thing)(peers.iterator().next()));
			}
		} catch (Exception e) {
			body.error("No saved session ", e);
		}
		return null;
	}

	public Session getSession(Communicator communicator, String key) {
		String type = communicator.getClass().getName();
		//TODO: synchronization!!!???
		Session session = (Session)sessions.getObject(type, key, true);
		if (session == null) {
			session = getSavedSession(communicator,type,key);
			if (session == null)
				session = new Session(this,communicator,type,key);
			sessions.putObject(type, key, session);
		}
		else
			session.communicator = communicator;
		return session;
	}
	
}