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; using FLocal.Common.actions; namespace FLocal.Common.dataobjects { public class Post : SqlObject { public class TableSpec : ISqlObjectTableSpec { public const string TABLE = "Posts"; public const string FIELD_ID = "Id"; public const string FIELD_POSTERID = "PosterId"; public const string FIELD_POSTDATE = "PostDate"; public const string FIELD_LASTCHANGEDATE = "LastChangeDate"; public const string FIELD_REVISION = "Revision"; public const string FIELD_LAYERID = "LayerId"; public const string FIELD_TITLE = "Title"; public const string FIELD_BODY = "Body"; public const string FIELD_THREADID = "ThreadId"; public const string FIELD_PARENTPOSTID = "ParentPostId"; 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) { Refresh(id); } } protected override ISqlObjectTableSpec table { get { return TableSpec.instance; } } private int _posterId; public int posterId { get { this.LoadIfNotLoaded(); return this._posterId; } } public User poster { get { this.LoadIfNotLoaded(); return User.LoadById(this.posterId); } } private DateTime _postDate; public DateTime postDate { get { this.LoadIfNotLoaded(); return this._postDate; } } private DateTime _lastChangeDate; public DateTime lastChangeDate { get { this.LoadIfNotLoaded(); return this._lastChangeDate; } } private int? _revision; public int? revision { get { this.LoadIfNotLoaded(); return this._revision; } } public Revision latestRevision { get { return Revision.LoadById( int.Parse( Config.instance.mainConnection.LoadIdsByConditions( Revision.TableSpec.instance, new ComplexCondition( ConditionsJoinType.AND, new ComparisonCondition( Revision.TableSpec.instance.getColumnSpec(Revision.TableSpec.FIELD_POSTID), ComparisonType.EQUAL, this.id.ToString() ), new ComparisonCondition( Revision.TableSpec.instance.getColumnSpec(Revision.TableSpec.FIELD_NUMBER), ComparisonType.EQUAL, this.revision.Value.ToString() ) ), Diapasone.unlimited ).Single() ) ); } } private int _layerId; public int layerId { get { this.LoadIfNotLoaded(); return this._layerId; } } public PostLayer layer { get { return PostLayer.LoadById(this.layerId); } } private string _title; public string title { get { this.LoadIfNotLoaded(); return this._title; } } private string _body; public string body { get { this.LoadIfNotLoaded(); return this._body; } } public string bodyShort { get { return this.body.Replace("
", Util.EOL).Replace("
", Util.EOL).PHPSubstring(0, 1000); } } private int _threadId; public int threadId { get { this.LoadIfNotLoaded(); return this._threadId; } } public Thread thread { get { return Thread.LoadById(this.threadId); } } private int? _parentPostId; public int? parentPostId { get { this.LoadIfNotLoaded(); return this._parentPostId; } } public Post parentPost { get { return Post.LoadById(this.parentPostId.Value); } } protected override void doFromHash(Dictionary data) { this._posterId = int.Parse(data[TableSpec.FIELD_POSTERID]); this._postDate = Util.ParseDateTimeFromTimestamp(data[TableSpec.FIELD_POSTDATE]).Value; this._lastChangeDate = Util.ParseDateTimeFromTimestamp(data[TableSpec.FIELD_LASTCHANGEDATE]).Value; this._revision = Util.ParseInt(data[TableSpec.FIELD_REVISION]); this._layerId = int.Parse(data[TableSpec.FIELD_LAYERID]); this._title = data[TableSpec.FIELD_TITLE]; this._body = data[TableSpec.FIELD_BODY]; this._threadId = int.Parse(data[TableSpec.FIELD_THREADID]); this._parentPostId = Util.ParseInt(data[TableSpec.FIELD_PARENTPOSTID]); } public XElement exportToXmlSimpleWithParent(UserContext context) { return new XElement("post", new XElement("id", this.id), new XElement("name", this.title), new XElement("parent", this.thread.exportToXmlSimpleWithParent(context)) ); } private XNode XMLBody(UserContext context) { return XElement.Parse("" + context.outputParams.preprocessBodyIntermediate(this.body) + "", LoadOptions.PreserveWhitespace); } public XElement exportToXml(UserContext context, bool includeParentPost, params XElement[] additional) { if(!context.isPostVisible(this)) return null; XElement result = new XElement("post", new XElement("id", this.id), new XElement("poster", this.poster.exportToXmlForViewing(context)), new XElement("postDate", this.postDate.ToXml()), new XElement("lastChangeDate", this.lastChangeDate.ToXml()), new XElement("revision", this.revision.ToString()), new XElement("layerId", this.layerId), new XElement("layerName", this.layer.name), new XElement("title", this.title), new XElement("body", context.outputParams.preprocessBodyIntermediate(this.body)), //this.XMLBody(context), new XElement("bodyShort", this.bodyShort), new XElement("threadId", this.threadId), new XElement("isOwner", ((context.account != null) && (this.poster.id == context.account.user.id)).ToPlainString()) ); if(includeParentPost) { if(this.parentPostId.HasValue) { result.Add(new XElement("parentPost", this.parentPost.exportToXml(context, false))); } } if(additional.Length > 0) { result.Add(additional); } return result; } public Post Reply(User poster, string title, string body, PostLayer desiredLayer) { return this.Reply(poster, title, body, desiredLayer, DateTime.Now, null); } public Post Reply(User poster, string title, string body, PostLayer desiredLayer, DateTime date, int? forcedPostId) { if(this.thread.isLocked && poster.name != Config.instance.AdminUserName) { throw new FLocalException("thread locked"); } PostLayer actualLayer = poster.getActualLayer(this.thread.board, desiredLayer); var changes = Thread.getNewPostChanges(this.thread.board, this.threadId, this, poster, actualLayer, title, body, date, forcedPostId); ChangeSetUtil.ApplyChanges(changes.Value.ToArray()); return Post.LoadById(changes.Key.getId().Value); } private readonly object Edit_locker = new object(); //TODO: move locking to DB public void Edit(User user, string newTitle, string newBody, PostLayer newDesiredLayer) { if(this.poster.id != user.id) { throw new AccessViolationException(); } PostLayer actualLayer = poster.getActualLayer(this.thread.board, newDesiredLayer); if(actualLayer.id < this.layer.id) { actualLayer = this.layer; } lock(this.Edit_locker) { List changes = new List { new InsertChange( Revision.TableSpec.instance, new Dictionary { { Revision.TableSpec.FIELD_POSTID, new ScalarFieldValue(this.id.ToString()) }, { Revision.TableSpec.FIELD_CHANGEDATE, new ScalarFieldValue(DateTime.Now.ToUTCString()) }, { Revision.TableSpec.FIELD_TITLE, new ScalarFieldValue(newTitle) }, { Revision.TableSpec.FIELD_BODY, new ScalarFieldValue(newBody) }, { Revision.TableSpec.FIELD_NUMBER, new ScalarFieldValue((this.revision + 1).ToString()) }, } ), new UpdateChange( TableSpec.instance, new Dictionary { { TableSpec.FIELD_TITLE, new ScalarFieldValue(newTitle) }, { TableSpec.FIELD_BODY, new ScalarFieldValue(UBBParser.UBBToIntermediate(newBody)) }, { TableSpec.FIELD_LASTCHANGEDATE, new ScalarFieldValue(DateTime.Now.ToUTCString()) }, { TableSpec.FIELD_REVISION, new IncrementFieldValue() }, { TableSpec.FIELD_LAYERID, new ScalarFieldValue(actualLayer.id.ToString()) }, }, this.id ) }; if(this.thread.firstPost.id == this.id) { changes.Add( new UpdateChange( Thread.TableSpec.instance, new Dictionary { { TableSpec.FIELD_TITLE, new ScalarFieldValue(newTitle) }, }, this.thread.id ) ); } ChangeSetUtil.ApplyChanges(changes.ToArray()); } } } }