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