1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374
import { Exception } from "./errors.ts";import { join } from "../deps/path.ts";
import type { Data } from "../core.ts";
export interface Options {  /** The root directory of the files */  src: string;}
/** * Class to read directories, files and store the content in a cache * It's used to avoid reading the same file multiple times */export default class Reader {  src: string;  cache = new Map<string, Promise<Data>>();
  constructor(options: Options) {    this.src = options.src;  }
  /** Delete a file from the cache */  deleteCache(path: string) {    const fullPath = this.getFullPath(path);    this.cache.delete(fullPath);  }
  /** Delete all the cache */  clearCache() {    this.cache.clear();  }
  getFullPath(path: string): string {    return join(this.src, path);  }
  /** Returns the file info of a path */  async getInfo(path: string): Promise<Deno.FileInfo | undefined> {    try {      return await Deno.stat(this.getFullPath(path));    } catch (err) {      if (err instanceof Deno.errors.NotFound) {        return;      }
      throw err;    }  }
  /** Reads a directory */  readDir(path: string): AsyncIterable<Deno.DirEntry> {    return Deno.readDir(this.getFullPath(path));  }
  /** Read a file using a loader and return the content */  async read(path: string, loader: Loader): Promise<Data> {    path = this.getFullPath(path);
    try {      if (!this.cache.has(path)) {        this.cache.set(path, loader(path));      }
      return await this.cache.get(path)!;    } catch (cause) {      throw new Exception("Couldn't load this file", { cause, path });    }  }}
/** A function that loads and returns the file content */export type Loader = (path: string) => Promise<Data>;