FLocal/IISMainHandler/handlers/response/ConversationHandler.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Web;
using System.Xml.Linq;
using FLocal.Common;
using FLocal.Common.dataobjects;
using FLocal.Core;
using FLocal.Core.DB;
using FLocal.Core.DB.conditions;

namespace FLocal.IISHandler.handlers.response {

	class ConversationHandler : AbstractGetHandler {

		override protected string templateName {
			get {
				return "Conversation.xslt";
			}
		}

		override protected IEnumerable<XElement> getSpecificData(WebContext context) {
			Account interlocutor = Account.LoadById(int.Parse(context.requestParts[1]));
			PMConversation conversation = PMConversation.LoadByAccounts(context.session.account, interlocutor);
			PageOuter pageOuter = PageOuter.createFromGet(
				context.requestParts,
				context.userSettings.postsPerPage,
				new Dictionary<char,Func<long>> {
					{
						'p',
						() => Config.instance.mainConnection.GetCountByConditions(
							PMMessage.TableSpec.instance,
							new ComplexCondition(
								ConditionsJoinType.AND,
								new ComparisonCondition(
									PMMessage.TableSpec.instance.getColumnSpec(PMMessage.TableSpec.FIELD_OWNERID),
									ComparisonType.EQUAL,
									context.session.account.id.ToString()
								),
								new ComparisonCondition(
									PMMessage.TableSpec.instance.getColumnSpec(PMMessage.TableSpec.FIELD_INTERLOCUTORID),
									ComparisonType.EQUAL,
									interlocutor.id.ToString()
								),
								new ComparisonCondition(
									PMMessage.TableSpec.instance.getIdSpec(),
									ComparisonType.LESSTHAN,
									int.Parse(context.requestParts[2].PHPSubstring(1)).ToString()
								)
							)
						)
					}
				},
				2
			);
			IEnumerable<PMMessage> messages = conversation.getMessages(pageOuter, context);

			XElement[] result = new XElement[] {
				conversation.exportToXml(context, false),
				new XElement("messages",
					from message in messages select message.exportToXml(context),
					pageOuter.exportToXml(2, 5, 2)
				)
			};

			if(messages.Count() > 0) {
				conversation.markAsRead(context.session.account, messages.Min(), messages.Max());
			}

			foreach(var message in messages) {
				message.MarkAsRead(context.session.account);
			}

			return result;
		}

	}

}