ваше сообщение коммита

backend/services/auth-service.js

@@ -9,6 +9,7 @@ const authTokenService = require('./authTokenService');
 const rpcProviderService = require('./rpcProviderService');
 const { getLinkedWallet } = require('./wallet-service');
 const { checkAdminRole } = require('./admin-role');
+const { broadcastContactsUpdate } = require('../wsHub');
 
 const ERC20_ABI = ['function balanceOf(address owner) view returns (uint256)'];
 
@@ -102,6 +103,8 @@ class AuthService {
         );
       }
 
+      broadcastContactsUpdate();
+
       return { userId, isAdmin };
     } catch (error) {
       logger.error('Error finding or creating user:', error);
@@ -743,6 +746,8 @@ class AuthService {
       delete session.tempUserId;
       delete session.pendingEmail;
 
+      broadcastContactsUpdate();
+
       return {
         userId,
         email: normalizedEmail,

backend/services/emailAuth.js

@@ -5,6 +5,7 @@ const EmailBotService = require('./emailBot.js');
 const db = require('../db');
 const authService = require('./auth-service');
 const { checkAdminRole } = require('./admin-role');
+const { broadcastContactsUpdate } = require('../wsHub');
 
 class EmailAuth {
   constructor() {
@@ -65,6 +66,9 @@ class EmailAuth {
         `Generated verification code for Email auth for ${email} and sent to user's email`
       );
 
+      // После каждого успешного создания пользователя:
+      broadcastContactsUpdate();
+
       return { success: true, verificationCode };
     } catch (error) {
       logger.error('Error in email auth initialization:', error);
@@ -201,6 +205,9 @@ class EmailAuth {
         delete session.tempUserId;
       }
 
+      // После каждого успешного создания пользователя:
+      broadcastContactsUpdate();
+
       return {
         verified: true,
         userId: finalUserId,

backend/services/emailBot.js

@@ -8,6 +8,7 @@ const { inspect } = require('util');
 const logger = require('../utils/logger');
 const identityService = require('./identity-service');
 const aiAssistant = require('./ai-assistant');
+const { broadcastContactsUpdate } = require('../wsHub');
 
 class EmailBotService {
   constructor() {
@@ -172,6 +173,8 @@ class EmailBotService {
                       );
                       // 5. Отправить ответ на email
                       await this.sendEmail(fromEmail, 'Re: ' + subject, aiResponse);
+                      // После каждого успешного создания пользователя:
+                      broadcastContactsUpdate();
                     } catch (processErr) {
                       logger.error('Error processing incoming email:', processErr);
                     }

backend/services/identity-service.js

@@ -544,6 +544,7 @@ class IdentityService {
       await this.saveIdentity(userId, provider, providerId, true);
       user = { id: userId, role: 'user' };
       isNew = true;
+      logger.info('[WS] broadcastContactsUpdate after new user created');
       broadcastContactsUpdate();
     }
     // Проверяем связь с кошельком

backend/services/telegramBot.js

@@ -7,6 +7,7 @@ const crypto = require('crypto');
 const identityService = require('./identity-service');
 const aiAssistant = require('./ai-assistant');
 const { checkAdminRole } = require('./admin-role');
+const { broadcastContactsUpdate } = require('../wsHub');
 
 let botInstance = null;
 let telegramSettingsCache = null;
@@ -252,6 +253,9 @@ async function getBot() {
           } catch (error) {
             logger.warn('Could not delete code message:', error);
           }
+
+          // После каждого успешного создания пользователя:
+          broadcastContactsUpdate();
         } catch (error) {
           logger.error('Error in Telegram auth:', error);
           await ctx.reply('Произошла ошибка при аутентификации. Попробуйте позже.');