Spaces:
Running on Zero
Running on Zero
| """Run the pinned SysIDE Legacy parser with its matching standard library.""" | |
| import json | |
| import os | |
| import queue | |
| import shutil | |
| import subprocess | |
| import threading | |
| import time | |
| import tempfile | |
| from pathlib import Path | |
| DEFAULT_PARSER = (Path(__file__).parent / 'assets/sysml-parser' if os.getenv('SPACE_ID') | |
| else Path.home() / '.cache/patent2sysml/sysml-parser') | |
| PARSER = Path(os.getenv('SYSML_PARSER_DIR', str(DEFAULT_PARSER))) | |
| def check_sysml(source): | |
| started = time.monotonic() | |
| source = Path(source).resolve() | |
| server_file = PARSER / 'syside-languageserver.js' | |
| base = {'validator': 'SysIDE Legacy 0.9.1', 'specification': '2024-12', | |
| 'note': 'Parser/semantic diagnostics are not certification against the final SysML 2.0 specification.'} | |
| if not shutil.which('node') or not server_file.exists(): | |
| return {**base, 'status': 'unavailable', 'error': 'Install Node.js and run python setup_parser.py.'} | |
| messages = queue.Queue() | |
| with tempfile.TemporaryDirectory(prefix='patent-sysml-check-') as directory, source.with_suffix('.parser.log').open('w') as log: | |
| document = Path(directory) / source.name | |
| document.write_text(source.read_text()) | |
| server = subprocess.Popen(['node', str(server_file), '--stdio'], stdin=subprocess.PIPE, | |
| stdout=subprocess.PIPE, stderr=log, cwd=directory) | |
| def send(value): | |
| body = json.dumps(value).encode() | |
| server.stdin.write(f'Content-Length: {len(body)}\r\n\r\n'.encode() + body) | |
| server.stdin.flush() | |
| def read(): | |
| while True: | |
| line = server.stdout.readline() | |
| if not line: | |
| return | |
| if not line.lower().startswith(b'content-length:'): | |
| continue | |
| size = int(line.split(b':', 1)[1]) | |
| while server.stdout.readline().strip(): | |
| pass | |
| try: messages.put(json.loads(server.stdout.read(size))) | |
| except (ValueError, OSError): return | |
| threading.Thread(target=read, daemon=True).start() | |
| settings = {'standardLibrary': True, 'standardLibraryPath': str(PARSER / 'stdlib'), | |
| 'skipWorkspaceInit': False, 'defaultBuildOptions': {'standardLibrary': 'standard'}} | |
| last, activity, diagnostics, protocol = None, time.monotonic(), [], [] | |
| try: | |
| send({'jsonrpc': '2.0', 'id': 1, 'method': 'initialize', 'params': { | |
| 'processId': None, 'rootUri': None, 'workspaceFolders': [], | |
| 'capabilities': {'workspace': {'configuration': True}}}}) | |
| deadline = time.monotonic() + 90 | |
| while time.monotonic() < deadline: | |
| try: message = messages.get(timeout=.3) | |
| except queue.Empty: | |
| if last and time.monotonic() - activity > 3: break | |
| continue | |
| activity = time.monotonic() | |
| protocol.append(message) | |
| if 'id' in message and 'method' in message: | |
| result = [settings for _ in message['params']['items']] if message['method'] == 'workspace/configuration' else None | |
| send({'jsonrpc': '2.0', 'id': message['id'], 'result': result}) | |
| elif message.get('id') == 1: | |
| send({'jsonrpc': '2.0', 'method': 'initialized', 'params': {}}) | |
| send({'jsonrpc': '2.0', 'method': 'workspace/didChangeConfiguration', 'params': {'settings': {'syside': settings}}}) | |
| send({'jsonrpc': '2.0', 'method': 'textDocument/didOpen', 'params': {'textDocument': { | |
| 'uri': document.as_uri(), 'languageId': 'sysml', 'version': 1, 'text': document.read_text()}}}) | |
| elif message.get('method') == 'textDocument/publishDiagnostics' and message['params']['uri'] == document.as_uri(): | |
| last, diagnostics = time.monotonic(), message['params']['diagnostics'] | |
| status = 'unavailable' if last is None else ('failed' if any(d.get('severity') == 1 for d in diagnostics) else 'passed') | |
| return {**base, 'status': status, 'diagnostics': diagnostics, 'protocol': protocol, | |
| 'server_exit_code': server.poll(), 'duration_seconds': time.monotonic() - started} | |
| finally: | |
| server.terminate() | |
| try: server.wait(timeout=5) | |
| except subprocess.TimeoutExpired: | |
| server.kill(); server.wait() | |
| server.stdin.close(); server.stdout.close() | |