Compare commits
2 Commits
0748256ce8
...
083cc95523
| Author | SHA1 | Date | |
|---|---|---|---|
| 083cc95523 | |||
| 7002e5a6c1 |
@ -174,16 +174,20 @@ export class SocketUser {
|
|||||||
data.objectType,
|
data.objectType,
|
||||||
data.filter
|
data.filter
|
||||||
);
|
);
|
||||||
|
if (typeof callback === 'function') {
|
||||||
callback({ success: true });
|
callback({ success: true });
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async handleSubscribeToObjectUpdateEvent(data, callback) {
|
async handleSubscribeToObjectUpdateEvent(data, callback) {
|
||||||
const result = await this.updateManager.subscribeToObjectUpdate(
|
const result = await this.updateManager.subscribeToObjectUpdate(
|
||||||
data._id,
|
data._id,
|
||||||
data.objectType
|
data.objectType
|
||||||
);
|
);
|
||||||
|
if (typeof callback === 'function') {
|
||||||
callback(result);
|
callback(result);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async handleSubscribeToObjectEventEvent(data) {
|
async handleSubscribeToObjectEventEvent(data) {
|
||||||
await this.eventManager.subscribeToObjectEvent(
|
await this.eventManager.subscribeToObjectEvent(
|
||||||
|
|||||||
@ -2,6 +2,7 @@ import log4js from 'log4js';
|
|||||||
import _ from 'lodash';
|
import _ from 'lodash';
|
||||||
import { loadConfig } from '../config.js';
|
import { loadConfig } from '../config.js';
|
||||||
import { natsServer } from '../database/nats.js';
|
import { natsServer } from '../database/nats.js';
|
||||||
|
import { expandObjectIds } from '../database/utils.js';
|
||||||
const config = loadConfig();
|
const config = loadConfig();
|
||||||
|
|
||||||
// Setup logger
|
// Setup logger
|
||||||
@ -155,11 +156,12 @@ export class UpdateManager {
|
|||||||
`${objectType}s.${id}.object`,
|
`${objectType}s.${id}.object`,
|
||||||
this.socketClient.socketId,
|
this.socketClient.socketId,
|
||||||
(key, value) => {
|
(key, value) => {
|
||||||
|
const expandedValue = expandObjectIds(value);
|
||||||
logger.trace('Object update event:', id);
|
logger.trace('Object update event:', id);
|
||||||
this.socketClient.socket.emit('objectUpdate', {
|
this.socketClient.socket.emit('objectUpdate', {
|
||||||
_id: id,
|
_id: id,
|
||||||
objectType: objectType,
|
objectType: objectType,
|
||||||
object: { ...value }
|
object: { ...expandedValue }
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
);
|
);
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user