545563e776
- Complete NestJS TypeScript implementation with WebSocket support - Direct messaging (DM) and group chat functionality - End-to-end encryption with AES encryption and key pairs - Media file support (images, videos, audio, documents) up to 100MB - Push notifications with Firebase Cloud Messaging integration - Mention alerts and real-time typing indicators - User authentication with JWT and Passport - SQLite database with TypeORM entities and relationships - Comprehensive API documentation with Swagger/OpenAPI - File upload handling with secure access control - Online/offline status tracking and presence management - Message editing, deletion, and reply functionality - Notification management with automatic cleanup - Health check endpoint for monitoring - CORS configuration for cross-origin requests - Environment-based configuration management - Structured for Flutter SDK integration Features implemented: ✅ Real-time messaging with Socket.IO ✅ User registration and authentication ✅ Direct messages and group chats ✅ Media file uploads and management ✅ End-to-end encryption ✅ Push notifications ✅ Mention alerts ✅ Typing indicators ✅ Message read receipts ✅ Online status tracking ✅ File access control ✅ Comprehensive API documentation Ready for Flutter SDK development and production deployment.
67 lines
2.1 KiB
JavaScript
67 lines
2.1 KiB
JavaScript
"use strict";
|
|
|
|
// rawAsap provides everything we need except exception management.
|
|
var rawAsap = require("./raw");
|
|
// RawTasks are recycled to reduce GC churn.
|
|
var freeTasks = [];
|
|
// We queue errors to ensure they are thrown in right order (FIFO).
|
|
// Array-as-queue is good enough here, since we are just dealing with exceptions.
|
|
var pendingErrors = [];
|
|
var requestErrorThrow = rawAsap.makeRequestCallFromTimer(throwFirstError);
|
|
|
|
function throwFirstError() {
|
|
if (pendingErrors.length) {
|
|
throw pendingErrors.shift();
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Calls a task as soon as possible after returning, in its own event, with priority
|
|
* over other events like animation, reflow, and repaint. An error thrown from an
|
|
* event will not interrupt, nor even substantially slow down the processing of
|
|
* other events, but will be rather postponed to a lower priority event.
|
|
* @param {{call}} task A callable object, typically a function that takes no
|
|
* arguments.
|
|
*/
|
|
module.exports = asap;
|
|
function asap(task) {
|
|
var rawTask;
|
|
if (freeTasks.length) {
|
|
rawTask = freeTasks.pop();
|
|
} else {
|
|
rawTask = new RawTask();
|
|
}
|
|
rawTask.task = task;
|
|
rawAsap(rawTask);
|
|
}
|
|
|
|
// We wrap tasks with recyclable task objects. A task object implements
|
|
// `call`, just like a function.
|
|
function RawTask() {
|
|
this.task = null;
|
|
}
|
|
|
|
// The sole purpose of wrapping the task is to catch the exception and recycle
|
|
// the task object after its single use.
|
|
RawTask.prototype.call = function () {
|
|
try {
|
|
this.task.call();
|
|
} catch (error) {
|
|
if (asap.onerror) {
|
|
// This hook exists purely for testing purposes.
|
|
// Its name will be periodically randomized to break any code that
|
|
// depends on its existence.
|
|
asap.onerror(error);
|
|
} else {
|
|
// In a web browser, exceptions are not fatal. However, to avoid
|
|
// slowing down the queue of pending tasks, we rethrow the error in a
|
|
// lower priority turn.
|
|
pendingErrors.push(error);
|
|
requestErrorThrow();
|
|
}
|
|
} finally {
|
|
this.task = null;
|
|
freeTasks[freeTasks.length] = this;
|
|
}
|
|
};
|