1
|
|
|
"""Python client for Nvim. |
2
|
|
|
|
3
|
|
|
Client library for talking with Nvim processes via it's msgpack-rpc API. |
4
|
|
|
""" |
5
|
6 |
|
import logging |
6
|
6 |
|
import os |
7
|
6 |
|
import sys |
8
|
|
|
|
9
|
6 |
|
from .api import DecodeHook, Nvim, SessionHook |
10
|
6 |
|
from .msgpack_rpc import (child_session, socket_session, stdio_session, |
11
|
|
|
tcp_session) |
12
|
6 |
|
from .plugin import (Host, autocmd, command, encoding, function, plugin, |
13
|
|
|
rpc_export, shutdown_hook) |
14
|
|
|
|
15
|
|
|
|
16
|
6 |
|
__all__ = ('tcp_session', 'socket_session', 'stdio_session', 'child_session', |
17
|
|
|
'start_host', 'autocmd', 'command', 'encoding', 'function', |
18
|
|
|
'plugin', 'rpc_export', 'Host', 'DecodeHook', 'Nvim', |
19
|
|
|
'SessionHook', 'shutdown_hook', 'attach', 'setup_logging') |
20
|
|
|
|
21
|
|
|
|
22
|
6 |
|
def start_host(session=None): |
23
|
|
|
"""Promote the current process into python plugin host for Nvim. |
24
|
|
|
|
25
|
|
|
Start msgpack-rpc event loop for `session`, listening for Nvim requests |
26
|
|
|
and notifications. It registers Nvim commands for loading/unloading |
27
|
|
|
python plugins. |
28
|
|
|
|
29
|
|
|
The sys.stdout and sys.stderr streams are redirected to Nvim through |
30
|
|
|
`session`. That means print statements probably won't work as expected |
31
|
|
|
while this function doesn't return. |
32
|
|
|
|
33
|
|
|
This function is normally called at program startup and could have been |
34
|
|
|
defined as a separate executable. It is exposed as a library function for |
35
|
|
|
testing purposes only. |
36
|
|
|
""" |
37
|
|
|
plugins = [] |
38
|
|
|
for arg in sys.argv: |
39
|
|
|
_, ext = os.path.splitext(arg) |
40
|
|
|
if ext == '.py': |
41
|
|
|
plugins.append(arg) |
42
|
|
|
|
43
|
|
|
if not plugins: |
44
|
|
|
sys.exit('must specify at least one plugin as argument') |
45
|
|
|
|
46
|
|
|
setup_logging() |
47
|
|
|
|
48
|
|
|
if not session: |
49
|
|
|
session = stdio_session() |
50
|
|
|
host = Host(Nvim.from_session(session)) |
51
|
|
|
host.start(plugins) |
52
|
|
|
|
53
|
|
|
|
54
|
6 |
|
def attach(session_type, address=None, port=None, path=None, argv=None): |
55
|
|
|
"""Provide a nicer interface to create python api sessions. |
56
|
|
|
|
57
|
|
|
Previous machinery to create python api sessions is still there. This only |
58
|
|
|
creates a facade function to make things easier for the most usual cases. |
59
|
|
|
Thus, instead of: |
60
|
|
|
from neovim import socket_session, Nvim |
61
|
|
|
session = tcp_session(address=<address>, port=<port>) |
62
|
|
|
nvim = Nvim.from_session(session) |
63
|
|
|
You can now do: |
64
|
|
|
from neovim import attach |
65
|
|
|
nvim = attach('tcp', address=<address>, port=<port>) |
66
|
|
|
And also: |
67
|
|
|
nvim = attach('socket', path=<path>) |
68
|
|
|
nvim = attach('child', argv=<argv>) |
69
|
|
|
nvim = attach('stdio') |
70
|
|
|
""" |
71
|
6 |
|
session = (tcp_session(address, port) if session_type == 'tcp' else |
72
|
|
|
socket_session(path) if session_type == 'socket' else |
73
|
|
|
stdio_session() if session_type == 'stdio' else |
74
|
|
|
child_session(argv) if session_type == 'child' else |
75
|
|
|
None) |
76
|
|
|
|
77
|
6 |
|
if not session: |
78
|
|
|
raise Exception('Unknown session type "%s"' % session_type) |
79
|
|
|
|
80
|
6 |
|
return Nvim.from_session(session) |
81
|
|
|
|
82
|
|
|
|
83
|
6 |
|
def setup_logging(): |
84
|
6 |
|
logger = logging.getLogger(__name__) |
85
|
6 |
|
if 'NVIM_PYTHON_LOG_FILE' in os.environ: |
86
|
|
|
logfile = (os.environ['NVIM_PYTHON_LOG_FILE'].strip() + |
87
|
|
|
'_' + str(os.getpid())) |
88
|
|
|
handler = logging.FileHandler(logfile, 'w') |
89
|
|
|
handler.formatter = logging.Formatter( |
90
|
|
|
'%(asctime)s [%(levelname)s @ ' |
91
|
|
|
'%(filename)s:%(funcName)s:%(lineno)s] %(process)s - %(message)s') |
92
|
|
|
logging.root.addHandler(handler) |
93
|
|
|
level = logging.INFO |
94
|
|
|
if 'NVIM_PYTHON_LOG_LEVEL' in os.environ: |
95
|
|
|
l = getattr(logging, |
96
|
|
|
os.environ['NVIM_PYTHON_LOG_LEVEL'].strip(), |
97
|
|
|
level) |
98
|
|
|
if isinstance(l, int): |
99
|
|
|
level = l |
100
|
|
|
logger.setLevel(level) |
101
|
|
|
|
102
|
|
|
|
103
|
|
|
# Required for python 2.6 |
104
|
6 |
|
class NullHandler(logging.Handler): |
105
|
6 |
|
def emit(self, record): |
106
|
6 |
|
pass |
107
|
|
|
|
108
|
|
|
|
109
|
6 |
|
if not logging.root.handlers: |
110
|
|
|
logging.root.addHandler(NullHandler()) |
111
|
|
|
|