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.
72 lines
2.8 KiB
JavaScript
72 lines
2.8 KiB
JavaScript
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
exports.IoAdapter = void 0;
|
|
const shared_utils_1 = require("@nestjs/common/utils/shared.utils");
|
|
const websockets_1 = require("@nestjs/websockets");
|
|
const constants_1 = require("@nestjs/websockets/constants");
|
|
const rxjs_1 = require("rxjs");
|
|
const operators_1 = require("rxjs/operators");
|
|
const socket_io_1 = require("socket.io");
|
|
/**
|
|
* @publicApi
|
|
*/
|
|
class IoAdapter extends websockets_1.AbstractWsAdapter {
|
|
create(port, options) {
|
|
if (!options) {
|
|
return this.createIOServer(port);
|
|
}
|
|
const { namespace, server, ...opt } = options;
|
|
return server && (0, shared_utils_1.isFunction)(server.of)
|
|
? server.of(namespace)
|
|
: namespace
|
|
? this.createIOServer(port, opt).of(namespace)
|
|
: this.createIOServer(port, opt);
|
|
}
|
|
createIOServer(port, options) {
|
|
if (this.httpServer && port === 0) {
|
|
return new socket_io_1.Server(this.httpServer, options);
|
|
}
|
|
return new socket_io_1.Server(port, options);
|
|
}
|
|
bindMessageHandlers(socket, handlers, transform) {
|
|
const disconnect$ = (0, rxjs_1.fromEvent)(socket, constants_1.DISCONNECT_EVENT).pipe((0, operators_1.share)(), (0, operators_1.first)());
|
|
handlers.forEach(({ message, callback }) => {
|
|
const source$ = (0, rxjs_1.fromEvent)(socket, message).pipe((0, operators_1.mergeMap)((payload) => {
|
|
const { data, ack } = this.mapPayload(payload);
|
|
return transform(callback(data, ack)).pipe((0, operators_1.filter)((response) => !(0, shared_utils_1.isNil)(response)), (0, operators_1.map)((response) => [response, ack]));
|
|
}), (0, operators_1.takeUntil)(disconnect$));
|
|
source$.subscribe(([response, ack]) => {
|
|
if (response.event) {
|
|
return socket.emit(response.event, response.data);
|
|
}
|
|
(0, shared_utils_1.isFunction)(ack) && ack(response);
|
|
});
|
|
});
|
|
}
|
|
mapPayload(payload) {
|
|
if (!Array.isArray(payload)) {
|
|
if ((0, shared_utils_1.isFunction)(payload)) {
|
|
return { data: undefined, ack: payload };
|
|
}
|
|
return { data: payload };
|
|
}
|
|
const lastElement = payload[payload.length - 1];
|
|
const isAck = (0, shared_utils_1.isFunction)(lastElement);
|
|
if (isAck) {
|
|
const size = payload.length - 1;
|
|
return {
|
|
data: size === 1 ? payload[0] : payload.slice(0, size),
|
|
ack: lastElement,
|
|
};
|
|
}
|
|
return { data: payload };
|
|
}
|
|
close(server) {
|
|
if (this.forceCloseConnections && server.httpServer === this.httpServer) {
|
|
return;
|
|
}
|
|
return super.close(server);
|
|
}
|
|
}
|
|
exports.IoAdapter = IoAdapter;
|