// SECTION 7.1: Publish an Item to a Node
exports.publish = {
	type: 'set',
	child: 'pubsub',
	ns: NS.PUBSUB,
	child2: 'publish',
	func: function(response, stanza, request, to) {
		if (!config.enabled('publish'))
			return makeError(response, errors.pub.publish.item_publication_not_supported.n);

		var nodeID = request.getAttribute('node');
		if (!nodeID || nodeID == '')
			return makeError(response, errors.nodeid_required.n);

		var autocreate = false;
		if (!storage.existsNode(nodeID)) {
			if (config.enabled('auto-create'))
				autocreate = true;
			else
				return makeError(response, errors.node_does_not_exist.n);
		}

		var affil = storage.getAffiliation(toBareJID(to), nodeID);
		if (typeof affil == 'number' && affil != errors.node_does_not_exist.n)
			return makeError(response, affil);
		if (!autocreate && affil != 'super-owner' && affil != 'owner' && affil != 'publisher' && affil != 'publish-only')
			return makeError(response, errors.forbidden.n);

		var item = request.getChild('item');
		var itemID = item.getAttribute('id');
		if (!config.enabled('item-ids') && itemID)
			return makeError(response, errors.itemid_required.n);
		itemID = itemID? itemID: fdsq.makeRandomId();

		if (item.tags.length != 1)
			return makeError(response, errors.pub.publish.bad_payload.n);

		var conf = storage.getConfiguration(nodeID);
		/*var publishOptions = pubsub.getChild('publish-options');
		if (publishOptions && config.enabled('publish-options')) {
			var x = publishOptions.getChild('x', 'jabber:x:data');
			if (!x || x.getAttribute('type') != 'submit')
				return makeError(response, errors.bad_request.n);

			var form = forms.parse(x, true);
			if (form.access_model != conf['pubsub#access_model'] && !autocreate)
				return makeError(response, errors.pub.configuration.precondition.n);
		}*/

		if (!config.enabled('persistent-items')) {
			var notifications = storage.purgeNode(nodeID);
			if (typeof notifications == 'number')
				return makeError(response, r);
		}

		if (autocreate) {
			if (!form)
				form = {};
			form['pubsub#creator'] = toBareJID(to);

			var r = storage.createNode(nodeID, form);
			if (typeof r == 'number')
				return makeError(response, r);
		}

		var content = item.getChild();

		subscribers = storage.setItem(nodeID, itemID, content);
		if (typeof subscribers == 'number')
			return makeError(response, subscribers);

		var attrs = {};
		if (content)
			attrs[itemID] = {content: content};
		else
			attrs[itemID] = {};
		notifs.send(subscribers, 'items', nodeID, attrs);

		response.c('pubsub', {xmlns: NS.PUBSUB})
			.c('publish', {node: nodeID})
			.c('item', {id: itemID});

		return response;
	}
}

// SECTION 7.2: Delete an Item from a Node
exports.retract = {
	type: 'set',
	child: 'pubsub',
	ns: NS.PUBSUB,
	child2: 'retract',
	func: function(response, stanza, request, to) {
		if (!config.enabled('retract-items'))
			return makeError(response, errors.pub.retract.item_deletion_not_supported.n);

		var nodeID = request.getAttribute('node');
		if (!nodeID || nodeID == '')
			return makeError(response, errors.nodeid_required.n);
		if (!storage.existsNode(nodeID))
			return makeError(response, errors.node_does_not_exist.n);

		var item = request.getChild('item');
		if (!item)
			return makeError(response, errors.pub.retract.item_or_itemid_required.n);

		var itemID = item.getAttribute('id')
		if (!itemID || itemID == '')
			return makeError(response, errors.pub.retract.item_or_itemid_required.n);

		var affil = storage.getAffiliation(toBareJID(to), nodeID);
		if (affil != 'super-owner' && affil != 'owner' && affil != 'publish-only')
			return makeError(response, errors.forbidden.n);

		var subscribers = storage.deleteItem(nodeID, itemID);
		if (typeof subscribers == 'number')
			return makeError(response, subscribers);

		var attrs = {};
		attrs[itemID] = {};
		notifs.send(subscribers, 'items', nodeID, attrs, 'retract')

		return response;
	}
}