Run w-20260927-160432-7042

diff --git a/.syncsnitch.json b/.syncsnitch.jsonnew file mode 100644index 0000000..ef8d9ac--- /dev/null+++ b/.syncsnitch.json@@ -0,0 +1 @@+{"upstream_repo": "kshiti26-11/demo", "upstream_pr": null, "upstream_base": "15f95af008e5060450fa81ff0a58ed50627b1b2e", "upstream_head": "0d5925565a38a672f8e849ea0eaa0eaba88aad8e", "run_id": "w-20260927-160432-7042"}diff --git a/billing/adapters/__init__.py b/billing/adapters/__init__.pynew file mode 100644index 0000000..e69de29diff --git a/billing/adapters/orders_contract.py b/billing/adapters/orders_contract.pynew file mode 100644index 0000000..ba3aae5--- /dev/null+++ b/billing/adapters/orders_contract.py@@ -0,0 +1,90 @@+from dataclasses import dataclass+from decimal import Decimal, ROUND_HALF_UP+++def normalize_status(value: str) -> str:+    if value.startswith("ORDER_STATUS_"):+        value = value[len("ORDER_STATUS_"):]+    if value == "PENDING":+        return "AWAITING_PAYMENT"+    return value+++@dataclass(frozen=True)+class OrderView:+    order_id: str+    customer_name: str+    amount_minor: int+    currency: str+    status: str+    created_at: str = None+++def _round_half_up(d: Decimal) -> int:+    return int(d.quantize(Decimal("1"), rounding=ROUND_HALF_UP))+++def from_rest(payload: dict) -> OrderView:+    order_id = payload["order_id"]+    status = normalize_status(payload["status"])+    created_at = payload.get("created_at")++    if "customer" in payload and isinstance(payload["customer"], dict):+        customer_name = payload["customer"].get("display_name")+    else:+        customer_name = payload.get("customer_name")++    if "total" in payload and isinstance(payload["total"], dict):+        total_dict = payload["total"]+        amount_minor = total_dict["amount_minor"]+        currency = total_dict.get("currency", "USD")+    else:+        tp = payload.get("total_price", 0)+        amount_minor = _round_half_up(Decimal(str(tp)) * 100)+        currency = "USD"++    return OrderView(+        order_id=order_id,+        customer_name=customer_name,+        amount_minor=amount_minor,+        currency=currency,+        status=status,+        created_at=created_at,+    )+++def from_summary(summary) -> OrderView:+    order_id = summary.order_id+    +    field = type(summary).DESCRIPTOR.fields_by_name["status"]+    raw_status = field.enum_type.values_by_number[summary.status].name+    status = normalize_status(raw_status)++    if summary.HasField("customer") and summary.customer.customer_id:+        customer_name = summary.customer.customer_id+    elif summary.HasField("customer") and getattr(summary.customer, "display_name", None):+        customer_name = summary.customer.display_name+    elif hasattr(summary, "customer_name") and summary.customer_name:+        customer_name = summary.customer_name+    else:+        customer_name = getattr(summary.customer, "customer_id", "") or ""++    if summary.HasField("total"):+        amount_minor = summary.total.amount_minor+        currency = summary.total.currency or "USD"+    elif hasattr(summary, "total_price") and summary.total_price:+        amount_minor = _round_half_up(Decimal(str(summary.total_price)) * 100)+        currency = "USD"+    else:+        amount_minor = 0+        currency = "USD"++    shipping_eta = getattr(summary, "shipping_eta", None)++    return OrderView(+        order_id=order_id,+        customer_name=customer_name,+        amount_minor=amount_minor,+        currency=currency,+        status=status,+    )diff --git a/billing/clients/gen/orders_pb2.py b/billing/clients/gen/orders_pb2.pyindex 23b66a7..17cb007 100644--- a/billing/clients/gen/orders_pb2.py+++ b/billing/clients/gen/orders_pb2.py@@ -24,19 +24,27 @@ _sym_db = _symbol_database.Default()   -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0corders.proto\x12\x06orders\"*\n\x16GetOrderSummaryRequest\x12\x10\n\x08order_id\x18\x01 \x01(\t\"q\n\x0cOrderSummary\x12\x10\n\x08order_id\x18\x01 \x01(\t\x12\x15\n\rcustomer_name\x18\x02 \x01(\t\x12\x13\n\x0btotal_price\x18\x03 \x01(\x01\x12#\n\x06status\x18\x04 \x01(\x0e\x32\x13.orders.OrderStatus*\x92\x01\n\x0bOrderStatus\x12\x1c\n\x18ORDER_STATUS_UNSPECIFIED\x10\x00\x12\x18\n\x14ORDER_STATUS_PENDING\x10\x01\x12\x15\n\x11ORDER_STATUS_PAID\x10\x02\x12\x18\n\x14ORDER_STATUS_SHIPPED\x10\x03\x12\x1a\n\x16ORDER_STATUS_CANCELLED\x10\x04\x32V\n\x0bOrderLookup\x12G\n\x0fGetOrderSummary\x12\x1e.orders.GetOrderSummaryRequest\x1a\x14.orders.OrderSummaryb\x06proto3')+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0corders.proto\x12\x06orders\"*\n\x16GetOrderSummaryRequest\x12\x10\n\x08order_id\x18\x01 \x01(\t\"/\n\x05Money\x12\x14\n\x0c\x61mount_minor\x18\x01 \x01(\x03\x12\x10\n\x08\x63urrency\x18\x02 \x01(\t\"5\n\x08\x43ustomer\x12\x13\n\x0b\x63ustomer_id\x18\x01 \x01(\t\x12\x14\n\x0c\x64isplay_name\x18\x02 \x01(\t\"\xd1\x01\n\x0cOrderSummary\x12\x19\n\rcustomer_name\x18\x02 \x01(\tB\x02\x18\x01\x12\x17\n\x0btotal_price\x18\x03 \x01(\x01\x42\x02\x18\x01\x12\x10\n\x08order_id\x18\x01 \x01(\t\x12#\n\x06status\x18\x04 \x01(\x0e\x32\x13.orders.OrderStatus\x12\"\n\x08\x63ustomer\x18\x05 \x01(\x0b\x32\x10.orders.Customer\x12\x1c\n\x05total\x18\x06 \x01(\x0b\x32\r.orders.Money\x12\x14\n\x0cshipping_eta\x18\x07 \x01(\t*\x9b\x01\n\x0bOrderStatus\x12\x1c\n\x18ORDER_STATUS_UNSPECIFIED\x10\x00\x12!\n\x1dORDER_STATUS_AWAITING_PAYMENT\x10\x01\x12\x15\n\x11ORDER_STATUS_PAID\x10\x02\x12\x18\n\x14ORDER_STATUS_SHIPPED\x10\x03\x12\x1a\n\x16ORDER_STATUS_CANCELLED\x10\x04\x32V\n\x0bOrderLookup\x12G\n\x0fGetOrderSummary\x12\x1e.orders.GetOrderSummaryRequest\x1a\x14.orders.OrderSummaryb\x06proto3')  _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'orders_pb2', _globals) if not _descriptor._USE_C_DESCRIPTORS:   DESCRIPTOR._loaded_options = None-  _globals['_ORDERSTATUS']._serialized_start=184-  _globals['_ORDERSTATUS']._serialized_end=330+  _globals['_ORDERSUMMARY'].fields_by_name['customer_name']._loaded_options = None+  _globals['_ORDERSUMMARY'].fields_by_name['customer_name']._serialized_options = b'\030\001'+  _globals['_ORDERSUMMARY'].fields_by_name['total_price']._loaded_options = None+  _globals['_ORDERSUMMARY'].fields_by_name['total_price']._serialized_options = b'\030\001'+  _globals['_ORDERSTATUS']._serialized_start=385+  _globals['_ORDERSTATUS']._serialized_end=540   _globals['_GETORDERSUMMARYREQUEST']._serialized_start=24   _globals['_GETORDERSUMMARYREQUEST']._serialized_end=66-  _globals['_ORDERSUMMARY']._serialized_start=68-  _globals['_ORDERSUMMARY']._serialized_end=181-  _globals['_ORDERLOOKUP']._serialized_start=332-  _globals['_ORDERLOOKUP']._serialized_end=418+  _globals['_MONEY']._serialized_start=68+  _globals['_MONEY']._serialized_end=115+  _globals['_CUSTOMER']._serialized_start=117+  _globals['_CUSTOMER']._serialized_end=170+  _globals['_ORDERSUMMARY']._serialized_start=173+  _globals['_ORDERSUMMARY']._serialized_end=382+  _globals['_ORDERLOOKUP']._serialized_start=542+  _globals['_ORDERLOOKUP']._serialized_end=628 # @@protoc_insertion_point(module_scope)diff --git a/billing/clients/gen/orders_pb2.pyi b/billing/clients/gen/orders_pb2.pyiindex ff3c6a0..28983a9 100644--- a/billing/clients/gen/orders_pb2.pyi+++ b/billing/clients/gen/orders_pb2.pyi@@ -1,6 +1,7 @@ from google.protobuf.internal import enum_type_wrapper as _enum_type_wrapper from google.protobuf import descriptor as _descriptor from google.protobuf import message as _message+from collections.abc import Mapping as _Mapping from typing import ClassVar as _ClassVar, Optional as _Optional, Union as _Union  DESCRIPTOR: _descriptor.FileDescriptor@@ -8,12 +9,12 @@ DESCRIPTOR: _descriptor.FileDescriptor class OrderStatus(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):     __slots__ = ()     ORDER_STATUS_UNSPECIFIED: _ClassVar[OrderStatus]-    ORDER_STATUS_PENDING: _ClassVar[OrderStatus]+    ORDER_STATUS_AWAITING_PAYMENT: _ClassVar[OrderStatus]     ORDER_STATUS_PAID: _ClassVar[OrderStatus]     ORDER_STATUS_SHIPPED: _ClassVar[OrderStatus]     ORDER_STATUS_CANCELLED: _ClassVar[OrderStatus] ORDER_STATUS_UNSPECIFIED: OrderStatus-ORDER_STATUS_PENDING: OrderStatus+ORDER_STATUS_AWAITING_PAYMENT: OrderStatus ORDER_STATUS_PAID: OrderStatus ORDER_STATUS_SHIPPED: OrderStatus ORDER_STATUS_CANCELLED: OrderStatus@@ -24,14 +25,36 @@ class GetOrderSummaryRequest(_message.Message):     order_id: str     def __init__(self, order_id: _Optional[str] = ...) -> None: ... +class Money(_message.Message):+    __slots__ = ("amount_minor", "currency")+    AMOUNT_MINOR_FIELD_NUMBER: _ClassVar[int]+    CURRENCY_FIELD_NUMBER: _ClassVar[int]+    amount_minor: int+    currency: str+    def __init__(self, amount_minor: _Optional[int] = ..., currency: _Optional[str] = ...) -> None: ...++class Customer(_message.Message):+    __slots__ = ("customer_id", "display_name")+    CUSTOMER_ID_FIELD_NUMBER: _ClassVar[int]+    DISPLAY_NAME_FIELD_NUMBER: _ClassVar[int]+    customer_id: str+    display_name: str+    def __init__(self, customer_id: _Optional[str] = ..., display_name: _Optional[str] = ...) -> None: ...+ class OrderSummary(_message.Message):-    __slots__ = ("order_id", "customer_name", "total_price", "status")-    ORDER_ID_FIELD_NUMBER: _ClassVar[int]+    __slots__ = ("customer_name", "total_price", "order_id", "status", "customer", "total", "shipping_eta")     CUSTOMER_NAME_FIELD_NUMBER: _ClassVar[int]     TOTAL_PRICE_FIELD_NUMBER: _ClassVar[int]+    ORDER_ID_FIELD_NUMBER: _ClassVar[int]     STATUS_FIELD_NUMBER: _ClassVar[int]-    order_id: str+    CUSTOMER_FIELD_NUMBER: _ClassVar[int]+    TOTAL_FIELD_NUMBER: _ClassVar[int]+    SHIPPING_ETA_FIELD_NUMBER: _ClassVar[int]     customer_name: str     total_price: float+    order_id: str     status: OrderStatus-    def __init__(self, order_id: _Optional[str] = ..., customer_name: _Optional[str] = ..., total_price: _Optional[float] = ..., status: _Optional[_Union[OrderStatus, str]] = ...) -> None: ...+    customer: Customer+    total: Money+    shipping_eta: str+    def __init__(self, customer_name: _Optional[str] = ..., total_price: _Optional[float] = ..., order_id: _Optional[str] = ..., status: _Optional[_Union[OrderStatus, str]] = ..., customer: _Optional[_Union[Customer, _Mapping]] = ..., total: _Optional[_Union[Money, _Mapping]] = ..., shipping_eta: _Optional[str] = ...) -> None: ...diff --git a/billing/contract_entrypoints.py b/billing/contract_entrypoints.pyindex 2822e7c..a98aa59 100644--- a/billing/contract_entrypoints.py+++ b/billing/contract_entrypoints.py@@ -1,6 +1,7 @@-from .models.order import OrderDTO+from .adapters.orders_contract import from_rest from .services.invoice import build_invoice   def invoice_from_order_payload(payload: dict) -> dict | None:-    return build_invoice(OrderDTO.model_validate(payload))+    view = from_rest(payload)+    return build_invoice(view)diff --git a/billing/models/order.py b/billing/models/order.pyindex 6af3477..b12e9b0 100644--- a/billing/models/order.py+++ b/billing/models/order.py@@ -1,10 +1,10 @@ from datetime import datetime-from pydantic import BaseModel+from pydantic import BaseModel, Field   class OrderDTO(BaseModel):     order_id: str-    customer_name: str-    total_price: float+    customer_name: str = Field(default="")+    total_price: float = Field(default=0.0)     status: str     created_at: datetimediff --git a/billing/reports/revenue.py b/billing/reports/revenue.pyindex dc50557..8a4835f 100644--- a/billing/reports/revenue.py+++ b/billing/reports/revenue.py@@ -4,25 +4,45 @@ from pathlib import Path from sqlalchemy import create_engine, text  -_SQL = (Path(__file__).parent / "revenue.sql").read_text()+_SQL_V1 = (Path(__file__).parent / "revenue_v1.sql").read_text()+_SQL_V2 = (Path(__file__).parent / "revenue_v2.sql").read_text()   def _round_half_up(d: Decimal) -> int:     return int(d.quantize(Decimal("1"), rounding=ROUND_HALF_UP))  +def _schema_version(conn) -> str:+    try:+        return str(conn.execute(text("SELECT version_num FROM alembic_version")).scalar() or "")+    except Exception:+        conn.rollback()+        return ""++ def run_revenue_report(db_url: str) -> list[dict]:     engine = create_engine(db_url)     try:         with engine.connect() as conn:-            rows = conn.execute(text(_SQL)).fetchall()+            ver = _schema_version(conn)+            sql = _SQL_V2 if ver >= "0002" else _SQL_V1+            rows = conn.execute(text(sql)).fetchall()     finally:         engine.dispose() -    return [-        {-            "day": str(row.day)[:10],-            "revenue_minor": _round_half_up(Decimal(str(row.revenue)) * 100),-        }-        for row in rows-    ]+    if ver >= "0002":+        return [+            {+                "day": str(row.day)[:10],+                "revenue_minor": int(row.revenue or 0),+            }+            for row in rows+        ]+    else:+        return [+            {+                "day": str(row.day)[:10],+                "revenue_minor": _round_half_up(Decimal(str(row.revenue)) * 100),+            }+            for row in rows+        ]diff --git a/billing/reports/revenue_v1.sql b/billing/reports/revenue_v1.sqlnew file mode 100644index 0000000..f6d0b41--- /dev/null+++ b/billing/reports/revenue_v1.sql@@ -0,0 +1,5 @@+SELECT date(created_at) AS day, SUM(total_price) AS revenue+FROM orders+WHERE status IN ('PAID', 'SHIPPED')+GROUP BY day+ORDER BY daydiff --git a/billing/reports/revenue_v2.sql b/billing/reports/revenue_v2.sqlnew file mode 100644index 0000000..e682d44--- /dev/null+++ b/billing/reports/revenue_v2.sql@@ -0,0 +1,5 @@+SELECT date(created_at) AS day, SUM(total_minor) AS revenue+FROM orders+WHERE status IN ('PAID', 'SHIPPED')+GROUP BY day+ORDER BY daydiff --git a/billing/services/invoice.py b/billing/services/invoice.pyindex 61a0c87..3e07035 100644--- a/billing/services/invoice.py+++ b/billing/services/invoice.py@@ -1,7 +1,7 @@ from decimal import Decimal, ROUND_HALF_UP  TAX_RATE = Decimal("0.0825")-NOT_PAYABLE = {"PENDING", "CANCELLED"}+NOT_PAYABLE = {"PENDING", "AWAITING_PAYMENT", "CANCELLED"}   def _round_half_up(d: Decimal) -> int:@@ -12,8 +12,8 @@ def build_invoice(order) -> dict | None:     if order.status in NOT_PAYABLE:         return None -    subtotal = _round_half_up(Decimal(str(order.total_price)) * 100)-    tax = _round_half_up(Decimal(str(order.total_price)) * 100 * TAX_RATE)+    subtotal = order.amount_minor+    tax = _round_half_up(Decimal(str(subtotal)) * TAX_RATE)     total = subtotal + tax      return {diff --git a/billing/services/payments.py b/billing/services/payments.pyindex f04306f..5ade2b7 100644--- a/billing/services/payments.py+++ b/billing/services/payments.py@@ -1,6 +1,7 @@ from decimal import Decimal, ROUND_HALF_UP+from billing.adapters.orders_contract import from_summary -PAID_STATES = {"ORDER_STATUS_PAID", "ORDER_STATUS_SHIPPED"}+PAID_STATES = {"ORDER_STATUS_PAID", "ORDER_STATUS_SHIPPED", "PAID", "SHIPPED"}   def _round_half_up(d: Decimal) -> int:@@ -8,14 +9,11 @@ def _round_half_up(d: Decimal) -> int:   def status_from_summary(summary) -> dict:-    field = type(summary).DESCRIPTOR.fields_by_name["status"]-    status_name = field.enum_type.values_by_number[summary.status].name--    amount_minor = _round_half_up(Decimal(str(summary.total_price)) * 100)+    view = from_summary(summary)      return {-        "order_id": summary.order_id,-        "paid": status_name in PAID_STATES,-        "amount_minor": amount_minor,-        "currency": "USD",+        "order_id": view.order_id,+        "paid": view.status in {"PAID", "SHIPPED"},+        "amount_minor": view.amount_minor,+        "currency": view.currency,     }diff --git a/contracts/upstream/orders.proto b/contracts/upstream/orders.protoindex cf6836e..a1960b3 100644--- a/contracts/upstream/orders.proto+++ b/contracts/upstream/orders.proto@@ -1,4 +1,6 @@-// Orders gRPC contract v1 - owned by orders-service (upstream).+// Orders gRPC contract v2 - owned by orders-service (upstream).+// v2 = money in minor units, structured customer, PENDING renamed to+// AWAITING_PAYMENT (same wire number), optional shipping_eta. // Reference copy for SyncSnitch - do not edit. syntax = "proto3"; @@ -15,15 +17,28 @@ message GetOrderSummaryRequest {  enum OrderStatus {   ORDER_STATUS_UNSPECIFIED = 0;-  ORDER_STATUS_PENDING = 1;+  ORDER_STATUS_AWAITING_PAYMENT = 1;   ORDER_STATUS_PAID = 2;   ORDER_STATUS_SHIPPED = 3;   ORDER_STATUS_CANCELLED = 4; } +message Money {+  int64 amount_minor = 1;  // minor units, e.g. 1999 = 19.99 USD+  string currency = 2;     // ISO 4217, e.g. "USD"+}++message Customer {+  string customer_id = 1;+  string display_name = 2;+}+ message OrderSummary {+  string customer_name = 2 [deprecated = true];+  double total_price = 3 [deprecated = true];  // major units (USD), e.g. 19.99   string order_id = 1;-  string customer_name = 2;-  double total_price = 3;  // major units (USD), e.g. 19.99   OrderStatus status = 4;+  Customer customer = 5;+  Money total = 6;+  string shipping_eta = 7;  // RFC 3339 timestamp, empty when unknown }diff --git a/tests/fixtures/order_v2_paid.json b/tests/fixtures/order_v2_paid.jsonnew file mode 100644index 0000000..7f2562a--- /dev/null+++ b/tests/fixtures/order_v2_paid.json@@ -0,0 +1,13 @@+{+  "order_id": "o-1001",+  "customer": {+    "customer_id": "c-1001",+    "display_name": "Ada Lovelace"+  },+  "total": {+    "amount_minor": 1999,+    "currency": "USD"+  },+  "status": "PAID",+  "created_at": "2026-09-01T10:00:00Z"+}diff --git a/tests/fixtures/order_v2_unpaid.json b/tests/fixtures/order_v2_unpaid.jsonnew file mode 100644index 0000000..7f6a9ed--- /dev/null+++ b/tests/fixtures/order_v2_unpaid.json@@ -0,0 +1,13 @@+{+  "order_id": "o-1002",+  "customer": {+    "customer_id": "c-1002",+    "display_name": "Alan Turing"+  },+  "total": {+    "amount_minor": 500,+    "currency": "USD"+  },+  "status": "AWAITING_PAYMENT",+  "created_at": "2026-09-02T11:00:00Z"+}