server_fuzzer.cc 2.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. #include <memory>
  2. #include <httplib.h>
  3. class FuzzedStream : public httplib::Stream {
  4. public:
  5. FuzzedStream(const uint8_t* data, size_t size)
  6. : data_(data), size_(size), read_pos_(0) {}
  7. ssize_t read(char* ptr, size_t size) override {
  8. if (size + read_pos_ > size_) {
  9. size = size_ - read_pos_;
  10. }
  11. memcpy(ptr, data_ + read_pos_, size);
  12. read_pos_ += size;
  13. return size;
  14. }
  15. ssize_t write(const char* ptr, size_t size) override {
  16. response_.append(ptr, size);
  17. return static_cast<int>(size);
  18. }
  19. int write(const char* ptr) { return write(ptr, strlen(ptr)); }
  20. int write(const std::string& s) { return write(s.data(), s.size()); }
  21. std::string get_remote_addr() const { return ""; }
  22. bool is_readable() const override { return true; }
  23. bool is_writable() const override { return true; }
  24. void get_remote_ip_and_port(std::string &ip, int &port) const override {
  25. ip = "127.0.0.1";
  26. port = 8080;
  27. }
  28. private:
  29. const uint8_t* data_;
  30. size_t size_;
  31. size_t read_pos_;
  32. std::string response_;
  33. };
  34. class FuzzableServer : public httplib::Server {
  35. public:
  36. void ProcessFuzzedRequest(FuzzedStream& stream) {
  37. bool connection_close = false;
  38. process_request(stream, /*last_connection=*/false, connection_close,
  39. nullptr);
  40. }
  41. };
  42. static FuzzableServer g_server;
  43. extern "C" int LLVMFuzzerInitialize(int* argc, char*** argv) {
  44. g_server.Get(R"(.*)",
  45. [&](const httplib::Request& req, httplib::Response& res) {
  46. res.set_content("response content", "text/plain");
  47. });
  48. g_server.Post(R"(.*)",
  49. [&](const httplib::Request& req, httplib::Response& res) {
  50. res.set_content("response content", "text/plain");
  51. });
  52. g_server.Put(R"(.*)",
  53. [&](const httplib::Request& req, httplib::Response& res) {
  54. res.set_content("response content", "text/plain");
  55. });
  56. g_server.Patch(R"(.*)",
  57. [&](const httplib::Request& req, httplib::Response& res) {
  58. res.set_content("response content", "text/plain");
  59. });
  60. g_server.Delete(R"(.*)",
  61. [&](const httplib::Request& req, httplib::Response& res) {
  62. res.set_content("response content", "text/plain");
  63. });
  64. g_server.Options(R"(.*)",
  65. [&](const httplib::Request& req, httplib::Response& res) {
  66. res.set_content("response content", "text/plain");
  67. });
  68. return 0;
  69. }
  70. extern "C" int LLVMFuzzerTestOneInput(const uint8_t* data, size_t size) {
  71. FuzzedStream stream{data, size};
  72. g_server.ProcessFuzzedRequest(stream);
  73. return 0;
  74. }