removed check for server id
This commit is contained in:
@@ -36,12 +36,9 @@ async def ingest_event(payload: Event | BatchEvents, game: str = Depends(verify_
|
|||||||
def check_event(e: Event):
|
def check_event(e: Event):
|
||||||
if not e.type or not e.type.strip():
|
if not e.type or not e.type.strip():
|
||||||
raise HTTPException(400, "Event type is required")
|
raise HTTPException(400, "Event type is required")
|
||||||
if not e.serverId:
|
|
||||||
raise HTTPException(400, "serverId is required")
|
|
||||||
if e.time <= 0:
|
if e.time <= 0:
|
||||||
raise HTTPException(400, "Invalid timestamp")
|
raise HTTPException(400, "Invalid timestamp")
|
||||||
# Optionally refuse huge data (e.g., >1KB per event)
|
|
||||||
|
|
||||||
if isinstance(payload, BatchEvents):
|
if isinstance(payload, BatchEvents):
|
||||||
for event in payload.events:
|
for event in payload.events:
|
||||||
write_event(event, game)
|
write_event(event, game)
|
||||||
|
|||||||
Reference in New Issue
Block a user