/home/mrjunejune/zenbu: seobeo/s

comparison seobeo/s_web.c @ 175:71ad34a8bc9a hg-web

[HgWeb] Can stream hg response now. Added react page for hg web since we use json anyway.

author	MrJuneJune <me@mrjunejune.com>
date	Tue, 20 Jan 2026 06:06:47 -0800
parents	827c6ac504cd
children	8cf4ec5e2191

comparison

equal deleted inserted replaced

-:1ba8c1df082c
+:71ad34a8bc9a
 Seobeo_Log(SEOBEO_DEBUG, "Parse completed with code %d\n", parse_result);
 // Recording IP to see who is ddosing or any web scrappers...
 void *p_real_ip_kv = Dowa_HashMap_Get_Ptr(p_req_map, "X-Real-IP");
 const char *real_ip = p_real_ip_kv ? ((Seobeo_Request_Entry*)p_real_ip_kv)->value : NULL;
 // Fallback
 if (!real_ip)
 {
 void *p_forwarded_kv = Dowa_HashMap_Get_Ptr(p_req_map, "X-Forwarded-For");
 real_ip = p_forwarded_kv ? ((Seobeo_Request_Entry*)p_forwarded_kv)->value : NULL;
 }
-// Fallback
 if (!real_ip)
 real_ip = p_cli_handle->host;
 void *p_method_kv = Dowa_HashMap_Get_Ptr(p_req_map, "HTTP_Method");
 const char *method = p_method_kv ? ((Seobeo_Request_Entry*)p_method_kv)->value : NULL;
 void *p_path_kv = Dowa_HashMap_Get_Ptr(p_req_map, "Path");
 const char *path = p_path_kv ? ((Seobeo_Request_Entry*)p_path_kv)->value : "/";
 // --- Check for WebSocket upgrade request ---
 #ifdef SEOBEO_WEBSOCKET_SERVER
-Seobeo_Log(SEOBEO_DEBUG, "Web soceket path \n");
+Seobeo_Log(SEOBEO_DEBUG, "Web socket path \n");
 if (Seobeo_WebSocket_Server_Handle_Upgrade(p_cli_handle, p_req_map, path))
 {
 Seobeo_Log(SEOBEO_INFO, "WebSocket connection established\n");
 if (p_request_arena)
 Dowa_Arena_Free(p_request_arena);
 Dowa_Arena_Free(p_response_arena);
 return;
 }
 #endif
-// --- Try to match API route first ---
+// --- Try to match streaming route first ---
+Seobeo_Stream_Handler stream_handler = Seobeo_Router_Find_Stream_Handler(method, path, &p_req_map, p_request_arena);
+if (stream_handler != NULL)
+{
+stream_handler(p_cli_handle, p_req_map, p_response_arena);
+goto clean_up;
+}
+// --- Try to match API route ---
 Seobeo_Route_Handler handler = Seobeo_Router_Find_Handler(method, path, &p_req_map, p_request_arena);
 if (handler != NULL)
 {
 Seobeo_Request_Entry *p_response_map = handler(p_req_map, p_response_arena);
 Seobeo_Router_Send_Response(p_cli_handle, p_response_map, p_response_arena);
 if (p_handle->read_buffer_len >= 4 &&
 strstr((char*)p_handle->read_buffer, "\r\n\r\n") != NULL)
 break;
 if (r == 0)
-return 1;     // EAGAIN, try again later TODO: Add this as part of Handle struct.
+{
+Seobeo_Log(SEOBEO_INFO, "Waiting?\n");
+continue;     // EAGAIN, try again later TODO: Add this as part of Handle struct.
+}
 }
 // "METHOD SP PATH SP VERSION CRLF"
 char *buf       = (char*)p_handle->read_buffer;
 char *hdr_end   = strstr(buf, "\r\n\r\n");
 while (line < hdr_end)
 {
 char *next = strstr(line, "\r\n");
 if (!next) break;
-// split at colon
 char *colon = memchr(line, ':', next - line);
 if (colon)
 {
 size_t key_len   = colon - line;
 size_t value_len = next - colon - 1;
 char *val = Dowa_Arena_Allocate(p_arena, value_len + 1);
 if (!val) return -1;
 memcpy(val, val_start, value_len);
 val[value_len] = '\0';
-// Both key and value are arena-allocated, hashmap will use them
 Dowa_HashMap_Push_Arena(*pp_map, key, val, p_arena);
 }
 line = next + 2;
 }
 const char *content_length_str = ((Seobeo_Request_Entry*)p_cl_kv)->value;
 size_t body_len = atoi(content_length_str);
 Seobeo_Log(SEOBEO_DEBUG, "Content-Length=%zu, reading body in chunks...\n", body_len);
