Add API endpoint to check if subscription is activated (#2582)

Subscription Management: used check to ensure subscription can be auto-canceled if
not activated.

---------
Co-authored-by: Ilya Kreymer <[email protected]>

Author: tw4l

backend/btrixcloud/orgs.py

@@ -548,6 +548,17 @@ async def cancel_subscription_data(
         )
         return Organization.from_dict(org_data) if org_data else None
 
+    async def is_subscription_activated(self, sub_id: str) -> bool:
+        """return true if subscription for this org was 'activated', eg. at least
+        one user has signed up and changed the slug
+        """
+        org_data = await self.orgs.find_one({"subscription.subId": sub_id})
+        if not org_data:
+            return False
+
+        org = Organization.from_dict(org_data)
+        return len(org.users) > 0 and org.slug != str(org.id)
+
     async def update_custom_storages(self, org: Organization) -> bool:
         """Update storage on an existing organization"""
 

backend/btrixcloud/subs.py

@@ -34,6 +34,7 @@
     UserRole,
     AddedResponseId,
     UpdatedResponse,
+    SuccessResponse,
     PaginatedSubscriptionEventResponse,
     REASON_CANCELED,
 )
@@ -392,6 +393,18 @@ async def cancel_subscription(
 
     assert org_ops.router
 
+    @app.get(
+        "/subscriptions/is-activated/{sub_id}",
+        tags=["subscriptions"],
+        dependencies=[Depends(user_or_shared_secret_dep)],
+        response_model=SuccessResponse,
+    )
+    async def is_subscription_activated(
+        sub_id: str,
+    ):
+        result = await org_ops.is_subscription_activated(sub_id)
+        return {"success": result}
+
     @app.get(
         "/subscriptions/events",
         tags=["subscriptions"],

backend/test/test_org_subs.py

@@ -68,6 +68,15 @@ def test_create_sub_org_and_invite_new_user(admin_auth_headers):
     new_subs_oid = org_id
 
 
+def test_validate_new_org_not_activated(admin_auth_headers):
+    r = requests.get(
+        f"{API_PREFIX}/subscriptions/is-activated/123",
+        headers=admin_auth_headers,
+    )
+    assert r.status_code == 200
+    assert r.json()["success"] is False
+
+
 def test_validate_new_org_with_quotas_and_name_is_uid(admin_auth_headers):
     r = requests.get(f"{API_PREFIX}/orgs/{new_subs_oid}", headers=admin_auth_headers)
     assert r.status_code == 200
@@ -126,6 +135,15 @@ def test_validate_new_org_with_quotas_and_update_name(admin_auth_headers):
     assert "subscription" in data
 
 
+def test_validate_new_org_is_activated(admin_auth_headers):
+    r = requests.get(
+        f"{API_PREFIX}/subscriptions/is-activated/123",
+        headers=admin_auth_headers,
+    )
+    assert r.status_code == 200
+    assert r.json()["success"] is True
+
+
 def test_create_sub_org_and_invite_existing_user_dupe_sub(admin_auth_headers):
     r = requests.post(
         f"{API_PREFIX}/subscriptions/create",