feat: POST /api/v3/chats, chat room creation, plus openAPI docs update

src/api/chats.js

@@ -0,0 +1,37 @@
+'use strict';
+
+const meta = require('../meta');
+const privileges = require('../privileges');
+const messaging = require('../messaging');
+
+
+const websockets = require('../socket.io');
+const socketHelpers = require('../socket.io/helpers');
+
+const chatsAPI = module.exports;
+
+function rateLimitExceeded(caller) {
+	const session = caller.request ? caller.request.session : caller.session;	// socket vs req
+	const now = Date.now();
+	session.lastChatMessageTime = session.lastChatMessageTime || 0;
+	if (now - session.lastChatMessageTime < meta.config.chatMessageDelay) {
+		return true;
+	}
+	session.lastChatMessageTime = now;
+	return false;
+}
+
+chatsAPI.create = async function (caller, data) {
+	if (rateLimitExceeded(caller)) {
+		throw new Error('[[error:too-many-messages]]');
+	}
+
+	if (!data.uids || !Array.isArray(data.uids)) {
+		throw new Error(`[[error:array-expected, uids, ${typeof data.uids}]]`);
+	}
+
+	await Promise.all(data.uids.map(async uid => messaging.canMessageUser(caller.uid, uid)));
+	const roomId = await messaging.newRoom(caller.uid, data.uids);
+
+	return await messaging.getRoomData(roomId);
+};

src/api/index.js

@@ -5,6 +5,7 @@ module.exports = {
 	groups: require('./groups'),
 	topics: require('./topics'),
 	posts: require('./posts'),
+	chats: require('./chats'),
 	categories: require('./categories'),
 	flags: require('./flags'),
 };

src/controllers/write/chats.js

@@ -18,7 +18,8 @@ Chats.list = async (req, res) => {
 };
 
 Chats.create = async (req, res) => {
-	// ...
+	const roomObj = await api.chats.create(req, req.body);
+	helpers.formatApiResponse(200, res, roomObj);
 };
 
 Chats.exists = async (req, res) => {

src/routes/write/chats.js

@@ -11,7 +11,7 @@ module.exports = function () {
 	const middlewares = [middleware.ensureLoggedIn, middleware.canChat];
 
 	setupApiRoute(router, 'get', '/', [...middlewares], controllers.write.chats.list);
-	// setupApiRoute(router, 'post', '/', [...middlewares, middleware.checkRequired.bind(null, ['uids'])], controllers.write.chats.create);
+	setupApiRoute(router, 'post', '/', [...middlewares, middleware.checkRequired.bind(null, ['uids'])], controllers.write.chats.create);
 
 	setupApiRoute(router, 'head', '/:roomId', [...middlewares, middleware.assert.room], controllers.write.chats.exists);
 	// setupApiRoute(router, 'get', '/:roomId', [...middlewares, middleware.assert.room], controllers.write.chats.get);

src/socket.io/modules.js

@@ -12,6 +12,9 @@ const server = require('./index');
 const user = require('../user');
 const privileges = require('../privileges');
 
+const sockets = require('.');
+const api = require('../api');
+
 const SocketModules = module.exports;
 
 SocketModules.chats = {};
@@ -43,20 +46,16 @@ SocketModules.chats.isDnD = async function (socket, uid) {
 };
 
 SocketModules.chats.newRoom = async function (socket, data) {
+	sockets.warnDeprecated(socket, 'POST /api/v3/chats');
+
 	if (!data) {
 		throw new Error('[[error:invalid-data]]');
 	}
 
-	if (rateLimitExceeded(socket)) {
-		throw new Error('[[error:too-many-messages]]');
-	}
-
-	const canChat = await privileges.global.can('chat', socket.uid);
-	if (!canChat) {
-		throw new Error('[[error:no-privileges]]');
-	}
-	await Messaging.canMessageUser(socket.uid, data.touid);
-	return await Messaging.newRoom(socket.uid, [data.touid]);
+	const roomObj = await api.chats.create(socket, {
+		uids: [data.touid],
+	});
+	return roomObj.roomId;
 };
 
 SocketModules.chats.send = async function (socket, data) {