Update components/middleware.py

components/middleware.py

@@ -23,7 +23,15 @@ import time
 
 from geopy.geocoders import Nominatim
 from geopy.exc import GeocoderServiceError
+from .mongodbconnection import provideClient
+
+
+
+
 geolocator = Nominatim(user_agent="velocity")
+dbclient=provideClient()
+db=dbclient["sdklogs_db"]
+col=dbclient["sdklogs_col"]
 
 
 
@@ -332,10 +340,22 @@ class x401Kit(BaseHTTPMiddleware):
 
             signverify=SignatureVerification(X_401_Addr,X_401_Nonce,X_401_Sign,challange)
             tokenverify=TokenCheck(X_401_Addr,required_mint,mint_amount)
+            
             print(tokenverify)
 
 
-            
+            sdkpayload={
+                
+                "signer":X_401_Addr,
+                 "challange":challange,
+                "token_amount":mint_amount,
+                "required_mint":required_mint,
+                "sign_verification":signverify,
+                "token_verification":tokenverify,
+                "geo_code":geo_code,
+                "restricted_loc":geo_code_locs
+                
+            }
 
             if signverify == True and tokenverify == True:
 
@@ -344,6 +364,7 @@ class x401Kit(BaseHTTPMiddleware):
                             
                             country=GEOCODER(coords)
                             print(country)
+                            sdkpayload["geography"]=country
                             
                             if country["data"] is None:
                                  return JSONResponse(
@@ -367,7 +388,14 @@ class x401Kit(BaseHTTPMiddleware):
                                             },
                                             status_code=401
                                             )
-                            
+
+                        coll.find_one_and_update(
+                            {"owner":"system"},
+                            {
+                                "$push":{
+                                    "logs":sdkpayload
+                                }
+                            })    
                     
                         response = await call_next(request)