X-Git-Url: https://git.artsoft.org/?a=blobdiff_plain;f=src%2Ffiles.c;h=6d99afccd0af57da1162fedb1ebe9c443f0be85a;hb=b937b0928312ad4a51f45c16a0792a09ba914659;hp=a38c4122567e1db7b61b23feaa08cf9032b2b107;hpb=6972be3456882f83dd05da98ce73beef3d7324fb;p=rocksndiamonds.git diff --git a/src/files.c b/src/files.c index a38c4122..6d99afcc 100644 --- a/src/files.c +++ b/src/files.c @@ -9094,11 +9094,12 @@ static void FreeThreadData_ApiGetScore(void *data_raw) checked_free(data); } -static void ApiGetScoreExt(struct HttpRequest *request, - struct HttpResponse *response, - int level_nr, - char *score_cache_filename) +static boolean SetRequest_ApiGetScore(struct HttpRequest *request, + void *data_raw) { + struct ApiGetScoreThreadData *data = data_raw; + int level_nr = data->level_nr; + request->hostname = setup.api_server_hostname; request->port = API_SERVER_PORT; request->method = API_SERVER_METHOD; @@ -9115,25 +9116,18 @@ static void ApiGetScoreExt(struct HttpRequest *request, getPasswordJSON(setup.api_server_password), getProgramRealVersionString(), getProgramPlatformString(), - levelset.identifier, level_nr); + levelset.identifier, + level_nr); ConvertHttpRequestBodyToServerEncoding(request); - if (!DoHttpRequest(request, response)) - { - Error("HTTP request failed: %s", GetHttpError()); - - return; - } - - if (!HTTP_SUCCESS(response->status_code)) - { - Error("server failed to handle request: %d %s", - response->status_code, - response->status_text); + return TRUE; +} - return; - } +static void HandleResponse_ApiGetScore(struct HttpResponse *response, + void *data_raw) +{ + struct ApiGetScoreThreadData *data = data_raw; if (response->body_size == 0) { @@ -9144,7 +9138,7 @@ static void ApiGetScoreExt(struct HttpRequest *request, ConvertHttpResponseBodyToClientEncoding(response); - char *filename = score_cache_filename; + char *filename = data->score_cache_filename; FILE *file; int i; @@ -9168,26 +9162,50 @@ static void ApiGetScoreExt(struct HttpRequest *request, server_scores.updated = TRUE; } -static void ApiGetScore(int level_nr, char *score_cache_filename) +static void ApiGetScore_HttpRequestExt(struct HttpRequest *request, + struct HttpResponse *response, + void *data_raw) { - struct HttpRequest *request = checked_calloc(sizeof(struct HttpRequest)); - struct HttpResponse *response = checked_calloc(sizeof(struct HttpResponse)); + if (!SetRequest_ApiGetScore(request, data_raw)) + return; - ApiGetScoreExt(request, response, - level_nr, score_cache_filename); + if (!DoHttpRequest(request, response)) + { + Error("HTTP request failed: %s", GetHttpError()); - checked_free(request); - checked_free(response); + return; + } + + if (!HTTP_SUCCESS(response->status_code)) + { + Error("server failed to handle request: %d %s", + response->status_code, + response->status_text); + + return; + } + + HandleResponse_ApiGetScore(response, data_raw); +} + +static void ApiGetScore_HttpRequest(struct HttpRequest *request, + struct HttpResponse *response, + void *data_raw) +{ + ApiGetScore_HttpRequestExt(request, response, data_raw); + + FreeThreadData_ApiGetScore(data_raw); } static int ApiGetScoreThread(void *data_raw) { - struct ApiGetScoreThreadData *data = data_raw; + struct HttpRequest *request = checked_calloc(sizeof(struct HttpRequest)); + struct HttpResponse *response = checked_calloc(sizeof(struct HttpResponse)); - ApiGetScore(data->level_nr, - data->score_cache_filename); + ApiGetScore_HttpRequest(request, response, data_raw); - FreeThreadData_ApiGetScore(data_raw); + checked_free(request); + checked_free(response); return 0; } @@ -9372,12 +9390,14 @@ static void FreeThreadData_ApiAddScore(void *data_raw) checked_free(data); } -static void ApiAddScoreExt(struct HttpRequest *request, - struct HttpResponse *response, - int level_nr, - char *score_tape_filename, - struct ScoreEntry *score_entry) +static boolean SetRequest_ApiAddScore(struct HttpRequest *request, + void *data_raw) { + struct ApiAddScoreThreadData *data = data_raw; + struct ScoreEntry *score_entry = &data->score_entry; + char *score_tape_filename = data->score_tape_filename; + int level_nr = data->level_nr; + request->hostname = setup.api_server_hostname; request->port = API_SERVER_PORT; request->method = API_SERVER_METHOD; @@ -9389,7 +9409,7 @@ static void ApiAddScoreExt(struct HttpRequest *request, { Error("loading and base64 encoding score tape file failed"); - return; + return FALSE; } char *player_name_raw = score_entry->name; @@ -9463,6 +9483,22 @@ static void ApiAddScoreExt(struct HttpRequest *request, ConvertHttpRequestBodyToServerEncoding(request); + return TRUE; +} + +static void HandleResponse_ApiAddScore(struct HttpResponse *response, + void *data_raw) +{ + server_scores.uploaded = TRUE; +} + +static void ApiAddScore_HttpRequestExt(struct HttpRequest *request, + struct HttpResponse *response, + void *data_raw) +{ + if (!SetRequest_ApiAddScore(request, data_raw)) + return; + if (!DoHttpRequest(request, response)) { Error("HTTP request failed: %s", GetHttpError()); @@ -9479,31 +9515,27 @@ static void ApiAddScoreExt(struct HttpRequest *request, return; } - server_scores.uploaded = TRUE; + HandleResponse_ApiAddScore(response, data_raw); } -static void ApiAddScore(int level_nr, char *score_tape_filename, - struct ScoreEntry *score_entry) +static void ApiAddScore_HttpRequest(struct HttpRequest *request, + struct HttpResponse *response, + void *data_raw) { - struct HttpRequest *request = checked_calloc(sizeof(struct HttpRequest)); - struct HttpResponse *response = checked_calloc(sizeof(struct HttpResponse)); - - ApiAddScoreExt(request, response, - level_nr, score_tape_filename, score_entry); + ApiAddScore_HttpRequestExt(request, response, data_raw); - checked_free(request); - checked_free(response); + FreeThreadData_ApiAddScore(data_raw); } static int ApiAddScoreThread(void *data_raw) { - struct ApiAddScoreThreadData *data = data_raw; + struct HttpRequest *request = checked_calloc(sizeof(struct HttpRequest)); + struct HttpResponse *response = checked_calloc(sizeof(struct HttpResponse)); - ApiAddScore(data->level_nr, - data->score_tape_filename, - &data->score_entry); + ApiAddScore_HttpRequest(request, response, data_raw); - FreeThreadData_ApiAddScore(data_raw); + checked_free(request); + checked_free(response); return 0; }