Implement ConfigMap and Secret based python packages.

Author: Patrick J. McNerthney

.gitignore

@@ -209,3 +209,6 @@ cython_debug/
 marimo/_static/
 marimo/_lsp/
 __marimo__/
+
+# function-pythonic
+pythonic-packages/

Dockerfile

@@ -1,43 +1,21 @@
-# syntax=docker/dockerfile:1
+FROM python:3.13-slim-trixie AS image
 
-# It's important that this is Debian 12 to match the distroless image.
-FROM debian:12-slim AS build
-
-#RUN --mount=type=cache,target=/var/lib/apt/lists \
-#    --mount=type=cache,target=/var/cache/apt \
-RUN \
-    rm -f /etc/apt/apt.conf.d/docker-clean \
-    && apt-get update \
-    && apt-get install --no-install-recommends --yes python3-venv git
-
-# Don't write .pyc bytecode files. These speed up imports when the program is
-# loaded. There's no point doing that in a container where they'll never be
-# persisted across restarts.
-ENV PYTHONDONTWRITEBYTECODE=true
-
-# Use Hatch to build a wheel. The build stage must do this in a venv because
-# Debian doesn't have a hatch package, and it won't let you install one globally
-# using pip.
-WORKDIR /build
-#RUN --mount=target=. \
-#    --mount=type=cache,target=/root/.cache/pip \
-COPY . /build
-RUN \
-    python3 -m venv /venv/build \
-    && /venv/build/bin/pip install hatch \
-    && /venv/build/bin/hatch build -t wheel /whl
-
-# Create a fresh venv and install only the pythonic wheel into it.
-#RUN --mount=type=cache,target=/root/.cache/pip \
+WORKDIR /root/pythonic
+COPY pyproject.toml /root/pythonic
+COPY crossplane /root/pythonic/crossplane
+WORKDIR /
 RUN \
