Function append_entry

src/orgkernel/pyapi/router.py:693–723

Append an entry to an AuditChain. The chain must not be closed. Call /audit/{chain_id}/close when done.

(
    chain_id: str,
    request: AuditChainAppendRequest,
    db: Annotated[AsyncSession, Depends(get_db)],
)

    description="Append a new entry to an AuditChain.",
)
async def append_entry(
    chain_id: str,
    request: AuditChainAppendRequest,
    db: Annotated[AsyncSession, Depends(get_db)],
) -> dict:
    """
    Append an entry to an AuditChain.

    The chain must not be closed. Call /audit/{chain_id}/close when done.
    """
    svc = AuditChainService()
    try:
        entry = await svc.append(
            db,
            chain_id=chain_id,
            layer=request.layer,
            event=request.event,
            agent_id=request.agent_id,
            mission_id=request.mission_id,
            data=request.data,
            token_id=request.token_id,
        )
        return {
            "entry_id": entry.entry_id,
            "chain_id": entry.chain_id,
            "sequence": entry.sequence,
            "entry_hash": entry.entry_hash,
            "message": "Entry appended",
        }
    except ValueError as e:
        raise HTTPException(status_code=400, detail=str(e))


@_audit.post(