Implement server lifecycle events

Makefile

@@ -63,7 +63,7 @@ isort: ## Reformat via isort
 lint: reformat flake8 mypy ## Run all linters
 
 mypy: ## Type-check via mypy
-	mypy ${project}/
+	mypy ${project}/ tests/
 
 mypy-cov: ## Type-check via mypy with coverage reported to ./mypycov/
 	mypy --html-report ./mypycov/ ${project}/

pyproject.toml

@@ -25,6 +25,7 @@ classifiers = [
 ]
 dependencies = [
   "platformdirs >= 4.0.0",
+  "psutil",
   "uqbar >= 0.7.3",
 ]
 description = "A Python API for SuperCollider"

supriya/contexts/__init__.py

@@ -2,7 +2,7 @@
 Tools for interacting with scsynth-compatible execution contexts.
 """
 
-from .core import Context
+from .core import BootStatus, Context
 from .entities import (
     Buffer,
     BufferGroup,
@@ -19,6 +19,7 @@
 __all__ = [
     "AsyncServer",
     "BaseServer",
+    "BootStatus",
     "Buffer",
     "BufferGroup",
     "Bus",

supriya/contexts/core.py

@@ -7,6 +7,7 @@
 import abc
 import contextlib
 import dataclasses
+import enum
 import itertools
 import threading
 from os import PathLike
@@ -101,6 +102,13 @@
 )
 
 
+class BootStatus(enum.IntEnum):
+    OFFLINE = 0
+    BOOTING = 1
+    ONLINE = 2
+    QUITTING = 3
+
+
 @dataclasses.dataclass
 class Moment:
     """
@@ -204,13 +212,20 @@ class Context(metaclass=abc.ABCMeta):
 
     ### INITIALIZER ###
 
-    def __init__(self, options: Optional[Options], **kwargs) -> None:
+    def __init__(
+        self,
+        options: Optional[Options],
+        name: Optional[str] = None,
+        **kwargs,
+    ) -> None:
         self._audio_bus_allocator = BlockAllocator()
+        self._boot_status = BootStatus.OFFLINE
         self._buffer_allocator = BlockAllocator()
         self._client_id = 0
         self._control_bus_allocator = BlockAllocator()
         self._latency = 0.0
         self._lock = threading.RLock()
+        self._name = name
         self._node_id_allocator = NodeIdAllocator()
         self._options = new(options or Options(), **kwargs)
         self._sync_id = self._sync_id_minimum = 0
@@ -1380,6 +1395,20 @@ def audio_output_bus_group(self) -> BusGroup:
             count=self.options.output_bus_channel_count,
         )
 
+    @property
+    def boot_status(self) -> BootStatus:
+        """
+        Get the server's boot status.
+        """
+        return self._boot_status
+
+    @property
+    def default_group(self) -> Group:
+        """
+        Get the server's default group.
+        """
+        return self.root_node
+
     @property
     def client_id(self) -> int:
         """
@@ -1394,6 +1423,13 @@ def latency(self) -> float:
         """
         return self._latency
 
+    @property
+    def name(self) -> Optional[str]:
+        """
+        Get the context's optional name.
+        """
+        return self._name
+
     @property
     def options(self) -> Options:
         """

supriya/contexts/nonrealtime.py

@@ -2,7 +2,6 @@
 Tools for interacting with non-realtime execution contexts.
 """
 
-import asyncio
 import hashlib
 import logging
 import platform
@@ -22,7 +21,7 @@
 from ..scsynth import AsyncNonrealtimeProcessProtocol, Options
 from ..typing import HeaderFormatLike, SampleFormatLike, SupportsOsc
 from ..ugens import SynthDef
-from .core import Context, ContextError, ContextObject, Node
+from .core import BootStatus, Context, ContextError, ContextObject, Node
 from .requests import DoNothing, RequestBundle, Requestable
 
 logger = logging.getLogger(__name__)
@@ -40,6 +39,7 @@ class Score(Context):
 
     def __init__(self, options: Optional[Options] = None, **kwargs):
         super().__init__(options=options, **kwargs)
+        self._boot_status = BootStatus.ONLINE
         self._requests: Dict[float, List[Requestable]] = {}
 
     ### CLASS METHODS ###
@@ -179,10 +179,9 @@ async def render(
                 ]
             )
             # render the datagram
-            exit_future = asyncio.get_running_loop().create_future()
-            protocol = AsyncNonrealtimeProcessProtocol(exit_future)
+            protocol = AsyncNonrealtimeProcessProtocol()
             await protocol.run(command, render_directory_path_)
-            exit_code: int = await exit_future
+            exit_code: int = await protocol.exit_future
             assert render_directory_path_ / render_file_name
             if output_file_path_:
                 shutil.copy(