Implement API Polling for Asynchronous Task Status Updates

async function pollTaskStatus(taskId, intervalMs = 2000, maxAttempts = 30) {
  let attempts = 0;
  return new Promise((resolve, reject) => {
    const poller = setInterval(async () => {
      attempts++;
      if (attempts > maxAttempts) {
        clearInterval(poller);
        return reject(new Error('Max polling attempts reached. Task timed out.'));
      }

      try {
        const response = await fetch(`/api/tasks/${taskId}/status`);
        if (!response.ok) {
          throw new Error(`Failed to fetch task status: ${response.status} ${response.statusText}`);
        }
        const statusData = await response.json();

        // Assuming the API returns a 'status' field, e.g., 'PENDING', 'COMPLETED', 'FAILED'
        if (statusData.status === 'COMPLETED') {
          clearInterval(poller);
          resolve(statusData); // Resolve with the final task data
        } else if (statusData.status === 'FAILED') {
          clearInterval(poller);
          reject(new Error(`Task failed: ${statusData.errorMessage || 'Unknown error'}`));
        } else {
          console.log(`Task ${taskId} is still ${statusData.status}. Attempt ${attempts}/${maxAttempts}...`);
        }
      } catch (error) {
        clearInterval(poller);
        reject(new Error(`Polling error for task ${taskId}: ${error.message}`));
      }
    }, intervalMs);
  });
}

// Example Usage:
// Assume we initiated a long-running task and got a taskId back.
// const myTaskId = 'abc-123-def';
// pollTaskStatus(myTaskId, 3000, 20) // Poll every 3 seconds, max 20 attempts
//   .then(result => console.log('Task completed successfully:', result))
//   .catch(error => console.error('Task polling failed:', error));