Update app.py

app.py

@@ -88,6 +88,7 @@ class RegisterPayload(BaseModel):
         owner:str
         description:str
         meta:str
+        price:str
 
 
 
@@ -98,6 +99,9 @@ class RegisterPayloadDynamic(BaseModel):
         description:str
         tag:str
         meta:str
+        price:str
+
+
 
 
 
@@ -125,6 +129,23 @@ class Invoice(BaseModel):
 
 
 
+LAMPORTS_PER_SOL = 1_000_000_000
+
+def to_lamports(sol: str | float | int) -> int:
+    """
+    Convert a human-readable SOL amount (e.g. "2", 0.05) to lamports (int).
+    Example: "2.5" -> 2500000000
+    """
+    try:
+        sol_value = float(sol)
+        if sol_value < 0:
+            raise ValueError("Amount cannot be negative")
+        return int(sol_value * LAMPORTS_PER_SOL)
+    except (ValueError, TypeError):
+        raise ValueError(f"Invalid SOL amount: {sol}")
+
+
+
 
 
 
@@ -166,7 +187,6 @@ def UpdateMarketData(endpoint_method,status_code):
 
 
 
-
 #GET requests proxy
 async def X402Proxy_GET(request: Request, endpoint: str):
     async with httpx.AsyncClient() as client:
@@ -296,9 +316,12 @@ def RegisterEndpoint(data:RegisterPayload):
                 "endpoint":data.endpoint,
                 "meta":data.meta,
                 "endpoint_linker":short_id_e,
+                 "price":data.price,
                 "invoices":[]
             }
 
+            
+
             coll.update_one(
                     {"owner": data.owner},
                     {"$push": {"endpoints": payload}}
@@ -307,12 +330,12 @@ def RegisterEndpoint(data:RegisterPayload):
 
             marketpayload={
                 
-                "owner":data.owner,
-                "endpoint_linker":short_id_e,
-                "meta":data.meta,
-                "description":data.description,
+                 "owner":data.owner,
+                 "endpoint_linker":short_id_e,
+                 "meta":data.meta,
+                 "description":data.description,
                  "endpoint_method":"",
-                 "endpoint_mcp_base:"https://mcpv100-production.up.railway.app/mcp:8080",
+                 "endpoint_mcp_base":"https://mcpv100-production.up.railway.app/mcp:8080",
                  "calls":0,
                 "failures":0
                 
@@ -347,6 +370,7 @@ def RegisterDynamicEndpoint(data:RegisterPayloadDynamic):
                 "description":data.description,
                 "meta":data.meta,
                 "endpoint_linker":f"{data.tag}",
+                "price":data.price,
                 "invoices":[]
                 }
             
@@ -363,14 +387,14 @@ def RegisterDynamicEndpoint(data:RegisterPayloadDynamic):
 
             marketpayload={
                 
-                "owner":data.owner,
-                "endpoint_linker":short_id_e,
-                "meta":data.meta,
-                "description":data.description,
+                 "owner":data.owner,
+                 "endpoint_linker":short_id_e,
+                 "meta":data.meta,
+                 "description":data.description,
                  "endpoint_method":"",
-                 "endpoint_mcp_base:"https://mcpv100-production.up.railway.app/mcp:8080",
+                 "endpoint_mcp_base":"https://mcpv100-production.up.railway.app/mcp:8080",
                  "calls":0,
-                "failures":0
+                 "failures":0
                 
                 
             }
@@ -519,9 +543,14 @@ async def FetchVelocityGET(x402id:str,request:Request):
         
 
         wallet=request.headers.get("x-wallet")
+        price=request.headers.get("x-price")
+    
         print(wallet)
         document=coll.find_one({"owner":wallet})
 
+
+        
+
         found_endpoint=None
     
         if "x402" in x402id:
@@ -769,6 +798,7 @@ async def FetchVelocityPost(request:Request):
     
         wallet=request.headers.get("x-wallet")
         x402id=request.headers.get("x402id")
+        price=request.headers.get("x-price")
     
         print(wallet)
         document=coll.find_one({"owner":wallet})