src/controllers/write/chats.js
'use strict';
const api = require('../../api');
const helpers = require('../helpers');
const Chats = module.exports;
Chats.list = async (req, res) => {
let stop;
let { page, perPage, start, uid } = req.query;
([page, perPage, start, uid] = [page, perPage, start, uid].map(value => isFinite(value) && parseInt(value, 10)));
page = page || 1;
perPage = perPage || 20;
// start supercedes page
if (start) {
stop = start + perPage - 1;
} else {
start = Math.max(0, page - 1) * perPage;
stop = start + perPage - 1;
}
const { rooms, nextStart } = await api.chats.list(req, { start, stop, uid });
helpers.formatApiResponse(200, res, { rooms, nextStart });
};
Chats.create = async (req, res) => {
const roomObj = await api.chats.create(req, req.body);
helpers.formatApiResponse(200, res, roomObj);
};
// currently only returns unread count, but open-ended for future additions if warranted.
Chats.getUnread = async (req, res) => helpers.formatApiResponse(200, res, await api.chats.getUnread(req));
Chats.sortPublicRooms = async (req, res) => {
const { roomIds, scores } = req.body;
await api.chats.sortPublicRooms(req, { roomIds, scores });
helpers.formatApiResponse(200, res);
};
Chats.exists = async (req, res) => {
// yes, this is fine. Room existence is checked via middleware :)
helpers.formatApiResponse(200, res);
};
Chats.get = async (req, res) => {
helpers.formatApiResponse(200, res, await api.chats.get(req, {
uid: req.query.uid || req.uid,
roomId: req.params.roomId,
}));
};
Chats.post = async (req, res) => {
const messageObj = await api.chats.post(req, {
message: req.body.message,
toMid: req.body.toMid,
roomId: req.params.roomId,
});
helpers.formatApiResponse(200, res, messageObj);
};
Chats.update = async (req, res) => {
const payload = { ...req.body };
payload.roomId = req.params.roomId;
const roomObj = await api.chats.update(req, payload);
helpers.formatApiResponse(200, res, roomObj);
};
Chats.rename = async (req, res) => {
const roomObj = await api.chats.rename(req, {
name: req.body.name,
roomId: req.params.roomId,
});
helpers.formatApiResponse(200, res, roomObj);
};
Chats.mark = async (req, res) => {
const state = req.method === 'PUT' ? 1 : 0;
await api.chats.mark(req, {
roomId: req.params.roomId,
state,
});
helpers.formatApiResponse(200, res);
};
Chats.watch = async (req, res) => {
const state = req.method === 'DELETE' ? -1 : parseInt(req.body.value, 10) || -1;
await api.chats.watch(req, { state, ...req.params });
helpers.formatApiResponse(200, res);
};
Chats.toggleTyping = async (req, res) => {
const { typing } = req.body;
await api.chats.toggleTyping(req, { typing, ...req.params });
helpers.formatApiResponse(200, res);
};
Chats.users = async (req, res) => {
const { roomId } = req.params;
const start = parseInt(req.query.start, 10) || 0;
const users = await api.chats.users(req, { roomId, start });
helpers.formatApiResponse(200, res, users);
};
Chats.invite = async (req, res) => {
const { uids } = req.body;
const users = await api.chats.invite(req, {
uids,
roomId: req.params.roomId,
});
helpers.formatApiResponse(200, res, users);
};
Chats.kick = async (req, res) => {
const { uids } = req.body;
const users = await api.chats.kick(req, {
uids,
roomId: req.params.roomId,
});
helpers.formatApiResponse(200, res, users);
};
Chats.kickUser = async (req, res) => {
const uids = [req.params.uid];
const users = await api.chats.kick(req, {
uids,
roomId: req.params.roomId,
});
helpers.formatApiResponse(200, res, users);
};
Chats.toggleOwner = async (req, res) => {
const state = req.method === 'PUT';
await api.chats.toggleOwner(req, { state, ...req.params });
helpers.formatApiResponse(200, res);
};
Chats.messages = {};
Chats.messages.list = async (req, res) => {
const uid = req.query.uid || req.uid;
const { roomId } = req.params;
const start = parseInt(req.query.start, 10) || 0;
const direction = parseInt(req.query.direction, 10) || null;
const { messages } = await api.chats.listMessages(req, {
uid, roomId, start, direction,
});
helpers.formatApiResponse(200, res, { messages });
};
Chats.messages.getPinned = async (req, res) => {
const { start } = req.query;
helpers.formatApiResponse(200, res, await api.chats.getPinnedMessages(req, { start, ...req.params }));
};
Chats.messages.get = async (req, res) => {
const { mid, roomId } = req.params;
helpers.formatApiResponse(200, res, await api.chats.getMessage(req, { mid, roomId }));
};
Chats.messages.getRaw = async (req, res) => {
helpers.formatApiResponse(200, res, await api.chats.getRawMessage(req, { ...req.params }));
};
Chats.messages.getIpAddress = async (req, res) => {
helpers.formatApiResponse(200, res, await api.chats.getIpAddress(req, { ...req.params }));
};
Chats.messages.edit = async (req, res) => {
const { mid, roomId } = req.params;
const { message } = req.body;
await api.chats.editMessage(req, { mid, roomId, message });
helpers.formatApiResponse(200, res, await api.chats.getMessage(req, { mid, roomId }));
};
Chats.messages.delete = async (req, res) => {
const { mid } = req.params;
await api.chats.deleteMessage(req, { mid });
helpers.formatApiResponse(200, res);
};
Chats.messages.restore = async (req, res) => {
const { mid } = req.params;
await api.chats.restoreMessage(req, { mid });
helpers.formatApiResponse(200, res);
};
Chats.messages.pin = async (req, res) => {
const { mid, roomId } = req.params;
await api.chats.pinMessage(req, { mid, roomId });
helpers.formatApiResponse(200, res);
};
Chats.messages.unpin = async (req, res) => {
const { mid, roomId } = req.params;
await api.chats.unpinMessage(req, { mid, roomId });
helpers.formatApiResponse(200, res);
};