include client names

coq/clients/lsp/mul_bandit.py

@@ -0,0 +1,3 @@
+
+class MultiArmedBandit:
+    pass

coq/clients/t9/worker.py

@@ -90,13 +90,13 @@ def _decode(
         or not isinstance((old_prefix := reply.get("old_prefix")), str)
         or not isinstance((results := reply.get("results")), Sequence)
     ):
-        log.warn("%s", reply)
+        log.warning("%s", reply)
     else:
         for result in results:
             try:
                 resp = _DECODER(result)
             except DecodeError as e:
-                log.warn("%s", e)
+                log.warning("%s", e)
             else:
                 new_text = resp.new_prefix + resp.new_suffix
                 edit = ContextualEdit(
@@ -262,7 +262,7 @@ async def cont() -> Optional[str]:
                         await self._proc.stdin.drain()
                         out = await _readline(self._proc.stdout)
                     except (ConnectionError, IncompleteReadError) as e:
-                        log.warn("%s", e)
+                        log.warning("%s", e)
                         await self._clean()
                         return None
                     else:
@@ -296,7 +296,7 @@ async def _work(self, context: Context) -> AsyncIterator[Completion]:
                     try:
                         resp = loads(reply)
                     except JSONDecodeError as e:
-                        log.warn("%s", e)
+                        log.warning("%s", e)
                     else:
                         if isinstance(resp, Mapping):
                             self._t9_locked = resp.get("is_locked", False)

coq/lsp/parse.py

@@ -237,7 +237,7 @@ def parse_item(
     else:
         go, parsed = _item_parser(item)
         if not go:
-            log.warn("%s -> %s", client, parsed)
+            log.warning("%s -> %s", client, parsed)
             return None
         else:
             assert isinstance(parsed, CompletionItem)
@@ -303,7 +303,7 @@ def parse_inline_item(
         go, parsed = _inline_item_parser(item)
         if not go:
             if "kind" not in item:
-                log.warn("%s -> %s", client, parsed)
+                log.warning("%s -> %s", client, parsed)
             return None
         else:
             assert isinstance(parsed, InlineCompletionItem)
@@ -359,7 +359,7 @@ def parse(
         is_complete = _falsy(resp.get("isIncomplete"))
 
         if not isinstance((items := resp.get("items")), Sequence):
-            log.warn("%s", f"Unknown LSP resp -- {type(items)}")
+            log.warning("%s", f"Unknown LSP resp -- {type(items)}")
             return LSPcomp(client=client, local_cache=is_complete, items=iter(()))
 
         else:
@@ -405,7 +405,7 @@ def parse(
         return LSPcomp(client=client, local_cache=True, items=comps)
 
     else:
-        log.warn("%s", f"Unknown LSP resp -- {type(resp)}")
+        log.warning("%s", f"Unknown LSP resp -- {type(resp)}")
         return LSPcomp(client=client, local_cache=False, items=iter(()))
 
 
@@ -426,7 +426,7 @@ def parse_inline(
 
     elif isinstance(resp, Mapping):
         if not isinstance((items := resp.get("items")), Sequence):
-            log.warn("%s", f"Unknown LSP resp -- {type(items)}")
+            log.warning("%s", f"Unknown LSP resp -- {type(items)}")
         else:
             comps = (
                 co1
@@ -467,6 +467,6 @@ def parse_inline(
         )
         return LSPcomp(client=client, local_cache=False, items=comps)
     else:
-        log.warn("%s", f"Unknown LSP resp -- {type(resp)}")
+        log.warning("%s", f"Unknown LSP resp -- {type(resp)}")
 
     return LSPcomp(client=client, local_cache=local_cache, items=iter(()))

coq/server/edit.py

@@ -438,7 +438,7 @@ async def apply(buf: Buffer, instructions: Iterable[EditInstruction]) -> _MarkSh
                 ctx = []
 
             msg = Template(dedent(tpl)).substitute(e=e, inst=inst, ctx=ctx)
-            log.warn("%s", msg)
+            log.warning("%s", msg)
 
     return m_shift
 
@@ -518,15 +518,15 @@ async def _view(
 
     for row in rows:
         if row.start < 0 or row.stop > state.context.line_count:
-            log.warn("%s", pformat(("BAD ROW", row, comp)))
+            log.warning("%s", pformat(("BAD ROW", row, comp)))
             return None
         else:
             atomic.buf_get_lines(buf, row.start, row.stop, True)
 
     try:
         lines = cast(Sequence[Sequence[str]], await atomic.commit(NoneType))
     except NvimError as e:
-        log.warn("%s", e)
+        log.warning("%s", e)
         return None
     else:
         return _lines(zip(rows, lines))

coq/server/registrants/marks.py

@@ -78,7 +78,7 @@ def _safexform(xform: Optional[TextTransform], text: str) -> str:
         try:
             return "".join(chain.from_iterable(xform(text)))
         except Exception as e:
-            log.warn("%s", e)
+            log.warning("%s", e)
             return text
 
 
@@ -127,7 +127,7 @@ async def _single_mark(
 
         {e}
         """
-        log.warn("%s", dedent(msg))
+        log.warning("%s", dedent(msg))
     else:
         await Nvim.exec("startinsert")
         state(inserted_pos=(row, col))

coq/server/registrants/omnifunc.py

@@ -188,7 +188,7 @@ async def _comp_done(stack: Stack, event: Mapping[str, Any]) -> None:
                             commit_id=uuid4(),
                         )
                     else:
-                        log.warn("%s", "delayed completion")
+                        log.warning("%s", "delayed completion")
 
 
 _ = (

coq/server/registrants/snippets.py

@@ -228,7 +228,7 @@ async def _rolling_load(
                 Failed to load compiled snips
                 ${e}
                 """.rstrip()
-            log.warn("%s", Template(dedent(tpl)).substitute(e=type(e)))
+            log.warning("%s", Template(dedent(tpl)).substitute(e=type(e)))
         else:
             await worker.populate(path, mtime=mtime, loaded=loaded)
             if not silent:

coq/server/registrants/user_snippets.py

@@ -118,7 +118,7 @@ async def eval_snips(
         grammar = SnippetGrammar[maybe_grammar]
     except KeyError:
         grammar = SnippetGrammar.lsp
-        log.warn("%s", "bad snippet grammar -- reverting to LSP")
+        log.warning("%s", "bad snippet grammar -- reverting to LSP")
 
     win = await Window.get_current()
     buf = await win.get_buf()

coq/snippets/loaders/load.py

@@ -55,7 +55,7 @@ def load_direct(
                     )
                 except LoadError as e:
                     if ignore_error:
-                        log.warn("%s", e)
+                        log.warning("%s", e)
                     else:
                         raise
                 else:

coq/snippets/parsers/lexer.py

@@ -124,7 +124,7 @@ def _consolidate(
             for reg in chain.from_iterable(acc.values())
             if _overlap(region, reg)
         ):
-            log.warn("%s", f"snippet region overlapped -- {overlapped}")
+            log.warning("%s", f"snippet region overlapped -- {overlapped}")
         else:
             a = acc.setdefault(idx, [])
             a.append(region)

lua/coq/lsp-request.lua

@@ -115,8 +115,16 @@
       )
 
       local new_payload = function()
+        local client_names = {}
+        for _, client in pairs(client_map) do
+          local client_name = client.name
+          coq.validate {client_name = {client_name, "string", true}}
+          table.insert(client_names, client_name or vim.NIL)
+        end
+
         return {
           client = vim.NIL,
+          client_names = client_names,
           done = true,
           method = vim.NIL,
           multipart = multipart,