--wip-- [skip ci]

Author: tdstein

src/posit/connect/client.py

@@ -6,6 +6,8 @@
 
 from requests import Response, Session
 
+from posit.connect.environments import Environments
+
 from . import hooks, me
 from .auth import Auth
 from .config import Config
@@ -184,6 +186,10 @@ def me(self) -> User:
         """
         return me.get(self.resource_params)
 
+    @property
+    def environments(self) -> Environments:
+        return Environments(self.ctx, "v1")
+
     @property
     def groups(self) -> Groups:
         """The groups resource interface.

src/posit/connect/environments.py

@@ -0,0 +1,18 @@
+from .resources import (
+    ActiveCreatorMethods,
+    ActiveDestroyerMethods,
+    ActiveFinderMethods,
+    ActiveUpdaterMethods,
+)
+
+
+class Environment(ActiveUpdaterMethods, ActiveDestroyerMethods):
+    pass
+
+
+class Environments(ActiveFinderMethods[Environment], ActiveCreatorMethods[Environment]):
+    def __init__(self, ctx, path, pathinfo="environments", uid="guid"):
+        super().__init__(ctx, path, pathinfo, uid)
+
+    def _create_instance(self, path, pathinfo, /, **attributes):
+        return Environment(self._ctx, path, pathinfo, **attributes)

src/posit/connect/resources.py

@@ -227,3 +227,30 @@ def find_by(self, **conditions: Any) -> Optional[T]:
             The first record matching the conditions, or `None` if no match is found.
         """
         return next((v for v in self._data if v.items() >= conditions.items()), None)
+
+
+class ActiveCreatorMethods(ActiveSequence[T], ABC):
+    def create(self, **attributes) -> T:
+        endpoint = self._ctx.url + self._path
+        response = self._ctx.session.post(endpoint, json=attributes)
+        result = response.json()
+        uid = result[self._uid]
+        return self._create_instance(self._path, uid, **result)
+
+
+class ActiveDestroyerMethods(Active):
+    def destroy(self):
+        endpoint = self._ctx.url + self._path
+        self._ctx.session.delete(endpoint)
+
+
+class ActiveUpdaterMethods(Active):
+    def update(self, /, **attributes):
+        super().update(**attributes)
+        self.save()
+
+    def save(self):
+        endpoint = self._ctx.url + self._path
+        response = self._ctx.session.put(endpoint, json=self)
+        result = response.json()
+        super().update(**result)