add token + fix entities

Author: RICHARD-Quentin

populate/.gitignore

@@ -0,0 +1,4 @@
+.dev-token.json
+.env
+!.env.example
+```

populate/populate_data.py

@@ -12,8 +12,7 @@
 # Load environment variables from .env file
 load_dotenv()
 
-# Get the MongoDB URL from the environment variables
-mongo_url = os.getenv("MONGODB_URL")
+token_path = os.path.join(os.path.dirname(__file__), '.dev-token.json')
 collections = [
     {
         "name": "identities",
@@ -72,37 +71,30 @@
     },
 ]
 
-# async def populate_collection(collection_name, db):
-#     print(f"Populating {collection_name}...")
-#     file_path = os.path.join(os.path.dirname(__file__), 'seeds', f"{collection_name}.json")
-#     with open(file_path) as f:
-#         data = json.load(f)
-#         for d in data:
-#             d["_id"] = ObjectId(d["_id"])
-#         try:
-#             result = await db[collection_name].insert_many(data)
-#             logger.info(f"{len(result.inserted_ids)} {collection_name} inserted")
-#         except Exception as e:
-#             logger.warning(f"Duplicate key error: {e}")
-#             logger.warning(f"Skipping {collection_name}...")
-
 api_endpoint = os.getenv("API_BASE_URL")
 
-async def populate_collection(collection):
+async def populate_collection(collection, token):
     logger.info(f"Populating {collection.get('name')}...")
     file_path = os.path.join(os.path.dirname(__file__), 'seeds', collection.get('file'))
+    headers = {
+        "Authorization": f"Bearer {token}", "Content-Type": "application/json; charset=utf-8"
+    }
     with open(file_path) as f:
         datas = json.load(f)
         for data in datas:
             try:
-                response = requests.post(f"{api_endpoint}/{collection.get('endpoint')}", json=data)
+
+                response = requests.post(f"{api_endpoint}/{collection.get('endpoint')}", headers=headers, json=data )
                 response.raise_for_status()
                 logger.info(f"{collection.get('name')} inserted")
             except Exception as e:
-                logger.warning(f"Failed to insert {collection.get('name')}: {e}")
+                error_message = response.json().get('message')
+                logger.warning(f"Failed to insert {collection.get('name')}: {error_message}")
 
 async def main():
-    collection_tasks = [populate_collection(col) for col in collections]
+    with open(token_path) as f:
+        token = json.load(f).get("access_token")
+    collection_tasks = [populate_collection(col, token) for col in collections]
     await asyncio.gather(*collection_tasks)
 
     print("DB populated")

populate/seeds/entities.json

@@ -13,13 +13,13 @@
                 {
                     "id": "5f84f96c8f3ac2082347f251",
                     "type": 3,
-                    "phoneNumber": "0329292929",
+                    "phoneNumber": "+33329292929",
                     "description": "Work Phone"
                 },
                 {
                     "id": "5f84f96c8f3ac2082347f252",
                     "type": 4,
-                    "phoneNumber": "0329292928",
+                    "phoneNumber": "+33329292928",
                     "description": "Personal Phone"
                 }
             ]