viktor/wrongmove
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

add healtcheck api endpoint

Browse source
This commit is contained in:
Viktor Barzin 2025-07-26 13:06:28 +00:00
parent 206471cee8
commit 4e7734d327
No known key found for this signature in database
GPG key ID: 4056458DBDBF8863
1 changed files with 8 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

9
crawler/api/app.py
View file

@ -58,6 +58,11 @@ app.add_middleware(
) )
@app.get("/api/status")
async def get_status():
return {"status": "OK"}
@app.get("/api/listing") @app.get("/api/listing")
async def get_listing(user: Annotated[User, Depends(get_current_user)]): async def get_listing(user: Annotated[User, Depends(get_current_user)]):
repository = ListingRepository(engine) repository = ListingRepository(engine)
@ -83,7 +88,9 @@ async def refresh_listings(
user: Annotated[User, Depends(get_current_user)], user: Annotated[User, Depends(get_current_user)],
query_parameters: Annotated[QueryParameters, Query()], query_parameters: Annotated[QueryParameters, Query()],
) -> dict[str, str]: ) -> dict[str, str]:
await send_notification(f"{user.email} refreshing listings with query parameters {query_parameters.model_dump_json()}") await send_notification(
f"{user.email} refreshing listings with query parameters {query_parameters.model_dump_json()}"
)
# TODO: rate limit # TODO: rate limit
expiry_time = datetime.now() + timedelta(minutes=10) expiry_time = datetime.now() + timedelta(minutes=10)
task = listing_tasks.dump_listings_task.apply_async( task = listing_tasks.dump_listings_task.apply_async(