Update tags.

moonstreamapi/moonstreamapi/actions.py

@@ -1181,10 +1181,10 @@ def create_resource_for_user(
     return resource
 
 
-def chekc_user_resource_access(
+def check_user_resource_access(
     customer_id: uuid.UUID,
     user_token: uuid.UUID,
-) -> bool:
+) -> Optional[BugoutResource]:
     """
     Check if user has access to customer_id
     """
@@ -1198,10 +1198,10 @@ def chekc_user_resource_access(
 
     except BugoutResponseException as e:
         if e.status_code == 404:
-            return False
+            return None
         raise MoonstreamHTTPException(status_code=e.status_code, detail=e.detail)
     except Exception as e:
         logger.error(f"Error get customer: {str(e)}")
         raise MoonstreamHTTPException(status_code=500, internal_error=e)
 
-    return str(response.id) == customer_id
+    return response

moonstreamapi/moonstreamapi/routes/subscriptions.py

@@ -20,7 +20,7 @@
     EntityJournalNotFoundException,
     apply_moonworm_tasks,
     check_if_smart_contract,
-    chekc_user_resource_access,
+    check_user_resource_access,
     get_entity_subscription_journal_id,
     get_list_of_support_interfaces,
     get_moonworm_tasks,
@@ -104,17 +104,19 @@ async def add_subscription_handler(
 
     if customer_id is not None:
 
-        results = chekc_user_resource_access(
+        results = check_user_resource_access(
             customer_id=customer_id,
             user_token=token,
         )
 
-        if not results:
+        if results is None:
             raise MoonstreamHTTPException(
-                status_code=403,
-                detail="User has no access to this customer",
+                status_code=404,
+                detail="Not found customer",
             )
 
+        customer_instance_name = results.resource_data["name"]
+
     active_subscription_types_response = subscription_types.list_subscription_types(
         active_only=True
     )
@@ -172,6 +174,18 @@ async def add_subscription_handler(
         {"user_id": f"{user.id}"},
     ]
 
+    if customer_id is not None and customer_instance_name is not None:
+        required_fields.extend(
+            [
+                {
+                    "customer_id": f"{customer_id}",
+                },
+                {
+                    "instance_name": f"{customer_instance_name}",
+                },
+            ]
+        )
+
     if allowed_required_fields:
         required_fields.extend(allowed_required_fields)
 
@@ -218,7 +232,7 @@ async def add_subscription_handler(
         f"{key}:{value}"
         for tag in entity_required_fields
         for key, value in tag.items()
-        if key not in MOONSTREAM_ENTITIES_RESERVED_TAGS
+        if key not in MOONSTREAM_ENTITIES_RESERVED_TAGS or key == "instance_name"
     ]
 
     if entity_secondary_fields.get("abi") and customer_id is not None:
@@ -402,7 +416,7 @@ async def get_subscriptions_handler(
             f"{key}:{value}"
             for tag in tags
             for key, value in tag.items()
-            if key not in MOONSTREAM_ENTITIES_RESERVED_TAGS
+            if key not in MOONSTREAM_ENTITIES_RESERVED_TAGS or key == "instance_name"
         ]
 
         subscriptions.append(
@@ -460,15 +474,15 @@ async def update_subscriptions_handler(
 
     if customer_id is not None:
 
-        results = chekc_user_resource_access(
+        results = check_user_resource_access(
             customer_id=customer_id,
             user_token=token,
         )
 
-        if not results:
+        if results is None:
             raise MoonstreamHTTPException(
-                status_code=403,
-                detail="User has no access to this customer",
+                status_code=404,
+                detail="Not found customer",
             )
 
     try:
@@ -624,7 +638,7 @@ async def update_subscriptions_handler(
         f"{key}:{value}"
         for tag in subscription_required_fields
         for key, value in tag.items()
-        if key not in MOONSTREAM_ENTITIES_RESERVED_TAGS
+        if key not in MOONSTREAM_ENTITIES_RESERVED_TAGS or key == "instance_name"
     ]
 
     return data.SubscriptionResourceData(

moonstreamapi/moonstreamapi/settings.py

@@ -309,6 +309,8 @@
     "user_id",
     "address",
     "blockchain",
+    "customer_id",
+    "instance_name",
 ]
 
 ## Moonstream resources types