-    python3 -m venv /venv/fn \
-    && /venv/fn/bin/pip install /whl/*.whl
+  set -eux && \
+  cd /root/pythonic && \
+  pip install --root-user-action ignore --no-build-isolation setuptools==80.9.0 && \
+  pip install --root-user-action ignore --no-build-isolation . && \
+  pip uninstall --root-user-action ignore --yes setuptools && \
+  cd .. && \
+  rm -rf .cache pythonic && \
+  groupadd --gid 2000 pythonic && \
+  useradd --uid 2000 --gid pythonic --home-dir /opt/pythonic --create-home --shell /usr/sbin/nologin pythonic
 
-# Copy the pythonic venv to our runtime stage. It's important that the path be
-# the same as in the build stage, to avoid shebang paths and symlinks breaking. 
-FROM gcr.io/distroless/python3-debian12 AS image
-WORKDIR /
-USER nonroot:nonroot
-COPY --from=build --chown=nonroot:nonroot /venv/fn /venv/fn
+USER pythonic:pythonic
+WORKDIR /opt/pythonic
 EXPOSE 9443
-ENTRYPOINT ["/venv/fn/bin/pythonic"]
+ENTRYPOINT ["python", "-m", "crossplane.pythonic.main"]

README.md

@@ -181,7 +181,7 @@ The BaseComposite class provides the following fields for manipulating the Compo
 | self.status | Map | The composite desired and observed status, read from observed if not in desired |
 | self.conditions | Conditions | The composite desired and observed conditions, read from observed if not in desired |
 | self.connection | Connection | The composite desired and observed connection detials, read from observed if not in desired |
-| self.results | Results | Returned results on the Composite and optionally on the Claim |
+| self.events | Events | Returned events against the Composite and optionally on the Claim |
 | self.ready | Boolean | The composite desired ready state |
 
 The BaseComposite also provides access to the following Crossplane Function level features:

crossplane/pythonic/__version__.py

@@ -32,7 +32,7 @@ def __init__(self, request, response, logger):
         self.status = Status(self.observed.status, self.desired.status)
         self.conditions = Conditions(observed, self.response)
         self.connection = Connection(observed, desired)
-        self.results = Results(self.response)
+        self.events = Events(self.response)
 
     @property
     def ttl(self):
@@ -235,6 +235,33 @@ def __getattr__(self, key):
     def __getitem__(self, key):
         return RequiredResources(self._composite, key)
 
+    def __bool__(self):
+        return bool(len(self))
+
+    def __len__(self):
+        names = set()
+        for name, resource in self._composite.request.extra_resources:
+            names.add(name)
+        for name, resource in self._composite.response.requirements.extra_resources:
+            names.add(name)
+        return len(names)
+
+    def __contains__(self, key):
+        if key in self._composite.request.extra_resources:
+            return True
+        if key in self._composite.response.desired.resources:
+            return True
+        return False
+
+    def __iter__(self):
+        names = set()
+        for name, resource in self._composite.request.extra_resources:
+            names.add(name)
+        for name, resource in self._composite.response.requirements.extra_resources:
+            names.add(name)
+        for name in sorted(names):
+            yield name, self[name]
+
 
 class RequiredResources:
     def __init__(self, composite, name):
@@ -384,14 +411,14 @@ def _protobuf_value(self):
             value['lastTransitionTime'] = time.isoformat().replace('+00:00', 'Z')
         return value
 
-    def __call__(self, status=_notset, reason=_notset, message=_notset, claim=_notset):
+    def __call__(self, reason=_notset, message=_notset, status=_notset, claim=_notset):
         self._find_condition(True)
-        if status != _notset:
-            self.status = status
         if reason != _notset:
             self.reason = reason
         if message != _notset:
             self.message = message
+        if status != _notset:
+            self.status = status
         if claim != _notset:
             self.claim = claim
         return self
@@ -514,39 +541,42 @@ def __setitem__(self, key, value):
         self._desired.connection_details[key] = value
 
 
-class Results:
+class Events:
     def __init__(self, response):
         self._results = response.results
 
-    def info(self, message, reason=_notset, claim=_notset):
-        result = Result(self._results.append())
-        result.info = True
-        result.message = message
+    def info(self, reason=_notset, message=_notset, claim=_notset):
+        event = Event(self._results.append())
+        event.info = True
         if reason != _notset:
-            result.reason = reason
+            event.reason = reason
+        if message != _notset:
+            event.message = message
         if claim != _notset:
-            result.claim = claim
-        return result
+            event.claim = claim
+        return event
 
-    def warning(self, message, reason=_notset, claim=_notset):
-        result = Result(self._results.append())
-        result.warning = True
-        result.message = message
+    def warning(self, reason=_notset, message=_notset, claim=_notset):
+        event = Event(self._results.append())
+        event.warning = True
         if reason != _notset:
-            result.reason = reason
+            event.reason = reason
+        if message != _notset:
+            event.message = message
         if claim != _notset:
-            result.claim = claim
-        return result
+            event.claim = claim
+        return event
 
-    def fatal(self, message, reason=_notset, claim=_notset):
-        result = Result(self._results.append())
-        result.fatal = True
-        result.message = message
+    def fatal(self, reason=_notset, message=_notset, claim=_notset):
+        event = Event(self._results.append())
+        event.fatal = True
         if reason != _notset:
-            result.reason = reason
+            event.reason = reason
+        if message != _notset:
+            event.message = message
         if claim != _notset:
-            result.claim = claim
-        return result
+            event.claim = claim
+        return event
 
     def __bool__(self):
         return len(self) > 0
@@ -556,15 +586,15 @@ def __len__(self):
 
     def __getitem__(self, key):
         if key >= len(self._results):
-            return Result()
-        return Result(self._results[ix])
+            return Event()
+        return Event(self._results[ix])
 
     def __iter__(self):
         for ix in range(len(self._results)):
             yield self[ix]
 
 
-class Result:
+class Event:
     def __init__(self, result=None):
         self._result = result