fixed error validation only working at startup

Author: m0mosenpai

client/commands/v2/persistent.py

@@ -187,14 +187,14 @@ async def try_initialize(
 async def _read_lsp_request(
     input_channel: connection.TextReader, output_channel: connection.TextWriter
 ) -> AsyncIterator[json_rpc.Request]:
-    LOG.info("** Inside the read lsp function ** ")
+    # LOG.info("** Inside the read lsp function ** ")
     try:
-        LOG.info("** Inside the try and except ** ")
+        # LOG.info("** Inside the try and except ** ")
         message = await lsp.read_json_rpc(input_channel)
-        LOG.info(f"** {message} **")
+        # LOG.info(f"** {message} **")
         yield message
     except json_rpc.JSONRPCException as json_rpc_error:
-        LOG.info("** Inside the except ** ")
+        # LOG.info("** Inside the except ** ")
         await lsp.write_json_rpc(
             output_channel,
             json_rpc.ErrorResponse(

client/commands/v2/pysa_server.py

@@ -35,6 +35,8 @@
 
 LOG: logging.Logger = logging.getLogger(__name__)
 
+PYSA_HANDLER_OBJ = None
+
 
 class PysaServer:
     # I/O Channels
@@ -101,7 +103,7 @@ async def wait_for_exit(self) -> int:
     async def process_open_request(
         self, parameters: lsp.DidOpenTextDocumentParameters
     ) -> None:
-        LOG.info("** Inside process_open_request() **")
+        # LOG.info("** Inside process_open_request() **")
         document_path = parameters.text_document.document_uri().to_file_path()
         if document_path is None:
             raise json_rpc.InvalidRequestError(
@@ -111,7 +113,7 @@ async def process_open_request(
     async def process_close_request(
         self, parameters: lsp.DidCloseTextDocumentParameters
     ) -> None:
-        LOG.info("** Inside process_close_request() **")
+        # LOG.info("** Inside process_close_request() **")
         document_path = parameters.text_document.document_uri().to_file_path()
         if document_path is None:
             raise json_rpc.InvalidRequestError(
@@ -126,7 +128,7 @@ async def process_close_request(
     async def process_did_save_request(
         self, parameters: lsp.DidSaveTextDocumentParameters
     ) -> None:
-        LOG.info("** Inside process_did_save_request() **")
+        # LOG.info("** Inside process_did_save_request() **")
         document_path = parameters.text_document.document_uri().to_file_path()
         if document_path is None:
             raise json_rpc.InvalidRequestError(
@@ -148,7 +150,7 @@ async def run(self) -> int:
                     )
                     return await self.wait_for_exit()
                 elif request.method == "textDocument/didOpen":
-                    LOG.info("** A Document just opened! **")
+                    # LOG.info("** A Document just opened! **")
                     parameters = request.parameters
                     if parameters is None:
                         raise json_rpc.InvalidRequestError(
@@ -160,7 +162,7 @@ async def run(self) -> int:
                         )
                     )
                 elif request.method == "textDocument/didClose":
-                    LOG.info("** A Document just closed! **")
+                    # LOG.info("** A Document just closed! **")
                     parameters = request.parameters
                     if parameters is None:
                         raise json_rpc.InvalidRequestError(
@@ -172,7 +174,7 @@ async def run(self) -> int:
                         )
                     )
                 elif request.method == "textDocument/didSave":
-                    LOG.info("** A Document just saved! **")
+                    # LOG.info("** A Document just saved! **")
                     parameters = request.parameters
                     if parameters is None:
                         raise json_rpc.InvalidRequestError(
@@ -185,13 +187,12 @@ async def run(self) -> int:
                     )
                 elif request.id is not None:
                     raise lsp.RequestCancelledError("Request not supported yet")
-                else:
-                    LOG.info("** Hmmm I guess nothing seems to be happening **")
 
 
 async def run_persistent(
     binary_location: str, server_identifier: str, pysa_arguments: start.Arguments
 ) -> int:
+    global PYSA_HANDLER_OBJ
     stdin, stdout = await connection.create_async_stdin_stdout()
     while True:
         initialize_result = await try_initialize(stdin, stdout)

client/commands/v2/start.py

@@ -513,7 +513,7 @@ def get_server_identifier(configuration: configuration_module.Configuration) ->
 
 
 def _write_argument_file(output_file: IO[str], arguments: Arguments) -> None:
-    LOG.info(f"Writing server startup configurations into {output_file.name}...")
+    # LOG.info(f"Writing server startup configurations into {output_file.name}...")
     serialized_arguments = arguments.serialize()
     LOG.debug(f"Arguments:\n{json.dumps(serialized_arguments, indent=2)}")
     output_file.write(json.dumps(serialized_arguments))