webadmin/pico-keys-sdk
1
0
Fork 0
mirror of https://github.com/polhenarejos/pico-keys-sdk synced 2026-05-26 08:05:10 +02:00
Code Issues Packages Projects Releases Wiki Activity

Intercept /cancel

Browse Source 
Signed-off-by: Pol Henarejos <pol.henarejos@cttc.es>
This commit is contained in:
Pol Henarejos
2026-04-30 15:55:46 +02:00
parent 3a03000df1
commit ee13b6904a
1 changed files with 28 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
src/usb/lwip/rest_server.c
View File

@@ -731,12 +731,7 @@ void rest_handle_request(rest_conn_t *conn) {
bool path_exists_for_other_method = false;
int parsed;
if (rest_core1_job.pending) {
send_json_error(conn, 503, "busy");
return;
}
memset(&rest_core1_job, 0, sizeof(rest_core1_job));
memset(request, 0, sizeof(*request));
parsed = parse_request(conn, request);
if (parsed <= 0) {
if (parsed < 0) {
@@ -745,6 +740,12 @@ void rest_handle_request(rest_conn_t *conn) {
return;
}
if (rest_core1_job.pending
&& !(request->method == REST_HTTP_POST && strcmp(request->path, "/device/jobs/cancel") == 0)) {
send_json_error(conn, 503, "busy");
return;
}
REST_DEBUG_LOG(
"[rest %s] request: %s %s\n",
(conn->conn_type == REST_CONN_TLS) ? "TLS" : "PLAIN",
@@ -810,6 +811,27 @@ void rest_handle_request(rest_conn_t *conn) {
}
request->session = session;
}
if (request->method == REST_HTTP_POST && strcmp(request->path, "/device/jobs/cancel") == 0) {
rest_response_t response = {0};
if (routes[i].handler(request, &response) != 0) {
send_json_error(conn, 500, "internal_error");
return;
}
uint16_t code = response.status_code == 0 ? 200 : response.status_code;
if (code == 204) {
send_response(conn, code, rest_status_text_from_code(code), "application/json", "", 0, response.headers);
}
else if (response.body != NULL && response.content_type != NULL) {
send_response(conn, code, rest_status_text_from_code(code), response.content_type, response.body, response.body_len, response.headers);
}
else {
send_json_error(conn, 500, "internal_error");
}
if (response.body != NULL) {
free(response.body);
}
return;
}
if (rest_start_core1_job(conn, routes[i].handler) != 0) {
send_json_error(conn, 500, "internal_error");
}