fix(examples): include media-buy response revisions

Author: bokelley

examples/sales_proposal_mode_seller/src/platform.py

@@ -44,6 +44,8 @@ class _MediaBuy:
     total_budget: float
     start_time: datetime
     end_time: datetime
+    confirmed_at: str
+    revision: int = 1
     status: str = "active"
     recipes_seen: dict[str, str] | None = None  # product_id -> line_item_template_id
 
@@ -139,6 +141,7 @@ def create_media_buy(
         total_budget = float(_dotted(req, "total_budget.amount", 0.0) or 0.0)
         start_time = _read_datetime(getattr(req, "start_time", None))
         end_time = _read_datetime(getattr(req, "end_time", None))
+        confirmed_at = datetime.now(timezone.utc).isoformat().replace("+00:00", "Z")
 
         with self._lock:
             self._buys[media_buy_id] = _MediaBuy(
@@ -147,6 +150,7 @@ def create_media_buy(
                 total_budget=total_budget,
                 start_time=start_time,
                 end_time=end_time,
+                confirmed_at=confirmed_at,
                 recipes_seen=recipes_seen,
             )
 
@@ -156,7 +160,8 @@ def create_media_buy(
             "media_buy_id": media_buy_id,
             "buyer_ref": getattr(req, "buyer_ref", None),
             "status": "active",
-            "confirmed_at": datetime.now(timezone.utc).isoformat().replace("+00:00", "Z"),
+            "confirmed_at": confirmed_at,
+            "revision": 1,
             "proposal_id": str(proposal_id) if proposal_id else None,
             "packages": [
                 {
@@ -203,10 +208,12 @@ def update_media_buy(
                     ),
                     recovery="terminal",
                 )
+            buy.revision += 1
         return {
             "media_buy_id": media_buy_id,
             "buyer_ref": buy.proposal_id,
             "status": buy.status,
+            "revision": buy.revision,
             "packages": [],
         }
 
@@ -269,6 +276,8 @@ def get_media_buys(self, req: Any, ctx: RequestContext[Any]) -> dict[str, Any]:
                     "media_buy_id": b.media_buy_id,
                     "status": b.status,
                     "buyer_ref": b.proposal_id,
+                    "confirmed_at": b.confirmed_at,
+                    "revision": b.revision,
                     "packages": [],
                 }
                 for b in buys

examples/v3_reference_seller/src/platform.py

@@ -135,6 +135,14 @@
 logger = logging.getLogger(__name__)
 
 
+def _order_confirmed_at(order: dict[str, Any]) -> str:
+    """Return a wire timestamp for the buy confirmation moment."""
+    value = order.get("confirmed_at") or order.get("updated_at") or order.get("created_at")
+    if value is not None:
+        return str(value)
+    return datetime.now(timezone.utc).isoformat()
+
+
 # ---------------------------------------------------------------------------
 # AccountStore — explicit (wire ref drives lookup)
 # ---------------------------------------------------------------------------
@@ -1193,6 +1201,7 @@ async def _project_create_success(
             wire_status = "pending_creatives"
         order_id = order["order_id"]
         buy_state = self._buy_state.setdefault(order_id, {"packages": {}, "canceled": False})
+        revision = self._buy_revisions.setdefault(order_id, 1)
         response_packages: list[dict[str, Any]] = []
         for idx, pkg in enumerate(req_packages):
             line_item = await upstream_helpers.add_line_item(
@@ -1217,6 +1226,8 @@ async def _project_create_success(
             {
                 "media_buy_id": order_id,
                 "status": wire_status,
+                "confirmed_at": _order_confirmed_at(order),
+                "revision": revision,
                 "packages": response_packages,
                 "invoice_recipient": (
                     invoice_recipient.model_dump(mode="json", exclude_none=True)
@@ -1676,6 +1687,8 @@ async def get_media_buys(
                 {
                     "media_buy_id": order_id,
                     "status": wire_status,
+                    "confirmed_at": _order_confirmed_at(order),
+                    "revision": self._buy_revisions.setdefault(order_id, 1),
                     "currency": order.get("currency", "USD"),
                     "total_budget": float(order.get("budget", 0.0)),
                     "packages": packages,