通知テスト

Author: hikuohiku

packages/backend/src/index.ts

@@ -5,6 +5,7 @@ import path from 'path';
 import { errorHandler } from './middlewares/errorHandler';
 import { logger } from '@/utils/logger';
 import { WebSocketDonChannel } from './websocket/donChannel';
+import { Don } from './websocket/messages';
 
 const app = express();
 
@@ -71,6 +72,16 @@ const server = app.listen(port, host, () => {
 const donChannel = new WebSocketDonChannel({ wssConfig: { port: 52601 } });
 logger.info('WebSocket server started on ws://localhost:52601');
 
+// 5秒ごとに通知をテスト送信
+setInterval(() => {
+  logger.info('Sending notification to active clients...');
+  const exampleDonState: Don[] = [
+    { id: '1', state: 'ordered' },
+    { id: '2', state: 'cooking' },
+  ];
+  donChannel.notifyActiveDonState(exampleDonState);
+}, 5000);
+
 // Graceful shutdown
 process.on('SIGTERM', () => {
   logger.info('SIGTERM signal received: closing HTTP server');