|
|
|
|
@ -162,17 +162,10 @@ export class CoreService {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
async callPluginApi<T = any>(pluginId: string, path: string, body?: any): Promise<T> {
|
|
|
|
|
const res = await this.fetchCore(`/api/plugins/rpc/${pluginId}/${path.replace(/^\//, '')}`, {
|
|
|
|
|
return this.fetchCore(`/api/plugins/rpc/${pluginId}/${path.replace(/^\//, '')}`, {
|
|
|
|
|
method: 'POST',
|
|
|
|
|
body: body !== undefined ? JSON.stringify(body) : undefined,
|
|
|
|
|
});
|
|
|
|
|
if (res && typeof res === 'object' && res.success === true) {
|
|
|
|
|
if (res.data && typeof res.data === 'object' && res.data.success === true) {
|
|
|
|
|
return res.data.data as T;
|
|
|
|
|
}
|
|
|
|
|
return res.data as T;
|
|
|
|
|
}
|
|
|
|
|
return res as T;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
async callAsService<T = any>(pluginId: string, path: string, body?: any): Promise<T> {
|
|
|
|
|
@ -331,19 +324,9 @@ export class CoreService {
|
|
|
|
|
source: this.serviceName,
|
|
|
|
|
timestamp: Date.now(),
|
|
|
|
|
};
|
|
|
|
|
try {
|
|
|
|
|
const conn = await amqp.connect(this.getRMQUrl());
|
|
|
|
|
const ch = await conn.createChannel();
|
|
|
|
|
await ch.assertExchange('system_events', 'topic', { durable: true });
|
|
|
|
|
ch.publish('system_events', pattern, Buffer.from(JSON.stringify({
|
|
|
|
|
pattern,
|
|
|
|
|
data: event,
|
|
|
|
|
})));
|
|
|
|
|
await ch.close();
|
|
|
|
|
await conn.close();
|
|
|
|
|
} catch (err: any) {
|
|
|
|
|
this.logger.error(`Failed to emit event ${pattern}: ${err.message}`);
|
|
|
|
|
}
|
|
|
|
|
this.client.emit(pattern, event).subscribe({
|
|
|
|
|
error: (err) => this.logger.error(`Failed to emit event ${pattern}:`, err),
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
async auditLog(action: string, resource: string, details?: any): Promise<void> {
|
|
|
|
|
@ -416,26 +399,14 @@ export class CoreService {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
async sendNotification(payload: { userId: number | null; title: string; message: string; icon?: string; image?: string; details?: any }): Promise<void> {
|
|
|
|
|
try {
|
|
|
|
|
const conn = await amqp.connect(this.getRMQUrl());
|
|
|
|
|
const ch = await conn.createChannel();
|
|
|
|
|
await ch.assertExchange('system_events', 'topic', { durable: true });
|
|
|
|
|
ch.publish('system_events', 'system.notification.send', Buffer.from(JSON.stringify({
|
|
|
|
|
pattern: 'system.notification.send',
|
|
|
|
|
data: {
|
|
|
|
|
await this.emit('system.notification.send', {
|
|
|
|
|
userId: payload.userId,
|
|
|
|
|
title: payload.title,
|
|
|
|
|
message: payload.message,
|
|
|
|
|
icon: payload.icon,
|
|
|
|
|
image: payload.image,
|
|
|
|
|
details: payload.details,
|
|
|
|
|
},
|
|
|
|
|
})));
|
|
|
|
|
await ch.close();
|
|
|
|
|
await conn.close();
|
|
|
|
|
} catch (err: any) {
|
|
|
|
|
this.logger.error(`[sendNotification] Failed: ${err.message}`);
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
getDbName(): string {
|
|
|
|
|
|