Class ISRHandler

libs/isr/server/src/isr-handler.ts:16–272

import { getVariant } from './utils/cache-utils';

export class ISRHandler {
  protected cache!: CacheHandler;
  protected cacheGeneration!: CacheGeneration;
  protected logger: ISRLogger;

  constructor(protected isrConfig: ISRHandlerConfig) {
    if (!isrConfig) {
      throw new Error('Provide ISRHandlerConfig!');
    }

    this.logger = new ISRLogger(this.isrConfig?.enableLogging || false);
    // if skipCachingOnHttpError is not provided it will default to true
    isrConfig.skipCachingOnHttpError =
      isrConfig.skipCachingOnHttpError !== false;
    // if buildId is not provided it will default to null
    isrConfig.buildId = isrConfig.buildId || null;
    // if invalidateSecretToken is not provided it will default to null
    isrConfig.invalidateSecretToken = isrConfig.invalidateSecretToken || null;

    if (isrConfig.cache && isrConfig.cache instanceof CacheHandler) {
      this.logger.log('Using custom cache handler!');
      this.cache = isrConfig.cache;
    } else {
      this.logger.log('Using in memory cache handler!');
      this.cache = new InMemoryCacheHandler();
    }

    this.cacheGeneration = new CacheGeneration(
      this.isrConfig,
      this.cache,
      this.logger,
    );
  }

  async invalidate(
    req: Request,
    res: Response,
    config?: InvalidateConfig,
  ): Promise<Response> {
    const { token, urlsToInvalidate } = extractDataFromBody(req);

    if (token !== this.isrConfig.invalidateSecretToken) {
      return res.json({
        status: 'error',
        message: 'Your secret token is wrong!!!',
      });
    }

    if (!urlsToInvalidate || !urlsToInvalidate.length) {
      return res.json({
        status: 'error',
        message: 'Please add `urlsToInvalidate` in the payload!',
      });
    }

    const notInCache: string[] = [];
    const urlWithErrors: Record<string, string[]> = {};