alma/NeahStable
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

notifications

Browse Source
This commit is contained in:
alma 2026-01-11 22:38:57 +01:00
parent b21921242e
commit af1635b7da
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
lib/services/notifications/rocketchat-adapter.ts
View File

@ -45,6 +45,7 @@ export class RocketChatAdapter implements NotificationAdapter {
/**
* Get RocketChat user ID from email
* Uses the same logic as the messages API: search by username OR email
*/
private async getRocketChatUserId(email: string): Promise<string | null> {
try {
@ -80,14 +81,19 @@ export class RocketChatAdapter implements NotificationAdapter {
logger.debug('[ROCKETCHAT_ADAPTER] Searching for user', {
username,
email,
totalUsers: usersData.users.length,
});
const currentUser = usersData.users.find((u: any) => u.username === username);
// Use the exact same logic as the messages API
const currentUser = usersData.users.find((user: any) =>
user.username === username || user.emails?.some((e: any) => e.address === email)
);
if (!currentUser) {
logger.warn('[ROCKETCHAT_ADAPTER] User not found in RocketChat', {
username,
email,
searchedIn: usersData.users.length,
availableUsernames: usersData.users.slice(0, 5).map((u: any) => u.username),
});
@ -96,6 +102,8 @@ export class RocketChatAdapter implements NotificationAdapter {
logger.debug('[ROCKETCHAT_ADAPTER] Found user', {
username,
email,
rocketChatUsername: currentUser.username,
userId: currentUser._id,
});