JezK

Edit File: extension.ts

"use strict";

import * as vscode from "vscode";
import {
  LanguageClient,
  LanguageClientOptions,
  ServerOptions,
} from "vscode-languageclient/node";
import * as net from "net";
import * as child_process from "child_process";
import { existsSync } from "fs";

interface Invoking {
  kind: "invoking";
  workspaceFolder: vscode.WorkspaceFolder;
  process: child_process.ChildProcessWithoutNullStreams;
}
interface Running {
  kind: "running";
  workspaceFolder: vscode.WorkspaceFolder;
  client: LanguageClient;
}
type State = Invoking | Running;

const CONFIGURATION_ROOT_SECTION = "typeprof";

function addToggleButton(context: vscode.ExtensionContext) {
  let statusBarItem = vscode.window.createStatusBarItem(vscode.StatusBarAlignment.Right, 100);
  statusBarItem.command = "typeprof.toggle";
  statusBarItem.text = "TypeProf $(eye)";
  statusBarItem.show();

context.subscriptions.push(disposable);
}

function addJumpToRBS(context: vscode.ExtensionContext) {
  const disposable = vscode.commands.registerCommand("typeprof.jumpToRBS",
    (arg0: any, arg1: any, arg2: any, arg3: any) => {
      const uri0 = vscode.Uri.parse(arg0);
      const pos0 = new vscode.Position(arg1.line, arg1.character);
      const uri1 = vscode.Uri.parse(arg2);
      const pos1 = new vscode.Position(arg3.start.line, arg3.start.character);
      const pos2 = new vscode.Position(arg3.end.line, arg3.end.character);
      const range = new vscode.Range(pos1, pos2);
      const loc = new vscode.Location(uri1, range);
      vscode.commands.executeCommand("editor.action.peekLocations", uri0, pos0, [loc], "peek");
    }
  );

context.subscriptions.push(disposable);
}

function executeTypeProf(folder: vscode.WorkspaceFolder, arg: String): child_process.ChildProcessWithoutNullStreams {
  const configuration = vscode.workspace.getConfiguration(CONFIGURATION_ROOT_SECTION);
  const customServerPath = configuration.get<string | null>("server.path");
  const cwd = folder.uri.fsPath;

let cmd: string;
  if (existsSync(`${cwd}/bin/typeprof`)) {
    cmd = "./bin/typeprof";
  }
  else if (customServerPath) {
    cmd = customServerPath;
  }
  else if (existsSync(`${cwd}/Gemfile`)) {
    cmd = "bundle exec typeprof";
  }
  else {
    cmd = "typeprof";
  }
  cmd = cmd + " " + arg;

return typeprof;
}

function getTypeProfVersion(folder: vscode.WorkspaceFolder, outputChannel: vscode.OutputChannel, callback: (version: string) => void): child_process.ChildProcessWithoutNullStreams {
  const typeprof = executeTypeProf(folder, "--version");
  let output = "";

const log = (msg: string) => {
    outputChannel.appendLine("[vscode] " + msg);
    console.info(msg);
  };

typeprof.stdout?.on("data", out => { output += out; });
  typeprof.stderr?.on("data", (out: Buffer) => {
    const str = ("" + out).trim();
    for (const line of str.split("\n")) {
      log("stderr: " + line);
    }
  });
  typeprof.on("error", e => {
    log(`typeprof is not supported for this folder: ${folder}`);
    log(`because: ${e}`);
  });
  typeprof.on("exit", (code) => {
    if (code == 0) {
      const str = output.trim();
      log(`typeprof version: ${str}`)
      const version = /^typeprof (\d+).(\d+).(\d+)$/.exec(str);
      if (version) {
        const major = Number(version[1]);
        const minor = Number(version[2]);
        const _teeny = Number(version[3]);
        if (major >= 1 || (major == 0 && minor >= 20)) {
          callback(str);
        }
        else {
          log(`typeprof version ${str} is too old; please use 0.20.0 or later for IDE feature`);
        }
      }
      else {
        log(`typeprof --version showed unknown message`);
      }
    }
    else {
      log(`failed to invoke typeprof: error code ${code}`);
    }
    typeprof.kill()
  });
  return typeprof;
}

