admin/zCode-CLI-X
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

debug: add detailed logging for streaming IDs

Browse Source
This commit is contained in:
admin
2026-05-05 13:44:47 +00:00
Unverified
parent 429b8a1633
commit f8a6edf4c7
1 changed files with 19 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/bot/message-sender.js
View File

@@ -57,11 +57,25 @@ export async function sendStreamingMessage(ctx, text, options = {}) {
// Send initial placeholder message
const sentMsg = await ctx.reply('⌨️ ⌨️', { parse_mode: 'Markdown' });
logger.info('📡 Initial message sent:', sentMsg.message_id, 'chat:', sentMsg.chat.id);
logger.info('📡 Initial message sent:', JSON.stringify({
message_id: sentMsg?.message_id,
chat_id: sentMsg?.chat?.id,
full_obj: Object.keys(sentMsg || {})
}));
// Extract IDs safely
const messageId = sentMsg?.message_id;
const chatId = sentMsg?.chat?.id;
if (!messageId || !chatId) {
logger.error('Failed to extract message ID or chat ID from reply response');
await sendFormatted(ctx, text);
return;
}
logger.info('📡 Using message_id:', messageId, 'chat_id:', chatId);
let sentText = '';
const chatId = sentMsg.chat.id;
const messageId = sentMsg.message_id;
if (charMode) {
// Character-by-character streaming
@@ -78,7 +92,7 @@ export async function sendStreamingMessage(ctx, text, options = {}) {
parse_mode: 'Markdown'
});
} catch (editErr) {
logger.error('Edit error:', editErr.message);
logger.error('Edit error:', editErr.message, 'payload:', { chat_id: chatId, message_id: messageId });
}
const delayMs = minDelay + Math.random() * (maxDelay - minDelay);
@@ -99,7 +113,7 @@ export async function sendStreamingMessage(ctx, text, options = {}) {
parse_mode: 'Markdown'
});
} catch (editErr) {
logger.error('Edit error:', editErr.message);
logger.error('Edit error:', editErr.message, 'payload:', { chat_id: chatId, message_id: messageId });
}
const wordDelay = Math.max(minDelay, Math.min(maxDelay, delay + words[i].length * 5));