reverseMessageIde.ts

import { IDE } from "../../index";
import { ToIdeFromWebviewOrCoreProtocol } from "../ide";

import { Message } from ".";

export class ReverseMessageIde {
  private on<T extends keyof ToIdeFromWebviewOrCoreProtocol>(
    messageType: T,
    handler: (
      data: ToIdeFromWebviewOrCoreProtocol[T][0],
    ) =>
      | Promise<ToIdeFromWebviewOrCoreProtocol[T][1]>
      | ToIdeFromWebviewOrCoreProtocol[T][1],
  ): void {
    this._on(messageType, (msg) => {
      const data = msg.data;
      const result = handler(data);
      return result;
    });
  }

  constructor(
    private readonly _on: <T extends keyof ToIdeFromWebviewOrCoreProtocol>(
      messageType: T,
      handler: (
        message: Message<ToIdeFromWebviewOrCoreProtocol[T][0]>,
      ) =>
        | Promise<ToIdeFromWebviewOrCoreProtocol[T][1]>
        | ToIdeFromWebviewOrCoreProtocol[T][1],
    ) => void,
    private readonly ide: IDE,
  ) {
    this.initializeListeners();
  }

  private initializeListeners() {
    this.on("getGitHubAuthToken", (data) => {
      return this.ide.getGitHubAuthToken(data);
    });

    this.on("getFileStats", (data) => {
      return this.ide.getFileStats(data.files);
    });

    this.on("getGitRootPath", (data) => {
      return this.ide.getGitRootPath(data.dir);
    });

    this.on("listDir", (data) => {
      return this.ide.listDir(data.dir);
    });

    this.on("showToast", (data) => {
      return this.ide.showToast(...data);
    });

    this.on("getRepoName", (data) => {
      return this.ide.getRepoName(data.dir);
    });

    this.on("getDebugLocals", (data) => {
      return this.ide.getDebugLocals(data.threadIndex);
    });

    this.on("getTopLevelCallStackSources", (data) => {
      return this.ide.getTopLevelCallStackSources(
        data.threadIndex,
        data.stackDepth,
      );
    });

    this.on("getAvailableThreads", () => {
      return this.ide.getAvailableThreads();
    });

    this.on("getTags", (data) => {
      return this.ide.getTags(data);
    });

    this.on("getIdeInfo", () => {
      return this.ide.getIdeInfo();
    });

    this.on("readRangeInFile", (data) => {
      return this.ide.readRangeInFile(data.filepath, data.range);
    });

    this.on("isTelemetryEnabled", () => {
      return this.ide.isTelemetryEnabled();
    });

    this.on("getUniqueId", () => {
      return this.ide.getUniqueId();
    });

    this.on("getWorkspaceConfigs", () => {
      return this.ide.getWorkspaceConfigs();
    });

    this.on("getIdeSettings", () => {
      return this.ide.getIdeSettings();
    });

    this.on("getDiff", (data) => {
      return this.ide.getDiff(data.includeUnstaged);
    });

    this.on("getTerminalContents", () => {
      return this.ide.getTerminalContents();
    });

    this.on("getWorkspaceDirs", () => {
      return this.ide.getWorkspaceDirs();
    });

    this.on("showLines", (data) => {
      return this.ide.showLines(data.filepath, data.startLine, data.endLine);
    });

    this.on("getControlPlaneSessionInfo", async (msg) => {
      // Not supported in testing
      return undefined;
    });

    this.on("writeFile", (data) => {
      return this.ide.writeFile(data.path, data.contents);
    });

    this.on("fileExists", (data) => {
      return this.ide.fileExists(data.filepath);
    });

    this.on("showVirtualFile", (data) => {
      return this.ide.showVirtualFile(data.name, data.content);
    });

    this.on("openFile", (data) => {
      return this.ide.openFile(data.path);
    });

    this.on("ripgrepSearch", (data) => {
      return this.ide.ripgrepSearch(data.args);
    });

    this.on("runCommandLocally", (data) => {
      return this.ide.runCommandLocally(data.command, data.options);
    });

    this.on("runCommandInWorkspace", (data) => {
      return this.ide.runCommandInWorkspace(data.command, data.options);
    });

    this.on("saveFile", (data) => {
      return this.ide.saveFile(data.filepath);
    });

    this.on("readFile", (data) => {
      return this.ide.readFile(data.filepath);
    });

    this.on("getOpenFiles", () => {
      return this.ide.getOpenFiles();
    });

    this.on("getCurrentFile", () => {
      return this.ide.getCurrentFile();
    });

    this.on("getPinnedFiles", () => {
      return this.ide.getPinnedFiles();
    });

    this.on("getProblems", (data) => {
      return this.ide.getProblems(data.filepath);
    });

    this.on("getBranch", (data) => {
      return this.ide.getBranch(data.dir);
    });
  }
}