virtuals/sdk/modules/middlewares

Classes

SDKCore_MIDDLEWARES

Defined in: studiocms/packages/studiocms/src/virtuals/sdk/modules/middlewares.ts:27^

Extends

• any

Constructors

Constructor

new SDKCore_MIDDLEWARES(): SDKCore_MIDDLEWARES

Returns

SDKCore_MIDDLEWARES

Inherited from

Effect.Service<SDKCore_MIDDLEWARES>()(
  'studiocms/sdk/SDKCore/modules/middlewares',
  {
    dependencies: [SDKCore_GET.Default, SDKCore_PLUGINS.Default],
    effect: genLogger('studiocms/sdk/SDKCore/modules/middlewares/effect')(function () {
      const [
        { FolderList, pages, folderTree, siteConfig, pageFolderTree, pluginData },
        {
          pages: updatePages,
          folderTree: updateFolderTree,
          pageFolderTree: updatePageFolderTree,
          folderList: updateFolderList,
          siteConfig: updateSiteConfig,
        },
        { initPluginDataCache },
      ] = yield Effect.all([CacheContext, SDKCore_GET, SDKCore_PLUGINS]);

      const Caches = new Map<
        string,
        // biome-ignore lint/suspicious/noExplicitAny: Allow any for cache and updater types
        { cache: Map<string, any>; updater: () => Effect.Effect<any, unknown, never> }
      >([
        ['pages', { cache: pages, updater: () => updatePages(true) }],
        ['folderList', { cache: FolderList, updater: () => updateFolderList() }],
        ['folderTree', { cache: folderTree, updater: () => updateFolderTree() }],
        ['pageFolderTree', { cache: pageFolderTree, updater: () => updatePageFolderTree() }],
        ['siteConfig', { cache: siteConfig, updater: () => updateSiteConfig() }],
        ['pluginData', { cache: pluginData, updater: () => initPluginDataCache() }],
      ]);

      const logger = _logger.fork('studiocms:middleware/cacheVerification');

      const middlewares = {
        verifyCache: () =>
          genLogger('studiocms/sdk/SDKCore/modules/middlewares/verifyCache')(function () {
            // Check if cache is enabled before proceeding
            const cacheStatus = yield isCacheEnabled.pipe(
              Effect.catchAll(() => Effect.succeed(false))
            );

            // If cache is not enabled, we skip the verification
            // and return early to avoid unnecessary operations.
            if (!cacheStatus) return;

            // Log the cache verification process
            isVerbose && logger.info('Verifying caches...');

            // biome-ignore lint/suspicious/noExplicitAny: Allow any for todos type
            const todos: Effect.Effect<any, unknown, never>[] = [];

            Caches.forEach(({ cache, updater }, name) => {
              if (cache.size === 0) {
                isVerbose && logger.info(Cache "${name}" is empty, updating...);
                todos.push(updater());
              } else {
                isVerbose && logger.info(Cache "${name}" is already populated.);
              }
            });

            // If there are no caches to update, we log and return
            if (todos.length === 0) {
              isVerbose && logger.info('All caches are already populated.');
              return;
            }

            // Log the caches that are being updated
            isVerbose && logger.info(Updating caches: ${todos.length} caches to update.);
            const start = Date.now();
            yield Effect.all(todos);
            isVerbose && logger.info(Cache verification completed in ${Date.now() - start}ms.);
          }),
      };

      return middlewares;
    }),
  }
).constructor