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.
82 lines
1.6 KiB
JavaScript
82 lines
1.6 KiB
JavaScript
'use strict';
|
|
const AggregateError = require('aggregate-error');
|
|
|
|
module.exports = async (
|
|
iterable,
|
|
mapper,
|
|
{
|
|
concurrency = Infinity,
|
|
stopOnError = true
|
|
} = {}
|
|
) => {
|
|
return new Promise((resolve, reject) => {
|
|
if (typeof mapper !== 'function') {
|
|
throw new TypeError('Mapper function is required');
|
|
}
|
|
|
|
if (!((Number.isSafeInteger(concurrency) || concurrency === Infinity) && concurrency >= 1)) {
|
|
throw new TypeError(`Expected \`concurrency\` to be an integer from 1 and up or \`Infinity\`, got \`${concurrency}\` (${typeof concurrency})`);
|
|
}
|
|
|
|
const result = [];
|
|
const errors = [];
|
|
const iterator = iterable[Symbol.iterator]();
|
|
let isRejected = false;
|
|
let isIterableDone = false;
|
|
let resolvingCount = 0;
|
|
let currentIndex = 0;
|
|
|
|
const next = () => {
|
|
if (isRejected) {
|
|
return;
|
|
}
|
|
|
|
const nextItem = iterator.next();
|
|
const index = currentIndex;
|
|
currentIndex++;
|
|
|
|
if (nextItem.done) {
|
|
isIterableDone = true;
|
|
|
|
if (resolvingCount === 0) {
|
|
if (!stopOnError && errors.length !== 0) {
|
|
reject(new AggregateError(errors));
|
|
} else {
|
|
resolve(result);
|
|
}
|
|
}
|
|
|
|
return;
|
|
}
|
|
|
|
resolvingCount++;
|
|
|
|
(async () => {
|
|
try {
|
|
const element = await nextItem.value;
|
|
result[index] = await mapper(element, index);
|
|
resolvingCount--;
|
|
next();
|
|
} catch (error) {
|
|
if (stopOnError) {
|
|
isRejected = true;
|
|
reject(error);
|
|
} else {
|
|
errors.push(error);
|
|
resolvingCount--;
|
|
next();
|
|
}
|
|
}
|
|
})();
|
|
};
|
|
|
|
for (let i = 0; i < concurrency; i++) {
|
|
next();
|
|
|
|
if (isIterableDone) {
|
|
break;
|
|
}
|
|
}
|
|
});
|
|
};
|