all files / src/socket.io/topics/ tools.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
 
 
1×
1×
1×
1×
1×
1×
 
1×
 
1×
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1×
 
 
 
1×
 
 
 
1×
 
 
 
1×
 
 
 
1×
 
 
 
1×
 
 
 
1×
 
 
 
1×
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
'use strict';
 
var async = require('async');
var topics = require('../../topics');
var events = require('../../events');
var privileges = require('../../privileges');
var plugins = require('../../plugins');
var socketHelpers = require('../helpers');
 
module.exports = function(SocketTopics) {
 
	SocketTopics.loadTopicTools = function(socket, data, callback) {
		if (!socket.uid) {
			return callback(new Error('[[error:no-privileges]]'));
		}
		if (!data) {
			return callback(new Error('[[error:invalid-data]]'));
		}
		var topic;
		async.waterfall([
			function (next) {
				async.parallel({
					topic: function(next) {
						topics.getTopicData(data.tid, next);
					},
					privileges: function(next) {
						privileges.topics.get(data.tid, socket.uid, next);
					}
				}, next);
			},
			function (results, next) {
				topic = results.topic;
				topic.privileges = results.privileges;
				plugins.fireHook('filter:topic.thread_tools', {topic: results.topic, uid: socket.uid, tools: []}, next);
			},
			function (data, next) {
				topic.deleted = parseInt(topic.deleted, 10) === 1;
				topic.locked = parseInt(topic.locked, 10) === 1;
				topic.pinned = parseInt(topic.pinned, 10) === 1;
				topic.thread_tools = data.tools;
				next(null, topic);
			}
		], callback);
	};
 
	SocketTopics.delete = function(socket, data, callback) {
		SocketTopics.doTopicAction('delete', 'event:topic_deleted', socket, data, callback);
	};
 
	SocketTopics.restore = function(socket, data, callback) {
		SocketTopics.doTopicAction('restore', 'event:topic_restored', socket, data, callback);
	};
 
	SocketTopics.purge = function(socket, data, callback) {
		SocketTopics.doTopicAction('purge', 'event:topic_purged', socket, data, callback);
	};
 
	SocketTopics.lock = function(socket, data, callback) {
		SocketTopics.doTopicAction('lock', 'event:topic_locked', socket, data, callback);
	};
 
	SocketTopics.unlock = function(socket, data, callback) {
		SocketTopics.doTopicAction('unlock', 'event:topic_unlocked', socket, data, callback);
	};
 
	SocketTopics.pin = function(socket, data, callback) {
		SocketTopics.doTopicAction('pin', 'event:topic_pinned', socket, data, callback);
	};
 
	SocketTopics.unpin = function(socket, data, callback) {
		SocketTopics.doTopicAction('unpin', 'event:topic_unpinned', socket, data, callback);
	};
 
	SocketTopics.doTopicAction = function(action, event, socket, data, callback) {
		callback = callback || function() {};
		if (!socket.uid) {
			return callback(new Error('[[error:no-privileges]]'));
		}
 
		if (!data || !Array.isArray(data.tids) || !data.cid) {
			return callback(new Error('[[error:invalid-tid]]'));
		}
 
		if (typeof topics.tools[action] !== 'function') {
			return callback();
		}
 
		async.each(data.tids, function(tid, next) {
			topics.tools[action](tid, socket.uid, function(err, data) {
				if (err) {
					return next(err);
				}
 
				socketHelpers.emitToTopicAndCategory(event, data);
 
				if (action === 'delete' || action === 'restore' || action === 'purge') {
					events.log({
						type: 'topic-' + action,
						uid: socket.uid,
						ip: socket.ip,
						tid: tid
					});
				}
 
				next();
			});
		}, callback);
	};
 
};