Retropex/datum_gateway
1
0
Fork 0
forked from Ocean/datum_gateway
Code Pull Requests Activity

api: Abstract datum_api_submit_uncached_response

Browse Source
This commit is contained in:
Luke Dashjr 2025-03-11 20:24:36 +00:00
parent 9379725ea2
commit ad96281588
No known key found for this signature in database
GPG Key ID: A291A2C45D0C504A
1 changed files with 19 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
src/datum_api.c
View File

@ -390,14 +390,18 @@ bool datum_api_formdata_to_json(struct MHD_Connection * const connection, char *
return true; return true;
} }
int datum_api_do_error(struct MHD_Connection * const connection, const unsigned int status_code) { int datum_api_submit_uncached_response(struct MHD_Connection * const connection, const unsigned int status_code, struct MHD_Response * const response) {
struct MHD_Response *response = MHD_create_response_from_buffer(0, "", MHD_RESPMEM_PERSISTENT);
http_resp_prevent_caching(response); http_resp_prevent_caching(response);
int ret = MHD_queue_response(connection, status_code, response); int ret = MHD_queue_response(connection, status_code, response);
MHD_destroy_response(response); MHD_destroy_response(response);
return ret; return ret;
} }
int datum_api_do_error(struct MHD_Connection * const connection, const unsigned int status_code) {
struct MHD_Response *response = MHD_create_response_from_buffer(0, "", MHD_RESPMEM_PERSISTENT);
return datum_api_submit_uncached_response(connection, status_code, response);
}
bool datum_api_check_admin_password_only(struct MHD_Connection * const connection, const char * const password) { bool datum_api_check_admin_password_only(struct MHD_Connection * const connection, const char * const password) {
if (datum_secure_strequals(datum_config.api_admin_password, datum_config.api_admin_password_len, password) && datum_config.api_admin_password_len) { if (datum_secure_strequals(datum_config.api_admin_password, datum_config.api_admin_password_len, password) && datum_config.api_admin_password_len) {
return true; return true;
@ -518,7 +522,7 @@ void datum_api_cmd_kill_client2(const char * const data, const size_t size, cons
int datum_api_cmd(struct MHD_Connection *connection, char *post, int len) { int datum_api_cmd(struct MHD_Connection *connection, char *post, int len) {
struct MHD_Response *response; struct MHD_Response *response;
char output[1024]; char output[1024];
int ret, sz=0; int sz = 0;
json_t *root, *cmd, *param; json_t *root, *cmd, *param;
json_error_t error; json_error_t error;
const char *cstr; const char *cstr;
@ -603,27 +607,21 @@ int datum_api_cmd(struct MHD_Connection *connection, char *post, int len) {
} }
response = MHD_create_response_from_buffer(0, "", MHD_RESPMEM_PERSISTENT); response = MHD_create_response_from_buffer(0, "", MHD_RESPMEM_PERSISTENT);
http_resp_prevent_caching(response);
MHD_add_response_header(response, "Location", redirect); MHD_add_response_header(response, "Location", redirect);
ret = MHD_queue_response(connection, MHD_HTTP_FOUND, response); return datum_api_submit_uncached_response(connection, MHD_HTTP_FOUND, response);
MHD_destroy_response(response);
return ret;
} }
} }
sprintf(output, "{}"); sprintf(output, "{}");
response = MHD_create_response_from_buffer (sz, (void *) output, MHD_RESPMEM_MUST_COPY); response = MHD_create_response_from_buffer (sz, (void *) output, MHD_RESPMEM_MUST_COPY);
MHD_add_response_header(response, "Content-Type", "application/json"); MHD_add_response_header(response, "Content-Type", "application/json");
http_resp_prevent_caching(response); return datum_api_submit_uncached_response(connection, MHD_HTTP_OK, response);
ret = MHD_queue_response (connection, MHD_HTTP_OK, response);
MHD_destroy_response (response);
return ret;
} }
int datum_api_coinbaser(struct MHD_Connection *connection) { int datum_api_coinbaser(struct MHD_Connection *connection) {
struct MHD_Response *response; struct MHD_Response *response;
T_DATUM_STRATUM_JOB *sjob; T_DATUM_STRATUM_JOB *sjob;
int j,i,max_sz = 0,sz=0,ret; int j, i, max_sz = 0, sz = 0;
char tempaddr[256]; char tempaddr[256];
uint64_t tv = 0; uint64_t tv = 0;
char *output = NULL; char *output = NULL;
@ -660,15 +658,12 @@ int datum_api_coinbaser(struct MHD_Connection *connection) {
response = MHD_create_response_from_buffer (sz, (void *) output, MHD_RESPMEM_MUST_FREE); response = MHD_create_response_from_buffer (sz, (void *) output, MHD_RESPMEM_MUST_FREE);
MHD_add_response_header(response, "Content-Type", "text/html"); MHD_add_response_header(response, "Content-Type", "text/html");
http_resp_prevent_caching(response); return datum_api_submit_uncached_response(connection, MHD_HTTP_OK, response);
ret = MHD_queue_response (connection, MHD_HTTP_OK, response);
MHD_destroy_response (response);
return ret;
} }
int datum_api_thread_dashboard(struct MHD_Connection *connection) { int datum_api_thread_dashboard(struct MHD_Connection *connection) {
struct MHD_Response *response; struct MHD_Response *response;
int sz=0, ret, max_sz = 0, j, ii; int sz=0, max_sz = 0, j, ii;
char *output = NULL; char *output = NULL;
T_DATUM_MINER_DATA *m = NULL; T_DATUM_MINER_DATA *m = NULL;
uint64_t tsms; uint64_t tsms;
@ -729,16 +724,13 @@ int datum_api_thread_dashboard(struct MHD_Connection *connection) {
response = MHD_create_response_from_buffer (sz, (void *) output, MHD_RESPMEM_MUST_FREE); response = MHD_create_response_from_buffer (sz, (void *) output, MHD_RESPMEM_MUST_FREE);
MHD_add_response_header(response, "Content-Type", "text/html"); MHD_add_response_header(response, "Content-Type", "text/html");
http_resp_prevent_caching(response); return datum_api_submit_uncached_response(connection, MHD_HTTP_OK, response);
ret = MHD_queue_response (connection, MHD_HTTP_OK, response);
MHD_destroy_response (response);
return ret;
} }
int datum_api_client_dashboard(struct MHD_Connection *connection) { int datum_api_client_dashboard(struct MHD_Connection *connection) {
struct MHD_Response *response; struct MHD_Response *response;
int connected_clients = 0; int connected_clients = 0;
int i,sz=0,ret,max_sz = 0,j,ii; int i, sz = 0, max_sz = 0, j, ii;
char *output = NULL; char *output = NULL;
T_DATUM_MINER_DATA *m = NULL; T_DATUM_MINER_DATA *m = NULL;
uint64_t tsms; uint64_t tsms;
@ -766,10 +758,7 @@ int datum_api_client_dashboard(struct MHD_Connection *connection) {
response = MHD_create_response_from_buffer(sz, output, MHD_RESPMEM_MUST_FREE); response = MHD_create_response_from_buffer(sz, output, MHD_RESPMEM_MUST_FREE);
MHD_add_response_header(response, "Content-Type", "text/html"); MHD_add_response_header(response, "Content-Type", "text/html");
http_resp_prevent_caching(response); return datum_api_submit_uncached_response(connection, MHD_HTTP_OK, response);
ret = MHD_queue_response(connection, MHD_HTTP_OK, response);
MHD_destroy_response(response);
return ret;
} }
if (!datum_api_check_admin_password_httponly(connection)) { if (!datum_api_check_admin_password_httponly(connection)) {
return MHD_YES; return MHD_YES;
@ -845,16 +834,13 @@ int datum_api_client_dashboard(struct MHD_Connection *connection) {
// return the home page with some data and such // return the home page with some data and such
response = MHD_create_response_from_buffer (sz, (void *) output, MHD_RESPMEM_MUST_FREE); response = MHD_create_response_from_buffer (sz, (void *) output, MHD_RESPMEM_MUST_FREE);
MHD_add_response_header(response, "Content-Type", "text/html"); MHD_add_response_header(response, "Content-Type", "text/html");
http_resp_prevent_caching(response); return datum_api_submit_uncached_response(connection, MHD_HTTP_OK, response);
ret = MHD_queue_response (connection, MHD_HTTP_OK, response);
MHD_destroy_response (response);
return ret;
} }
int datum_api_homepage(struct MHD_Connection *connection) { int datum_api_homepage(struct MHD_Connection *connection) {
struct MHD_Response *response; struct MHD_Response *response;
char output[DATUM_API_HOMEPAGE_MAX_SIZE]; char output[DATUM_API_HOMEPAGE_MAX_SIZE];
int j, k = 0, kk = 0, ii, ret; int j, k = 0, kk = 0, ii;
T_DATUM_MINER_DATA *m; T_DATUM_MINER_DATA *m;
T_DATUM_API_DASH_VARS vardata; T_DATUM_API_DASH_VARS vardata;
unsigned char astat; unsigned char astat;
@ -910,22 +896,15 @@ int datum_api_homepage(struct MHD_Connection *connection) {
// return the home page with some data and such // return the home page with some data and such
response = MHD_create_response_from_buffer (strlen(output), (void *) output, MHD_RESPMEM_MUST_COPY); response = MHD_create_response_from_buffer (strlen(output), (void *) output, MHD_RESPMEM_MUST_COPY);
MHD_add_response_header(response, "Content-Type", "text/html"); MHD_add_response_header(response, "Content-Type", "text/html");
http_resp_prevent_caching(response); return datum_api_submit_uncached_response(connection, MHD_HTTP_OK, response);
ret = MHD_queue_response (connection, MHD_HTTP_OK, response);
MHD_destroy_response (response);
return ret;
} }
int datum_api_OK(struct MHD_Connection *connection) { int datum_api_OK(struct MHD_Connection *connection) {
enum MHD_Result ret;
struct MHD_Response *response; struct MHD_Response *response;
const char *ok_response = "OK"; const char *ok_response = "OK";
response = MHD_create_response_from_buffer(strlen(ok_response), (void *)ok_response, MHD_RESPMEM_PERSISTENT); response = MHD_create_response_from_buffer(strlen(ok_response), (void *)ok_response, MHD_RESPMEM_PERSISTENT);
MHD_add_response_header(response, "Content-Type", "text/html"); MHD_add_response_header(response, "Content-Type", "text/html");
http_resp_prevent_caching(response); return datum_api_submit_uncached_response(connection, MHD_HTTP_OK, response);
ret = MHD_queue_response (connection, MHD_HTTP_OK, response);
MHD_destroy_response (response);
return ret;
} }
int datum_api_testnet_fastforward(struct MHD_Connection * const connection) { int datum_api_testnet_fastforward(struct MHD_Connection * const connection) {