123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286
const { cwd } = Deno;
import { Module } from "./module.ts";import {  Action,  ADD_ALIAS,  ADD_LINK,  ADD_MODULE,  REMOVE_ALIAS,  REMOVE_LINK,  REMOVE_MODULE,  UPDATE_MODULE,} from "./actions.ts";import { mutateRepository, mutateStore } from "./mutations.ts";import { Store } from "./store.ts";import { Repository } from "./repository.ts";import { getFormattedImportFilePaths } from "./ast.ts";
export class App {  constructor(public store: Store, private repo: Repository) {}
  async init(): Promise<void> {    await this.repo.saveConfig({      modules: [],      aliases: {},    });    console.log("successfully initialized dem.json");  }
  async addModule(urlStr: string): Promise<void> {    let module: Module;    try {      module = Module.parse(urlStr);    } catch (e) {      console.error(e.toString());      return;    }
    try {      await this.commit([        {          type: ADD_MODULE,          payload: { module },        },      ]);    } catch (e) {      console.error(e.toString());      return;    }
    console.log(      `successfully added new module: ${module.toString()}, version: ${module.version}`,    );  }
  async removeModule(urlStr: string): Promise<void> {    let module: Module;    try {      module = Module.parse(urlStr);    } catch (e) {      console.error(e.toString());      return;    }
    try {      await this.commit([        {          type: REMOVE_MODULE,          payload: {            moduleProtocol: module.protocol,            modulePath: module.path,          },        },      ]);    } catch (e) {      console.error(e.toString());      return;    }
    console.log(`successfully removed module: ${urlStr}`);  }
  async addLink(urlStr: string): Promise<void> {    try {      await this.commit([        {          type: ADD_LINK,          payload: {            link: urlStr,          },        },      ]);    } catch (e) {      console.error(e.toString());      return;    }
    console.log(`successfully created link: ${urlStr}`);  }
  async removeLink(urlStr: string): Promise<void> {    try {      await this.commit([        {          type: REMOVE_LINK,          payload: {            link: urlStr,          },        },      ]);    } catch (e) {      console.error(e.toString());      return;    }
    console.log(`successfully removed link: ${urlStr}`);  }
  async addAlias(aliasTargetPath: string, aliasPath: string): Promise<void> {    try {      await this.commit([        {          type: ADD_ALIAS,          payload: {            aliasPath,            aliasTargetPath,          },        },      ]);    } catch (e) {      console.error(e.toString());      return;    }
    console.log(      `successfully created alias: ${aliasPath} => ${aliasTargetPath}`,    );  }
  async removeAlias(aliasPath: string): Promise<void> {    try {      await this.commit([        {          type: REMOVE_ALIAS,          payload: {            aliasPath,          },        },      ]);    } catch (e) {      console.error(e.toString());      return;    }
    console.log(`successfully removed alias: ${aliasPath}`);  }
  async updateModule(urlStr: string): Promise<void> {    const updatedMod = Module.parse(urlStr);    if (!updatedMod) {      console.error(`failed to parse module: ${urlStr}`);      return;    }
    try {      await this.commit([        {          type: UPDATE_MODULE,          payload: {            moduleProtocol: updatedMod.protocol,            modulePath: updatedMod.path,            moduleVersion: updatedMod.version,          },        },      ]);    } catch (e) {      console.error(e.toString());      return;    }
    console.log(      `successfully updated module: ${updatedMod.toString()}, version: ${updatedMod.version}`,    );  }
  async ensure(excludes: string[]): Promise<void> {    const imports = await getFormattedImportFilePaths(cwd(), excludes);    const actions: Action[] = [];    for (const urlStr of imports) {      let link = urlStr;      if (this.store.config.aliases[urlStr]) {        link = this.store.config.aliases[urlStr];      }      actions.push({        type: ADD_LINK,        payload: {          link,        },      });    }
    await this.commit(actions);    console.log(`succeeded to resolve modules`);  }
  async prune(excludes: string[]): Promise<void> {    const imports = await getFormattedImportFilePaths(cwd(), excludes);
    // Detect removed links    const removedLinks: string[] = [];    const aliasValues = Object.values(this.store.config.aliases);    for (const mod of this.store.config.modules) {      for (const filePath of mod.files) {        const modUrlStr = `${mod.protocol}://${mod.path}${filePath}`;        if (!imports.includes(modUrlStr) && !aliasValues.includes(modUrlStr)) {          removedLinks.push(modUrlStr);        }      }    }
    const removeLinkActions: Action[] = [];    // Remove links    for (const link of removedLinks) {      removeLinkActions.push({        type: REMOVE_LINK,        payload: {          link,        },      });    }
    try {      this.store = mutateStore(this.store, removeLinkActions);    } catch (e) {      console.error(e.stack);      return;    }
    const removeModuleActions: Action[] = [];    for (const mod of this.store.config.modules) {      if (mod.files.length === 0) {        removeModuleActions.push({          type: REMOVE_MODULE,          payload: {            moduleProtocol: mod.protocol,            modulePath: mod.path,          },        });      }    }
    try {      this.store = mutateStore(this.store, removeModuleActions);    } catch (e) {      console.error(e.stack);      return;    }
    const actions: Action[] = [...removeLinkActions, ...removeModuleActions];
    try {      await mutateRepository(this.repo, this.store, actions);    } catch (e) {      console.error(e.stack);      return;    }
    await this.repo.saveConfig(this.store.config);    console.log(`succeeded to prune modules`);  }
  async commit(actions: Action[]) {    try {      this.store = mutateStore(this.store, actions);    } catch (e) {      console.error(e.stack);    }    try {      await mutateRepository(this.repo, this.store, actions);    } catch (e) {      console.error(e.stack);    }    await this.repo.saveConfig(this.store.config);  }}