function getTypeProfStream(folder: vscode.WorkspaceFolder, error: (msg: string) => void):
  Promise<{ host: string; port: number; pid: number; stop: () => void }>
{
  return new Promise((resolve, reject) => {
    const typeprof = executeTypeProf(folder, "--lsp");

let err = "";
    typeprof.stderr.on("data", (data) => {
      err += data;
      while (true) {
        const i = err.indexOf("\n");
        if (i < 0) break;
        error(err.slice(0, i));
        err = err.slice(i + 1);
      }
    });

typeprof.on("exit", (code) => reject(`error code ${code}`));
  });
}

function invokeTypeProf(folder: vscode.WorkspaceFolder, outputChannel: vscode.OutputChannel): LanguageClient {
  let client: LanguageClient;

const reportError = (msg: string) => client.info(msg);

const serverOptions: ServerOptions = async () => {
    const { host, port, stop } = await getTypeProfStream(folder, reportError);
    const socket: net.Socket = net.createConnection(port, host);
    socket.on("close", (_had_error) => stop());

return {
      reader: socket,
      writer: socket,
    };
  };

const clientOptions: LanguageClientOptions = {
    documentSelector: [
      { scheme: "file", language: "ruby" },
      { scheme: "file", language: "rbs" },
    ],
    outputChannel,
    synchronize: {
      fileEvents:
        vscode.workspace.createFileSystemWatcher("{**/*.rb,**/*.rbs}"),
    },
  };

client = new LanguageClient("Ruby TypeProf", serverOptions, clientOptions);

return client;
}

const clientSessions: Map<vscode.WorkspaceFolder, State> = new Map();

function startTypeProf(folder: vscode.WorkspaceFolder) {
  const outputChannel = vscode.window.createOutputChannel("Ruby TypeProf");
  const showStatus = (msg: string) => {
    outputChannel.appendLine("[vscode] " + msg);
    vscode.window.setStatusBarMessage(msg, 3000);
  }
  outputChannel.appendLine("[vscode] Try to start TypeProf for IDE");

clientSessions.set(folder, { kind: "invoking", workspaceFolder: folder, process: typeprof });
}

function stopTypeProf(state: State) {
  switch (state.kind) {
    case "invoking":
      state.process.kill();

break;
    case "running":
      state.client.stop();
      break;
  }
  clientSessions.delete(state.workspaceFolder);
}

function restartTypeProf() {
  vscode.workspace.workspaceFolders?.forEach((folder) => {
    let state = clientSessions.get(folder);
    if (state) stopTypeProf(state);
    startTypeProf(folder);
  });
}

function ensureTypeProf() {
  if (!vscode.workspace.workspaceFolders) return;

const activeFolders = new Set(vscode.workspace.workspaceFolders);

clientSessions.forEach((state) => {
    if (!activeFolders.has(state.workspaceFolder)) {
      stopTypeProf(state);
    }
  });

activeFolders.forEach((folder) => {
    if (folder.uri.scheme === "file" && !clientSessions.has(folder)) {
      startTypeProf(folder);
    }
  });
}

function addRestartCommand(context: vscode.ExtensionContext) {
  const disposable = vscode.commands.registerCommand("typeprof.restart", () => {
    restartTypeProf();
  });
  context.subscriptions.push(disposable);
}

export function activate(context: vscode.ExtensionContext) {
  addToggleButton(context);
  addJumpToRBS(context);
  addRestartCommand(context)
  ensureTypeProf();
}

export function deactivate() {
  clientSessions.forEach((state) => {
    stopTypeProf(state);
  });
}

Veranstaltungen | Fairnetzt-Hochrhein

Keine Veranstaltung gefunden!