Skip to content

Commit fb6315e

Browse files
committed
chore: add log level mixin to all micro services
1 parent 2772d86 commit fb6315e

File tree

2 files changed

+28
-1
lines changed

2 files changed

+28
-1
lines changed
Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
import type { LogLevelSetting } from '@rocket.chat/logger';
2+
import { logLevel } from '@rocket.chat/logger';
3+
import { Settings } from '@rocket.chat/models';
4+
import type { ServiceSchema, Context } from 'moleculer';
5+
6+
export const LogLevel: ServiceSchema = {
7+
name: 'LogLevel',
8+
async started() {
9+
const LogLevel = await Settings.getValueById('Log_Level');
10+
if (LogLevel) {
11+
logLevel.emit('changed', LogLevel as LogLevelSetting);
12+
}
13+
},
14+
events: {
15+
'watch.settings': {
16+
handler(ctx: Context<[{ clientAction: string; setting: { _id: string; value: string } }]>) {
17+
const [{ setting }] = ctx.params;
18+
19+
if (setting._id !== 'Log_Level') {
20+
return;
21+
}
22+
logLevel.emit('changed', setting.value as LogLevelSetting);
23+
},
24+
},
25+
},
26+
};

ee/packages/network-broker/src/NetworkBroker.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@ import { injectCurrentContext, tracerSpan } from '@rocket.chat/tracing';
44
import type { ServiceBroker, Context, ServiceSchema } from 'moleculer';
55

66
import { EnterpriseCheck } from './EnterpriseCheck';
7+
import { LogLevel } from './LogLevelMixin';
78

89
const events: { [k: string]: string } = {
910
onNodeConnected: '$node.connected',
@@ -94,7 +95,7 @@ export class NetworkBroker implements IBroker {
9495
const service: ServiceSchema = {
9596
name,
9697
actions: {},
97-
mixins: !instance.isInternal() ? [EnterpriseCheck] : [],
98+
mixins: !instance.isInternal() ? [EnterpriseCheck, LogLevel] : [],
9899
...(dependencies.length ? { dependencies } : {}),
99100
events: instanceEvents.reduce<Record<string, (ctx: Context) => void>>((map, { eventName }) => {
100101
map[eventName] = /^\$/.test(eventName)

0 commit comments

Comments
 (0)