Update app.py

app.py

@@ -110,9 +110,7 @@ class Update(BaseModel):
 
 
 class Owner(BaseModel):
-        owner:str
-
-
+      owner:str
 
 
 class Delete(BaseModel):
@@ -143,7 +141,7 @@ def saveToMarket(payload):
 
 
 
-def UpdateMarketData(endpoint,endpoint_linker,status_code):
+def UpdateMarketData(resource,endpoint,endpoint_linker,endpoint_method,status_code):
 
     
     call_success = 200 <= status_code < 300
@@ -151,7 +149,11 @@ def UpdateMarketData(endpoint,endpoint_linker,status_code):
     marketplace.update_one(
            { owner: "system" },
                 {
-                "$set": { "marketplace.$[elem].mcp_endpoint": endpoint },
+                "$set": { 
+                    "marketplace.$[elem].endpoint": endpoint ,
+                    "endpoint_method":endpoint_method,
+                    "resource":resource
+                },
                 "$inc": { 
                     "marketplace.$[elem].calls": 1,
                     "marketplace.$[elem].failures": 0 if call_success else 1
@@ -308,9 +310,11 @@ def RegisterEndpoint(data:RegisterPayload):
                 "endpoint_linker":short_id_e,
                 "meta":data.meta,
                 "description":data.description,
-                "mcp_endpoint":"",
+                "endpoint":"",
+                 "endpoint_method":"",
+                "resource":"",
                  "calls":0,
-                 "failures":0
+                "failures":0
                 
                 
             }
@@ -362,7 +366,9 @@ def RegisterDynamicEndpoint(data:RegisterPayloadDynamic):
                  "endpoint_linker":short_id_e,
                  "meta":data.meta,
                  "description":data.description,
-                 "mcp_endpoint":""
+                 "endpoint":"",
+                 "endpoint_method":"",
+                 "resource":"",
                  "calls":0,
                  "failures":0
             
@@ -447,7 +453,7 @@ def checkDEP(data:Owner):
 
 
 
-    
+
 #''' Dynamic Endpoint Updation  '''
 
 @app.post("/update_dynamic_endpoint")
@@ -598,7 +604,7 @@ async def FetchVelocityGET(x402id:str,request:Request):
                             #proxying here
                              
                             response=await X402Proxy_GET(request,found_endpoint)
-                            UpdateMarketData(found_endpoint,x402id,response.status_code)
+                            UpdateMarketData(found_endpoint,resource,x402id,"GET",response.status_code)
                             
                             
 
@@ -853,7 +859,7 @@ async def FetchVelocityPost(request:Request):
                             updateInvoice(owner=wallet,endpoint_linker=x402id,data=invoicePayload)
                             #proxying here
                             response=await X402Proxy_POST(request,found_endpoint)
-                            UpdateMarketData(found_endpoint,x402id,response.status_code)
+                            UpdateMarketData(found_endpoint,resource,x402id,response.status_code)