diff options
| author | Dirk Engling <erdgeist@erdgeist.org> | 2026-10-26 17:13:36 +0100 |
|---|---|---|
| committer | Dirk Engling <erdgeist@erdgeist.org> | 2026-10-26 17:13:36 +0100 |
| commit | 6837c5ac80e3624c6dc3a82d03e50d68b2f5a989 (patch) | |
| tree | f829fa152980cefec412483b240813432c9406d7 /ot_http.c | |
| parent | 6871825565d0ba24436dbd5b92cc09e02f93af6a (diff) | |
Second run of making variable and function names more readable, urlencoder now matches overall naming scheme
Diffstat (limited to 'ot_http.c')
| -rw-r--r-- | ot_http.c | 40 |
1 files changed, 20 insertions, 20 deletions
| @@ -27,7 +27,7 @@ | |||
| 27 | #include "ot_scan.h" | 27 | #include "ot_scan.h" |
| 28 | #include "ot_fdstate.h" | 28 | #include "ot_fdstate.h" |
| 29 | #include "ot_stats.h" | 29 | #include "ot_stats.h" |
| 30 | #include "scan_urlencoded_query.h" | 30 | #include "ot_urlencoded.h" |
| 31 | #include "trackerlogic.h" | 31 | #include "trackerlogic.h" |
| 32 | 32 | ||
| 33 | #define OT_MAXMULTISCRAPE_COUNT 64 | 33 | #define OT_MAXMULTISCRAPE_COUNT 64 |
| @@ -257,21 +257,21 @@ static ssize_t http_handle_stats(const int64_t sock, struct ot_workstruct *ws, c | |||
| 257 | #endif | 257 | #endif |
| 258 | 258 | ||
| 259 | while (scanon) { | 259 | while (scanon) { |
| 260 | switch (scan_find_keywords(keywords_main, &read_ptr, SCAN_SEARCHPATH_PARAM)) { | 260 | switch (urlencoded_match_keyword(keywords_main, &read_ptr, SCAN_SEARCHPATH_PARAM)) { |
| 261 | case -2: | 261 | case -2: |
| 262 | scanon = 0; | 262 | scanon = 0; |
| 263 | break; /* TERMINATOR */ | 263 | break; /* TERMINATOR */ |
| 264 | case -1: | 264 | case -1: |
| 265 | HTTPERROR_400_PARAM; /* PARSE ERROR */ | 265 | HTTPERROR_400_PARAM; /* PARSE ERROR */ |
| 266 | case -3: | 266 | case -3: |
| 267 | scan_urlencoded_skipvalue(&read_ptr); | 267 | urlencoded_skip_value(&read_ptr); |
| 268 | break; | 268 | break; |
| 269 | case 1: /* matched "mode" */ | 269 | case 1: /* matched "mode" */ |
| 270 | if ((mode = scan_find_keywords(keywords_mode, &read_ptr, SCAN_SEARCHPATH_VALUE)) <= 0) | 270 | if ((mode = urlencoded_match_keyword(keywords_mode, &read_ptr, SCAN_SEARCHPATH_VALUE)) <= 0) |
| 271 | HTTPERROR_400_PARAM; | 271 | HTTPERROR_400_PARAM; |
| 272 | break; | 272 | break; |
| 273 | case 2: /* matched "format" */ | 273 | case 2: /* matched "format" */ |
| 274 | if ((format = scan_find_keywords(keywords_format, &read_ptr, SCAN_SEARCHPATH_VALUE)) <= 0) | 274 | if ((format = urlencoded_match_keyword(keywords_format, &read_ptr, SCAN_SEARCHPATH_VALUE)) <= 0) |
| 275 | HTTPERROR_400_PARAM; | 275 | HTTPERROR_400_PARAM; |
| 276 | break; | 276 | break; |
| 277 | case 3: | 277 | case 3: |
| @@ -418,18 +418,18 @@ static ssize_t http_handle_scrape(const int64_t sock, struct ot_workstruct *ws, | |||
| 418 | } | 418 | } |
| 419 | 419 | ||
| 420 | while (scanon) { | 420 | while (scanon) { |
| 421 | switch (scan_find_keywords(keywords_scrape, &read_ptr, SCAN_SEARCHPATH_PARAM)) { | 421 | switch (urlencoded_match_keyword(keywords_scrape, &read_ptr, SCAN_SEARCHPATH_PARAM)) { |
| 422 | case -2: | 422 | case -2: |
| 423 | scanon = 0; | 423 | scanon = 0; |
| 424 | break; /* TERMINATOR */ | 424 | break; /* TERMINATOR */ |
| 425 | default: | 425 | default: |
| 426 | HTTPERROR_400_PARAM; /* PARSE ERROR */ | 426 | HTTPERROR_400_PARAM; /* PARSE ERROR */ |
| 427 | case -3: | 427 | case -3: |
| 428 | scan_urlencoded_skipvalue(&read_ptr); | 428 | urlencoded_skip_value(&read_ptr); |
| 429 | break; | 429 | break; |
| 430 | case 1: /* matched "info_hash" */ | 430 | case 1: /* matched "info_hash" */ |
| 431 | /* ignore this, when we have less than 20 bytes */ | 431 | /* ignore this, when we have less than 20 bytes */ |
| 432 | if (scan_urlencoded_query(&read_ptr, (char *)(multiscrape_buf + numwant++), SCAN_SEARCHPATH_VALUE) != (ssize_t)sizeof(ot_hash)) | 432 | if (urlencoded_parse(&read_ptr, (char *)(multiscrape_buf + numwant++), SCAN_SEARCHPATH_VALUE) != (ssize_t)sizeof(ot_hash)) |
| 433 | HTTPERROR_400_PARAM; | 433 | HTTPERROR_400_PARAM; |
| 434 | break; | 434 | break; |
| 435 | } | 435 | } |
| @@ -518,24 +518,24 @@ static ssize_t http_handle_announce(const int64_t sock, struct ot_workstruct | |||
| 518 | scanon = 1; | 518 | scanon = 1; |
| 519 | 519 | ||
| 520 | while (scanon) { | 520 | while (scanon) { |
| 521 | switch (scan_find_keywords(keywords_announce, &read_ptr, SCAN_SEARCHPATH_PARAM)) { | 521 | switch (urlencoded_match_keyword(keywords_announce, &read_ptr, SCAN_SEARCHPATH_PARAM)) { |
| 522 | case -2: | 522 | case -2: |
| 523 | scanon = 0; | 523 | scanon = 0; |
| 524 | break; /* TERMINATOR */ | 524 | break; /* TERMINATOR */ |
| 525 | case -1: | 525 | case -1: |
| 526 | HTTPERROR_400_PARAM; /* PARSE ERROR */ | 526 | HTTPERROR_400_PARAM; /* PARSE ERROR */ |
| 527 | case -3: | 527 | case -3: |
| 528 | scan_urlencoded_skipvalue(&read_ptr); | 528 | urlencoded_skip_value(&read_ptr); |
| 529 | break; | 529 | break; |
| 530 | case 1: /* matched "port" */ | 530 | case 1: /* matched "port" */ |
| 531 | len = scan_urlencoded_query(&read_ptr, write_ptr = read_ptr, SCAN_SEARCHPATH_VALUE); | 531 | len = urlencoded_parse(&read_ptr, write_ptr = read_ptr, SCAN_SEARCHPATH_VALUE); |
| 532 | if ((len <= 0) || scan_fixed_int(write_ptr, len, &tmp) || (tmp > 0xffff)) | 532 | if ((len <= 0) || scan_fixed_int(write_ptr, len, &tmp) || (tmp > 0xffff)) |
| 533 | HTTPERROR_400_PARAM; | 533 | HTTPERROR_400_PARAM; |
| 534 | port = htons(tmp); | 534 | port = htons(tmp); |
| 535 | OT_SETPORT(&ws->peer, &port); | 535 | OT_SETPORT(&ws->peer, &port); |
| 536 | break; | 536 | break; |
| 537 | case 2: /* matched "left" */ | 537 | case 2: /* matched "left" */ |
| 538 | if ((len = scan_urlencoded_query(&read_ptr, write_ptr = read_ptr, SCAN_SEARCHPATH_VALUE)) <= 0) | 538 | if ((len = urlencoded_parse(&read_ptr, write_ptr = read_ptr, SCAN_SEARCHPATH_VALUE)) <= 0) |
| 539 | HTTPERROR_400_PARAM; | 539 | HTTPERROR_400_PARAM; |
| 540 | if (scan_fixed_int(write_ptr, len, &tmp)) | 540 | if (scan_fixed_int(write_ptr, len, &tmp)) |
| 541 | tmp = 0; | 541 | tmp = 0; |
| @@ -543,7 +543,7 @@ static ssize_t http_handle_announce(const int64_t sock, struct ot_workstruct | |||
| 543 | OT_PEERFLAG(&ws->peer) |= PEER_FLAG_SEEDING; | 543 | OT_PEERFLAG(&ws->peer) |= PEER_FLAG_SEEDING; |
| 544 | break; | 544 | break; |
| 545 | case 3: /* matched "event" */ | 545 | case 3: /* matched "event" */ |
| 546 | switch (scan_find_keywords(keywords_announce_event, &read_ptr, SCAN_SEARCHPATH_VALUE)) { | 546 | switch (urlencoded_match_keyword(keywords_announce_event, &read_ptr, SCAN_SEARCHPATH_VALUE)) { |
| 547 | case -1: | 547 | case -1: |
| 548 | HTTPERROR_400_PARAM; | 548 | HTTPERROR_400_PARAM; |
| 549 | case 1: /* matched "completed" */ | 549 | case 1: /* matched "completed" */ |
| @@ -557,7 +557,7 @@ static ssize_t http_handle_announce(const int64_t sock, struct ot_workstruct | |||
| 557 | } | 557 | } |
| 558 | break; | 558 | break; |
| 559 | case 4: /* matched "numwant" */ | 559 | case 4: /* matched "numwant" */ |
| 560 | len = scan_urlencoded_query(&read_ptr, write_ptr = read_ptr, SCAN_SEARCHPATH_VALUE); | 560 | len = urlencoded_parse(&read_ptr, write_ptr = read_ptr, SCAN_SEARCHPATH_VALUE); |
| 561 | if ((len <= 0) || scan_fixed_int(write_ptr, len, &tmp)) | 561 | if ((len <= 0) || scan_fixed_int(write_ptr, len, &tmp)) |
| 562 | HTTPERROR_400_PARAM; | 562 | HTTPERROR_400_PARAM; |
| 563 | if (tmp < 0) | 563 | if (tmp < 0) |
| @@ -567,7 +567,7 @@ static ssize_t http_handle_announce(const int64_t sock, struct ot_workstruct | |||
| 567 | numwant = tmp; | 567 | numwant = tmp; |
| 568 | break; | 568 | break; |
| 569 | case 5: /* matched "compact" */ | 569 | case 5: /* matched "compact" */ |
| 570 | len = scan_urlencoded_query(&read_ptr, write_ptr = read_ptr, SCAN_SEARCHPATH_VALUE); | 570 | len = urlencoded_parse(&read_ptr, write_ptr = read_ptr, SCAN_SEARCHPATH_VALUE); |
| 571 | if ((len <= 0) || scan_fixed_int(write_ptr, len, &tmp)) | 571 | if ((len <= 0) || scan_fixed_int(write_ptr, len, &tmp)) |
| 572 | HTTPERROR_400_PARAM; | 572 | HTTPERROR_400_PARAM; |
| 573 | if (!tmp) | 573 | if (!tmp) |
| @@ -577,7 +577,7 @@ static ssize_t http_handle_announce(const int64_t sock, struct ot_workstruct | |||
| 577 | if (ws->hash) | 577 | if (ws->hash) |
| 578 | HTTPERROR_400_DOUBLEHASH; | 578 | HTTPERROR_400_DOUBLEHASH; |
| 579 | /* ignore this, when we have less than 20 bytes */ | 579 | /* ignore this, when we have less than 20 bytes */ |
| 580 | if (scan_urlencoded_query(&read_ptr, write_ptr = read_ptr, SCAN_SEARCHPATH_VALUE) != 20) | 580 | if (urlencoded_parse(&read_ptr, write_ptr = read_ptr, SCAN_SEARCHPATH_VALUE) != 20) |
| 581 | HTTPERROR_400_PARAM; | 581 | HTTPERROR_400_PARAM; |
| 582 | ws->hash = (ot_hash *)write_ptr; | 582 | ws->hash = (ot_hash *)write_ptr; |
| 583 | break; | 583 | break; |
| @@ -585,7 +585,7 @@ static ssize_t http_handle_announce(const int64_t sock, struct ot_workstruct | |||
| 585 | case 7: /* matched "ip" */ | 585 | case 7: /* matched "ip" */ |
| 586 | { | 586 | { |
| 587 | char *tmp_buf1 = ws->reply, *tmp_buf2 = ws->reply + 16; | 587 | char *tmp_buf1 = ws->reply, *tmp_buf2 = ws->reply + 16; |
| 588 | len = scan_urlencoded_query(&read_ptr, tmp_buf2, SCAN_SEARCHPATH_VALUE); | 588 | len = urlencoded_parse(&read_ptr, tmp_buf2, SCAN_SEARCHPATH_VALUE); |
| 589 | tmp_buf2[len] = 0; | 589 | tmp_buf2[len] = 0; |
| 590 | if ((len <= 0) || !ip_scan(tmp_buf2, tmp_buf1)) | 590 | if ((len <= 0) || !ip_scan(tmp_buf2, tmp_buf1)) |
| 591 | HTTPERROR_400_PARAM; | 591 | HTTPERROR_400_PARAM; |
| @@ -601,7 +601,7 @@ static ssize_t http_handle_announce(const int64_t sock, struct ot_workstruct | |||
| 601 | uint64_t value; | 601 | uint64_t value; |
| 602 | signed short parsed, bits; | 602 | signed short parsed, bits; |
| 603 | 603 | ||
| 604 | len = scan_urlencoded_query(&read_ptr, tmp_buf, SCAN_SEARCHPATH_VALUE); | 604 | len = urlencoded_parse(&read_ptr, tmp_buf, SCAN_SEARCHPATH_VALUE); |
| 605 | tmp_buf[len] = 0; | 605 | tmp_buf[len] = 0; |
| 606 | if (len <= 0) | 606 | if (len <= 0) |
| 607 | HTTPERROR_400_PARAM; | 607 | HTTPERROR_400_PARAM; |
| @@ -630,7 +630,7 @@ static ssize_t http_handle_announce(const int64_t sock, struct ot_workstruct | |||
| 630 | #endif | 630 | #endif |
| 631 | case 9: /* matched "peer_id" */ | 631 | case 9: /* matched "peer_id" */ |
| 632 | /* ignore this, when we have less than 20 bytes */ | 632 | /* ignore this, when we have less than 20 bytes */ |
| 633 | if (scan_urlencoded_query(&read_ptr, write_ptr = read_ptr, SCAN_SEARCHPATH_VALUE) != 20) | 633 | if (urlencoded_parse(&read_ptr, write_ptr = read_ptr, SCAN_SEARCHPATH_VALUE) != 20) |
| 634 | HTTPERROR_400_PARAM; | 634 | HTTPERROR_400_PARAM; |
| 635 | ws->peer_id = write_ptr; | 635 | ws->peer_id = write_ptr; |
| 636 | break; | 636 | break; |
| @@ -709,7 +709,7 @@ ssize_t http_handle_request(const int64_t sock, struct ot_workstruct *ws) { | |||
| 709 | In reality we abandoned requiring the url to be correct. This now | 709 | In reality we abandoned requiring the url to be correct. This now |
| 710 | only decodes url encoded characters, we check for announces and | 710 | only decodes url encoded characters, we check for announces and |
| 711 | scrapes by looking for "a*" or "sc" */ | 711 | scrapes by looking for "a*" or "sc" */ |
| 712 | len = scan_urlencoded_query(&read_ptr, write_ptr = read_ptr, SCAN_PATH); | 712 | len = urlencoded_parse(&read_ptr, write_ptr = read_ptr, SCAN_PATH); |
| 713 | 713 | ||
| 714 | /* If parsing returned an error, leave with not found */ | 714 | /* If parsing returned an error, leave with not found */ |
| 715 | if (g_redirecturl && (len == -2)) | 715 | if (g_redirecturl && (len == -2)) |
