using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Xml.Linq; using FLocal.Core; using FLocal.Core.DB; using FLocal.Core.DB.conditions; using FLocal.Common.actions; namespace FLocal.Common.dataobjects { public class Session : SqlObject { public struct SessionKey : IEquatable { private string key; public static SessionKey Parse(string _key) { if(_key == null) { throw new FLocalException("SessionKey is null"); } return new SessionKey { key = _key }; } bool IEquatable.Equals(SessionKey _key) { return this.key.Equals(_key.key); } public override bool Equals(object obj) { if(obj == null) return base.Equals(obj); if(!(obj is SessionKey)) throw new InvalidCastException(); return ((IEquatable)this).Equals((SessionKey)obj); } public override int GetHashCode() { return this.key.GetHashCode(); } public override string ToString() { return this.key; } } public class TableSpec : ISqlObjectTableSpec { public const string TABLE = "Sessions"; public const string FIELD_ID = FIELD_SESSIONKEY; public const string FIELD_SESSIONKEY = "SessionKey"; public const string FIELD_ACCOUNTID = "AccountId"; public const string FIELD_LASTACTIVITY = "LastActivity"; public const string FIELD_LASTURL = "LastUrl"; public const string FIELD_ISDELETED = "IsDeleted"; public static readonly TableSpec instance = new TableSpec(); public string name { get { return TABLE; } } public string idName { get { return FIELD_ID; } } public void refreshSqlObject(int id) { throw new NotImplementedException(); } } protected override ISqlObjectTableSpec table { get { return TableSpec.instance; } } private string _sessionKey; public string sessionKey { get { this.LoadIfNotLoaded(); return this._sessionKey; } } private int _accountId; public int accountId { get { this.LoadIfNotLoaded(); return this._accountId; } } public Account account { get { return Account.LoadById(this.accountId); } } private DateTime _lastActivity; public DateTime lastActivity { get { this.LoadIfNotLoaded(); return this._lastActivity; } } private string _lastUrl; public string lastUrl { get { this.LoadIfNotLoaded(); return this._lastUrl; } } private bool _isDeleted; public bool isDeleted { get { this.LoadIfNotLoaded(); return this._isDeleted; } } protected override void doFromHash(Dictionary data) { this._sessionKey = data[TableSpec.FIELD_SESSIONKEY]; this._lastActivity = new DateTime(long.Parse(data[TableSpec.FIELD_LASTACTIVITY])); this._accountId = int.Parse(data[TableSpec.FIELD_ACCOUNTID]); this._lastUrl = data[TableSpec.FIELD_LASTURL]; this._isDeleted = Util.string2bool(data[TableSpec.FIELD_ISDELETED]); } public void updateLastActivity(string lastUrl) { if(DateTime.Now.Subtract(this.lastActivity).TotalSeconds < 30) return; //to partially remove db load try { Config.Transactional(transaction => { Config.instance.mainConnection.update( transaction, TableSpec.instance, this.id.ToString(), new Dictionary() { { TableSpec.FIELD_LASTACTIVITY, DateTime.Now.ToUTCString() }, { TableSpec.FIELD_LASTURL, (lastUrl != null) ? lastUrl : this.lastUrl }, } ); }); } finally { this.ReLoad(); } } public static Session create(Account account) { string key=null; Config.Transactional(transaction => { Config.instance.mainConnection.lockTable(transaction, TableSpec.instance); do { key = Util.RandomString(32, Util.RandomSource.LETTERS_DIGITS); } while(Config.instance.mainConnection.LoadByIds(transaction, TableSpec.instance, new List() { key }).Count > 0); Config.instance.mainConnection.insert( transaction, TableSpec.instance, new Dictionary() { { TableSpec.FIELD_SESSIONKEY, key }, { TableSpec.FIELD_ACCOUNTID, account.id.ToString() }, { TableSpec.FIELD_LASTACTIVITY, DateTime.Now.ToUTCString() }, { TableSpec.FIELD_LASTURL, "" }, { TableSpec.FIELD_ISDELETED, "0" }, } ); }); return Session.LoadById(SessionKey.Parse(key)); } public void delete() { try { Config.Transactional(transaction => { Config.instance.mainConnection.update( transaction, TableSpec.instance, this.id.ToString(), new Dictionary() { { TableSpec.FIELD_ISDELETED, "1" }, } ); }); } finally { this.ReLoad(); } } public XElement exportToXml(UserContext context) { return new XElement("session", new XElement("lastActivity", this.lastActivity.ToXml()), new XElement("sessionKey", this.sessionKey), this.account.user.exportToXmlForViewing(context), AccountIndicator.LoadByAccount(this.account).exportToXml(context) ); } public static Session LoadByKey(string sessionKey) { Session result = LoadById(SessionKey.Parse(sessionKey)); if(result.isDeleted) throw new NotFoundInDBException(TableSpec.instance, sessionKey); return result; } public static Session GetLastSession(Account account) { var ids = Config.instance.mainConnection.LoadIdsByConditions( TableSpec.instance, new ComparisonCondition( TableSpec.instance.getColumnSpec(TableSpec.FIELD_ACCOUNTID), ComparisonType.EQUAL, account.id.ToString() ), Diapasone.first, new JoinSpec[0], new SortSpec[] { new SortSpec( TableSpec.instance.getColumnSpec(TableSpec.FIELD_LASTACTIVITY), false ) } ); if(ids.Count < 1) { throw new NotFoundInDBException(TableSpec.instance.getColumnSpec(TableSpec.FIELD_ACCOUNTID), account.id.ToString()); } return Session.LoadById(SessionKey.Parse(ids[0])); } } }