Mirrors/audiobookshelf
Mirrors/audiobookshelf
1
0
Fork 0
mirror of https://github.com/advplyr/audiobookshelf.git synced 2025-06-28 01:16:10 +02:00
Code Issues Packages Projects Releases Wiki Activity

moved flatten after O(1)

Browse Source
This commit is contained in:
Vito0912 2025-05-17 18:03:55 +02:00
parent 7b62b6be86
commit 39f59e5189
No known key found for this signature in database
GPG Key ID: 29A3D509FE70B237
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
server/SocketAuthority.js
View File

@ -33,7 +33,7 @@ class SocketAuthority {
if (!this.emittedNotifications.has(event)) return if (!this.emittedNotifications.has(event)) return
Logger.debug(`[SocketAuthority] fireNotification - ${event}`) Logger.debug(`[SocketAuthority] fireNotification - ${event}`)
NotificationManager.fireNotificationFromSocket(event, payload) NotificationManager.fireNotificationFromSocket(event, flattenAny(payload))
} }
/** /**
@ -69,7 +69,7 @@ class SocketAuthority {
* @param {Function} [filter] optional filter function to only send event to specific users * @param {Function} [filter] optional filter function to only send event to specific users
*/ */
emitter(evt, data, filter = null) { emitter(evt, data, filter = null) {
void this._fireNotification(evt, flattenAny(data)) void this._fireNotification(evt, data)
for (const socketId in this.clients) { for (const socketId in this.clients) {
if (this.clients[socketId].user) { if (this.clients[socketId].user) {
if (filter && !filter(this.clients[socketId].user)) continue if (filter && !filter(this.clients[socketId].user)) continue
@ -81,7 +81,7 @@ class SocketAuthority {
// Emits event to all clients for a specific user // Emits event to all clients for a specific user
clientEmitter(userId, evt, data) { clientEmitter(userId, evt, data) {
void this._fireNotification(evt, flattenAny(data)) void this._fireNotification(evt, data)
const clients = this.getClientsForUser(userId) const clients = this.getClientsForUser(userId)
if (!clients.length) { if (!clients.length) {
return Logger.debug(`[SocketAuthority] clientEmitter - no clients found for user ${userId}`) return Logger.debug(`[SocketAuthority] clientEmitter - no clients found for user ${userId}`)
@ -95,7 +95,7 @@ class SocketAuthority {
// Emits event to all admin user clients // Emits event to all admin user clients
adminEmitter(evt, data) { adminEmitter(evt, data) {
void this._fireNotification(evt, flattenAny(data)); void this._fireNotification(evt, data);
for (const socketId in this.clients) { for (const socketId in this.clients) {
if (this.clients[socketId].user?.isAdminOrUp) { if (this.clients[socketId].user?.isAdminOrUp) {
this.clients[socketId].socket.emit(evt, data) this.clients[socketId].socket.emit(evt, data)
@ -111,7 +111,7 @@ class SocketAuthority {
* @param {import('./models/LibraryItem')} libraryItem * @param {import('./models/LibraryItem')} libraryItem
*/ */
libraryItemEmitter(evt, libraryItem) { libraryItemEmitter(evt, libraryItem) {
void this._fireNotification(evt, flattenAny(libraryItem.toOldJSONMinified())) void this._fireNotification(evt, libraryItem.toOldJSONMinified())
for (const socketId in this.clients) { for (const socketId in this.clients) {
if (this.clients[socketId].user?.checkCanAccessLibraryItem(libraryItem)) { if (this.clients[socketId].user?.checkCanAccessLibraryItem(libraryItem)) {
this.clients[socketId].socket.emit(evt, libraryItem.toOldJSONExpanded()) this.clients[socketId].socket.emit(evt, libraryItem.toOldJSONExpanded())