Function deleteMessagesWithRetry

dme/dme.ts:91–117

* 带重试机制的删除消息函数

(
  client: TelegramClient,
  chatEntity: any,
  messageIds: number[],
  retryCount: number = 0
)

): Promise<number> {
  try {
    await client.deleteMessages(chatEntity, messageIds, { revoke: true });
    
    // 强制刷新更新状态，确保跨平台同步
    try {
      await client.invoke(new Api.updates.GetState());
      console.log(`[DME] 已触发跨平台同步刷新`);
    } catch (syncError) {
      console.log(`[DME] 同步刷新失败，但不影响删除操作:`, syncError);
    }
    
    return messageIds.length;
  } catch (error: any) {
    if (retryCount < CONFIG.RETRY_ATTEMPTS) {
      console.log(`[DME] 删除失败，第 ${retryCount + 1} 次重试:`, error.message);
      await sleep(CONFIG.DELAYS.RETRY * (retryCount + 1));
      return deleteMessagesWithRetry(client, chatEntity, messageIds, retryCount + 1);
    }
    throw error;
  }
}

/**
 * 通用删除消息函数 - 增强版本
 */
async function deleteMessagesUniversal(
  client: TelegramClient,
  chatEntity: any,
  messageIds: number[]
): Promise<number> {
  return deleteMessagesWithRetry(client, chatEntity, messageIds);