openclaw - 💡(How to fix) Fix Feishu WebSocket: No exponential backoff on reconnect, causes rate limit amplification [1 participants]

const WebSocket = require('ws');
const axios = require('axios');

// Exponential backoff settings
const minBackoff = 60000; // 1 minute
const maxBackoff = 960000; // 16 minutes
let backoffDelay = minBackoff;

// WebSocket connection
let ws;

// Reconnect function with exponential backoff
async function reconnect() {
  try {
    // Optional health check
    const response = await axios.get('https://example.com/feishu/healthcheck');
    if (response.status !== 200) {
      throw new Error('Feishu API is not available');
    }

    // Reconnect to WebSocket
    ws = new WebSocket('wss://example.com/feishu/ws');

    // Reset backoff delay
    backoffDelay = minBackoff;
  } catch (error) {
    console.error('Reconnect failed:', error);

    // Exponential backoff
    backoffDelay = Math.min(backoffDelay * 2, maxBackoff);
    setTimeout(reconnect, backoffDelay);
  }
}

// Handle WebSocket close event
ws.on('close', () => {
  reconnect();
});

// Handle WebSocket error event
ws.on('error', (error) => {
  console.error('WebSocket error:', error);
  reconnect();
});

// Fix race condition on closed WebSocket access
function getPingInterval() {
  if (ws && ws.readyState === WebSocket.OPEN) {
    return ws.pingInterval;
  } else {
    return null;
  }
}