complete-circuit-breaker.js

import axios, { AxiosRequestConfig, AxiosResponse } from 'axios';

class CircuitBreaker implements ICircuitBreaker {
  private readonly http: IHttp;
  private readonly timeout: number;
  private isOpen = false;
  private errorHandler: (error: any) => boolean;

  constructor(http: IHttp, options: ICircuitBreakerOptions) {
    this.http = http;
    this.timeout = options.timeout;
    this.errorHandler = options.errorHandler;

    this.http.instance.interceptors.request.use(this.interceptRequest.bind(this));
    this.http.instance.interceptors.response.use(
      (response: AxiosResponse) => response,
      this.interceptErrorResponse.bind(this),
    );
  }

  public getStatus() {
    return this.isOpen;
  }

  private interceptRequest(config: AxiosRequestConfig) {
    const CancelToken = axios.CancelToken;

    const cancelToken = new CancelToken((cancel) => cancel('Circuit breaker is open'));

    return {
      ...config,
      ...(this.isOpen ? { cancelToken } : {}),
    };
  }

  private interceptErrorResponse(error: any) {
    const shouldCircuitBreakerBeOpen = this.errorHandler(error);

    if (shouldCircuitBreakerBeOpen && !this.isOpen) {
      this.openCircuitBreaker();
    }

    return Promise.reject(error);
  }

  private openCircuitBreaker() {
    this.isOpen = true;

    setTimeout(() => {
      this.isOpen = false;
    }, this.timeout);
  }
}