Function createSourcemapCache

packages/core/src/log/index.ts:97–202

(input: {
  config: StageCredentials;
  logGroup?: string;
  key: string;
})

export type Processor = ReturnType<typeof createProcessor>;

export function createSourcemapCache(input: {
  config: StageCredentials;
  logGroup?: string;
  key: string;
}) {
  const s3bootstrap = new S3Client({
    ...input.config,
    retryStrategy: RETRY_STRATEGY,
  });
  const sourcemapCache = new Map<string, any>();

  const getBootstrap = lazy(() => AWS.Account.bootstrap(input.config));
  const getBootstrapV3 = lazy(() => AWS.Account.bootstrapIon(input.config));
  const sourcemapsMeta = lazy(async () => {
    const results = [] as {
      bucket: string;
      key: string;
      created: number;
    }[];
    const bootstrap = await getBootstrap();
    if (bootstrap) {
      const result = await s3bootstrap
        .send(
          new ListObjectsV2Command({
            Bucket: bootstrap.bucket,
            Prefix: `sourcemap/${input.config.app}/${input.config.stage}/${input.key}`,
          }),
        )
        .catch(() => {});
      if (result) {
        const maps = (result.Contents || []).map((item) => ({
          bucket: bootstrap.bucket,
          key: item.Key!,
          created: item.LastModified!.getTime(),
        }));
        results.push(...maps);
      }
    }

    const bootstrapV3 = await getBootstrapV3();
    if (bootstrapV3 && input.logGroup) {
      const result = await s3bootstrap
        .send(
          new ListObjectsV2Command({
            Bucket: bootstrapV3.asset,
            Prefix: `sourcemap/` + input.logGroup,
          }),
        )
        .catch(() => {});
      if (result) {
        const maps = (result.Contents || []).map((item) => ({
          bucket: bootstrapV3.asset,
          key: item.Key!,
          created: item.LastModified!.getTime(),
        }));
        results.push(...maps);
      }
    }