Native remote connection support

lib/connection.coffee

@@ -24,17 +24,33 @@ module.exports =
 
   consumeInk: (ink) ->
     @IPC.consumeInk ink
+    @ink = ink
 
   consumeTerminal: (term) ->
     @terminal.consumeTerminal term
 
-  boot: ->
+  consumeGetServerConfig: (getconf) ->
+    @local.consumeGetServerConfig(getconf)
+
+  consumeGetServerName: (name) ->
+    @local.consumeGetServerName(name)
+
+  _boot: (provider) ->
     if not @client.isActive() and not @booting
       @booting = true
-      p = @local.start()
+      p = @local.start(provider)
+      @client.setBootMode(provider)
+      if @ink?
+        @ink.Opener.allowRemoteFiles(provider == 'Remote')
       p.then =>
         @booting = false
       p.catch =>
         @booting = false
       time "Julia Boot", @client.import('ping')().then =>
         metrics()
+
+  bootRemote: ->
+    @_boot('Remote')
+
+  boot: ->
+    @_boot(atom.config.get('julia-client.juliaOptions.bootMode'))

lib/connection/client.coffee

@@ -28,6 +28,8 @@ module.exports =
 
     @emitter = new Emitter
 
+    @bootMode = atom.config.get('julia-client.juliaOptions.bootMode')
+
     @ipc.writeMsg = (msg) =>
       if @isActive() and @conn.ready?() isnt false
         @conn.message msg
@@ -55,6 +57,25 @@ module.exports =
     @onDetached =>
       plotpane?.dispose()
 
+    @onBoot (proc) =>
+      @remoteConfig = proc.config
+
+  setBootMode: (@bootMode) ->
+
+  editorPath: (ed) ->
+    if not ed? then return ed
+    if @bootMode is 'Remote' and @remoteConfig?
+      path = ed.getPath()
+      if not path? then return path
+      ind = path.indexOf(@remoteConfig.host)
+      if ind > -1
+        path = path.slice(ind + @remoteConfig.host.length, path.length)
+        path = path.replace(/\\/g, '/')
+        return path
+      else
+        return path
+    else
+      return ed.getPath()
 
   deactivate: ->
     @emitter.dispose()
@@ -126,6 +147,10 @@ module.exports =
       else if atom.config.get('julia-client.consoleOptions.consoleStyle') is 'REPL-based'
         @clientCall 'interrupts', 'interruptREPL'
 
+  disconnect: ->
+    if @isActive()
+      @clientCall 'disconnecting', 'disconnect'
+
   kill: ->
     if @isActive()
       if not @isWorking()
@@ -150,15 +175,15 @@ module.exports =
   connectedError: (action = 'do that') ->
     if @isActive()
       atom.notifications.addError "Can't #{action} with a Julia client running.",
-        detail: "Stop the current client with Packages → Julia → Stop Julia."
+        description: "Stop the current client with Packages → Julia → Stop Julia."
       true
     else
       false
 
   notConnectedError: (action = 'do that') ->
     if not @isActive()
       atom.notifications.addError "Can't #{action} without a Julia client running.",
-        detail: "Start Julia using Packages → Julia → Start Julia."
+        description: "Start Julia using Packages → Julia → Start Julia."
       true
     else
       false

lib/connection/local.coffee

@@ -6,20 +6,32 @@ cd = client.import 'cd', false
 
 # legacy
 basic  = require './process/basic'
+
 cycler = require './process/cycler'
+ssh = require './process/remote'
 # server = require './process/server'
 
 # new console
 basic2 = require './process/basic2'
 
 module.exports =
-  # server: server
+  consumeGetServerConfig: (getconf) ->
+    ssh.consumeGetServerConfig(getconf)
+
+  consumeGetServerName: (name) ->
+    ssh.consumeGetServerName(name)
 
-  provider: ->
-    switch atom.config.get 'julia-client.juliaOptions.bootMode'
+  provider: (p) ->
+    @bootMode = undefined
+    if p?
+      @bootMode = p
+    else
+      @bootMode = atom.config.get('julia-client.juliaOptions.bootMode')
+    switch @bootMode
       when 'Cycler' then cycler
+      when 'Remote' then ssh
       when 'Basic'
-        switch atom.config.get 'julia-client.consoleOptions.consoleStyle'
+        switch atom.config.get('julia-client.consoleOptions.consoleStyle')
           when 'REPL-based' then basic2
           when 'Legacy' then basic
 
@@ -28,7 +40,7 @@ module.exports =
       process.env.JULIA_EDITOR = "\"#{process.execPath}\" -a"
     else
       process.env.JULIA_EDITOR = "atom -a"
-      
+
     paths.getVersion()
       .then =>
         @provider().start? paths.jlpath(), client.clargs()
@@ -73,16 +85,15 @@ module.exports =
     client.flush()
     proc
 
-  start: ->
+  start: (provider) ->
     [path, args] = [paths.jlpath(), client.clargs()]
-    paths.projectDir().then (dir) -> cd dir
     check = paths.getVersion()
 
     check.catch (err) =>
       messages.jlNotFound paths.jlpath(), err
 
     proc = check
-      .then => @spawnJulia(path, args)
+      .then => @spawnJulia(path, args, provider)
       .then (proc) => if proc.ty? then @monitor2(proc) else @monitor(proc)
     proc
       .then (proc) =>
@@ -92,7 +103,12 @@ module.exports =
       .catch (e) ->
         client.detach()
         console.error("Julia exited with #{e}.")
+      .then =>
+        if @bootMode is 'Remote'
+          ssh.withRemoteConfig((conf) -> cd conf.remote).catch ->
+        else
+          paths.projectDir().then (dir) -> cd dir
     proc
 
-  spawnJulia: (path, args) ->
-    @provider().get(path, args)
+  spawnJulia: (path, args, provider) ->
+    @provider(provider).get(path, args)

lib/connection/messages.coffee

@@ -92,4 +92,4 @@ module.exports =
       client.onceAttached ->
         if not msg.isDismissed()
           msg.dismiss()
-          atom.notifications.addSuccess "Julia is connected."
+        atom.notifications.addSuccess "Julia is connected."

lib/connection/process/basic2.js

@@ -36,7 +36,7 @@ export function get_ (path, args) {
 
 function getUnix (path, args, env) {
   return new Promise((resolve, reject) => {
-    tcp.listen().then((port, server) => {
+    tcp.listen().then((port) => {
       paths.fullPath(path).then((path) => {
         paths.projectDir().then((cwd) => {
           // space before port needed for pty.js on windows:
@@ -76,7 +76,7 @@ function getWindows (path, args, env) {
     return getUnix(path, args, env)
   }
   return new Promise((resolve, reject) => {
-    tcp.listen().then((port, server) => {
+    tcp.listen().then((port) => {
       freePort().then((wrapPort) => {
         paths.fullPath("powershell").then((psPath) => {
           paths.projectDir().then((cwd) => {