javaServerStarter.ts

import os from 'os'
import * as path from 'path'
import * as net from 'net'
import * as glob from 'glob'
import { StreamInfo, Executable } from 'coc.nvim'
import { RequirementsData, ServerConfiguration } from './requirements'

declare var v8debug
const DEBUG = (typeof v8debug === 'object') || startedInDebugMode()

const isWindows = process.platform.indexOf('win') === 0
const JAVA_FILENAME = 'java' + (isWindows ? '.exe' : '')

export function prepareExecutable(requirements: RequirementsData, workspacePath, config: ServerConfiguration): Executable {
  let executable: Executable = Object.create(null)
  let options = Object.create(null)
  options.env = process.env
  options.stdio = 'pipe'
  executable.options = options
  executable.command = path.resolve(requirements.java_home, 'bin', JAVA_FILENAME)
  executable.args = prepareParams(requirements, config, workspacePath)
  // tslint:disable-next-line: no-console
  console.log('Starting Java server with: ' + executable.command + ' ' + executable.args.join(' '))
  return executable
}

export function awaitServerConnection(port): Thenable<StreamInfo> {
  let addr = parseInt(port, 10)
  return new Promise((res, rej) => {
    let server = net.createServer(stream => {
      server.close()
      // tslint:disable-next-line: no-console
      console.log('JDT LS connection established on port ' + addr)
      res({ reader: stream, writer: stream })
    })
    server.on('error', rej)
    server.listen(addr, () => {
      server.removeListener('error', rej)
      // tslint:disable-next-line: no-console
      console.log('Awaiting JDT LS connection on port ' + addr)
    })
    return server
  })
}

function prepareParams(requirements: RequirementsData, config: ServerConfiguration, workspacePath: string): string[] {
  let params: string[] = []
  if (DEBUG) {
    params.push('-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=localhost:1044,quiet=y')
    // suspend=y is the default. Use this form if you need to debug the server startup code:
    //  params.push('-agentlib:jdwp=transport=dt_socket,server=y,address=localhost:1044')
  }
  if (requirements.java_version > 8) {
    params.push('--add-modules=ALL-SYSTEM',
      '--add-opens',
      'java.base/java.util=ALL-UNNAMED',
      '--add-opens',
      'java.base/java.lang=ALL-UNNAMED')
  }

  params.push('-Declipse.application=org.eclipse.jdt.ls.core.id1',
    '-Dosgi.bundles.defaultStartLevel=4',
    '-Declipse.product=org.eclipse.jdt.ls.core.product')
  if (DEBUG) {
    params.push('-Dlog.level=ALL')
  }
  let { vmargs, root } = config
  const encodingKey = '-Dfile.encoding='
  if (vmargs.indexOf(encodingKey) < 0 && config.encoding) {
    params.push(encodingKey + config.encoding)
  }
  if (os.platform() == 'win32') {
    const watchParentProcess = '-DwatchParentProcess='
    if (vmargs.indexOf(watchParentProcess) < 0) {
      params.push(watchParentProcess + 'false')
    }
  }

  parseVMargs(params, vmargs)
  let launchersFound: string[] = glob.sync('**/plugins/org.eclipse.equinox.launcher_*.jar', { cwd: root })
  if (launchersFound.length) {
    params.push('-jar'); params.push(path.resolve(root, launchersFound[0]))
  } else {
    return null
  }

  // select configuration directory according to OS
  let configDir = 'config_win'
  if (process.platform === 'darwin') {
    configDir = 'config_mac'
  } else if (process.platform === 'linux') {
    configDir = 'config_linux'
  }
  params.push('-configuration'); params.push(path.join(root, configDir))
  params.push('-data'); params.push(workspacePath)
  return params
}

function startedInDebugMode(): boolean {
  let args = (process as any).execArgv
  if (args) {
    return args.some(arg => /^--debug=?/.test(arg) || /^--debug-brk=?/.test(arg) || /^--inspect-brk=?/.test(arg))
  }
  return false
}

// exported for tests
export function parseVMargs(params: any[], vmargsLine: string): void {
  if (!vmargsLine) {
    return
  }
  let vmargs = vmargsLine.match(/(?:[^\s"]+|"[^"]*")+/g)
  if (vmargs === null) {
    return
  }
  vmargs.forEach(arg => {
    // remove all standalone double quotes
    // tslint:disable-next-line: only-arrow-functions typedef
    arg = arg.replace(/(\\)?"/g, function($0, $1) { return ($1 ? $0 : '') })
    // unescape all escaped double quotes
    arg = arg.replace(/(\\)"/g, '"')
    if (params.indexOf(arg) < 0) {
      params.push(arg)
    }
  })
}