Fix ws
This commit is contained in:
@@ -13,30 +13,30 @@ module.exports.getAllNotifs = async socket => {
|
|||||||
try {
|
try {
|
||||||
const allData = await Promise.all([
|
const allData = await Promise.all([
|
||||||
// unreadCuMsgs
|
// unreadCuMsgs
|
||||||
ContactPageMessage.find({ read: false }),
|
ContactPageMessage.countDocuments({ read: false }),
|
||||||
|
|
||||||
// unreadTickets
|
// unreadTickets
|
||||||
TicketConversation.find({ messages: { $elemMatch: { isUser: true, read: false } } }),
|
TicketConversation.countDocuments({ messages: { $elemMatch: { isUser: true, read: false } } }),
|
||||||
|
|
||||||
// newCustomers
|
// newCustomers
|
||||||
User.find({ scope: ['user'], seenByAdmin: false, confirmed: true }),
|
User.countDocuments({ scope: ['user'], seenByAdmin: false, confirmed: true }),
|
||||||
|
|
||||||
// newRepresentations
|
// newRepresentations
|
||||||
Representation.find({ status: 'registered' }),
|
Representation.countDocuments({ status: 'registered' }),
|
||||||
|
|
||||||
// newPieceRequests
|
// newPieceRequests
|
||||||
PieceRequest.find({ status: 'sent' }),
|
PieceRequest.countDocuments({ status: 'sent' }),
|
||||||
|
|
||||||
// newOldPieceRequests
|
// newOldPieceRequests
|
||||||
OldPieceRequest.find({ status: 'sent' }),
|
OldPieceRequest.countDocuments({ status: 'sent' }),
|
||||||
|
|
||||||
// newBufferRequests
|
// newBufferRequests
|
||||||
BufferRequest.find({ status: 'sent' }),
|
BufferRequest.countDocuments({ status: 'sent' }),
|
||||||
|
|
||||||
// newGuaranteeReports
|
// newGuaranteeReports
|
||||||
GuaranteeReport.find({ status: 'sent', seen: false }),
|
GuaranteeReport.countDocuments({ status: 'sent', seen: false }),
|
||||||
|
|
||||||
Complaint.find({ read: false })
|
Complaint.countDocuments({ read: false })
|
||||||
])
|
])
|
||||||
|
|
||||||
const unreadCuMsgs = allData[0]
|
const unreadCuMsgs = allData[0]
|
||||||
@@ -47,19 +47,19 @@ module.exports.getAllNotifs = async socket => {
|
|||||||
const newOldPieceRequests = allData[5]
|
const newOldPieceRequests = allData[5]
|
||||||
const newBufferRequests = allData[6]
|
const newBufferRequests = allData[6]
|
||||||
const newGuaranteeReports = allData[7]
|
const newGuaranteeReports = allData[7]
|
||||||
const complaint = allData[8]
|
const newComplaintReports = allData[8]
|
||||||
|
|
||||||
|
|
||||||
socket.emit(`admin:allNotifs`, {
|
socket.emit(`admin:allNotifs`, {
|
||||||
unreadCuMsgs: unreadCuMsgs.length,
|
unreadCuMsgs,
|
||||||
unreadTickets: unreadTickets.length,
|
unreadTickets,
|
||||||
newCustomers: newCustomers.length,
|
newCustomers,
|
||||||
newRepresentations: newRepresentations.length,
|
newRepresentations,
|
||||||
newPieceRequests: newPieceRequests.length,
|
newPieceRequests,
|
||||||
newOldPieceRequests: newOldPieceRequests.length,
|
newOldPieceRequests,
|
||||||
newBufferRequests: newBufferRequests.length,
|
newBufferRequests,
|
||||||
newGuaranteeReports: newGuaranteeReports.length,
|
newGuaranteeReports,
|
||||||
newComplaintReports:complaint.length
|
newComplaintReports
|
||||||
})
|
})
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
console.log(e)
|
console.log(e)
|
||||||
|
|||||||
@@ -1,7 +1,6 @@
|
|||||||
/// / develop environment config
|
/// / develop environment config
|
||||||
const { isDev, isProduction, DevServerPort } = require('./_env')
|
const { isDev, isProduction, DevServerPort } = require('./_env')
|
||||||
const wss = require('./WebSocket/wss')
|
const wss = require('./WebSocket/wss')
|
||||||
|
|
||||||
/// / init express app (wrapping all functions into init() to prevent running in development mode by nuxt dev mode)
|
/// / init express app (wrapping all functions into init() to prevent running in development mode by nuxt dev mode)
|
||||||
function init() {
|
function init() {
|
||||||
// run preConfigured modules
|
// run preConfigured modules
|
||||||
|
|||||||
Reference in New Issue
Block a user