Skip to content

Convirtiendo src/messaging/create.js de JS a TS #61

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Kukki8 wants to merge 7 commits into
base: f24
Choose a base branch
from
Open

Convirtiendo src/messaging/create.js de JS a TS #61

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
0707d24
Declaracion de tipos y creacion de interfaz de Messaging
Kukki8 Oct 14, 2024
a16a6fd
Correccion de errores de eslint
Kukki8 Oct 14, 2024
119d931
Agregando compilado y solucionando ultimos errores de linter.
Kukki8 Oct 14, 2024
738e4cd
Arreglando error de tipo en linea 70.
Kukki8 Oct 14, 2024
3e6f044
Intentando solucionar ultimo problema de linter (undefined reference)
Kukki8 Oct 14, 2024
36e8a21
Correcion error de orden en importacion
Kukki8 Oct 14, 2024
7f748f5
Cambios en sintaxis de importacion
Kukki8 Oct 14, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
284 changes: 154 additions & 130 deletions src/messaging/create.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,132 +1,156 @@
'use strict';

const _ = require('lodash');

const meta = require('../meta');
const plugins = require('../plugins');
const db = require('../database');
const user = require('../user');
const utils = require('../utils');

"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
/* eslint-disable import/no-import-module-exports */
const lodash_1 = __importDefault(require("lodash"));
// eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
const plugins_1 = __importDefault(require("../plugins"));
// eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
const meta_1 = __importDefault(require("../meta"));
// eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
const database_1 = __importDefault(require("../database"));
// eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
const user_1 = __importDefault(require("../user"));
// eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
const utils_1 = __importDefault(require("../utils"));
module.exports = function (Messaging) {
Messaging.sendMessage = async (data) => {
await Messaging.checkContent(data.content);
const inRoom = await Messaging.isUserInRoom(data.uid, data.roomId);
if (!inRoom) {
throw new Error('[[error:not-allowed]]');
}

return await Messaging.addMessage(data);
};

Messaging.checkContent = async (content) => {
if (!content) {
throw new Error('[[error:invalid-chat-message]]');
}

const maximumChatMessageLength = meta.config.maximumChatMessageLength || 1000;
content = String(content).trim();
let { length } = content;
({ content, length } = await plugins.hooks.fire('filter:messaging.checkContent', { content, length }));
if (!content) {
throw new Error('[[error:invalid-chat-message]]');
}
if (length > maximumChatMessageLength) {
throw new Error(`[[error:chat-message-too-long, ${maximumChatMessageLength}]]`);
}
};

Messaging.addMessage = async (data) => {
const { uid, roomId } = data;
const roomData = await Messaging.getRoomData(roomId);
if (!roomData) {
throw new Error('[[error:no-room]]');
}
if (data.toMid) {
if (!utils.isNumber(data.toMid)) {
throw new Error('[[error:invalid-mid]]');
}
if (!await Messaging.canViewMessage(data.toMid, roomId, uid)) {
throw new Error('[[error:no-privileges]]');
}
}
const mid = await db.incrObjectField('global', 'nextMid');
const timestamp = data.timestamp || Date.now();
let message = {
mid: mid,
content: String(data.content),
timestamp: timestamp,
fromuid: uid,
roomId: roomId,
};
if (data.toMid) {
message.toMid = data.toMid;
}
if (data.system) {
message.system = data.system;
}

if (data.ip) {
message.ip = data.ip;
}

message = await plugins.hooks.fire('filter:messaging.save', message);
await db.setObject(`message:${mid}`, message);
const isNewSet = await Messaging.isNewSet(uid, roomId, timestamp);

const tasks = [
Messaging.addMessageToRoom(roomId, mid, timestamp),
Messaging.markRead(uid, roomId),
db.sortedSetAdd('messages:mid', timestamp, mid),
db.incrObjectField('global', 'messageCount'),
];
if (data.toMid) {
tasks.push(db.sortedSetAdd(`mid:${data.toMid}:replies`, timestamp, mid));
}
if (roomData.public) {
tasks.push(
db.sortedSetAdd('chat:rooms:public:lastpost', timestamp, roomId)
);
} else {
let uids = await Messaging.getUidsInRoom(roomId, 0, -1);
uids = await user.blocks.filterUids(uid, uids);
tasks.push(
Messaging.addRoomToUsers(roomId, uids, timestamp),
Messaging.markUnread(uids.filter(uid => uid !== String(data.uid)), roomId),
);
}
await Promise.all(tasks);

const messages = await Messaging.getMessagesData([mid], uid, roomId, true);
if (!messages || !messages[0]) {
return null;
}

messages[0].newSet = isNewSet;
plugins.hooks.fire('action:messaging.save', { message: message, data: data });
return messages[0];
};

Messaging.addSystemMessage = async (content, uid, roomId) => {
const message = await Messaging.addMessage({
content: content,
uid: uid,
roomId: roomId,
system: 1,
});
Messaging.notifyUsersInRoom(uid, roomId, message);
};

Messaging.addRoomToUsers = async (roomId, uids, timestamp) => {
if (!uids.length) {
return;
}
const keys = _.uniq(uids).map(uid => `uid:${uid}:chat:rooms`);
await db.sortedSetsAdd(keys, timestamp, roomId);
};

Messaging.addMessageToRoom = async (roomId, mid, timestamp) => {
await db.sortedSetAdd(`chat:room:${roomId}:mids`, timestamp, mid);
await db.incrObjectField(`chat:room:${roomId}`, 'messageCount');
};
Messaging.sendMessage = (data) => __awaiter(this, void 0, void 0, function* () {
yield Messaging.checkContent(data.content);
const inRoom = yield Messaging.isUserInRoom(data.uid, data.roomId);
if (!inRoom) {
throw new Error('[[error:not-allowed]]');
}
return yield Messaging.addMessage(data);
});
Messaging.checkContent = (content) => __awaiter(this, void 0, void 0, function* () {
if (!content) {
throw new Error('[[error:invalid-chat-message]]');
}
// eslint-disable-next-line max-len
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access, @typescript-eslint/no-unsafe-assignment
const maximumChatMessageLength = meta_1.default.config.maximumChatMessageLength || 1000;
content = String(content).trim();
let { length } = content;
// eslint-disable-next-line max-len
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access, @typescript-eslint/no-unsafe-assignment
({ content, length } = yield plugins_1.default.hooks.fire('filter:messaging.checkContent', { content, length }));
if (!content) {
throw new Error('[[error:invalid-chat-message]]');
}
if (length > maximumChatMessageLength) {
throw new Error(`[[error:chat-message-too-long, ${maximumChatMessageLength}]]`);
}
});
Messaging.addMessage = (data) => __awaiter(this, void 0, void 0, function* () {
const { uid, roomId } = data;
const roomData = yield Messaging.getRoomData(roomId);
if (!roomData) {
throw new Error('[[error:no-room]]');
}
if (data.toMid) {
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access
if (!utils_1.default.isNumber(data.toMid)) {
throw new Error('[[error:invalid-mid]]');
}
if (!(yield Messaging.canViewMessage(data.toMid, roomId, uid))) {
throw new Error('[[error:no-privileges]]');
}
}
// eslint-disable-next-line max-len
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access, @typescript-eslint/no-unsafe-assignment
const mid = yield database_1.default.incrObjectField('global', 'nextMid');
const timestamp = data.timestamp || Date.now();
let message = {
mid: mid,
content: String(data.content),
timestamp: timestamp,
fromuid: uid,
roomId: roomId,
};
if (data.toMid) {
message.toMid = data.toMid;
}
if (data.system) {
message.system = data.system;
}
if (data.ip) {
message.ip = data.ip;
}
// eslint-disable-next-line max-len
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access, @typescript-eslint/no-unsafe-assignment
message = yield plugins_1.default.hooks.fire('filter:messaging.save', message);
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access
yield database_1.default.setObject(`message:${mid}`, message);
const isNewSet = yield Messaging.isNewSet(uid, roomId, timestamp);
const tasks = [
Messaging.addMessageToRoom(roomId, mid, timestamp),
Messaging.markRead(uid, roomId),
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access
database_1.default.sortedSetAdd('messages:mid', timestamp, mid),
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access
database_1.default.incrObjectField('global', 'messageCount'),
];
if (data.toMid) {
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access
tasks.push(database_1.default.sortedSetAdd(`mid:${data.toMid}:replies`, timestamp, mid));
}
if (roomData.public) {
tasks.push(
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access
database_1.default.sortedSetAdd('chat:rooms:public:lastpost', timestamp, roomId));
}
else {
let uids = yield Messaging.getUidsInRoom(roomId, 0, -1);
// eslint-disable-next-line max-len
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access, @typescript-eslint/no-unsafe-assignment
uids = yield user_1.default.blocks.filterUids(uid, uids);
tasks.push(Messaging.addRoomToUsers(roomId, uids, timestamp), Messaging.markUnread(uids.filter((uid) => uid !== data.uid), roomId));
}
yield Promise.all(tasks);
const messages = yield Messaging.getMessagesData([mid], uid, roomId, true);
if (!messages || !messages[0]) {
return null;
}
messages[0].newSet = isNewSet;
// eslint-disable-next-line max-len
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access, @typescript-eslint/no-unsafe-assignment
yield plugins_1.default.hooks.fire('action:messaging.save', { message: message, data: data });
return messages[0];
});
Messaging.addSystemMessage = (content, uid, roomId) => __awaiter(this, void 0, void 0, function* () {
const message = yield Messaging.addMessage({
content: content,
uid: uid,
roomId: roomId,
system: 1,
});
Messaging.notifyUsersInRoom(uid, roomId, message);
});
Messaging.addRoomToUsers = (roomId, uids, timestamp) => __awaiter(this, void 0, void 0, function* () {
if (!uids.length) {
return;
}
// eslint-disable-next-line max-len
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access, @typescript-eslint/no-unsafe-assignment
const keys = lodash_1.default.uniq(uids).map(uid => `uid:${uid}:chat:rooms`);
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access
yield database_1.default.sortedSetsAdd(keys, timestamp, roomId);
});
Messaging.addMessageToRoom = (roomId, mid, timestamp) => __awaiter(this, void 0, void 0, function* () {
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access
yield database_1.default.sortedSetAdd(`chat:room:${roomId}:mids`, timestamp, mid);
// eslint-disable-next-line @typescript-eslint/no-unsafe-call, @typescript-eslint/no-unsafe-member-access
yield database_1.default.incrObjectField(`chat:room:${roomId}`, 'messageCount');
});
};
Loading