Function handle_clear_draft_chunks

crates/openshell-server/src/grpc/policy.rs:2998–3032

(
    state: &Arc<ServerState>,
    request: Request<ClearDraftChunksRequest>,
)

}

pub(super) async fn handle_clear_draft_chunks(
    state: &Arc<ServerState>,
    request: Request<ClearDraftChunksRequest>,
) -> Result<Response<ClearDraftChunksResponse>, Status> {
    let req = request.into_inner();
    if req.name.is_empty() {
        return Err(Status::invalid_argument("name is required"));
    }

    let sandbox = state
        .store
        .get_message_by_name::<Sandbox>(&req.name)
        .await
        .map_err(|e| Status::internal(format!("fetch sandbox failed: {e}")))?
        .ok_or_else(|| Status::not_found("sandbox not found"))?;
    let sandbox_id = sandbox.object_id().to_string();

    let deleted = state
        .store
        .delete_draft_chunks(&sandbox_id, "pending")
        .await
        .map_err(|e| Status::internal(format!("delete draft chunks failed: {e}")))?;

    state.sandbox_watch_bus.notify(&sandbox_id);

    info!(
        sandbox_id = %sandbox_id,
        chunks_cleared = deleted,
        "ClearDraftChunks: pending chunks cleared"
    );

    Ok(Response::new(ClearDraftChunksResponse {
        chunks_cleared: u32::try_from(deleted).unwrap_or(0),
    }))
}

pub(super) async fn handle_get_draft_history(
    state: &Arc<ServerState>,