vim-fireplace/autoload/nrepl/fireplace_connection.vim

266 lines
8.0 KiB
VimL
Raw Normal View History

2013-03-12 19:37:37 +00:00
" autoload/nrepl/fireplace_connection.vim
2012-12-04 06:06:22 +00:00
" Maintainer: Tim Pope <http://tpo.pe/>
2013-03-12 19:37:37 +00:00
if exists("g:autoloaded_nrepl_fireplace_connection") || &cp
2012-12-04 06:06:22 +00:00
finish
endif
2013-03-12 19:37:37 +00:00
let g:autoloaded_nrepl_fireplace_connection = 1
2012-12-04 06:06:22 +00:00
function! s:function(name) abort
return function(substitute(a:name,'^s:',matchstr(expand('<sfile>'), '<SNR>\d\+_'),''))
endfunction
" Bencode {{{1
2013-03-12 19:37:37 +00:00
function! nrepl#fireplace_connection#bencode(value) abort
2012-12-04 06:06:22 +00:00
if type(a:value) == type(0)
return 'i'.a:value.'e'
elseif type(a:value) == type('')
return strlen(a:value).':'.a:value
elseif type(a:value) == type([])
2013-03-12 19:37:37 +00:00
return 'l'.join(map(a:value,'nrepl#fireplace_connection#bencode(v:val)'),'').'e'
2012-12-04 06:06:22 +00:00
elseif type(a:value) == type({})
2013-03-12 19:37:37 +00:00
return 'd'.join(values(map(a:value,'nrepl#fireplace_connection#bencode(v:key).nrepl#fireplace_connection#bencode(v:val)')),'').'e'
2012-12-04 06:06:22 +00:00
else
throw "Can't bencode ".string(a:value)
endif
endfunction
2013-03-12 19:37:37 +00:00
function! nrepl#fireplace_connection#bdecode(value) abort
2012-12-04 06:06:22 +00:00
return s:bdecode({'pos': 0, 'value': a:value})
endfunction
function! s:bdecode(state) abort
let value = a:state.value
if value[a:state.pos] =~# '\d'
let pos = a:state.pos
let length = matchstr(value[pos : -1], '^\d\+')
let a:state.pos += strlen(length) + length + 1
return value[pos+strlen(length)+1 : pos+strlen(length)+length]
elseif value[a:state.pos] ==# 'i'
let int = matchstr(value[a:state.pos+1:-1], '[^e]*')
let a:state.pos += 2 + strlen(int)
return str2nr(int)
elseif value[a:state.pos] ==# 'l'
let values = []
let a:state.pos += 1
while value[a:state.pos] !=# 'e' && value[a:state.pos] !=# ''
call add(values, s:bdecode(a:state))
endwhile
let a:state.pos += 1
return values
elseif value[a:state.pos] ==# 'd'
let values = {}
let a:state.pos += 1
while value[a:state.pos] !=# 'e' && value[a:state.pos] !=# ''
let key = s:bdecode(a:state)
let values[key] = s:bdecode(a:state)
endwhile
let a:state.pos += 1
return values
else
throw 'bencode parse error: '.string(a:state)
endif
endfunction
" }}}1
function! s:shellesc(arg) abort
if a:arg =~ '^[A-Za-z0-9_/.-]\+$'
return a:arg
elseif &shell =~# 'cmd'
return '"'.substitute(substitute(a:arg, '"', '""""', 'g'), '%', '"%"', 'g').'"'
2012-12-04 06:06:22 +00:00
else
let escaped = shellescape(a:arg)
if &shell =~# 'sh' && &shell !~# 'csh'
return substitute(escaped, '\\\n', '\n', 'g')
else
return escaped
endif
endif
endfunction
2013-03-12 19:37:37 +00:00
function! nrepl#fireplace_connection#prompt() abort
return fireplace#input_host_port()
2012-12-04 06:06:22 +00:00
endfunction
2013-03-12 19:37:37 +00:00
function! nrepl#fireplace_connection#open(arg) abort
2012-12-04 06:06:22 +00:00
if a:arg =~# '^\d\+$'
let host = 'localhost'
let port = a:arg
elseif a:arg =~# ':\d\+$'
let host = matchstr(a:arg, '.*\ze:')
let port = matchstr(a:arg, ':\zs.*')
else
throw "nREPL: Couldn't find [host:]port in " . a:arg
endif
let client = deepcopy(s:nrepl)
let client.host = host
let client.port = port
2012-12-15 05:07:46 +00:00
let session = client.process({'op': 'clone'})['new-session']
let response = client.process({'op': 'eval', 'session': session, 'code':
\ '(do (println "success") (symbol (str (System/getProperty "path.separator") (System/getProperty "java.class.path"))))'})
let client._path = response.value[-1]
2012-12-15 05:07:46 +00:00
if has_key(response, 'out')
let client.session = session
endif
2012-12-04 06:06:22 +00:00
return client
endfunction
function! s:nrepl_path() dict abort
return split(self._path[1:-1], self._path[0])
endfunction
function! s:nrepl_process(payload) dict abort
2012-12-15 05:07:46 +00:00
let combined = {'status': [], 'session': []}
for response in self.call(a:payload)
for key in keys(response)
if key ==# 'id' || key ==# 'ns'
let combined[key] = response[key]
elseif key ==# 'value'
let combined.value = extend(get(combined, 'value', []), [response.value])
elseif key ==# 'status'
for entry in response[key]
if index(combined[key], entry) < 0
call extend(combined[key], [entry])
endif
endfor
elseif key ==# 'session'
if index(combined[key], response[key]) < 0
call extend(combined[key], [response[key]])
endif
elseif key ==# 'out' && response.out =~# '^\b.*(.*)$'
let combined.stacktrace = split(response.out, "\b")
2012-12-15 05:07:46 +00:00
elseif type(response[key]) == type('')
let combined[key] = get(combined, key, '') . response[key]
else
let combined[key] = response[key]
endif
endfor
2012-12-04 06:06:22 +00:00
endfor
2012-12-15 05:07:46 +00:00
if index(combined.status, 'error') >= 0
throw 'nREPL: ' . tr(combined.status[0], '-', ' ')
endif
return combined
2012-12-04 06:06:22 +00:00
endfunction
function! s:nrepl_eval(expr, ...) dict abort
2013-01-07 06:51:48 +00:00
let payload = {"op": "eval"}
2013-01-16 06:01:09 +00:00
let payload.code = '(try (clojure.core/eval ''(do '.a:expr."\n".'))' .
\ ' (catch Exception e' .
\ ' (clojure.core/print (clojure.core/apply clojure.core/str (clojure.core/interleave (clojure.core/repeat "\b") (clojure.core/map clojure.core/str (.getStackTrace e)))))' .
\ ' (throw e)))'
let options = a:0 ? a:1 : {}
if has_key(options, 'ns')
let payload.ns = options.ns
2012-12-04 06:06:22 +00:00
elseif has_key(self, 'ns')
let payload.ns = self.ns
endif
if get(options, 'session', 1)
if has_key(self, 'session')
let payload.session = self.session
elseif &verbose
echohl WarningMSG
echo "nREPL: server has bug preventing session support"
echohl None
endif
endif
2012-12-15 05:07:46 +00:00
let response = self.process(payload)
if has_key(response, 'ns') && !a:0
let self.ns = response.ns
endif
if has_key(response, 'value')
let response.value = response.value[-1]
2012-12-15 05:07:46 +00:00
endif
return response
2012-12-04 06:06:22 +00:00
endfunction
function! s:nrepl_call(payload) dict abort
let in = 'ruby -rsocket -e '.s:shellesc(
\ 'begin;' .
\ 'TCPSocket.open(%(' . self.host . '), ' . self.port . ') {|s|' .
\ 's.write(ARGV.first); loop {' .
\ 'body = s.readpartial(8192);' .
\ 'raise %(not an nREPL server: upgrade to Leiningen 2) if body =~ /=> $/;' .
\ 'print body;' .
2012-12-04 06:06:22 +00:00
\ 'break if body.include?(%(6:statusl4:done)) }};' .
\ 'rescue; abort $!.to_s;' .
\ 'end') . ' ' .
2013-03-12 19:37:37 +00:00
\ s:shellesc(nrepl#fireplace_connection#bencode(a:payload))
2012-12-04 06:06:22 +00:00
let out = system(in)
if !v:shell_error
2013-03-12 19:37:37 +00:00
return nrepl#fireplace_connection#bdecode('l'.out.'e')
2012-12-04 06:06:22 +00:00
endif
throw 'nREPL: '.split(out, "\n")[0]
endfunction
let s:nrepl = {
\ 'call': s:function('s:nrepl_call'),
\ 'eval': s:function('s:nrepl_eval'),
\ 'path': s:function('s:nrepl_path'),
\ 'process': s:function('s:nrepl_process')}
if !has('python')
finish
endif
python << EOF
import vim
import select
import socket
import string
import re
2013-03-12 19:37:37 +00:00
def fireplace_string_encode(input):
str_list = []
for c in input:
if (000 <= ord(c) and ord(c) <= 037) or c == '"' or c == "\\":
2013-04-19 15:41:51 +00:00
str_list.append("\\{0:03o}".format(ord(c)))
else:
str_list.append(c)
return '"' + ''.join(str_list) + '"'
2013-03-12 19:37:37 +00:00
def fireplace_let(var, value):
return vim.command('let ' + var + " = " + fireplace_string_encode(value))
2013-03-12 19:37:37 +00:00
def fireplace_repl_interact():
buffer = ''
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
host = vim.eval('self.host')
port = int(vim.eval('self.port'))
s.settimeout(8)
try:
2013-04-17 17:35:47 +00:00
try:
s.connect((host, port))
s.setblocking(1)
s.sendall(vim.eval('payload'))
while True:
while len(select.select([s], [], [], 0.1)[0]) == 0:
vim.eval('getchar(1)')
body = s.recv(8192)
if re.search("=> $", body) != None:
raise Exception("not an nREPL server: upgrade to Leiningen 2")
buffer += body
if string.find(body, '6:statusl4:done') != -1:
break
fireplace_let('out', buffer)
except Exception, e:
fireplace_let('err', str(e))
finally:
s.close()
EOF
function! s:nrepl_call(payload) dict abort
2013-03-12 19:37:37 +00:00
let payload = nrepl#fireplace_connection#bencode(a:payload)
python << EOF
2013-03-12 19:37:37 +00:00
fireplace_repl_interact()
EOF
if !exists('err')
2013-03-12 19:37:37 +00:00
return nrepl#fireplace_connection#bdecode('l'.out.'e')
endif
throw 'nREPL Connection Error: '.err
endfunction
2012-12-04 06:06:22 +00:00
" vim:set et sw=2: