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.
85 lines
4.5 KiB
JavaScript
85 lines
4.5 KiB
JavaScript
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
exports.SocketModule = void 0;
|
|
const guards_consumer_1 = require("@nestjs/core/guards/guards-consumer");
|
|
const guards_context_creator_1 = require("@nestjs/core/guards/guards-context-creator");
|
|
const load_adapter_1 = require("@nestjs/core/helpers/load-adapter");
|
|
const interceptors_consumer_1 = require("@nestjs/core/interceptors/interceptors-consumer");
|
|
const interceptors_context_creator_1 = require("@nestjs/core/interceptors/interceptors-context-creator");
|
|
const pipes_consumer_1 = require("@nestjs/core/pipes/pipes-consumer");
|
|
const pipes_context_creator_1 = require("@nestjs/core/pipes/pipes-context-creator");
|
|
const iterare_1 = require("iterare");
|
|
const constants_1 = require("./constants");
|
|
const exception_filters_context_1 = require("./context/exception-filters-context");
|
|
const ws_context_creator_1 = require("./context/ws-context-creator");
|
|
const ws_proxy_1 = require("./context/ws-proxy");
|
|
const socket_server_provider_1 = require("./socket-server-provider");
|
|
const sockets_container_1 = require("./sockets-container");
|
|
const web_sockets_controller_1 = require("./web-sockets-controller");
|
|
class SocketModule {
|
|
constructor() {
|
|
this.socketsContainer = new sockets_container_1.SocketsContainer();
|
|
}
|
|
register(container, applicationConfig, graphInspector, appOptions, httpServer) {
|
|
this.applicationConfig = applicationConfig;
|
|
this.appOptions = appOptions;
|
|
this.httpServer = httpServer;
|
|
const contextCreator = this.getContextCreator(container);
|
|
const serverProvider = new socket_server_provider_1.SocketServerProvider(this.socketsContainer, applicationConfig);
|
|
this.webSocketsController = new web_sockets_controller_1.WebSocketsController(serverProvider, applicationConfig, contextCreator, graphInspector, this.appOptions);
|
|
const modules = container.getModules();
|
|
modules.forEach(({ providers }, moduleName) => this.connectAllGateways(providers, moduleName));
|
|
}
|
|
connectAllGateways(providers, moduleName) {
|
|
(0, iterare_1.iterate)(providers.values())
|
|
.filter(wrapper => wrapper && !wrapper.isNotMetatype)
|
|
.forEach(wrapper => this.connectGatewayToServer(wrapper, moduleName));
|
|
}
|
|
connectGatewayToServer(wrapper, moduleName) {
|
|
const { instance, metatype } = wrapper;
|
|
const metadataKeys = Reflect.getMetadataKeys(metatype);
|
|
if (!metadataKeys.includes(constants_1.GATEWAY_METADATA)) {
|
|
return;
|
|
}
|
|
if (!this.isAdapterInitialized) {
|
|
this.initializeAdapter();
|
|
}
|
|
this.webSocketsController.connectGatewayToServer(instance, metatype, moduleName, wrapper.id);
|
|
}
|
|
async close() {
|
|
if (!this.applicationConfig) {
|
|
return;
|
|
}
|
|
const adapter = this.applicationConfig.getIoAdapter();
|
|
if (!adapter) {
|
|
return;
|
|
}
|
|
const servers = this.socketsContainer.getAll();
|
|
await Promise.all((0, iterare_1.iterate)(servers.values())
|
|
.filter(({ server }) => server)
|
|
.map(async ({ server }) => adapter.close(server)));
|
|
await adapter?.dispose();
|
|
this.socketsContainer.clear();
|
|
}
|
|
initializeAdapter() {
|
|
const forceCloseConnections = this.appOptions
|
|
.forceCloseConnections;
|
|
const adapter = this.applicationConfig.getIoAdapter();
|
|
if (adapter) {
|
|
adapter.forceCloseConnections =
|
|
forceCloseConnections;
|
|
this.isAdapterInitialized = true;
|
|
return;
|
|
}
|
|
const { IoAdapter } = (0, load_adapter_1.loadAdapter)('@nestjs/platform-socket.io', 'WebSockets', () => require('@nestjs/platform-socket.io'));
|
|
const ioAdapter = new IoAdapter(this.httpServer);
|
|
ioAdapter.forceCloseConnections = forceCloseConnections;
|
|
this.applicationConfig.setIoAdapter(ioAdapter);
|
|
this.isAdapterInitialized = true;
|
|
}
|
|
getContextCreator(container) {
|
|
return new ws_context_creator_1.WsContextCreator(new ws_proxy_1.WsProxy(), new exception_filters_context_1.ExceptionFiltersContext(container), new pipes_context_creator_1.PipesContextCreator(container), new pipes_consumer_1.PipesConsumer(), new guards_context_creator_1.GuardsContextCreator(container), new guards_consumer_1.GuardsConsumer(), new interceptors_context_creator_1.InterceptorsContextCreator(container), new interceptors_consumer_1.InterceptorsConsumer());
|
|
}
|
|
}
|
|
exports.SocketModule = SocketModule;
|