- Customizable page size

- Customizable thread numbers
- Fixed page navigation

Author: unknownpersonog

cmds/server.h

@@ -2,7 +2,7 @@
 #include "command_base.h"
 #include "../func/server/server.h"
 #include <iostream>
-
+#include <thread>
 class ServerCommand : public Command {
 public:
     const char* name() const override { 
@@ -35,10 +35,24 @@ class ServerCommand : public Command {
         } else if (ctx.flags.count("p")) {
             port = std::stoi(ctx.flags.at("p"));
         }
+        size_t page_size = 100;
+        if (ctx.flags.count("pagesize")) {
+            page_size = std::stoul(ctx.flags.at("pagesize"));
+        } else if (ctx.flags.count("ps")) {
+            page_size = std::stoul(ctx.flags.at("ps"));
+        }
+
+        int threads = 1;
+        if (ctx.flags.count("threads")) {
+            threads = std::stoi(ctx.flags.at("threads"));
+        } else if (ctx.flags.count("t")) {
+            threads = std::stoi(ctx.flags.at("t"));
+        } else if (std::thread::hardware_concurrency() > 0) {
+            threads = static_cast<int>(std::thread::hardware_concurrency());
+        }
+        Logger::Log(LOG_INFO, "Starting server for folder: " + folder + " on port " + std::to_string(port) + " with page size " + std::to_string(page_size) + " and thread pool size " + std::to_string(threads));
 
-        Logger::Log(LOG_INFO, "Starting server for folder: " + folder + " on port " + std::to_string(port));
-        
-        return start_server(folder, port);
+        return start_server(folder, port, page_size, threads);
     }
 };
 

func/server/server.cpp

@@ -15,18 +15,18 @@
 #include <csignal>
 #include <atomic>
 #include <thread>
+
 namespace fs = std::filesystem;
 
 namespace {
     // Global server pointer for signal handling
     std::atomic<httplib::Server*> g_server_ptr{nullptr};
-    unsigned int n = std::thread::hardware_concurrency();
 
     // Configuration
     struct Config {
         bool show_hidden = false;
         size_t page_size = 100;
-        int thread_pool_size = n;
+        int thread_pool_size = 1;
         bool follow_symlinks = false;
     } g_config;
 
@@ -202,7 +202,7 @@ namespace {
         return html.str();
     }
 
-    // Parse query parameters
+    // Parse query parameters 
     std::unordered_map<std::string, std::string> parse_query(const std::string& query) {
         std::unordered_map<std::string, std::string> params;
         if (query.empty()) return params;
@@ -449,7 +449,13 @@ namespace {
     }
 }
 
-int start_server(const std::string& root_path, int port) {
+// Updated signature to accept page_size and thread_pool_size
+int start_server(const std::string& root_path, int port, size_t page_size, int thread_pool_size) {
+    // Update global config
+    g_config.page_size = page_size;
+    // Ensure at least 1 thread
+    g_config.thread_pool_size = (thread_pool_size > 0) ? thread_pool_size : 1; 
+
     httplib::Server svr;
 
     // Setup signal handlers for graceful shutdown
@@ -572,11 +578,11 @@ int start_server(const std::string& root_path, int port) {
                 return;
             }
 
-            auto query_params = parse_query(req.get_header_value("Query-String"));
-            // Also parse from URL if httplib doesn't provide it
-            size_t query_pos = req.path.find('?');
-            if (query_pos != std::string::npos) {
-                query_params = parse_query(req.path.substr(query_pos + 1));
+            // FIX: httplib parses query strings into req.params automatically.
+            // We use req.params instead of manually parsing req.path.
+            std::unordered_map<std::string, std::string> query_params;
+            for (const auto& param : req.params) {
+                query_params[param.first] = param.second;
             }
 
             serve_directory(p, url_path, query_params, res);

func/server/server.h

@@ -8,4 +8,4 @@
  * @param port The port to listen on.
  * @return int 0 on success, non-zero on failure.
  */
-int start_server(const std::string& root_path, int port);
+int start_server(const std::string& root_path, int port, size_t page_size, int thread_pool_size);

version.h

@@ -1,4 +1,4 @@
 #ifndef VERSION_H
 #define VERSION_H
-#define VERSION "0.7.0-alpha-1"
+#define VERSION "0.7.0-alpha-2"
 #endif