Function adaptiveBatchDelete

dme/dme.ts:562–606

* 自适应批次删除函数

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

  let deletedCount = 0;
  let failedCount = 0;
  let currentBatchSize: number = CONFIG.BATCH_SIZE;

  for (let i = 0; i < messageIds.length; i += currentBatchSize) {
    const batch = messageIds.slice(i, i + currentBatchSize);
    
    try {
      await deleteMessagesWithRetry(client, chatEntity, batch);
      deletedCount += batch.length;
      
      // 成功则可以适当增加批次大小
      if (currentBatchSize < CONFIG.MAX_BATCH_SIZE) {
        currentBatchSize = Math.min(currentBatchSize + 5, CONFIG.MAX_BATCH_SIZE);
      }
      
      console.log(`[DME] 成功删除批次 ${batch.length} 条，当前批次大小: ${currentBatchSize}`);
      await sleep(CONFIG.DELAYS.BATCH);
      
    } catch (error: any) {
      console.log(`[DME] 批次删除失败，减少批次大小:`, error.message);
      
      // 失败则减少批次大小
      currentBatchSize = Math.max(Math.floor(currentBatchSize / 2), CONFIG.MIN_BATCH_SIZE);
      
      if (currentBatchSize <= CONFIG.MIN_BATCH_SIZE && batch.length === 1) {
        // 单条消息删除失败，跳过
        failedCount += 1;
        console.log(`[DME] 跳过无法删除的消息: ${batch[0]}`);
      } else {
        // 重新尝试当前批次（使用更小的批次大小）
        i -= batch.length;
      }
      
      await sleep(CONFIG.DELAYS.RETRY);
    }
  }

  return { deletedCount, failedCount };
}

/**
 * 收藏夹直接按数量删除（不做媒体编辑）
 */
async function deleteInSavedMessages(
  client: TelegramClient,
  chatEntity: any,
  userRequestedCount: number
): Promise<{ processedCount: number; actualCount: number; editedCount: number }> {
  const targetCount =