fa9bd5972b
modified buffers are handled properly now nimrod threads are terminated at program exit added commands for service shutdown/restart
98 lines
2.4 KiB
Python
98 lines
2.4 KiB
Python
import threading, Queue, subprocess, signal, os
|
|
|
|
try:
|
|
import vim
|
|
except ImportError:
|
|
class Vim:
|
|
def command(self, x):
|
|
print("Executing vim command: " + x)
|
|
|
|
vim = Vim()
|
|
|
|
class NimrodThread(threading.Thread):
|
|
def __init__(self, project_path):
|
|
super(NimrodThread, self).__init__()
|
|
self.tasks = Queue.Queue()
|
|
self.responses = Queue.Queue()
|
|
self.nim = subprocess.Popen(
|
|
["nimrod", "serve", "--server.type:stdin", project_path],
|
|
cwd = os.path.dirname(project_path),
|
|
stdin = subprocess.PIPE,
|
|
stdout = subprocess.PIPE,
|
|
stderr = subprocess.STDOUT,
|
|
universal_newlines = True,
|
|
bufsize = 1)
|
|
|
|
def postNimCmd(self, msg, async = True):
|
|
self.tasks.put((msg, async))
|
|
if not async:
|
|
return self.responses.get()
|
|
|
|
def run(self):
|
|
while True:
|
|
(msg, async) = self.tasks.get()
|
|
|
|
if msg == "quit":
|
|
self.nim.terminate()
|
|
break
|
|
|
|
self.nim.stdin.write(msg + "\n")
|
|
result = ""
|
|
|
|
while True:
|
|
line = self.nim.stdout.readline()
|
|
result += line
|
|
if line == "\n":
|
|
if not async:
|
|
self.responses.put(result)
|
|
else:
|
|
self.asyncOpComplete(msg, result)
|
|
break
|
|
|
|
|
|
def nimVimEscape(expr):
|
|
return expr.replace("\\", "\\\\").replace('"', "\\\"").replace("\n", "\\n")
|
|
|
|
class NimrodVimThread(NimrodThread):
|
|
def asyncOpComplete(self, msg, result):
|
|
cmd = "/usr/local/bin/mvim --remote-expr 'NimrodAsyncCmdComplete(1, \"" + nimVimEscape(result) + "\")'"
|
|
os.system (cmd)
|
|
|
|
NimProjects = {}
|
|
|
|
def nimStartService(project):
|
|
target = NimrodVimThread(project)
|
|
NimProjects[project] = target
|
|
target.start()
|
|
return target
|
|
|
|
def nimTerminateService(project):
|
|
if NimProjects.has_key(project):
|
|
NimProjects[project].postNimCmd("quit")
|
|
del NimProjects[project]
|
|
|
|
def nimRestartService(project):
|
|
nimTerminateService(project)
|
|
nimStartService(project)
|
|
|
|
NimLog = open("/tmp/nim-log.txt", "w")
|
|
|
|
def nimExecCmd(project, cmd, async = True):
|
|
target = None
|
|
if NimProjects.has_key(project):
|
|
target = NimProjects[project]
|
|
else:
|
|
target = nimStartService(project)
|
|
|
|
result = target.postNimCmd(cmd, async)
|
|
if result != None:
|
|
NimLog.write(result)
|
|
NimLog.flush()
|
|
|
|
if not async:
|
|
vim.command('let l:py_res = "' + nimVimEscape(result) + '"')
|
|
|
|
def nimTerminateAll():
|
|
for thread in NimProjects.values():
|
|
thread.postNimCmd("quit")
|
|
|