smartnpm/ts/smartnpm.classes.registrycache.ts

import { NpmRegistry } from './smartnpm.classes.npmregistry';
import * as plugins from './smartnpm.plugins';


export interface ICacheDescriptor {
  registryUrl: string;
  packageName: string;
  filePath: string;
  distTag?: string;
  version?: string;
}

export class RegistryCache {
  npmregistryRef: NpmRegistry;
  public levelCache: plugins.levelcache.LevelCache;

  constructor(npmRegistryRefArg: NpmRegistry) {
    this.npmregistryRef = npmRegistryRefArg;
    this.levelCache = new plugins.levelcache.LevelCache({
      cacheId: encodeURIComponent(this.npmregistryRef.options.npmRegistryUrl),
      
    });
  }

  public async getCachedFile (cacheDescriptorArg: ICacheDescriptor): Promise<plugins.smartfile.Smartfile> {
    const cacheEntry = await this.levelCache.retrieveCacheEntryByKey(this.getCacheDescriptorAsString(cacheDescriptorArg));
    if (cacheEntry) {
      return plugins.smartfile.Smartfile.fromFoldedJson(cacheEntry.contents.toString());
    }
    return null;
  }

  public async cacheSmartFile (cacheDescriptorArg: ICacheDescriptor, smartfileArg: plugins.smartfile.Smartfile) {
    if (smartfileArg && cacheDescriptorArg.version) {
      await this.levelCache.storeCacheEntryByKey(this.getCacheDescriptorAsString(cacheDescriptorArg), new plugins.levelcache.CacheEntry({
        contents: Buffer.from(smartfileArg.foldToJson()),
        ttl: plugins.smarttime.getMilliSecondsFromUnits({hours: 1})
      }));
    } else {
      await this.levelCache.storeCacheEntryByKey(this.getCacheDescriptorAsString(cacheDescriptorArg), new plugins.levelcache.CacheEntry({
        contents: Buffer.from(smartfileArg.foldToJson()),
        ttl: plugins.smarttime.getMilliSecondsFromUnits({minutes: 1})
      }));
    }
  }

  public getCacheDescriptorAsString(cacheDescriptorArg?: ICacheDescriptor) {
    return `${cacheDescriptorArg.registryUrl}//+//${cacheDescriptorArg.packageName}//+//${cacheDescriptorArg.filePath}//+//${cacheDescriptorArg.distTag || cacheDescriptorArg.version}`;
  }
}