Deployed!

Author: peterrauscher

config_lambdas.py

@@ -0,0 +1,36 @@
+import json
+import subprocess
+
+
+def get_lambdas():
+    functions = {}
+    res = subprocess.Popen(
+        ["aws", "lambda", "list-functions"],
+        stdout=subprocess.PIPE,
+    )
+    output = res.communicate()[0]
+    functions.update(json.loads(output))
+    return functions["Functions"]
+
+
+# for lambda_function in get_lambdas():
+#     function_name = lambda_function["FunctionName"]
+
+with open(".env", "r") as f:
+    env_vars = [
+        line for line in f.read().splitlines() if line.startswith("SOLESEARCH_")
+    ]
+    env = ",".join(env_vars)
+    subprocess.run(
+        [
+            "aws",
+            "lambda",
+            "update-function-configuration",
+            "--region",
+            "us-east-1",
+            "--function-name",
+            "solesearch-api",
+            "--environment",
+            f"Variables={{{env}}}",
+        ]
+    )

pyproject.toml

@@ -18,7 +18,7 @@ dependencies = [
   "pydantic",
   "mangum",
   "Authlib",
-  "httpx",
+  "requests",
   "Starlette",
   "itsdangerous",
   "core @ git+ssh://git@github.com/SoleSearch-Demos/core.git@main",
@@ -31,11 +31,11 @@ path = "src/api/__about__.py"
 allow-direct-references = true
 
 [tool.hatch.envs.default.scripts]
-start = "python -m api.server"
+start = "python -m src.api.main"
 
 [tool.hatch.envs.dev]
 pre-install-commands = ["pip install -e ../core"]
-scripts.start = "uvicorn src.api.main:app --reload"
+scripts.start = "python -m src.api.main"
 
 [tool.hatch.build.targets.wheel]
 packages = ["src/api"]

src/api/__init__.py

@@ -1,12 +1,11 @@
-import motor.motor_asyncio
-from dotenv import dotenv_values
+import os
 
-config = dotenv_values(dotenv_path=".env")
+import motor.motor_asyncio
 
 client = motor.motor_asyncio.AsyncIOMotorClient(
-    config["SOLESEARCH_DB_CONNECTION_STRING"]
+    os.environ.get("SOLESEARCH_DB_CONNECTION_STRING")
 )
-db = client[config["SOLESEARCH_DB_NAME"]]
-sneakers = db[config["SOLESEARCH_DB_PRIMARY_COLLECTION"]]
-DEFAULT_LIMIT = int(config["SOLESEARCH_DEFAULT_LIMIT"])
-DEFAULT_OFFSET = int(config["SOLESEARCH_DEFAULT_OFFSET"])
+db = client[os.environ.get("SOLESEARCH_DB_NAME")]
+sneakers = db[os.environ.get("SOLESEARCH_DB_PRIMARY_COLLECTION")]
+DEFAULT_LIMIT = int(os.environ.get("SOLESEARCH_DEFAULT_LIMIT", 10))
+DEFAULT_OFFSET = int(os.environ.get("SOLESEARCH_DEFAULT_OFFSET", 0))

src/api/data/instance.py

@@ -1,9 +1,4 @@
 from enum import Enum
-from typing import List
-
-from core.models.details import Audience, Images, Links, Prices
-from core.models.shoes import Sneaker
-from pydantic import BaseModel, ValidationError
 
 
 class SortKey(str, Enum):

src/api/data/models.py

@@ -2,10 +2,10 @@
 from datetime import UTC, datetime
 
 from bson import ObjectId
-from bson.json_util import dumps
 
 from api.data.instance import DEFAULT_LIMIT, DEFAULT_OFFSET, db, sneakers
-from api.data.models import Audience, SortKey, SortOrder
+from api.data.models import SortKey, SortOrder
+from core.models.details import Audience
 
 
 def find_sneaker_by_id(id: str = ""):

src/api/data/queries.py

@@ -1,7 +1,13 @@
+import os
+
+from dotenv import load_dotenv
 from fastapi import FastAPI
 from mangum import Mangum
 from starlette.middleware.sessions import SessionMiddleware
 
+if not os.environ.get("AWS_EXECUTION_ENV"):
+    load_dotenv(os.path.join(os.getcwd(), ".env"))
+
 from api.routes import auth, sneakers
 
 app = FastAPI(
@@ -14,3 +20,8 @@
 app.include_router(sneakers.router)
 app.include_router(auth.router)
 handler = Mangum(app)
+
+if __name__ == "__main__":
+    import uvicorn
+
+    uvicorn.run(app, host="localhost", port=8000)

src/api/main.py

@@ -3,8 +3,9 @@
 from fastapi import APIRouter, Query
 
 from api.data.instance import DEFAULT_LIMIT, DEFAULT_OFFSET
-from api.data.models import Audience, SortKey, SortOrder
+from api.data.models import SortKey, SortOrder
 from api.data.queries import find_sneaker_by_id, find_sneaker_by_sku, find_sneakers
+from core.models.details import Audience
 
 router = APIRouter(
     prefix="/sneakers",