OpenClaw 深度集成 WhatsApp —— session.ts 与 Baileys 的健壮连接管理

// session.ts → saveAuthState()
async saveAuthState(auth: AuthenticationState) {
  const tmpPath = `${this.credsPath}.tmp`;
  const bakPath = `${this.credsPath}.bak`;

  // 1. 先写临时文件
  await writeFile(tmpPath, JSON.stringify(auth.creds));

  // 2. 若原文件存在，先备份
  if (await pathExists(this.credsPath)) {
    await copyFile(this.credsPath, bakPath);
  }

  // 3. 原子替换
  await rename(tmpPath, this.credsPath);
}

// session.ts → loadAuthState()
try {
  const creds = JSON.parse(await readFile(this.credsPath, 'utf8'));
  return { creds, keys };
} catch (e) {
  logger.warn('Main creds.json corrupted, trying backup...');
  if (await pathExists(`${this.credsPath}.bak`)) {
    await copyFile(`${this.credsPath}.bak`, this.credsPath);
    return this.loadAuthState(); // 递归重试
  } else {
    throw new Error('No valid auth state found');
  }
}

// session.ts → connect()
this.client = makeWASocket({
  auth: this.authState,
  printQRInTerminal: false, // 禁用终端输出
});

this.client.ev.on('connection.update', async (update) => {
  if (update.qr) {
    // 生成 PNG 格式 QR 码
    const qrPng = await qrcode.toBuffer(update.qr, { type: 'png' });
    
    // 通过 ACP 通知上层（如 Web UI）
    emitACPEvent('whatsapp.loginRequired', {
      sessionKey: this.sessionKey,
      qrCode: qrPng.toString('base64')
    });
  }
});

if (update.connection === 'open') {
  logger.info(`WhatsApp connected for ${this.sessionKey}`);
  emitACPEvent('whatsapp.connected', { sessionKey: this.sessionKey });
  
  // 保存最新凭据
  await this.saveAuthState(this.authState);
}

// session.ts → handleConnectionUpdate()
private async handleConnectionUpdate(update: ConnectionUpdate) {
  const { connection, lastDisconnect } = update;

  if (connection === 'close') {
    const statusCode = lastDisconnect?.error?.output?.statusCode;
    
    // 关键：Meta 定义的登出状态码
    const isLoggedOut = [
      DisconnectReason.loggedOut,      // 401
      DisconnectReason.badSession,     // 403
      DisconnectReason.replaced,       // 428 (多设备冲突)
      DisconnectReason.restartRequired // 515
    ].includes(statusCode as DisconnectReason);

    if (isLoggedOut) {
      logger.warn(`User logged out or session replaced for ${this.sessionKey}`);
      
      // 清除凭据，触发重新登录
      await this.clearAuthState();
      emitACPEvent('whatsapp.loggedOut', { sessionKey: this.sessionKey });
      
    } else {
      // 网络问题，指数退避重连
      const delay = Math.min(1000 * 2 ** this.reconnectAttempts, 30000);
      logger.info(`Reconnecting in ${delay}ms...`);
      setTimeout(() => this.connect(), delay);
      this.reconnectAttempts++;
    }
  }
}

# WhatsApp 连接状态
openclaw_whatsapp_connected{session="+1234567890"} 1

# 重连次数（突增表示网络问题）
openclaw_whatsapp_reconnects_total{session="+1234567890"} 3

# 登出事件（需人工介入）
openclaw_whatsapp_logged_out_total{reason="replaced"} 1