chore: filled in project structure

Added some example basic files containing a functioning /message
endpoint which logs the received message to INFO.

ref: N25B-144
This commit is contained in:
2025-10-08 15:02:11 +02:00
parent 9e96d57b6c
commit 1229df70b0
9 changed files with 100 additions and 0 deletions

View File

@@ -0,0 +1,4 @@
from spade.agent import Agent
class TestAgent(Agent):
pass

View File

@@ -0,0 +1,13 @@
from fastapi import APIRouter, Request
import logging
from control_backend.schemas.message import Message
logger = logging.getLogger(__name__)
router = APIRouter()
# TODO: implement
@router.post("/message")
async def receive_message(message: Message, request: Request):
logger.info("Received message: %s", message.message)

View File

@@ -0,0 +1,8 @@
from fastapi import APIRouter, Request
router = APIRouter()
# TODO: implement
@router.get("/sse")
async def sse(request: Request):
pass

View File

@@ -0,0 +1,15 @@
from fastapi.routing import APIRouter
from control_backend.api.v1.endpoints import message, sse
api_router = APIRouter()
api_router.include_router(
message.router,
tags=["Messages"]
)
api_router.include_router(
sse.router,
tags=["SSE"]
)

View File

@@ -0,0 +1,11 @@
from pydantic import HttpUrl
from pydantic_settings import BaseSettings, SettingsConfigDict
class Settings(BaseSettings):
app_title: str = "PepperPlus"
ui_url: HttpUrl = "http://locahost:5173"
model_config = SettingsConfigDict(env_file=".env")
settings = Settings()

View File

@@ -0,0 +1,36 @@
# External imports
import contextlib
from fastapi import FastAPI
from fastapi.middleware.cors import CORSMiddleware
import logging
# Internal imports
from control_backend.api.v1.router import api_router
from control_backend.core.config import settings
logger = logging.getLogger(__name__)
logging.basicConfig(level=logging.INFO)
@contextlib.asynccontextmanager
async def lifespan(app: FastAPI):
logger.info("%s starting up.", app.title)
yield
logger.info("%s shutting down.", app.title)
# if __name__ == "__main__":
app = FastAPI(title=settings.app_title, lifespan=lifespan)
app.include_router(api_router, prefix="") # TODO: make prefix /api/v1
# This middleware allows other origins to communicate with us
app.add_middleware(
CORSMiddleware, # https://developer.mozilla.org/en-US/docs/Web/HTTP/Guides/CORS
allow_origins=[settings.ui_url.unicode_string()], # address of our UI application
allow_methods=["*"], # GET, POST, etc.
)
@app.get("/")
async def root():
return {"status": "ok"}

View File

@@ -0,0 +1,4 @@
from pydantic import BaseModel
class Message(BaseModel):
message: str