-// Allocate buffer for entire body
 char *body = Dowa_Arena_Allocate(p_arena, body_len + 1);
 if (!body)
 {
 Seobeo_Log(SEOBEO_ERROR, "Failed to allocate %zu bytes for body\n", body_len);
 return -1;
 /* Router logic */
 struct Seobeo_Route_Struct {
 char *method; // "GET", "POST", "PUT", "DELETE"
 char *path_pattern; // "/v1/users/:id/posts/:post_id"
 Seobeo_Route_Handler handler;
+Seobeo_Stream_Handler stream_handler; // For streaming responses
 // Pre-parsed path segments for efficient matching
 char **path_segments; // ["v1", "users", ":id", "posts", ":post_id"]
 boolean *is_param; // [false, false, true, false, true]
 size_t segment_count;
 Seobeo_Route route = {0};
 route.method = strdup(method);
 route.path_pattern = strdup(path_pattern);
 route.handler = handler;
+route.stream_handler = NULL;
+route.path_segments = Dowa_String_Split(path_pattern, "/", strlen(path_pattern), 1, NULL);
+route.segment_count = Dowa_Array_Length(route.path_segments);
+route.is_param = (boolean*)malloc(sizeof(boolean) * route.segment_count);
+for (size_t i = 0; i < route.segment_count; i++)
+route.is_param[i] = (route.path_segments[i][0] == ':');
+Dowa_Array_Push(g_routes, route);
+}
+void Seobeo_Router_Register_Stream(const char *method, const char *path_pattern, Seobeo_Stream_Handler handler)
+{
+Seobeo_Route route = {0};
+route.method = strdup(method);
+route.path_pattern = strdup(path_pattern);
+route.handler = NULL;
+route.stream_handler = handler;
 route.path_segments = Dowa_String_Split(path_pattern, "/", strlen(path_pattern), 1, NULL);
 route.segment_count = Dowa_Array_Length(route.path_segments);
 route.is_param = (boolean*)malloc(sizeof(boolean) * route.segment_count);
 for (size_t i = 0; i < route.segment_count; i++)
 }
 return NULL;
 }
+Seobeo_Stream_Handler Seobeo_Router_Find_Stream_Handler(
+const char *method,
+const char *path,
+Seobeo_Request_Entry **pp_request_map,
+Dowa_Arena *p_arena)
+{
+if (g_routes == NULL || method == NULL || path == NULL)
+return NULL;
+size_t route_count = Dowa_Array_Length(g_routes);
+for (size_t i = 0; i < route_count; i++)
+{
+Seobeo_Route *route = &g_routes[i];
+if (strcmp(route->method, method) != 0)
+continue;
+if (route->stream_handler && match_route_and_extract(route, path, pp_request_map, p_arena))
+return route->stream_handler;
+}
+return NULL;
+}
 void Seobeo_Router_Send_Response(
 Seobeo_Handle *p_handle,
 Seobeo_Request_Entry *p_response_map,
 Dowa_Arena *p_arena)
 {
 }
 const char *body = "";
 void *p_body_kv = Dowa_HashMap_Get_Ptr(p_response_map, "body");
 if (p_body_kv)
-{
 body = ((Seobeo_Request_Entry*)p_body_kv)->value;
-}
 const char *content_type = "text/html";
 void *p_content_type_kv = Dowa_HashMap_Get_Ptr(p_response_map, "content-type");
 if (p_content_type_kv)
-{
 content_type = ((Seobeo_Request_Entry*)p_content_type_kv)->value;
-}
+// TODO: Update this to be integer
-size_t body_length = strlen(body);
+size_t body_length;
 void *p_content_length_kv = Dowa_HashMap_Get_Ptr(p_response_map, "content-length");
 if (p_content_length_kv)
 {
 const char *content_length_str = ((Seobeo_Request_Entry*)p_content_length_kv)->value;
 body_length = atoi(content_length_str);
 }
+else
+body_length = strlen(body);
 char *header = Dowa_Arena_Allocate(p_arena, 4096);
 Seobeo_Web_Header_Generate(header, status, content_type, body_length);
 for (int i = 0; i < Dowa_Array_Length(p_response_map); i++)
 {
 sprintf(temp, "%s: %s\r\n\r\n", p_response_map[i].key, p_response_map[i].value);
 memcpy(&header[current_header_len - 2 /* \r\n */], temp, strlen(temp));
 free(temp);
 }
+printf("hEADER %s\n", header);
 Seobeo_Handle_Queue(p_handle, (uint8_t*)header, strlen(header));
 Seobeo_Handle_Queue(p_handle, (uint8_t*)body, body_length);
 Seobeo_Handle_Flush(p_handle);
 }

Mercurial

comparison seobeo/s_web.c @ 175:71ad34a8bc9a hg-web