Function getEntityWithRetry

dme/dme.ts:435–450

* 带重试机制的实体获取函数

(
  client: TelegramClient,
  entityId: string,
  retryCount: number = 0
)

  try {
    return await client.getEntity(entityId);
  } catch (error: any) {
    if (retryCount < 2) {
      console.log(`[DME] 获取实体失败，第 ${retryCount + 1} 次重试:`, error.message);
      await sleep(1000 * (retryCount + 1));
      return getEntityWithRetry(client, entityId, retryCount + 1);
    }
    throw error;
  }
}

/**
 * 通用实体解析器 - 增强版本
 */
async function resolveChatEntity(client: TelegramClient, chatId: string): Promise<any> {
  console.log(`[DME] 开始解析聊天实体: ${chatId}`);

  // 策略1: 优先使用主仓库共享的 accessHash 感知解析器，覆盖折叠/归档等缓存未预热场景
  try {
    const entity = await getEntityWithHash(client, chatId);