-- XEP-0313: Message Archive Management for Prosody MUC

-- Copyright (C) 2011-2014 Kim Alvefur

--

-- This file is MIT/X11 licensed.

if module:get_host_type() ~= "component" then

	module:log("error", "mod_%s should be loaded only on a MUC component, not normal hosts", module.name);

	return;

end

local xmlns_mam     = "urn:xmpp:mam:1";

local xmlns_delay   = "urn:xmpp:delay";

local xmlns_forward = "urn:xmpp:forward:0";

local muc_form_enable_logging = "muc#roomconfig_enablelogging"

local st = require "util.stanza";

local rsm = require "util.rsm";

local jid_bare = require "util.jid".bare;

local jid_split = require "util.jid".split;

local dataform = require "util.dataforms".new;

local it = require"util.iterators";

-- Support both old and new MUC code

local mod_muc = module:depends"muc";

local rooms = rawget(mod_muc, "rooms");

local each_room = rawget(mod_muc, "each_room") or function() return it.values(rooms); end;

local new_muc = not rooms;

if new_muc then

	rooms = module:shared"muc/rooms";

end

local get_room_from_jid = rawget(mod_muc, "get_room_from_jid") or

	function (jid)

		return rooms[jid];

	end

local is_stanza = st.is_stanza;

local tostring = tostring;

local time_now = os.time;

local m_min = math.min;

local timestamp, timestamp_parse = require "util.datetime".datetime, require "util.datetime".parse;

local max_history_length = module:get_option_number("max_history_messages", 1000);

local default_max_items, max_max_items = 20, module:get_option_number("max_archive_query_results", max_history_length);

local log_all_rooms = module:get_option_boolean("muc_log_all_rooms", false);

local log_by_default = module:get_option_boolean("muc_log_by_default", true);

local archive_store = "muc_log";

local archive = module:open_store(archive_store, "archive");

if archive.name == "null" or not archive.find then

	if not archive.find then

		module:log("error", "Attempt to open archive storage returned a valid driver but it does not seem to implement the storage API");

		module:log("error", "mod_%s does not support archiving", archive._provided_by or archive.name and "storage_"..archive.name.."(?)" or "<unknown>");