Revert "Adding APIs to UpsertGraphTemplate (#132)"

This reverts commit c1a74ed.

Author: NiveditJain

state-manager/app/controller/upsert_graph_template.py

@@ -20,7 +20,6 @@
 # injecting models
 from .models.db.state import State
 from .models.db.namespace import Namespace
-from .models.db.graph_template_model import GraphTemplate
 
 # injecting routes
 from .routes import router
@@ -36,7 +35,7 @@ async def lifespan(app: FastAPI):
     # initializing beanie
     client = AsyncMongoClient(os.getenv("MONGO_URI"))
     db = client[os.getenv("MONGO_DATABASE_NAME", "exosphere-state-manager")]
-    await init_beanie(db, document_models=[State, Namespace, GraphTemplate])
+    await init_beanie(db, document_models=[State, Namespace])
     logger.info("beanie dbs initialized")
 
     # initialize secret

state-manager/app/main.py

@@ -18,18 +18,15 @@
 from .models.errored_models import ErroredRequestModel, ErroredResponseModel
 from .controller.errored_state import errored_state
 
-from .models.graph_models import UpsertGraphTemplateRequest, UpsertGraphTemplateResponse
-from .controller.upsert_graph_template import upsert_graph_template as upsert_graph_template_controller
-
 
 
 logger = LogsManager().get_logger()
 
-router = APIRouter(prefix="/v0/namespace/{namespace_name}", tags=["state"])
+router = APIRouter(prefix="/v0/namespace/{namespace_name}/states", tags=["state"])
 
 
 @router.post(
-    "/states/enqueue",
+    "/enqueue",
     response_model=EnqueueResponseModel,
     status_code=status.HTTP_200_OK,
     response_description="State enqueued on node queue successfully"
@@ -48,7 +45,7 @@ async def enqueue_state(namespace_name: str, body: EnqueueRequestModel, request:
 
 
 @router.post(
-    "/states/create",
+    "/create",
     response_model=CreateResponseModel,
     status_code=status.HTTP_200_OK,
     response_description="States created successfully"
@@ -67,7 +64,7 @@ async def create_state(namespace_name: str, body: CreateRequestModel, request: R
 
 
 @router.post(
-    "/states/{state_id}/executed",
+    "/{state_id}/executed",
     response_model=ExecutedResponseModel,
     status_code=status.HTTP_200_OK,
     response_description="State executed successfully"
@@ -86,7 +83,7 @@ async def executed_state_route(namespace_name: str, state_id: str, body: Execute
 
 
 @router.post(
-    "/states/{state_id}/errored",
+    "/{state_id}/errored",
     response_model=ErroredResponseModel,
     status_code=status.HTTP_200_OK,
     response_description="State errored successfully"
@@ -101,22 +98,4 @@ async def errored_state_route(namespace_name: str, state_id: str, body: ErroredR
         logger.error(f"API key is invalid for namespace {namespace_name}", x_exosphere_request_id=x_exosphere_request_id)
         raise HTTPException(status_code=status.HTTP_401_UNAUTHORIZED, detail="Invalid API key")
 
-    return await errored_state(namespace_name, ObjectId(state_id), body, x_exosphere_request_id)
-
-
-@router.put(
-    "/graph-templates/{graph_name}",
-    response_model=UpsertGraphTemplateResponse,
-    status_code=status.HTTP_200_OK,
-    response_description="Graph template upserted successfully"
-)   
-async def upsert_graph_template(namespace_name: str, graph_name: str, body: UpsertGraphTemplateRequest, request: Request, api_key: str = Depends(check_api_key)):
-    x_exosphere_request_id = getattr(request.state, "x_exosphere_request_id", str(uuid4()))
-
-    if api_key:
-        logger.info(f"API key is valid for namespace {namespace_name}", x_exosphere_request_id=x_exosphere_request_id)
-    else:
-        logger.error(f"API key is invalid for namespace {namespace_name}", x_exosphere_request_id=x_exosphere_request_id)
-        raise HTTPException(status_code=status.HTTP_401_UNAUTHORIZED, detail="Invalid API key")
-
-    return await upsert_graph_template_controller(namespace_name, graph_name, body, x_exosphere_request_id)
+    return await errored_state(namespace_name, ObjectId(state_id), body, x_exosphere_request_id)